[jira] [Commented] (FLINK-7293) Support custom order by in PatternStream

2017-07-31 Thread Dawid Wysakowicz (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7293?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16106931#comment-16106931 ] Dawid Wysakowicz commented on FLINK-7293: - I had another look at the sorting strategy and I

[jira] [Created] (FLINK-7301) Rework state documentation

2017-07-31 Thread Timo Walther (JIRA)
Timo Walther created FLINK-7301: --- Summary: Rework state documentation Key: FLINK-7301 URL: https://issues.apache.org/jira/browse/FLINK-7301 Project: Flink Issue Type: Improvement

[GitHub] flink pull request #4353: [FLINK-7213] Introduce state management by Operato...

2017-07-31 Thread StephanEwen
Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/4353#discussion_r130295736 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/AbstractStreamOperator.java --- @@ -208,13 +208,13 @@ public

[jira] [Commented] (FLINK-7300) End-to-end tests are instable on Travis

2017-07-31 Thread Aljoscha Krettek (JIRA)
258569408/log.txt?X-Amz-Expires=30=20170731T060526Z=AWS4-HMAC-SHA256=AKIAJRYRXRSVGNKPKO5A/20170731/us-east-1/s3/aws4_request=host=4ef9ff5e60fe06db53a84be8d73775a46cb595a8caeb806b05dbbf824d3b69e8 > Another failure example of a different cause then the above, also on the > end-to-end tes

[jira] [Commented] (FLINK-7044) Add methods to the client API that take the stateDescriptor.

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

[jira] [Commented] (FLINK-7201) ConcurrentModificationException in JobLeaderIdService

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

[jira] [Commented] (FLINK-7201) ConcurrentModificationException in JobLeaderIdService

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

[jira] [Commented] (FLINK-7297) Instable Kafka09ProducerITCase.testCustomPartitioning test case

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

[GitHub] flink pull request #4423: [FLINK-7297] [table] Fix failed to run CorrelateIT...

2017-07-31 Thread zhangminglei
Github user zhangminglei closed the pull request at: https://github.com/apache/flink/pull/4423 --- 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-7306) function notFollowedBy in CEP dont return a Pattern object

2017-07-31 Thread Hanmiao Li (JIRA)
Hanmiao Li created FLINK-7306: - Summary: function notFollowedBy in CEP dont return a Pattern object Key: FLINK-7306 URL: https://issues.apache.org/jira/browse/FLINK-7306 Project: Flink

[jira] [Commented] (FLINK-7278) Flink job can stuck while ZK leader reelected during ZK cluster migration

2017-07-31 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7278?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16107017#comment-16107017 ] Till Rohrmann commented on FLINK-7278: -- Hi [~zhenzhongxu], thanks for reporting the issue. Does the

[GitHub] flink pull request #4423: [FLINK-7297] [table] Fix failed to run CorrelateIT...

2017-07-31 Thread zhangminglei
GitHub user zhangminglei opened a pull request: https://github.com/apache/flink/pull/4423 [FLINK-7297] [table] Fix failed to run CorrelateITCase class under wi… With a environment on Windows, Test run failed as reference to UserDefinedFunctionTestUtils is ambiguous; it is

[jira] [Commented] (FLINK-7302) Failed to run CorrelateITCase class under windows environment

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

[GitHub] flink pull request #4424: [FLINK-7302] [table] Fix failed to run CorrelateIT...

2017-07-31 Thread zhangminglei
GitHub user zhangminglei opened a pull request: https://github.com/apache/flink/pull/4424 [FLINK-7302] [table] Fix failed to run CorrelateITCase class under wi… With an environment on Windows, Test run failed as reference to UserDefinedFunctionTestUtils is ambiguous; it is

[jira] [Commented] (FLINK-5832) Support for simple hive UDF

2017-07-31 Thread Zhuoluo Yang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5832?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16107177#comment-16107177 ] Zhuoluo Yang commented on FLINK-5832: - [~twalthr] Sorry for the delay. I wil update the patch this

[jira] [Commented] (FLINK-7213) Introduce state management by OperatorID in TaskManager

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

[jira] [Commented] (FLINK-4789) Avoid Kafka partition discovery on restore and share consumer instance for discovery and data consumption

2017-07-31 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4789?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16107050#comment-16107050 ] Tzu-Li (Gordon) Tai commented on FLINK-4789: I would like to close this issue now. Since Flink

[GitHub] flink issue #4401: [hotfix][tests] minor test improvements in TaskManagerCon...

2017-07-31 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/4401 merging, --- 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] [Commented] (FLINK-7169) Support AFTER MATCH SKIP function in CEP library API

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

