[jira] [Commented] (FLINK-2017) Add predefined required parameters to ParameterTool

[ https://issues.apache.org/jira/browse/FLINK-2017?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14733249#comment-14733249 ] ASF GitHub Bot commented on FLINK-2017: --- Github user mliesenberg commented on the pu

[GitHub] flink pull request: [FLINK-2017] Add predefined required parameter...

Github user mliesenberg commented on the pull request: https://github.com/apache/flink/pull/1097#issuecomment-138189037 One of the builds failed because of a test failure in: CoStreamCheckpointingITCase>StreamFaultToleranceTestBase.runCheckpointedProgram:105->postSubmit:126 Restor

[jira] [Commented] (FLINK-2622) Scala DataStream API does not have writeAsText method which supports WriteMode

[ https://issues.apache.org/jira/browse/FLINK-2622?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14733236#comment-14733236 ] ASF GitHub Bot commented on FLINK-2622: --- GitHub user HuangWHWHW opened a pull reques

[GitHub] flink pull request: [FLINK-2622][streaming]add WriteMode for write...

GitHub user HuangWHWHW opened a pull request: https://github.com/apache/flink/pull/1098 [FLINK-2622][streaming]add WriteMode for writeAsText in DataStream.scala Add a parameter writeMode in writeAsText with default setting "null". You can merge this pull request into a Git repositor

[jira] [Commented] (FLINK-2017) Add predefined required parameters to ParameterTool

[ https://issues.apache.org/jira/browse/FLINK-2017?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14732531#comment-14732531 ] ASF GitHub Bot commented on FLINK-2017: --- GitHub user mliesenberg opened a pull reque

[GitHub] flink pull request: [FLINK-2017] Add predefined required parameter...

GitHub user mliesenberg opened a pull request: https://github.com/apache/flink/pull/1097 [FLINK-2017] Add predefined required parameters to ParameterTool - adds Option class to represent required parameter - adds RequiredParameter class to interact with ParameterTool to check an

[jira] [Commented] (FLINK-1743) Add multinomial logistic regression to machine learning library

[ https://issues.apache.org/jira/browse/FLINK-1743?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14732507#comment-14732507 ] Ozturk Gokal commented on FLINK-1743: - Hi Till, I would like to work on this issue. Co

[jira] [Commented] (FLINK-2525) Add configuration support in Storm-compatibility

[ https://issues.apache.org/jira/browse/FLINK-2525?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14732295#comment-14732295 ] ASF GitHub Bot commented on FLINK-2525: --- Github user ffbin commented on the pull req

[GitHub] flink pull request: [FLINK-2525]Add configuration support in Storm...

Github user ffbin commented on the pull request: https://github.com/apache/flink/pull/1046#issuecomment-138051794 @mjsax @StephanEwen Thanks. I have finish the changes at the core classes. when user use env.getConfig().setGlobalJobParameters(conf); to set storm configuration, I n