[jira] [Comment Edited] (FLINK-5486) Lack of synchronization in BucketingSink#handleRestoredBucketState()

[ https://issues.apache.org/jira/browse/FLINK-5486?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16351986#comment-16351986 ] Ted Yu edited comment on FLINK-5486 at 4/8/18 4:02 AM: --- Can this get more review,

[jira] [Comment Edited] (FLINK-9143) Restart strategy defined in flink-conf.yaml is ignored

[ https://issues.apache.org/jira/browse/FLINK-9143?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16429590#comment-16429590 ] yuqi edited comment on FLINK-9143 at 4/8/18 2:51 AM: - En, Agree with you on this point

[jira] [Commented] (FLINK-9143) Restart strategy defined in flink-conf.yaml is ignored

[ https://issues.apache.org/jira/browse/FLINK-9143?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16429590#comment-16429590 ] yuqi commented on FLINK-9143: - En, Agree with you on this point [~Zentol], I also wonder why flink ignores

[jira] [Commented] (FLINK-9142) Lower the minimum number of buffers for incoming channels to 1

[ https://issues.apache.org/jira/browse/FLINK-9142?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16429589#comment-16429589 ] zhijiang commented on FLINK-9142: - Yeah, this change seems more reasonable as we discussed before.(y) >

[GitHub] flink pull request #5827: [hotfix][docs][minor] fix typo in documentation

GitHub user pradithya opened a pull request: https://github.com/apache/flink/pull/5827 [hotfix][docs][minor] fix typo in documentation ## Brief change log - Fix typo in DataSet API and DataStream API documentation ## Verifying this change This change is

[jira] [Assigned] (FLINK-9123) Scala version of ProcessFunction doesn't work

[ https://issues.apache.org/jira/browse/FLINK-9123?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang reassigned FLINK-9123: --- Assignee: (was: vinoyang) > Scala version of ProcessFunction doesn't work >

[jira] [Commented] (FLINK-9089) Upgrade Orc dependency to 1.4.3

[ https://issues.apache.org/jira/browse/FLINK-9089?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16429580#comment-16429580 ] ASF GitHub Bot commented on FLINK-9089: --- GitHub user yanghua opened a pull request:

[jira] [Commented] (FLINK-9089) Upgrade Orc dependency to 1.4.3

[ https://issues.apache.org/jira/browse/FLINK-9089?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16429581#comment-16429581 ] ASF GitHub Bot commented on FLINK-9089: --- Github user yanghua commented on the issue:

[GitHub] flink issue #5826: [FLINK-9089] Upgrade Orc dependency to 1.4.3

Github user yanghua commented on the issue: https://github.com/apache/flink/pull/5826 cc @tillrohrmann ---

[GitHub] flink pull request #5826: [FLINK-9089] Upgrade Orc dependency to 1.4.3

GitHub user yanghua opened a pull request: https://github.com/apache/flink/pull/5826 [FLINK-9089] Upgrade Orc dependency to 1.4.3 ## What is the purpose of the change *This pull request upgrade Orc dependency from 1.4.1 to 1.4.3* ## Brief change log

[jira] [Assigned] (FLINK-9141) Calling getSideOutput() and split() on one DataStream causes NPE

[ https://issues.apache.org/jira/browse/FLINK-9141?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang reassigned FLINK-9141: --- Assignee: vinoyang > Calling getSideOutput() and split() on one DataStream causes NPE >

[jira] [Assigned] (FLINK-9040) JobVertex#setMaxParallelism does not validate argument

[ https://issues.apache.org/jira/browse/FLINK-9040?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sihua Zhou reassigned FLINK-9040: - Assignee: Sihua Zhou > JobVertex#setMaxParallelism does not validate argument >

[jira] [Commented] (FLINK-9040) JobVertex#setMaxParallelism does not validate argument

[ https://issues.apache.org/jira/browse/FLINK-9040?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16429385#comment-16429385 ] ASF GitHub Bot commented on FLINK-9040: --- GitHub user sihuazhou opened a pull request:

[jira] [Commented] (FLINK-9040) JobVertex#setMaxParallelism does not validate argument

[ https://issues.apache.org/jira/browse/FLINK-9040?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16429386#comment-16429386 ] ASF GitHub Bot commented on FLINK-9040: --- Github user sihuazhou commented on the issue:

[GitHub] flink issue #5825: [FLINK-9040][local runtime] check maxParallelism in JobVe...

Github user sihuazhou commented on the issue: https://github.com/apache/flink/pull/5825 CC: @zentol ---

[GitHub] flink pull request #5825: [FLINK-9040][local runtime] check maxParallelism i...

GitHub user sihuazhou opened a pull request: https://github.com/apache/flink/pull/5825 [FLINK-9040][local runtime] check maxParallelism in JobVertex#setMaxParallelism() ## What is the purpose of the change this PR performs `maxParallelism` checking in

[jira] [Commented] (FLINK-9070) Improve performance of RocksDBMapState.clear()

[ https://issues.apache.org/jira/browse/FLINK-9070?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16429383#comment-16429383 ] Sihua Zhou commented on FLINK-9070: --- Hi [~kien_truong] I also share my idea for improving this here

[jira] [Commented] (FLINK-9143) Restart strategy defined in flink-conf.yaml is ignored

[ https://issues.apache.org/jira/browse/FLINK-9143?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16429285#comment-16429285 ] Chesnay Schepler commented on FLINK-9143: - Yes itt is a bug: {{// check if a restart strategy has

[jira] [Assigned] (FLINK-9143) Restart strategy defined in flink-conf.yaml is ignored

[ https://issues.apache.org/jira/browse/FLINK-9143?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] yuqi reassigned FLINK-9143: --- Assignee: yuqi > Restart strategy defined in flink-conf.yaml is ignored >

[jira] [Commented] (FLINK-9143) Restart strategy defined in flink-conf.yaml is ignored

[ https://issues.apache.org/jira/browse/FLINK-9143?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16429282#comment-16429282 ] yuqi commented on FLINK-9143: - As far as i know, if you set  {code:java} env.enableCheckpointing(5000,