[jira] [Commented] (FLINK-4641) Support branching CEP patterns

2017-07-06 Thread Dian Fu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4641?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16077624#comment-16077624 ] Dian Fu commented on FLINK-4641: Hi [~dawidwys], just think of one more use case: for the above second

[jira] [Assigned] (FLINK-7099) Replace usages of deprecated JOB_MANAGER_IPC_PORT_KEY

2017-07-06 Thread Fang Yong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7099?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fang Yong reassigned FLINK-7099: Assignee: Fang Yong > Replace usages of deprecated JOB_MANAGER_IPC_PORT_KEY >

[jira] [Commented] (FLINK-6969) Add support for deferred computation for group window aggregates

2017-07-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6969?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16077552#comment-16077552 ] ASF GitHub Bot commented on FLINK-6969: --- Github user sunjincheng121 commented on the issue:

[GitHub] flink issue #4183: [FLINK-6969][table]Add support for deferred computation f...

2017-07-06 Thread sunjincheng121
Github user sunjincheng121 commented on the issue: https://github.com/apache/flink/pull/4183 BTW. The PR adjust the watermark by injecting a custom operator, that can ensure the integrity of the data. It is currently reasonable, but in essence the watermark adjustment should be

[jira] [Assigned] (FLINK-7106) Make SubmittedJobGraphStore implementation configurable

