[jira] [Commented] (FLINK-6422) Unreachable code in FileInputFormat#createInputSplits

2017-07-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6422?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16071527#comment-16071527 ] ASF GitHub Bot commented on FLINK-6422: --- Github user zhangminglei commented on the i

[GitHub] flink issue #4202: [FLINK-6422] [core] Unreachable code in FileInputFormat#c...

2017-07-01 Thread zhangminglei
Github user zhangminglei commented on the issue: https://github.com/apache/flink/pull/4202 Seems I could not get any useful information from CI, except for this kinda stuff following and it seems not relevant to this issue. ``` Running org.apache.flink.test.recovery.JobMa

[jira] [Commented] (FLINK-6927) Support pattern group in CEP

2017-07-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6927?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16071525#comment-16071525 ] ASF GitHub Bot commented on FLINK-6927: --- Github user dianfu commented on a diff in t

[GitHub] flink pull request #4153: [FLINK-6927] [cep] Support pattern group in CEP

2017-07-01 Thread dianfu
Github user dianfu commented on a diff in the pull request: https://github.com/apache/flink/pull/4153#discussion_r125173912 --- Diff: flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/pattern/Pattern.java --- @@ -430,6 +431,54 @@ public Quantifier getQuantifier() {

[jira] [Commented] (FLINK-6927) Support pattern group in CEP

2017-07-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6927?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16071523#comment-16071523 ] ASF GitHub Bot commented on FLINK-6927: --- Github user dianfu commented on a diff in t

[jira] [Commented] (FLINK-6927) Support pattern group in CEP

2017-07-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6927?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16071524#comment-16071524 ] ASF GitHub Bot commented on FLINK-6927: --- Github user dianfu commented on a diff in t

[GitHub] flink pull request #4153: [FLINK-6927] [cep] Support pattern group in CEP

2017-07-01 Thread dianfu
Github user dianfu commented on a diff in the pull request: https://github.com/apache/flink/pull/4153#discussion_r125173877 --- Diff: flink-libraries/flink-cep/src/test/java/org/apache/flink/cep/nfa/TimesRangeITCase.java --- @@ -92,6 +92,57 @@ public boolean filter(Event value) th

[GitHub] flink pull request #4153: [FLINK-6927] [cep] Support pattern group in CEP

2017-07-01 Thread dianfu
Github user dianfu commented on a diff in the pull request: https://github.com/apache/flink/pull/4153#discussion_r125173876 --- Diff: flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/pattern/Quantifier.java --- @@ -153,9 +153,8 @@ public int hashCode() {

[jira] [Commented] (FLINK-6927) Support pattern group in CEP

2017-07-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6927?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16071522#comment-16071522 ] ASF GitHub Bot commented on FLINK-6927: --- Github user dianfu commented on a diff in t

[GitHub] flink pull request #4153: [FLINK-6927] [cep] Support pattern group in CEP

2017-07-01 Thread dianfu
Github user dianfu commented on a diff in the pull request: https://github.com/apache/flink/pull/4153#discussion_r125173871 --- Diff: flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/compiler/NFAStateNameHandler.java --- @@ -55,6 +55,11 @@ public void checkNameUniq

[jira] [Commented] (FLINK-6927) Support pattern group in CEP

2017-07-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6927?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16071520#comment-16071520 ] ASF GitHub Bot commented on FLINK-6927: --- Github user dianfu commented on a diff in t

[jira] [Commented] (FLINK-6927) Support pattern group in CEP

2017-07-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6927?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16071521#comment-16071521 ] ASF GitHub Bot commented on FLINK-6927: --- Github user dianfu commented on a diff in t

[GitHub] flink pull request #4153: [FLINK-6927] [cep] Support pattern group in CEP

2017-07-01 Thread dianfu
Github user dianfu commented on a diff in the pull request: https://github.com/apache/flink/pull/4153#discussion_r125173832 --- Diff: flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/compiler/NFACompiler.java --- @@ -455,6 +548,76 @@ private void addStopStateToLoop

[GitHub] flink pull request #4153: [FLINK-6927] [cep] Support pattern group in CEP

2017-07-01 Thread dianfu
Github user dianfu commented on a diff in the pull request: https://github.com/apache/flink/pull/4153#discussion_r125173828 --- Diff: flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/compiler/NFACompiler.java --- @@ -455,6 +548,76 @@ private void addStopStateToLoop