[GitHub] flink pull request #4331: [FLINK-7169][CEP] Support AFTER MATCH SKIP functio...

2017-07-31 Thread yestinchen
Github user yestinchen commented on a diff in the pull request: https://github.com/apache/flink/pull/4331#discussion_r130317270 --- Diff: flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/NFA.java --- @@ -551,18 +579,47 @@ private boolean isSelfIgnore(final

[jira] [Commented] (FLINK-7294) mesos.resourcemanager.framework.role not working

2017-07-31 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7294?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16107013#comment-16107013 ] Aljoscha Krettek commented on FLINK-7294: - Hi [~eronwright], do you have any idea what could be

[jira] [Commented] (FLINK-7169) Support AFTER MATCH SKIP function in CEP library API

2017-07-31 Thread Dawid Wysakowicz (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7169?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16107012#comment-16107012 ] Dawid Wysakowicz commented on FLINK-7169: - Hi [~ychen] I've tried to put some of my ideas

[GitHub] flink pull request #4420: [FLINK-7295] [rpc] Add postStop callback for prope...

2017-07-31 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/4420 --- 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-7295) Add callback for proper RpcEndpoint shut down

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

[jira] [Closed] (FLINK-7295) Add callback for proper RpcEndpoint shut down

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

[jira] [Closed] (FLINK-7201) ConcurrentModificationException in JobLeaderIdService

2017-07-31 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7201?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-7201. Resolution: Fixed Fix Version/s: 1.4.0 The problem should no longer occur with the changes

[jira] [Commented] (FLINK-7289) Memory allocation of RocksDB can be problematic in container environments