2017-07-06 Thread Chen Qin (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7106?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chen Qin reassigned FLINK-7106: --- Assignee: Chen Qin > Make SubmittedJobGraphStore implementation configurable >

[jira] [Commented] (FLINK-6058) Don't read DEFAULT_PARALLELISM from GlobalConfiguration

2017-07-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6058?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16077518#comment-16077518 ] ASF GitHub Bot commented on FLINK-6058: --- Github user zjureel commented on the issue:

[GitHub] flink issue #3921: [FLINK-6058] fix read DEFAULT_PARALLELISM from ContextEnv...

2017-07-06 Thread zjureel
Github user zjureel commented on the issue: https://github.com/apache/flink/pull/3921 I have updated the code according to your suggestion, please have a look when you are free, thanks :) --- If your project is set up for it, you can reply to this email and have your reply appear on

[jira] [Updated] (FLINK-7122) When metric name contains special characters then Graphite will not display them

2017-07-06 Thread wyp (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7122?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] wyp updated FLINK-7122: --- Description: When metric name contains special characters then Graphite will not display them, because

[jira] [Updated] (FLINK-7122) When metric name contains special characters then Graphite will not display them

2017-07-06 Thread wyp (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7122?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] wyp updated FLINK-7122: --- Description: When metric name contains special characters then Graphite will not display them, because

[jira] [Updated] (FLINK-7122) When metric name contains special characters then Graphite will not display them

2017-07-06 Thread wyp (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7122?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] wyp updated FLINK-7122: --- Description: When metric name contains special characters then Graphite will not display them, because

[jira] [Updated] (FLINK-7122) When metric name contains special characters then Graphite will not display them

2017-07-06 Thread wyp (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7122?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] wyp updated FLINK-7122: --- Description: When metric name contains special characters then Graphite will not display them, because

[jira] [Created] (FLINK-7122) When metric name contains special characters then Graphite will not display them

2017-07-06 Thread wyp (JIRA)
wyp created FLINK-7122: -- Summary: When metric name contains special characters then Graphite will not display them Key: FLINK-7122 URL: https://issues.apache.org/jira/browse/FLINK-7122 Project: Flink

[jira] [Commented] (FLINK-7092) Shutdown ResourceManager components properly

2017-07-06 Thread mingleizhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7092?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16077508#comment-16077508 ] mingleizhang commented on FLINK-7092: - This issue looks great and looks very very interesting to me! I

[jira] [Assigned] (FLINK-6667) Pass a callback type to the RestartStrategy, rather than the full ExecutionGraph

2017-07-06 Thread Fang Yong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6667?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fang Yong reassigned FLINK-6667: Assignee: Fang Yong > Pass a callback type to the RestartStrategy, rather than the full >

[jira] [Commented] (FLINK-6667) Pass a callback type to the RestartStrategy, rather than the full ExecutionGraph

2017-07-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6667?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16077501#comment-16077501 ] ASF GitHub Bot commented on FLINK-6667: --- Github user zjureel commented on the issue:

[GitHub] flink issue #4277: [FLINK-6667] Pass a callback type to the RestartStrategy,...

2017-07-06 Thread zjureel
Github user zjureel commented on the issue: https://github.com/apache/flink/pull/4277 @StephanEwen @tillrohrmann As discussed in https://github.com/apache/flink/pull/4220, I create this PR to fix issue [FLINK-6667](https://issues.apache.org/jira/browse/FLINK-6667). Could you please

[jira] [Commented] (FLINK-6667) Pass a callback type to the RestartStrategy, rather than the full ExecutionGraph

2017-07-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6667?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16077496#comment-16077496 ] ASF GitHub Bot commented on FLINK-6667: --- GitHub user zjureel opened a pull request:

[GitHub] flink pull request #4277: [FLINK-6667] Pass a callback type to the RestartSt...

2017-07-06 Thread zjureel
GitHub user zjureel opened a pull request: https://github.com/apache/flink/pull/4277 [FLINK-6667] Pass a callback type to the RestartStrategy, rather than the full ExecutionGraph … the full ExecutionGraph Thanks for contributing to Apache Flink. Before you open your pull

[jira] [Commented] (FLINK-6058) Don't read DEFAULT_PARALLELISM from GlobalConfiguration

2017-07-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6058?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16077495#comment-16077495 ] ASF GitHub Bot commented on FLINK-6058: --- Github user zjureel commented on the issue:

[GitHub] flink issue #3921: [FLINK-6058] fix read DEFAULT_PARALLELISM from ContextEnv...

2017-07-06 Thread zjureel
Github user zjureel commented on the issue: https://github.com/apache/flink/pull/3921 @aljoscha Sorry for replying late, your suggestion sounds good to me. In fact, I was hesitating to add `getDefaultParallelism()` in `ContextEnvironment` and `ClusterClient` for there have been

[jira] [Commented] (FLINK-6811) Add TIMESTAMPADD supported in SQL

2017-07-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6811?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16077474#comment-16077474 ] ASF GitHub Bot commented on FLINK-6811: --- Github user sunjincheng121 commented on the issue:

[jira] [Commented] (FLINK-6891) Add LOG(X) supported in SQL

2017-07-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6891?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16077469#comment-16077469 ] ASF GitHub Bot commented on FLINK-6891: --- Github user sunjincheng121 commented on the issue:

[GitHub] flink issue #4076: [FLINK-6811][table] Add TIMESTAMPADD supported in SQL

2017-07-06 Thread sunjincheng121
Github user sunjincheng121 commented on the issue: https://github.com/apache/flink/pull/4076 I have rebase the code and update the PR. --- 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

[jira] [Updated] (FLINK-7121) Remove the hardcoded way in core

2017-07-06 Thread mingleizhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7121?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] mingleizhang updated FLINK-7121: Issue Type: Sub-task (was: Bug) Parent: FLINK-7114 > Remove the hardcoded way in core >

[GitHub] flink issue #4122: [FLINK-6891][table]Add LOG supported in SQL

2017-07-06 Thread sunjincheng121
Github user sunjincheng121 commented on the issue: https://github.com/apache/flink/pull/4122 I have rebase the code and update the PR. --- 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

[jira] [Created] (FLINK-7121) Remove the hardcoded way in core

2017-07-06 Thread mingleizhang (JIRA)
mingleizhang created FLINK-7121: --- Summary: Remove the hardcoded way in core Key: FLINK-7121 URL: https://issues.apache.org/jira/browse/FLINK-7121 Project: Flink Issue Type: Bug

[jira] [Updated] (FLINK-7120) Remove the hardcoded way in Utils

2017-07-06 Thread mingleizhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7120?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] mingleizhang updated FLINK-7120: Issue Type: Sub-task (was: Bug) Parent: FLINK-7114 > Remove the hardcoded way in Utils >

[jira] [Commented] (FLINK-6892) Add L/RPAD supported in SQL

2017-07-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6892?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16077464#comment-16077464 ] ASF GitHub Bot commented on FLINK-6892: --- Github user sunjincheng121 commented on the issue:

