[jira] [Commented] (FLINK-9147) PrometheusReporter jar does not include Prometheus dependencies

2018-04-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9147?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16429648#comment-16429648 ] ASF GitHub Bot commented on FLINK-9147: --- GitHub user tillrohrmann opened a pull requ

[GitHub] flink pull request #5828: [FLINK-9147] [metrics] Include shaded Prometheus d...

2018-04-07 Thread tillrohrmann
GitHub user tillrohrmann opened a pull request: https://github.com/apache/flink/pull/5828 [FLINK-9147] [metrics] Include shaded Prometheus dependencies in jar ## What is the purpose of the change The Prometheus metrics reporter does not include the shaded Prometheus depende

[jira] [Created] (FLINK-9147) PrometheusReporter jar does not include Prometheus dependencies

2018-04-07 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-9147: Summary: PrometheusReporter jar does not include Prometheus dependencies Key: FLINK-9147 URL: https://issues.apache.org/jira/browse/FLINK-9147 Project: Flink

[jira] [Assigned] (FLINK-9147) PrometheusReporter jar does not include Prometheus dependencies

2018-04-07 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9147?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-9147: Assignee: Till Rohrmann > PrometheusReporter jar does not include Prometheus dependencies >

[jira] [Created] (FLINK-9146) 1.4 more than local cannot start submitting

2018-04-07 Thread abel-sun (JIRA)
abel-sun created FLINK-9146: --- Summary: 1.4 more than local cannot start submitting Key: FLINK-9146 URL: https://issues.apache.org/jira/browse/FLINK-9146 Project: Flink Issue Type: Bug Co

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

2018-04-07 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5486?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16351986#comment-16351986 ] Ted Yu edited comment on FLINK-5486 at 4/8/18 4:02 AM: --- Can this get

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

2018-04-07 Thread yuqi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9143?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16429590#comment-16429590 ] yuqi edited comment on FLINK-9143 at 4/8/18 2:51 AM: - En, Agree with y

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

2018-04-07 Thread yuqi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9143?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16429590#comment-16429590 ] yuqi commented on FLINK-9143: - En, Agree with you on this point [~Zentol], I also wonder why f

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

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

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

2018-04-07 Thread pradithya
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 a

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

2018-04-07 Thread vinoyang (JIRA)
[ 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

2018-04-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9089?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=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

2018-04-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9089?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=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

2018-04-07 Thread yanghua
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

2018-04-07 Thread yanghua
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

2018-04-07 Thread vinoyang (JIRA)
[ 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

2018-04-07 Thread Sihua Zhou (JIRA)
[ 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

2018-04-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9040?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=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

2018-04-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9040?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16429386#comment-16429386 ] ASF GitHub Bot commented on FLINK-9040: --- Github user sihuazhou commented on the issu

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

2018-04-07 Thread sihuazhou
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...

2018-04-07 Thread sihuazhou
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 `JobVertex#setMaxPara

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

2018-04-07 Thread Sihua Zhou (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9070?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16429383#comment-16429383 ] Sihua Zhou commented on FLINK-9070: --- Hi [~kien_truong] I also share my idea for improvin

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

2018-04-07 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9143?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16429285#comment-16429285 ] Chesnay Schepler commented on FLINK-9143: - Yes itt is a bug: {{// check if a rest

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

2018-04-07 Thread yuqi (JIRA)
[ 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

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