2017-07-31 Thread Stefan Richter (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7289?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16107037#comment-16107037 ] Stefan Richter commented on FLINK-7289: --- Thanks for the input. I have one question about the last

[jira] [Updated] (FLINK-5704) Deprecate FlinkKafkaConsumer constructors in favor of improvements to decoupling from Kafka offset committing

2017-07-31 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5704?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-5704: --- Fix Version/s: 1.4.0 > Deprecate FlinkKafkaConsumer constructors in favor of

[jira] [Commented] (FLINK-7297) Instable Kafka09ProducerITCase.testCustomPartitioning test case

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

[GitHub] flink issue #4331: [FLINK-7169][CEP] Support AFTER MATCH SKIP function in CE...

2017-07-31 Thread yestinchen
Github user yestinchen commented on the issue: https://github.com/apache/flink/pull/4331 @dianfu Thanks for your reviewing. I found @dawidwys wrote a draft about the JIRA's implementation. I'll go through that first and address those issues in this PR latter. --- If your

[GitHub] flink pull request #3614: [FLINK-6189][YARN]Do not use yarn client config to...

2017-07-31 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/3614#discussion_r130315320 --- Diff: flink-yarn/src/test/java/org/apache/flink/yarn/YarnClusterDescriptorTest.java --- @@ -51,57 +51,23 @@ public void beforeTest() throws

[GitHub] flink pull request #3614: [FLINK-6189][YARN]Do not use yarn client config to...

2017-07-31 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/3614#discussion_r130315352 --- Diff: flink-yarn/src/test/java/org/apache/flink/yarn/YarnClusterDescriptorTest.java --- @@ -51,57 +51,23 @@ public void beforeTest() throws

[GitHub] flink issue #4347: [FLINK-7201] fix concurrency in JobLeaderIdService when s...

2017-07-31 Thread tillrohrmann
Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/4347 With the changes of #4420, this problem should be resolved. Could you please close this PR then @XuPingyong. --- If your project is set up for it, you can reply to this email and have your

[jira] [Commented] (FLINK-7201) ConcurrentModificationException in JobLeaderIdService

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

[jira] [Commented] (FLINK-7300) End-to-end tests are instable on Travis

2017-07-31 Thread Tzu-Li (Gordon) Tai (JIRA)
gt; profile to sporadically fail. > Incorrect matched output: > https://s3.amazonaws.com/archive.travis-ci.org/jobs/258569408/log.txt?X-Amz-Expires=30=20170731T060526Z=AWS4-HMAC-SHA256=AKIAJRYRXRSVGNKPKO5A/20170731/us-east-1/s3/aws4_request=host=4ef9ff5e60fe06db53a84be8d73775a46cb595a

[jira] [Commented] (FLINK-6213) When number of failed containers exceeds maximum failed containers and application is stopped, the AM container will be released 10 minutes later

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

[jira] [Commented] (FLINK-7297) Instable Kafka09ProducerITCase.testCustomPartitioning test case

2017-07-31 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7297?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16107052#comment-16107052 ] Till Rohrmann commented on FLINK-7297: -- Somehow I didn't manage to post working links recently. I've

[jira] [Updated] (FLINK-7297) Instable Kafka09ProducerITCase.testCustomPartitioning test case

2017-07-31 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7297?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-7297: - Description: There seems to be a test instability of

[jira] [Closed] (FLINK-4789) Avoid Kafka partition discovery on restore and share consumer instance for discovery and data consumption

2017-07-31 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4789?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai closed FLINK-4789. -- Resolution: Won't Fix > Avoid Kafka partition discovery on restore and share consumer

[jira] [Commented] (FLINK-7303) Build elasticsearch5 by default

2017-07-31 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7303?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16107065#comment-16107065 ] Tzu-Li (Gordon) Tai commented on FLINK-7303: +1 > Build elasticsearch5 by default >

[jira] [Commented] (FLINK-7269) Refactor passing of dynamic properties

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

[GitHub] flink issue #4399: [FLINK-7250] [build] Remove jdk8 profile

2017-07-31 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/4399 merging. --- 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

[GitHub] flink issue #4335: [FLINK-7192] Activate checkstyle flink-java/test/operator

2017-07-31 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/4335 merging. --- 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

[GitHub] flink issue #4398: [FLINK-7249] [build] Bump java.version property to 1.8

2017-07-31 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/4398 I've created JIRAs for addressing the issues you found. Will merge this. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If

[jira] [Commented] (FLINK-7249) Bump Java version in build plugin

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

[jira] [Created] (FLINK-7304) Simnplify garbage collector configuration in taskmanager.sh

2017-07-31 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-7304: --- Summary: Simnplify garbage collector configuration in taskmanager.sh Key: FLINK-7304 URL: https://issues.apache.org/jira/browse/FLINK-7304 Project: Flink

[GitHub] flink issue #4400: [FLINK-7253] [tests] Remove CommonTestUtils#assumeJava8

2017-07-31 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/4400 will fix the checkstyle violations while merging. --- 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

[GitHub] flink pull request #4415: [FLINK-7269] Refactor passing of dynamic propertie...

2017-07-31 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/4415#discussion_r130312761 --- Diff: flink-core/src/main/java/org/apache/flink/configuration/Configuration.java --- @@ -79,7 +79,15 @@ public Configuration(Configuration other) {

[jira] [Created] (FLINK-7305) Add new import block for shaded dependencies

2017-07-31 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-7305: --- Summary: Add new import block for shaded dependencies Key: FLINK-7305 URL: https://issues.apache.org/jira/browse/FLINK-7305 Project: Flink Issue Type:

[jira] [Created] (FLINK-7307) Add proper command line parsing tool to ClusterEntrypoint

2017-07-31 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-7307: Summary: Add proper command line parsing tool to ClusterEntrypoint Key: FLINK-7307 URL: https://issues.apache.org/jira/browse/FLINK-7307 Project: Flink

[GitHub] flink issue #4347: [FLINK-7201] fix concurrency in JobLeaderIdService when s...

2017-07-31 Thread XuPingyong
Github user XuPingyong commented on the issue: https://github.com/apache/flink/pull/4347 Thanks @tillrohrmann ! --- 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

[jira] [Updated] (FLINK-7302) Failed to run CorrelateITCase class under windows environment

2017-07-31 Thread mingleizhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7302?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] mingleizhang updated FLINK-7302: Description: Error:(220, 5) reference to UserDefinedFunctionTestUtils is ambiguous; it is imported