[jira] [Created] (FLINK-7120) Remove the hardcoded way in Utils

2017-07-06 Thread mingleizhang (JIRA)
mingleizhang created FLINK-7120: --- Summary: Remove the hardcoded way in Utils Key: FLINK-7120 URL: https://issues.apache.org/jira/browse/FLINK-7120 Project: Flink Issue Type: Bug

[GitHub] flink issue #4127: [FLINK-6892][table]Add L/RPAD supported in SQL

2017-07-06 Thread sunjincheng121
Github user sunjincheng121 commented on the issue: https://github.com/apache/flink/pull/4127 I had rebase the code and update the PR. --- 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

[jira] [Updated] (FLINK-7119) Remove the hardcoded way in HadoopUtils

2017-07-06 Thread mingleizhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7119?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] mingleizhang updated FLINK-7119: Issue Type: Sub-task (was: Bug) Parent: FLINK-7114 > Remove the hardcoded way in

[jira] [Created] (FLINK-7119) Remove the hardcoded way in HadoopUtils

2017-07-06 Thread mingleizhang (JIRA)
mingleizhang created FLINK-7119: --- Summary: Remove the hardcoded way in HadoopUtils Key: FLINK-7119 URL: https://issues.apache.org/jira/browse/FLINK-7119 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-6893) Add BIN supported in SQL

2017-07-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6893?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16077454#comment-16077454 ] ASF GitHub Bot commented on FLINK-6893: --- Github user sunjincheng121 commented on the issue:

[GitHub] flink issue #4128: [FLINK-6893][table]Add BIN supported in SQL

2017-07-06 Thread sunjincheng121
Github user sunjincheng121 commented on the issue: https://github.com/apache/flink/pull/4128 I had rebase code and add the document. --- 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

[jira] [Updated] (FLINK-7118) Remove hadoop1.x code in HadoopUtils

2017-07-06 Thread mingleizhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7118?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] mingleizhang updated FLINK-7118: Description: Since flink no longer support hadoop 1.x version, we should remove it.

[jira] [Updated] (FLINK-7118) Remove hadoop1.x code in HadoopUtils

2017-07-06 Thread mingleizhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7118?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] mingleizhang updated FLINK-7118: Issue Type: Improvement (was: Bug) > Remove hadoop1.x code in HadoopUtils >

[jira] [Updated] (FLINK-7118) Remove hadoop1.x code in HadoopUtils

2017-07-06 Thread mingleizhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7118?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] mingleizhang updated FLINK-7118: Description: Since flink no longer support hadoop 1.x version, so, we should remove it.

[jira] [Created] (FLINK-7118) Remove hadoop1.x code in HadoopUtils

2017-07-06 Thread mingleizhang (JIRA)
mingleizhang created FLINK-7118: --- Summary: Remove hadoop1.x code in HadoopUtils Key: FLINK-7118 URL: https://issues.apache.org/jira/browse/FLINK-7118 Project: Flink Issue Type: Bug

[jira] [Comment Edited] (FLINK-7114) Remove the hardcoded way like classpath is written by a string

2017-07-06 Thread mingleizhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7114?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16077427#comment-16077427 ] mingleizhang edited comment on FLINK-7114 at 7/7/17 12:54 AM: -- This is not

[jira] [Commented] (FLINK-7114) Remove the hardcoded way like classpath is written by a string

2017-07-06 Thread mingleizhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7114?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16077427#comment-16077427 ] mingleizhang commented on FLINK-7114: - This is not only the problem of hadoop version, but this kinda

[jira] [Updated] (FLINK-7019) Rework parallelism in Gelly algorithms and examples

