[jira] [Created] (FLINK-10056) Add testRequestNextInputSplit

2018-08-04 Thread JIRA 
陈梓立 created FLINK-10056:
---

 Summary: Add testRequestNextInputSplit
 Key: FLINK-10056
 URL: https://issues.apache.org/jira/browse/FLINK-10056
 Project: Flink
  Issue Type: Improvement
  Components: JobManager, Tests
Affects Versions: 1.5.0
Reporter: 陈梓立
Assignee: 陈梓立


Add testRequestNextInputSplit to make sure JobMaster#testRequestNextInputSplit 
works as expected.



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)

[jira] [Created] (FLINK-10057) optimalize org.apache.flink.yarn.cli.FlinkYarnSessionCli.isYarnPropertiesFileMode

2018-08-04 Thread liuzq (JIRA) 
liuzq created FLINK-10057:
-

 Summary: optimalize 
org.apache.flink.yarn.cli.FlinkYarnSessionCli.isYarnPropertiesFileMode
 Key: FLINK-10057
 URL: https://issues.apache.org/jira/browse/FLINK-10057
 Project: Flink
  Issue Type: Improvement
  Components: Client
Affects Versions: 1.5.1
Reporter: liuzq


--in function : 
org.apache.flink.yarn.cli.FlinkYarnSessionCli.isYarnPropertiesFileMode

private boolean isYarnPropertiesFileMode(CommandLine commandLine) {
 boolean canApplyYarnProperties = 
!commandLine.hasOption(addressOption.getOpt());

*//if canApplyYarnProperties is false,return quickly !*
 *if(false==canApplyYarnProperties){*
      *return canApplyYarnProperties;*
 *}*
 
 for (Option option : commandLine.getOptions()) {
 if (allOptions.hasOption(option.getOpt())) {
 if (!isDetachedOption(option)) {

...

 



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)