[jira] [Commented] (FLINK-7192) Activate checkstyle flink-java/test/operator

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

[jira] [Commented] (FLINK-7250) Drop the jdk8 build profile

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

[jira] [Commented] (FLINK-7253) Remove all 'assume Java 8' code in tests

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

[jira] [Commented] (FLINK-7188) Activate checkstyle flink-java/summarize

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

[GitHub] flink issue #4338: [FLINK-7188] Activate checkstyle flink-java/summarize

2017-07-31 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/4338 merging. --- 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

[GitHub] flink issue #4417: [hotfix][tests] fix Invokable subclasses being private

2017-07-31 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/4417 merging. --- 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

[GitHub] flink pull request #4331: [FLINK-7169][CEP] Support AFTER MATCH SKIP functio...

2017-07-31 Thread yestinchen
Github user yestinchen commented on a diff in the pull request: https://github.com/apache/flink/pull/4331#discussion_r130317122 --- Diff: flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/NFA.java --- @@ -551,18 +579,47 @@ private boolean isSelfIgnore(final

[jira] [Commented] (FLINK-7169) Support AFTER MATCH SKIP function in CEP library API

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

[jira] [Commented] (FLINK-7169) Support AFTER MATCH SKIP function in CEP library API

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

[GitHub] flink pull request #4331: [FLINK-7169][CEP] Support AFTER MATCH SKIP functio...

2017-07-31 Thread yestinchen
Github user yestinchen commented on a diff in the pull request: https://github.com/apache/flink/pull/4331#discussion_r130317411 --- Diff: flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/NFA.java --- @@ -551,18 +579,47 @@ private boolean isSelfIgnore(final

[jira] [Commented] (FLINK-6189) Do not use yarn client config to do sanity check

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

[jira] [Commented] (FLINK-6189) Do not use yarn client config to do sanity check

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

[jira] [Commented] (FLINK-7297) Instable Kafka09ProducerITCase.testCustomPartitioning test case

2017-07-31 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7297?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16106974#comment-16106974 ] Aljoscha Krettek commented on FLINK-7297: - [~till.rohrmann] The log cannot be accessed. >

[jira] [Created] (FLINK-7302) Failed to run CorrelateITCase class under windows environment

2017-07-31 Thread mingleizhang (JIRA)
mingleizhang created FLINK-7302: --- Summary: Failed to run CorrelateITCase class under windows environment Key: FLINK-7302 URL: https://issues.apache.org/jira/browse/FLINK-7302 Project: Flink

[GitHub] flink issue #4309: [FLINK-7166][avro] cleanup generated test classes in the ...

2017-07-31 Thread tzulitai
Github user tzulitai commented on the issue: https://github.com/apache/flink/pull/4309 Thanks for the fix. I think this LGTM, +1. @NicoK could you rebase on the latest master to incorproate the new test profiles (just to make sure nothing bad is affected by this change, although I

[jira] [Commented] (FLINK-7166) generated avro sources not cleaned up or re-created after changes

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

[jira] [Commented] (FLINK-7169) Support AFTER MATCH SKIP function in CEP library API

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

[GitHub] flink issue #4409: [FLINK-7283][python] fix PythonPlanBinderTest issues with...