2017-07-06 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7019?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan updated FLINK-7019: -- Description: Flink job parallelism is set with {{ExecutionConfig#setParallelism}} or when {{-p}} on

[jira] [Commented] (FLINK-6842) Uncomment or remove code in HadoopFileSystem

2017-07-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6842?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16077414#comment-16077414 ] ASF GitHub Bot commented on FLINK-6842: --- Github user zhangminglei commented on the issue:

[GitHub] flink issue #4219: [FLINK-6842] [runtime] Uncomment and activate code in Had...

2017-07-06 Thread zhangminglei
Github user zhangminglei commented on the issue: https://github.com/apache/flink/pull/4219 Thanks, Greg. --- 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,

[jira] [Commented] (FLINK-7117) Add JobManagerLeaderRetrieval method with default JobManager address

2017-07-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7117?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16077318#comment-16077318 ] ASF GitHub Bot commented on FLINK-7117: --- Github user asfgit closed the pull request at:

[jira] [Closed] (FLINK-7117) Add JobManagerLeaderRetrieval method with default JobManager address

2017-07-06 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7117?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-7117. Resolution: Fixed Fix Version/s: 1.4.0 Fixed via d1a0935e22303c22b5be0e8346b9aac6d69ca43f >

[GitHub] flink pull request #4276: [FLINK-7117] [ha] Add HighAvailabilityServices.get...

2017-07-06 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/4276 --- 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 is

[jira] [Commented] (FLINK-7117) Add JobManagerLeaderRetrieval method with default JobManager address

2017-07-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7117?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16077288#comment-16077288 ] ASF GitHub Bot commented on FLINK-7117: --- GitHub user tillrohrmann opened a pull request:

[GitHub] flink pull request #4276: [FLINK-7117] [ha] Add HighAvailabilityServices.get...

2017-07-06 Thread tillrohrmann
GitHub user tillrohrmann opened a pull request: https://github.com/apache/flink/pull/4276 [FLINK-7117] [ha] Add HighAvailabilityServices.getJobManagerLeaderRetriever(jobId, defaultJobManagerAddress) The getJobManagerLeaderRetriever method with the defaultJobManagerAddress

[jira] [Created] (FLINK-7117) Add JobManagerLeaderRetrieval method with default JobManager address

2017-07-06 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-7117: Summary: Add JobManagerLeaderRetrieval method with default JobManager address Key: FLINK-7117 URL: https://issues.apache.org/jira/browse/FLINK-7117 Project: Flink

[jira] [Commented] (FLINK-7116) Add getPort method to RpcService

2017-07-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7116?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16077253#comment-16077253 ] ASF GitHub Bot commented on FLINK-7116: --- Github user asfgit closed the pull request at:

[GitHub] flink pull request #4275: [FLINK-7116] [rpc] Add getPort to RpcService

2017-07-06 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/4275 --- 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 is

[jira] [Closed] (FLINK-7116) Add getPort method to RpcService

2017-07-06 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7116?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-7116. Resolution: Fixed Fix Version/s: 1.4.0 Added via 12efc553c6e1ee88f4234a41e2ac83ce65a2cc4c >

[jira] [Commented] (FLINK-7116) Add getPort method to RpcService

2017-07-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7116?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16077250#comment-16077250 ] ASF GitHub Bot commented on FLINK-7116: --- Github user tillrohrmann commented on the issue:

[GitHub] flink issue #4275: [FLINK-7116] [rpc] Add getPort to RpcService

2017-07-06 Thread tillrohrmann
Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/4275 Merging this PR since it is trivial. --- 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

[jira] [Commented] (FLINK-7116) Add getPort method to RpcService

2017-07-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7116?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16077238#comment-16077238 ] ASF GitHub Bot commented on FLINK-7116: --- GitHub user tillrohrmann opened a pull request:

[GitHub] flink pull request #4275: [FLINK-7116] [rpc] Add getPort to RpcService

2017-07-06 Thread tillrohrmann
GitHub user tillrohrmann opened a pull request: https://github.com/apache/flink/pull/4275 [FLINK-7116] [rpc] Add getPort to RpcService The `RpcService` should expose its port it is bound to. That way it is easier to connect to a remote `RpcService`. You can merge this pull

[jira] [Created] (FLINK-7116) Add getPort method to RpcService

2017-07-06 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-7116: Summary: Add getPort method to RpcService Key: FLINK-7116 URL: https://issues.apache.org/jira/browse/FLINK-7116 Project: Flink Issue Type: Sub-task

[jira] [Commented] (FLINK-6842) Uncomment or remove code in HadoopFileSystem

2017-07-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6842?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16077151#comment-16077151 ] ASF GitHub Bot commented on FLINK-6842: --- Github user greghogan commented on the issue:

[GitHub] flink issue #4219: [FLINK-6842] [runtime] Uncomment and activate code in Had...

2017-07-06 Thread greghogan
Github user greghogan commented on the issue: https://github.com/apache/flink/pull/4219 +1 --- 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

[jira] [Assigned] (FLINK-7064) test instability in WordCountMapreduceITCase

2017-07-06 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7064?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan reassigned FLINK-7064: - Assignee: Greg Hogan > test instability in WordCountMapreduceITCase >

[jira] [Commented] (FLINK-7114) Remove the hardcoded way like classpath is written by a string

2017-07-06 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7114?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16077076#comment-16077076 ] Greg Hogan commented on FLINK-7114: --- It looks like much of this code can be removed or simplified since

[jira] [Commented] (FLINK-6975) Add CONCAT/CONCAT_WS supported in TableAPI

2017-07-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6975?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16076879#comment-16076879 ] ASF GitHub Bot commented on FLINK-6975: --- GitHub user sunjincheng121 opened a pull request:

[GitHub] flink pull request #4274: [FLINK-6975][table]Add CONCAT/CONCAT_WS supported ...

2017-07-06 Thread sunjincheng121
GitHub user sunjincheng121 opened a pull request: https://github.com/apache/flink/pull/4274 [FLINK-6975][table]Add CONCAT/CONCAT_WS supported in TableAPI In this PR. I have Add CONCAT/CONCAT_WS supported in TableAPI. - [x] General - The pull request references the related

[jira] [Assigned] (FLINK-7080) Deploy Yarn cluster with job

2017-07-06 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7080?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-7080: Assignee: Till Rohrmann > Deploy Yarn cluster with job > > >

[jira] [Commented] (FLINK-7113) Make ClusterDescriptor independent of Flink cluster size

2017-07-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7113?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16076812#comment-16076812 ] ASF GitHub Bot commented on FLINK-7113: --- Github user zentol commented on a diff in the pull request:

[jira] [Commented] (FLINK-7113) Make ClusterDescriptor independent of Flink cluster size

2017-07-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7113?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16076814#comment-16076814 ] ASF GitHub Bot commented on FLINK-7113: --- Github user zentol commented on a diff in the pull request:

[jira] [Commented] (FLINK-7113) Make ClusterDescriptor independent of Flink cluster size

2017-07-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7113?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16076813#comment-16076813 ] ASF GitHub Bot commented on FLINK-7113: --- Github user zentol commented on a diff in the pull request:

[GitHub] flink pull request #4271: [FLINK-7113] Make ClusterDescriptor independent of...

2017-07-06 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/4271#discussion_r125944216 --- Diff: flink-yarn/src/main/java/org/apache/flink/yarn/AbstractYarnClusterDescriptor.java --- @@ -520,72 +439,128 @@ protected YarnClusterClient

[GitHub] flink pull request #4271: [FLINK-7113] Make ClusterDescriptor independent of...

2017-07-06 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/4271#discussion_r125943654 --- Diff: flink-yarn-tests/src/test/java/org/apache/flink/yarn/YarnTestBase.java --- @@ -631,12 +634,15 @@ protected static void sendOutput() {

[GitHub] flink pull request #4271: [FLINK-7113] Make ClusterDescriptor independent of...

2017-07-06 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/4271#discussion_r125944668 --- Diff: flink-yarn/src/main/java/org/apache/flink/yarn/AbstractYarnClusterDescriptor.java --- @@ -520,72 +439,128 @@ protected YarnClusterClient

[jira] [Commented] (FLINK-7110) Allow ClusterDescriptor to deploy per-job cluster

2017-07-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7110?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16076794#comment-16076794 ] ASF GitHub Bot commented on FLINK-7110: --- Github user zentol commented on a diff in the pull request:

[GitHub] flink pull request #4270: [FLINK-7110] [client] Add per-job cluster deployme...

2017-07-06 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/4270#discussion_r125942139 --- Diff: flink-clients/src/main/java/org/apache/flink/client/deployment/ClusterDescriptor.java --- @@ -44,5 +45,12 @@ * @return Client for the

[GitHub] flink pull request #4271: [FLINK-7113] Make ClusterDescriptor independent of...

2017-07-06 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/4271#discussion_r125938365 --- Diff: flink-clients/src/main/java/org/apache/flink/client/deployment/ClusterSpecification.java --- @@ -0,0 +1,81 @@ +/* + * Licensed to the

[jira] [Commented] (FLINK-7113) Make ClusterDescriptor independent of Flink cluster size

2017-07-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7113?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16076781#comment-16076781 ] ASF GitHub Bot commented on FLINK-7113: --- Github user zentol commented on a diff in the pull request:

[GitHub] flink pull request #4271: [FLINK-7113] Make ClusterDescriptor independent of...

2017-07-06 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/4271#discussion_r125938448 --- Diff: flink-clients/src/main/java/org/apache/flink/client/deployment/ClusterSpecification.java --- @@ -0,0 +1,81 @@ +/* + * Licensed to the

[jira] [Commented] (FLINK-7113) Make ClusterDescriptor independent of Flink cluster size

2017-07-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7113?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16076780#comment-16076780 ] ASF GitHub Bot commented on FLINK-7113: --- Github user zentol commented on a diff in the pull request:

[jira] [Commented] (FLINK-7110) Allow ClusterDescriptor to deploy per-job cluster

2017-07-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7110?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16076768#comment-16076768 ] ASF GitHub Bot commented on FLINK-7110: --- Github user tillrohrmann commented on a diff in the pull

[GitHub] flink pull request #4270: [FLINK-7110] [client] Add per-job cluster deployme...

2017-07-06 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/4270#discussion_r125937463 --- Diff: flink-clients/src/main/java/org/apache/flink/client/deployment/ClusterDescriptor.java --- @@ -44,5 +45,12 @@ * @return Client for

[GitHub] flink pull request #4270: [FLINK-7110] [client] Add per-job cluster deployme...

2017-07-06 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/4270#discussion_r125937353 --- Diff: flink-clients/src/main/java/org/apache/flink/client/deployment/ClusterDescriptor.java --- @@ -44,5 +45,12 @@ * @return Client for

[jira] [Commented] (FLINK-7110) Allow ClusterDescriptor to deploy per-job cluster

2017-07-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7110?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16076767#comment-16076767 ] ASF GitHub Bot commented on FLINK-7110: --- Github user tillrohrmann commented on a diff in the pull

[jira] [Commented] (FLINK-7110) Allow ClusterDescriptor to deploy per-job cluster

2017-07-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7110?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16076759#comment-16076759 ] ASF GitHub Bot commented on FLINK-7110: --- Github user zentol commented on a diff in the pull request:

[jira] [Commented] (FLINK-7110) Allow ClusterDescriptor to deploy per-job cluster

2017-07-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7110?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16076758#comment-16076758 ] ASF GitHub Bot commented on FLINK-7110: --- Github user zentol commented on a diff in the pull request:

[GitHub] flink pull request #4270: [FLINK-7110] [client] Add per-job cluster deployme...

2017-07-06 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/4270#discussion_r125935922 --- Diff: flink-clients/src/main/java/org/apache/flink/client/deployment/ClusterDescriptor.java --- @@ -44,5 +45,12 @@ * @return Client for the

[GitHub] flink pull request #4270: [FLINK-7110] [client] Add per-job cluster deployme...

2017-07-06 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/4270#discussion_r125935645 --- Diff: flink-clients/src/main/java/org/apache/flink/client/deployment/ClusterDescriptor.java --- @@ -44,5 +45,12 @@ * @return Client for the

[jira] [Created] (FLINK-7115) test instability in MiniClusterITCase.runJobWithMultipleJobManagers

2017-07-06 Thread Nico Kruber (JIRA)
=20170706T151556Z=AWS4-HMAC-SHA256=AKIAJRYRXRSVGNKPKO5A/20170706/us-east-1/s3/aws4_request=host=5b7c512137c7cbd82dcb77a98aeadc3d761b7055bea6d8f07ad6b786dc196f37 {code} == Maven produced no output for 300 seconds

[jira] [Commented] (FLINK-7114) Remove the hardcoded way like classpath is written by a string

2017-07-06 Thread mingleizhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7114?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16076700#comment-16076700 ] mingleizhang commented on FLINK-7114: - [~tzulitai] Could you help me take a look on this issue ? And

[jira] [Commented] (FLINK-7111) flink-scala-shell fails on mvn verify

2017-07-06 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7111?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16076699#comment-16076699 ] Chesnay Schepler commented on FLINK-7111: - In that case i would suggest to disable the test for

[jira] [Updated] (FLINK-7114) Remove the hardcoded way like classpath is written by a string

2017-07-06 Thread mingleizhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7114?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] mingleizhang updated FLINK-7114: Description: For example, Like in {{HadoopFileSystem}} class, there is a field which is written

[jira] [Commented] (FLINK-7065) separate the flink-streaming-java module from flink-clients

2017-07-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7065?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16076693#comment-16076693 ] ASF GitHub Bot commented on FLINK-7065: --- GitHub user XuPingyong opened a pull request:

[jira] [Updated] (FLINK-7114) Remove the hardcoded way like classpath is written by a string

2017-07-06 Thread mingleizhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7114?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] mingleizhang updated FLINK-7114: Component/s: Local Runtime > Remove the hardcoded way like classpath is written by a string >

