Mailing-List: contact issues-help@flink.apache.org; run by ezmlm
Precedence: bulk
Reply-To: dev@flink.apache.org
Date: Thu, 11 May 2017 01:04:04 +0000 (UTC)
From: "Ted Yu (JIRA)" <jira@apache.org>
To: issues@flink.apache.org
Message-ID: <JIRA.13035680.1484688282000.182548.1494464644247@Atlassian.JIRA>
In-Reply-To: <JIRA.13035680.1484688282000@Atlassian.JIRA>
References: <JIRA.13035680.1484688282000@Atlassian.JIRA> <JIRA.13035680.1484688282846@jira-lw-us.apache.org>
Subject: [jira] [Updated] (FLINK-5541) Missing null check for localJar in
 FlinkSubmitter#submitTopology()
MIME-Version: 1.0
Content-Type: text/plain; charset=utf-8
Content-Transfer-Encoding: 7bit
archived-at: Thu, 11 May 2017 01:04:09 -0000


     [ https://issues.apache.org/jira/browse/FLINK-5541?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Ted Yu updated FLINK-5541:
--------------------------
    Description: 
{code}
      if (localJar == null) {
        try {
          for (final URL url : ((ContextEnvironment) ExecutionEnvironment.getExecutionEnvironment())
              .getJars()) {
            // TODO verify that there is only one jar
            localJar = new File(url.toURI()).getAbsolutePath();
          }
        } catch (final URISyntaxException e) {
          // ignore
        } catch (final ClassCastException e) {
          // ignore
        }
      }

      logger.info("Submitting topology " + name + " in distributed mode with conf " + serConf);
      client.submitTopologyWithOpts(name, localJar, topology);
{code}
Since the try block may encounter URISyntaxException / ClassCastException, we should check that localJar is not null before calling submitTopologyWithOpts().

  was:
{code}
      if (localJar == null) {
        try {
          for (final URL url : ((ContextEnvironment) ExecutionEnvironment.getExecutionEnvironment())
              .getJars()) {
            // TODO verify that there is only one jar
            localJar = new File(url.toURI()).getAbsolutePath();
          }
        } catch (final URISyntaxException e) {
          // ignore
        } catch (final ClassCastException e) {
          // ignore
        }
      }

      logger.info("Submitting topology " + name + " in distributed mode with conf " + serConf);
      client.submitTopologyWithOpts(name, localJar, topology);
{code}

Since the try block may encounter URISyntaxException / ClassCastException, we should check that localJar is not null before calling submitTopologyWithOpts().


> Missing null check for localJar in FlinkSubmitter#submitTopology()
> ------------------------------------------------------------------
>
>                 Key: FLINK-5541
>                 URL: https://issues.apache.org/jira/browse/FLINK-5541
>             Project: Flink
>          Issue Type: Bug
>          Components: Storm Compatibility
>            Reporter: Ted Yu
>            Priority: Minor
>
> {code}
>       if (localJar == null) {
>         try {
>           for (final URL url : ((ContextEnvironment) ExecutionEnvironment.getExecutionEnvironment())
>               .getJars()) {
>             // TODO verify that there is only one jar
>             localJar = new File(url.toURI()).getAbsolutePath();
>           }
>         } catch (final URISyntaxException e) {
>           // ignore
>         } catch (final ClassCastException e) {
>           // ignore
>         }
>       }
>       logger.info("Submitting topology " + name + " in distributed mode with conf " + serConf);
>       client.submitTopologyWithOpts(name, localJar, topology);
> {code}
> Since the try block may encounter URISyntaxException / ClassCastException, we should check that localJar is not null before calling submitTopologyWithOpts().


--
This message was sent by Atlassian JIRA
(v6.3.15#6346)