2017-07-31 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/4409 merging. --- 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] [Commented] (FLINK-7305) Add new import block for shaded dependencies

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

[GitHub] flink pull request #4425: [FLINK-7305] [checkstyle] Allow imports from org.a...

2017-07-31 Thread zentol
GitHub user zentol opened a pull request: https://github.com/apache/flink/pull/4425 [FLINK-7305] [checkstyle] Allow imports from org.apache.flink.shaded and add new import block ## What is the purpose of the change This PR allows shaded imports which is hard requirement

[jira] [Closed] (FLINK-7263) Improve Pull Request Template

2017-07-31 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7263?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-7263. --- Resolution: Fixed > Improve Pull Request Template > - > >

[GitHub] flink pull request #4334: [FLINK-7191] Activate checkstyle flink-java/operat...

2017-07-31 Thread NicoK
Github user NicoK commented on a diff in the pull request: https://github.com/apache/flink/pull/4334#discussion_r130292761 --- Diff: flink-java/src/main/java/org/apache/flink/api/java/operators/translation/PlanProjectOperator.java --- @@ -27,30 +27,32 @@ import

[jira] [Commented] (FLINK-7191) Activate checkstyle flink-java/operators/translation

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

[GitHub] flink pull request #4347: [FLINK-7201] fix concurrency in JobLeaderIdService...

2017-07-31 Thread XuPingyong
Github user XuPingyong closed the pull request at: https://github.com/apache/flink/pull/4347 --- 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

[GitHub] flink pull request #3640: [FLINK-6213] [yarn] terminate resource manager its...

2017-07-31 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/3640#discussion_r130309444 --- Diff: flink-yarn/src/main/java/org/apache/flink/yarn/YarnFlinkResourceManager.java --- @@ -300,6 +301,8 @@ protected void

[jira] [Commented] (FLINK-7297) Instable Kafka09ProducerITCase.testCustomPartitioning test case

2017-07-31 Thread mingleizhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7297?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16107062#comment-16107062 ] mingleizhang commented on FLINK-7297: - Every time, I dont know why It would take me several hours to

[jira] [Created] (FLINK-7303) Build elasticsearch5 by default

2017-07-31 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-7303: --- Summary: Build elasticsearch5 by default Key: FLINK-7303 URL: https://issues.apache.org/jira/browse/FLINK-7303 Project: Flink Issue Type: Sub-task

[jira] [Comment Edited] (FLINK-7297) Instable Kafka09ProducerITCase.testCustomPartitioning test case

2017-07-31 Thread mingleizhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7297?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16107062#comment-16107062 ] mingleizhang edited comment on FLINK-7297 at 7/31/17 9:56 AM: -- Every time, I

[jira] [Commented] (FLINK-7283) PythonPlanBinderTest issues with python paths

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

[jira] [Commented] (FLINK-5832) Support for simple hive UDF

2017-07-31 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5832?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16106948#comment-16106948 ] Timo Walther commented on FLINK-5832: - [~clarkyzl] what is the status of your PR? If you have no time

[jira] [Comment Edited] (FLINK-5832) Support for simple hive UDF

2017-07-31 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5832?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16106948#comment-16106948 ] Timo Walther edited comment on FLINK-5832 at 7/31/17 8:04 AM: -- [~clarkyzl]

[GitHub] flink pull request #4225: [FLINK-7044] [queryable-st] Allow to specify names...

2017-07-31 Thread kl0u
Github user kl0u closed the pull request at: https://github.com/apache/flink/pull/4225 --- 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-6996) FlinkKafkaProducer010 doesn't guarantee at-least-once semantic

2017-07-31 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6996?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16107029#comment-16107029 ] Till Rohrmann commented on FLINK-6996: -- True. I hope this link works now:

[jira] [Commented] (FLINK-5704) Deprecate FlinkKafkaConsumer constructors in favor of improvements to decoupling from Kafka offset committing

