[jira] [Closed] (FLINK-9460) Redundant output in table & upsert semantics

2018-05-29 Thread zhengcanbin (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9460?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhengcanbin closed FLINK-9460. -- Resolution: Not A Problem > Redundant output in table & upsert se

[jira] [Commented] (FLINK-9460) Redundant output in table & upsert semantics

2018-05-29 Thread zhengcanbin (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9460?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16493380#comment-16493380 ] zhengcanbin commented on FLINK-9460: u r right, tkx! Btw, is there any Jira a

[jira] [Updated] (FLINK-9460) Redundant output in table & upsert semantics

2018-05-28 Thread zhengcanbin (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9460?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhengcanbin updated FLINK-9460: --- Description: The output seems incorrect in my table & upsert example, here's the code: {

[jira] [Created] (FLINK-9460) Redundant output in table & upsert semantics

2018-05-28 Thread zhengcanbin (JIRA)
zhengcanbin created FLINK-9460: -- Summary: Redundant output in table & upsert semantics Key: FLINK-9460 URL: https://issues.apache.org/jira/browse/FLINK-9460 Project: Flink Issue Type:

[GitHub] flink issue #3600: [FLINK-6117]Make setting of 'zookeeper.sasl.disable' work...

2017-04-13 Thread zhengcanbin
Github user zhengcanbin commented on the issue: https://github.com/apache/flink/pull/3600 @StephanEwen @EronWright --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and

[GitHub] flink pull request #3682: [FLINK-6269][JobManager]var could be val

2017-04-06 Thread zhengcanbin
GitHub user zhengcanbin opened a pull request: https://github.com/apache/flink/pull/3682 [FLINK-6269][JobManager]var could be val In JobManager.scala var userCodeLoader = libraryCacheManager.getClassLoader(jobGraph.getJobID) this var could be a val You can merge this pull

[GitHub] flink issue #3600: [FLINK-6117]Make setting of 'zookeeper.sasl.disable' work...

2017-03-28 Thread zhengcanbin
Github user zhengcanbin commented on the issue: https://github.com/apache/flink/pull/3600 @StephanEwen @vijikarthi @EronWright @Rucongzhang Thanks all! I have changed this default behaviour, now `zookeeper.sasl.disable` is `false` by default. --- If your project is set up for

[GitHub] flink issue #3600: [FLINK-6117]Make setting of 'zookeeper.sasl.disable' work...

2017-03-27 Thread zhengcanbin
Github user zhengcanbin commented on the issue: https://github.com/apache/flink/pull/3600 @EronWright @vijikarthi --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and

[GitHub] flink pull request #3612: [FLINK-6186][cleanup]Remove unused import.

2017-03-25 Thread zhengcanbin
GitHub user zhengcanbin opened a pull request: https://github.com/apache/flink/pull/3612 [FLINK-6186][cleanup]Remove unused import. Remove unused import in org.apache.flink.streaming.api.scala.StreamExecutionEnvironment.scala You can merge this pull request into a Git repository

[GitHub] flink issue #3600: [FLINK-6117]Make setting of 'zookeeper.sasl.disable' work...

2017-03-24 Thread zhengcanbin
Github user zhengcanbin commented on the issue: https://github.com/apache/flink/pull/3600 @EronWright @StephanEwen In ZookeeperSaslClient.java, 'zookeeper.sasl.client' is true by default, so I agree to set 'zookeeper.sasl.disable' to false by default, for c

[GitHub] flink issue #3600: [FLINK-6117]Make setting of 'zookeeper.sasl.disable' work...

2017-03-23 Thread zhengcanbin
Github user zhengcanbin commented on the issue: https://github.com/apache/flink/pull/3600 Hi, this patch works and passes all tests on my side, but now all checks have failed, I check all the five raw logs, obviously those errors are not from my side. ![image](https

[GitHub] flink pull request #3600: [FLINK-6117]Make setting of 'zookeeper.sasl.disabl...

2017-03-22 Thread zhengcanbin
GitHub user zhengcanbin opened a pull request: https://github.com/apache/flink/pull/3600 [FLINK-6117]Make setting of 'zookeeper.sasl.disable' work correctly The value of 'zookeeper.sasl.disable' not used in the right way when starting CuratorFramework. When &#x

[GitHub] flink pull request #3575: [FLINK-6117]Make setting of 'zookeeper.sasl.disabl...

2017-03-22 Thread zhengcanbin
Github user zhengcanbin closed the pull request at: https://github.com/apache/flink/pull/3575 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature

[jira] [Created] (FLINK-6159) Add Java/Scala FlinkLauncher

2017-03-22 Thread zhengcanbin (JIRA)
zhengcanbin created FLINK-6159: -- Summary: Add Java/Scala FlinkLauncher Key: FLINK-6159 URL: https://issues.apache.org/jira/browse/FLINK-6159 Project: Flink Issue Type: Improvement

[GitHub] flink pull request #3566: [FLINK-6117]makes setting of 'zookeeper.sasl.disab...

2017-03-20 Thread zhengcanbin
Github user zhengcanbin commented on a diff in the pull request: https://github.com/apache/flink/pull/3566#discussion_r106940624 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/util/ZooKeeperUtils.java --- @@ -89,6 +90,7 @@ public static CuratorFramework

[GitHub] flink pull request #3575: [FLINK-6117]makes setting of 'zookeeper.sasl.disab...

2017-03-20 Thread zhengcanbin
GitHub user zhengcanbin opened a pull request: https://github.com/apache/flink/pull/3575 [FLINK-6117]makes setting of 'zookeeper.sasl.disable' work correctly Thanks for contributing to Apache Flink. Before you open your pull request, please take the following check