[GitHub] flink pull request #4273: [FLINK-7065] Separate the flink-streaming-java mod...

2017-07-06 Thread XuPingyong
GitHub user XuPingyong opened a pull request: https://github.com/apache/flink/pull/4273 [FLINK-7065] Separate the flink-streaming-java module from flink-clients You can merge this pull request into a Git repository by running: $ git pull https://github.com/XuPingyong/flink

[jira] [Updated] (FLINK-7065) separate the flink-streaming-java module from flink-clients

2017-07-06 Thread Xu Pingyong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7065?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xu Pingyong updated FLINK-7065: --- Description: Motivation: It is not good that "flink-streaming-java" module depends on

[jira] [Updated] (FLINK-7114) Remove the hardcoded way like classpath is written by a string

2017-07-06 Thread mingleizhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7114?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] mingleizhang updated FLINK-7114: Description: For example, in {{HadoopFileSystem}} class, there is a field which is written like

[jira] [Updated] (FLINK-7065) separate the flink-streaming-java module from flink-clients

2017-07-06 Thread Xu Pingyong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7065?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xu Pingyong updated FLINK-7065: --- Description: Motivation: It is not good that "flink-streaming-java" module depends on

[jira] [Commented] (FLINK-7086) Create entry point for standalone session mode

2017-07-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7086?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16076681#comment-16076681 ] ASF GitHub Bot commented on FLINK-7086: --- GitHub user tillrohrmann opened a pull request:

[GitHub] flink pull request #4272: [FLINK-7086] Add Flip-6 standalone session cluster...

2017-07-06 Thread tillrohrmann
GitHub user tillrohrmann opened a pull request: https://github.com/apache/flink/pull/4272 [FLINK-7086] Add Flip-6 standalone session cluster entry point This PR is based on #4259, #4260, #4261. This PR implements the standalone session cluster entry point. You can merge

[jira] [Updated] (FLINK-7114) Remove the hardcoded way like classpath is written by a string

2017-07-06 Thread mingleizhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7114?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] mingleizhang updated FLINK-7114: Summary: Remove the hardcoded way like classpath is written by a string (was: Remove the hardcoded

[jira] [Commented] (FLINK-6900) Limit size of indiivual components in DropwizardReporter

2017-07-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6900?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16076678#comment-16076678 ] ASF GitHub Bot commented on FLINK-6900: --- Github user zentol commented on the issue:

[GitHub] flink issue #4110: [FLINK-6900] [metrics] Limit size of metric name componen...

2017-07-06 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/4110 @NicoK yes, that's how they would be stored in some backends. --- 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

[jira] [Created] (FLINK-7114) Remove the hardcoded way in flink

2017-07-06 Thread mingleizhang (JIRA)
mingleizhang created FLINK-7114: --- Summary: Remove the hardcoded way in flink Key: FLINK-7114 URL: https://issues.apache.org/jira/browse/FLINK-7114 Project: Flink Issue Type: Bug

  1   2   3   >