[GitHub] flink pull request #4153: [FLINK-6927] [cep] Support pattern group in CEP

2017-07-01 Thread dianfu
Github user dianfu commented on a diff in the pull request: https://github.com/apache/flink/pull/4153#discussion_r125173760 --- Diff: flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/pattern/Pattern.java --- @@ -366,8 +366,9 @@ public Quantifier getQuantifier() {

[jira] [Commented] (FLINK-6927) Support pattern group in CEP

2017-07-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6927?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16071519#comment-16071519 ] ASF GitHub Bot commented on FLINK-6927: --- Github user dianfu commented on a diff in t

[jira] [Commented] (FLINK-7061) Fix quantifier range starting from 0

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

[GitHub] flink pull request #4242: [FLINK-7061] [cep] Fix quantifier range starting f...

2017-07-01 Thread dianfu
GitHub user dianfu opened a pull request: https://github.com/apache/flink/pull/4242 [FLINK-7061] [cep] Fix quantifier range starting from 0 Thanks for contributing to Apache Flink. Before you open your pull request, please take the following check list into consideration. If you

[jira] [Created] (FLINK-7061) Fix quantifier range starting from 0

2017-07-01 Thread Dian Fu (JIRA)
Dian Fu created FLINK-7061: -- Summary: Fix quantifier range starting from 0 Key: FLINK-7061 URL: https://issues.apache.org/jira/browse/FLINK-7061 Project: Flink Issue Type: Bug Components:

[jira] [Commented] (FLINK-6422) Unreachable code in FileInputFormat#createInputSplits

2017-07-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6422?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16071483#comment-16071483 ] ASF GitHub Bot commented on FLINK-6422: --- Github user tedyu commented on the issue:

[GitHub] flink issue #4202: [FLINK-6422] [core] Unreachable code in FileInputFormat#c...

2017-07-01 Thread tedyu
Github user tedyu commented on the issue: https://github.com/apache/flink/pull/4202 Can you take a look at the error in CI ? --- 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 enabl

[jira] [Updated] (FLINK-6493) Ineffective null check in RegisteredOperatorBackendStateMetaInfo#equals()