2017-07-31 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5704?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16107058#comment-16107058 ] Tzu-Li (Gordon) Tai commented on FLINK-5704: Setting "Fix Version" to 1.4.0 for this issue.

[jira] [Commented] (FLINK-7297) Instable Kafka09ProducerITCase.testCustomPartitioning test case

2017-07-31 Thread mingleizhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7297?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16107059#comment-16107059 ] mingleizhang commented on FLINK-7297: - It is just a XML instead. > Instable

[jira] [Commented] (FLINK-6521) Add per job cleanup methods to HighAvailabilityServices

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

[GitHub] flink issue #4376: [FLINK-6521] Add per job cleanup methods to HighAvailabil...

2017-07-31 Thread tillrohrmann
Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/4376 The test case `JobManagerHACheckpointRecoveryITCase.testCheckpointedStreamingProgramIncrementalRocksDB` seems to be failing on Travis. It might be something caused by the changes. --- If your

[jira] [Commented] (FLINK-7289) Memory allocation of RocksDB can be problematic in container environments

2017-07-31 Thread Vinay (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7289?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16107105#comment-16107105 ] Vinay commented on FLINK-7289: -- Actually, I was expecting that the memory will be reclaimed when the job is

[jira] [Commented] (FLINK-7289) Memory allocation of RocksDB can be problematic in container environments

2017-07-31 Thread Vinay (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7289?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16107165#comment-16107165 ] Vinay commented on FLINK-7289: -- You are right about this "the memory pages will be replaced eventually when

[jira] [Commented] (FLINK-7270) Add support for dynamic properties to cluster entry point

2017-07-31 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7270?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16107175#comment-16107175 ] Till Rohrmann commented on FLINK-7270: -- We first have to address the command line parsing before

[jira] [Comment Edited] (FLINK-7270) Add support for dynamic properties to cluster entry point

2017-07-31 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7270?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16107175#comment-16107175 ] Till Rohrmann edited comment on FLINK-7270 at 7/31/17 11:41 AM: We first

[GitHub] flink pull request #4340: [FLINK-7185] Activate checkstyle flink-java/io

2017-07-31 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/4340#discussion_r130338928 --- Diff: flink-java/src/main/java/org/apache/flink/api/java/io/CsvReader.java --- @@ -23,9 +23,32 @@ import

[jira] [Commented] (FLINK-7185) Activate checkstyle flink-java/io

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

[jira] [Commented] (FLINK-7306) function notFollowedBy in CEP dont return a Pattern object

2017-07-31 Thread Kostas Kloudas (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7306?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16107265#comment-16107265 ] Kostas Kloudas commented on FLINK-7306: --- Hi [~Hanmiao Li]. You are right. This should be fixed. >

[jira] [Created] (FLINK-7309) NullPointerException in CodeGenUtils.timePointToInternalCode() generated code

2017-07-31 Thread Liangliang Chen (JIRA)
Liangliang Chen created FLINK-7309: -- Summary: NullPointerException in CodeGenUtils.timePointToInternalCode() generated code Key: FLINK-7309 URL: https://issues.apache.org/jira/browse/FLINK-7309

[GitHub] flink issue #4150: [FLINK-6951] Incompatible versions of httpcomponents jars...

2017-07-31 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/4150 @tzulitai Do we shade the `aws-sdk-java` in the Kinesis connector? We should probably, and shade it in Hadoop as well. If not, this could be a cause of the conflict... --- If your project is

[GitHub] flink issue #4340: [FLINK-7185] Activate checkstyle flink-java/io

2017-07-31 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/4340 merging. --- 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

[GitHub] flink pull request #4431: [FLINK-7318] [futures] Replace Flink's futures in ...

2017-07-31 Thread tillrohrmann
GitHub user tillrohrmann opened a pull request: https://github.com/apache/flink/pull/4431 [FLINK-7318] [futures] Replace Flink's futures in StackTraceSampleCoordinator with Java 8 CompletableFuture ## What is the purpose of the change Replace Flink's futures in

  1   2   3   >