2017-07-01 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6493?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated FLINK-6493: -- Description: {code} && ((partitionStateSerializer == null && ((Snapshot) obj).getPartitionStateSerializ

[jira] [Updated] (FLINK-6997) SavepointITCase fails in master branch sometimes

2017-07-01 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6997?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated FLINK-6997: -- Description: I got the following test failure (with commit a0b781461bcf8c2f1d00b93464995f03eda589f1) {code} te

[jira] [Commented] (FLINK-6965) Avro is missing snappy dependency

2017-07-01 Thread Sebastian Klemke (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6965?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16071454#comment-16071454 ] Sebastian Klemke commented on FLINK-6965: - flink-avro connector for DataSet API is

[GitHub] flink pull request #4220: [FLINK-6665] Pass a ScheduledExecutorService to th...

2017-07-01 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/4220#discussion_r125165310 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/restart/RestartStrategy.java --- @@ -36,6 +38,15 @@ * Restarts t

[jira] [Commented] (FLINK-6665) Pass a ScheduledExecutorService to the RestartStrategy

2017-07-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6665?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16071328#comment-16071328 ] ASF GitHub Bot commented on FLINK-6665: --- Github user tillrohrmann commented on a dif

[jira] [Commented] (FLINK-6665) Pass a ScheduledExecutorService to the RestartStrategy

2017-07-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6665?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16071330#comment-16071330 ] ASF GitHub Bot commented on FLINK-6665: --- Github user tillrohrmann commented on a dif

[jira] [Commented] (FLINK-6665) Pass a ScheduledExecutorService to the RestartStrategy

2017-07-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6665?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16071326#comment-16071326 ] ASF GitHub Bot commented on FLINK-6665: --- Github user tillrohrmann commented on a dif

[jira] [Commented] (FLINK-6665) Pass a ScheduledExecutorService to the RestartStrategy

2017-07-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6665?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16071329#comment-16071329 ] ASF GitHub Bot commented on FLINK-6665: --- Github user tillrohrmann commented on a dif

[jira] [Commented] (FLINK-6665) Pass a ScheduledExecutorService to the RestartStrategy

2017-07-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6665?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16071327#comment-16071327 ] ASF GitHub Bot commented on FLINK-6665: --- Github user tillrohrmann commented on a dif

[GitHub] flink pull request #4220: [FLINK-6665] Pass a ScheduledExecutorService to th...

2017-07-01 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/4220#discussion_r125165302 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/restart/RestartStrategy.java --- @@ -36,6 +38,15 @@ * Restarts t

[GitHub] flink pull request #4220: [FLINK-6665] Pass a ScheduledExecutorService to th...

2017-07-01 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/4220#discussion_r125165262 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/restart/ExecutionGraphRestarter.java --- @@ -42,4 +48,23 @@ public Object

[GitHub] flink pull request #4220: [FLINK-6665] Pass a ScheduledExecutorService to th...

2017-07-01 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/4220#discussion_r125165267 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/restart/ExecutionGraphRestarter.java --- @@ -42,4 +48,23 @@ public Object

[GitHub] flink pull request #4220: [FLINK-6665] Pass a ScheduledExecutorService to th...

2017-07-01 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/4220#discussion_r125165228 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/restart/ExecutionGraphRestarter.java --- @@ -23,9 +23,15 @@ import o

[jira] [Commented] (FLINK-5893) Race condition in removing previous JobManagerRegistration in ResourceManager

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

[jira] [Commented] (FLINK-6522) Add ZooKeeper cleanup logic to ZooKeeperHaServices

2017-07-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6522?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16071318#comment-16071318 ] ASF GitHub Bot commented on FLINK-6522: --- Github user tillrohrmann commented on a dif

[GitHub] flink pull request #3399: [FLINK-5893] [ResourceManager] [FLIP-6] Fix the bu...

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

[jira] [Resolved] (FLINK-5893) Race condition in removing previous JobManagerRegistration in ResourceManager

2017-07-01 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5893?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-5893. -- Resolution: Fixed Fixed via 750325e74c1cd91006b251f18f3ed8acf90c2a91 > Race condition in removi

[jira] [Commented] (FLINK-6522) Add ZooKeeper cleanup logic to ZooKeeperHaServices

2017-07-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6522?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16071319#comment-16071319 ] ASF GitHub Bot commented on FLINK-6522: --- Github user tillrohrmann commented on a dif

[jira] [Commented] (FLINK-6522) Add ZooKeeper cleanup logic to ZooKeeperHaServices

2017-07-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6522?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16071316#comment-16071316 ] ASF GitHub Bot commented on FLINK-6522: --- Github user tillrohrmann commented on a dif

[jira] [Commented] (FLINK-6522) Add ZooKeeper cleanup logic to ZooKeeperHaServices

2017-07-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6522?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16071314#comment-16071314 ] ASF GitHub Bot commented on FLINK-6522: --- Github user tillrohrmann commented on a dif

[jira] [Commented] (FLINK-6522) Add ZooKeeper cleanup logic to ZooKeeperHaServices

2017-07-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6522?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16071317#comment-16071317 ] ASF GitHub Bot commented on FLINK-6522: --- Github user tillrohrmann commented on a dif

[jira] [Commented] (FLINK-6522) Add ZooKeeper cleanup logic to ZooKeeperHaServices

2017-07-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6522?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16071315#comment-16071315 ] ASF GitHub Bot commented on FLINK-6522: --- Github user tillrohrmann commented on a dif

[GitHub] flink pull request #4204: [FLINK-6522] Add ZooKeeper cleanup logic to ZooKee...

2017-07-01 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/4204#discussion_r125164998 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/zookeeper/filesystem/FileSystemStateStorageHelper.java --- @@ -77,4 +83,18 @@ public Fil

[GitHub] flink pull request #4204: [FLINK-6522] Add ZooKeeper cleanup logic to ZooKee...

2017-07-01 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/4204#discussion_r125164895 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/highavailability/zookeeper/ZooKeeperHaServices.java --- @@ -102,6 +104,8 @@ /**

[GitHub] flink pull request #4204: [FLINK-6522] Add ZooKeeper cleanup logic to ZooKee...

2017-07-01 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/4204#discussion_r125164914 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/highavailability/zookeeper/ZooKeeperHaServices.java --- @@ -190,6 +198,18 @@ public void

[GitHub] flink pull request #4204: [FLINK-6522] Add ZooKeeper cleanup logic to ZooKee...

2017-07-01 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/4204#discussion_r125164958 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/util/ZooKeeperUtils.java --- @@ -244,6 +244,7 @@ public static ZooKeeperLeaderElectionSe

[GitHub] flink pull request #4204: [FLINK-6522] Add ZooKeeper cleanup logic to ZooKee...

2017-07-01 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/4204#discussion_r125164937 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/zookeeper/filesystem/FileSystemStateStorageHelper.java --- @@ -77,4 +83,18 @@ public Fil

[GitHub] flink pull request #4204: [FLINK-6522] Add ZooKeeper cleanup logic to ZooKee...

2017-07-01 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/4204#discussion_r125164898 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/highavailability/zookeeper/ZooKeeperHaServices.java --- @@ -113,6 +117,7 @@ public ZooKe

[jira] [Commented] (FLINK-6221) Add Prometheus support to metrics

2017-07-01 Thread Maximilian Bode (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6221?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16071312#comment-16071312 ] Maximilian Bode commented on FLINK-6221: [~Zentol] I'll update as soon as the rele

[jira] [Commented] (FLINK-5476) Fail fast if trying to submit a job to a non-existing Flink cluster

2017-07-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5476?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16071309#comment-16071309 ] ASF GitHub Bot commented on FLINK-5476: --- Github user tillrohrmann commented on a dif

[GitHub] flink pull request #4001: [FLINK-5476] Fail fast if trying to submit a job t...

2017-07-01 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/4001#discussion_r125163883 --- Diff: flink-clients/src/main/java/org/apache/flink/client/program/StandaloneClusterClient.java --- @@ -70,6 +76,8 @@ public GetClusterStatusRespons

[jira] [Commented] (FLINK-6773) Use compression (e.g. snappy) for full check/savepoints

2017-07-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6773?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16071289#comment-16071289 ] ASF GitHub Bot commented on FLINK-6773: --- Github user tillrohrmann commented on a dif

[GitHub] flink pull request #4130: [FLINK-6773] [checkpoint] Introduce compression (s...

2017-07-01 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/4130#discussion_r125163526 --- Diff: flink-runtime/src/test/java/org/apache/flink/runtime/state/StateSnapshotCompressionTest.java --- @@ -0,0 +1,180 @@ +/* + * Licensed t

[jira] [Commented] (FLINK-5893) Race condition in removing previous JobManagerRegistration in ResourceManager

2017-07-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5893?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16071280#comment-16071280 ] ASF GitHub Bot commented on FLINK-5893: --- Github user tillrohrmann commented on the i

[GitHub] flink issue #3399: [FLINK-5893] [ResourceManager] [FLIP-6] Fix the bug of ra...

2017-07-01 Thread tillrohrmann
Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/3399 Really good fix @zhijiangW. Merging this 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 fe

[jira] [Commented] (FLINK-4461) Ensure all the classes are tagged with suitable annotations

2017-07-01 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4461?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16071238#comment-16071238 ] Robert Metzger commented on FLINK-4461: --- I'm not aware of anything. Maybe we have to

[jira] [Commented] (FLINK-1722) Streaming not respecting FinalizeOnMaster for output formats

2017-07-01 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1722?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16071226#comment-16071226 ] Robert Metzger commented on FLINK-1722: --- I think we should add a check to the code.

[jira] [Updated] (FLINK-7010) Lamdba expression in flatMap throws InvalidTypesException in DataSet

2017-07-01 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7010?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-7010: -- Component/s: Java API DataSet API > Lamdba expression in flatMap throws Invalid

[jira] [Updated] (FLINK-7033) Update Flink's MapR documentation to include default trust store for secure servers

2017-07-01 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7033?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-7033: -- Component/s: Documentation > Update Flink's MapR documentation to include default trust store fo

[jira] [Updated] (FLINK-7049) TestingApplicationMaster keeps running after integration tests finish

2017-07-01 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7049?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-7049: -- Component/s: YARN Tests > TestingApplicationMaster keeps running after integrat

[jira] [Updated] (FLINK-7058) flink-scala-shell unintended dependencies for scala 2.11

2017-07-01 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7058?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-7058: -- Component/s: Build System > flink-scala-shell unintended dependencies for scala 2.11 > -

[jira] [Commented] (FLINK-6695) Activate strict checkstyle in flink-contrib

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

[jira] [Commented] (FLINK-6695) Activate strict checkstyle in flink-contrib

2017-07-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6695?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16071204#comment-16071204 ] ASF GitHub Bot commented on FLINK-6695: --- Github user zentol closed the pull request

[jira] [Commented] (FLINK-6695) Activate strict checkstyle in flink-contrib

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

[GitHub] flink issue #4231: [FLINK-6695] Activate strict checkstyle for flink-contrib

2017-07-01 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/4231 subsumed by #4112. --- 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

[GitHub] flink pull request #4231: [FLINK-6695] Activate strict checkstyle for flink-...

2017-07-01 Thread zentol
Github user zentol closed the pull request at: https://github.com/apache/flink/pull/4231 --- 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 enab

[GitHub] flink issue #4231: [FLINK-6695] Activate strict checkstyle for flink-contrib

2017-07-01 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/4231 subsumed by #4112. --- 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

[jira] [Resolved] (FLINK-6575) Disable all tests on Windows that use HDFS

2017-07-01 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6575?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai resolved FLINK-6575. Resolution: Fixed Fix Version/s: 1.3.2 1.4.0 Fixed for mas

[jira] [Resolved] (FLINK-6680) App & Flink migration guide: updates for the 1.3 release

2017-07-01 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6680?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai resolved FLINK-6680. Resolution: Fixed Assignee: Tzu-Li (Gordon) Tai Fix Version/s: (w

[jira] [Resolved] (FLINK-6376) when deploy flink cluster on the yarn, it is lack of hdfs delegation token.

2017-07-01 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6376?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai resolved FLINK-6376. Resolution: Fixed Fix Version/s: 1.3.2 1.4.0 Fixed for mas

[jira] [Resolved] (FLINK-6789) Remove duplicated test utility reducer in optimizer

2017-07-01 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6789?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai resolved FLINK-6789. Resolution: Fixed Fix Version/s: 1.3.2 1.4.0 Fixed for 1.3

[jira] [Resolved] (FLINK-6496) Migrate SSL configuration options

2017-07-01 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6496?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai resolved FLINK-6496. Resolution: Fixed Fix Version/s: 1.4.0 Fixed for master via 67bf467a10f68a26a

[jira] [Resolved] (FLINK-6867) Elasticsearch 1.x ITCase still instable due to embedded node instability

2017-07-01 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6867?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai resolved FLINK-6867. Resolution: Fixed Fix Version/s: 1.3.2 1.4.0 Fixed for mas

[jira] [Resolved] (FLINK-7011) Instable Kafka testStartFromKafkaCommitOffsets failures on Travis

2017-07-01 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7011?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai resolved FLINK-7011. Resolution: Fixed Fix Version/s: 1.3.2 1.4.0 Merged for ma

[jira] [Resolved] (FLINK-4022) Partition discovery / regex topic subscription for the Kafka consumer

2017-07-01 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4022?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai resolved FLINK-4022. Resolution: Fixed Merged for 1.4 via 085d4db849b9c659ba6bb2c7d66a04debeb048c4. > Pa

[jira] [Commented] (FLINK-7058) flink-scala-shell unintended dependencies for scala 2.11

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

[GitHub] flink issue #4240: [FLINK-7058] Fix scala-2.10 dependencies

2017-07-01 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/4240 You can rebase this PR now. --- 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 wishe

[jira] [Commented] (FLINK-7015) Separate OperatorConfig from StreamConfig

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

[GitHub] flink pull request #4241: [FLINK-7015] [streaming] separate from OperatorCon...

2017-07-01 Thread juliennju
GitHub user juliennju opened a pull request: https://github.com/apache/flink/pull/4241 [FLINK-7015] [streaming] separate from OperatorConfig from StreamConfig You can merge this pull request into a Git repository by running: $ git pull https://github.com/Xupingyong/flink FLINK

[jira] [Closed] (FLINK-7046) Hide logging about downloaded artifacts on travis

2017-07-01 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7046?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-7046. --- Resolution: Fixed 1.4: 6e3f839ac114bae66b09401766da057d637293e7 > Hide logging about download

[jira] [Closed] (FLINK-6908) start-cluster.sh accepts batch/streaming mode argument

2017-07-01 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6908?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-6908. --- Resolution: Fixed Fix Version/s: 1.4.0 1.4: 90a640748f04edfcca0b25b56df4099c0852b7c6 >

[jira] [Closed] (FLINK-7048) Define javadoc skipping in travis watchdog script

2017-07-01 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7048?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-7048. --- Resolution: Fixed 1.4: 95d70db36ca05b63e7bd6563ff534038b765c4ed > Define javadoc skipping in

[jira] [Closed] (FLINK-7030) Build with scala-2.11 by default

2017-07-01 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7030?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-7030. --- Resolution: Fixed Fix Version/s: 1.4.0 1.4: caf149eb40c35afb6efc76052dd5c0bc0ee8b229 >

[jira] [Closed] (FLINK-6221) Add Prometheus support to metrics

2017-07-01 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6221?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-6221. --- Resolution: Fixed Fix Version/s: 1.4.0 1.4: bb9505ddee6fbf42ef24853dab8475cff9c7948d [

[jira] [Closed] (FLINK-5918) port range support for config taskmanager.rpc.port

2017-07-01 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5918?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-5918. --- Resolution: Fixed 1.4: 3f0ac26e9f502f9e032af0375d52c5e4af2126f3 > port range support for conf

[jira] [Closed] (FLINK-6498) Migrate Zookeeper configuration options

2017-07-01 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6498?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-6498. --- Resolution: Fixed Fix Version/s: 1.4.0 1.4: f839018131024860a1b25b13cea7e1313add28d5 >

[jira] [Closed] (FLINK-6638) Allow overriding default value for all types when retrieving ConfigOption

2017-07-01 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6638?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-6638. --- Resolution: Fixed Fix Version/s: 1.4.0 1.4: 60a59d27012a0343d1c9bff8b8816284d6ef762a >

[jira] [Closed] (FLINK-7000) Add custom configuration for StreamExecutionEnvironment#createLocalEnvironment

2017-07-01 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7000?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-7000. --- Resolution: Fixed Fix Version/s: 1.4.0 1.4: acc2e34f5045a0e239eb4e3b8affdfa69530c0a9 >

[jira] [Closed] (FLINK-6785) Ineffective checks in MetricRegistryTest

2017-07-01 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6785?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-6785. --- Resolution: Fixed Fix Version/s: 1.4.0 1.4: 08580765ee0b604a2d878d3e1f06c059d6703824 >

[jira] [Commented] (FLINK-6461) Deprecate web-related configuration defaults in ConfigConstants

2017-07-01 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6461?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16071160#comment-16071160 ] Chesnay Schepler commented on FLINK-6461: - Additional usages replaced in 1.4: 80b

[jira] [Closed] (FLINK-6987) TextInputFormatTest fails when run in path containing spaces

2017-07-01 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6987?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-6987. --- Resolution: Fixed Fix Version/s: 1.3.2 1.4.0 1.3: c0ad4699af12454f54

[jira] [Closed] (FLINK-6655) Misleading error message when HistoryServer path is empty

2017-07-01 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6655?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-6655. --- Resolution: Fixed Fix Version/s: 1.3.2 1.4.0 1.3: d02e688e72c3d7a9a9

[jira] [Closed] (FLINK-6742) Improve error message when savepoint migration fails due to task removal

2017-07-01 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6742?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-6742. --- Resolution: Fixed Fix Version/s: 1.3.2 1.4.0 Additional checks for p

[jira] [Closed] (FLINK-5488) yarnClient should be closed in AbstractYarnClusterDescriptor for error conditions

2017-07-01 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5488?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-5488. --- Resolution: Fixed Fix Version/s: 1.3.2 1.4.0 1.3: 17c5de5a35b4fa72e3

[jira] [Closed] (FLINK-6898) Limit size of operator component in metric name

2017-07-01 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6898?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-6898. --- Resolution: Fixed 1.3: 1d2c615853ffa627a61de6c9880c53c3b00f1e31 1.4: edb79b0a8bb2b33e1a0470b99

[GitHub] flink pull request #3416: [FLINK-5918] [runtime] port range support for conf...

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

[jira] [Commented] (FLINK-6898) Limit size of operator component in metric name

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

[jira] [Commented] (FLINK-6908) start-cluster.sh accepts batch/streaming mode argument

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

[jira] [Commented] (FLINK-7000) Add custom configuration for StreamExecutionEnvironment#createLocalEnvironment

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

  1   2   >