[jira] [Updated] (FLINK-6738) HBaseConnectorITCase is flaky

2017-07-23 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6738?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated FLINK-6738: -- Labels: hbase (was: ) > HBaseConnectorITCase is flaky > - > > Key:

[jira] [Updated] (FLINK-6838) RescalingITCase fails in master branch

2017-07-23 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6838?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated FLINK-6838: -- Description: {code} Tests in error: RescalingITCase.testSavepointRescalingInKeyedState[1] » JobExecution Job

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

2017-07-23 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} tes

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

2017-07-23 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7049?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16069086#comment-16069086 ] Ted Yu edited comment on FLINK-7049 at 7/24/17 6:56 AM: Stack trac

[jira] [Closed] (FLINK-6365) Adapt default values of the Kinesis connector

2017-07-23 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6365?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai closed FLINK-6365. -- Resolution: Fixed > Adapt default values of the Kinesis connector >

[jira] [Reopened] (FLINK-6365) Adapt default values of the Kinesis connector

2017-07-23 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6365?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai reopened FLINK-6365: > Adapt default values of the Kinesis connector > --

[jira] [Updated] (FLINK-6365) Adapt default values of the Kinesis connector

2017-07-23 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6365?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-6365: --- Fix Version/s: (was: 1.3.2) > Adapt default values of the Kinesis connector >

[jira] [Resolved] (FLINK-6365) Adapt default values of the Kinesis connector

2017-07-23 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6365?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai resolved FLINK-6365. Resolution: Fixed Release Note: Some default values for configurations for AWS

[jira] [Closed] (FLINK-6365) Adapt default values of the Kinesis connector

2017-07-23 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6365?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai closed FLINK-6365. -- > Adapt default values of the Kinesis connector > --

[jira] [Commented] (FLINK-6365) Adapt default values of the Kinesis connector

2017-07-23 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6365?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16097956#comment-16097956 ] Tzu-Li (Gordon) Tai commented on FLINK-6365: Thanks for the discussions and co

[jira] [Commented] (FLINK-6301) Flink KafkaConnector09 leaks memory on reading compressed messages due to a Kafka consumer bug

2017-07-23 Thread Rahul Yadav (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6301?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16097953#comment-16097953 ] Rahul Yadav commented on FLINK-6301: [~StephanEwen]: https://github.com/apache/flink/p

[GitHub] flink pull request #4015: [FLINK-6301] [flink-connector-kafka-0.10] Upgradin...

2017-07-23 Thread vidhu5269
Github user vidhu5269 closed the pull request at: https://github.com/apache/flink/pull/4015 --- 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 e

[jira] [Commented] (FLINK-6301) Flink KafkaConnector09 leaks memory on reading compressed messages due to a Kafka consumer bug

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

[jira] [Commented] (FLINK-7174) Bump dependency of Kafka 0.10.x to the latest one

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

[GitHub] flink pull request #4386: (backport-1.3) [FLINK-7174] [kafka] Bump Kafka 0.1...

2017-07-23 Thread tzulitai
GitHub user tzulitai opened a pull request: https://github.com/apache/flink/pull/4386 (backport-1.3) [FLINK-7174] [kafka] Bump Kafka 0.10 dependency to 0.10.2.1 Backport of #4321 to `release-1.3`, with the following things being different: 1. No need to touch `KafkaConsumerThrea

[jira] [Commented] (FLINK-6301) Flink KafkaConnector09 leaks memory on reading compressed messages due to a Kafka consumer bug

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

[GitHub] flink issue #4015: [FLINK-6301] [flink-connector-kafka-0.10] Upgrading Kafka...

2017-07-23 Thread vidhu5269
Github user vidhu5269 commented on the issue: https://github.com/apache/flink/pull/4015 Closing this pull request as the change mentioned here is already covered as part of #4321. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub a

[jira] [Commented] (FLINK-6301) Flink KafkaConnector09 leaks memory on reading compressed messages due to a Kafka consumer bug

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

[jira] [Commented] (FLINK-7224) Incorrect Javadoc description in all Kafka consumer versions

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

[GitHub] flink issue #4015: [FLINK-6301] [flink-connector-kafka-0.10] Upgrading Kafka...

2017-07-23 Thread vidhu5269
Github user vidhu5269 commented on the issue: https://github.com/apache/flink/pull/4015 @StephanEwen : Oh, ok. Didn't know the policy. --- 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 fea

[GitHub] flink pull request #4363: [FLINK-7224] [kafka, docs] Fix incorrect Javadoc /...

2017-07-23 Thread tzulitai
Github user tzulitai closed the pull request at: https://github.com/apache/flink/pull/4363 --- 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 en

[jira] [Commented] (FLINK-7224) Incorrect Javadoc description in all Kafka consumer versions

2017-07-23 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7224?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16097917#comment-16097917 ] Tzu-Li (Gordon) Tai commented on FLINK-7224: Fixed for {{master}} via 58b53748

[jira] [Closed] (FLINK-7224) Incorrect Javadoc description in all Kafka consumer versions

2017-07-23 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7224?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai closed FLINK-7224. -- Resolution: Fixed Fix Version/s: 1.3.2 1.4.0 > Incorrect Javad

[jira] [Commented] (FLINK-7143) Partition assignment for Kafka consumer is not stable

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

[GitHub] flink pull request #4310: [misc] Commit read offsets in Kafka integration te...

2017-07-23 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/4310 --- 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 pull request #4375: [Flink-6365][kinesis-connector] Adapt default valu...

2017-07-23 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/4375 --- 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 pull request #4302: (master) [FLINK-7143] [kafka] Stricter tests for d...

2017-07-23 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/4302 --- 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 #4375: [Flink-6365][kinesis-connector] Adapt default values of t...

2017-07-23 Thread tzulitai
Github user tzulitai commented on the issue: https://github.com/apache/flink/pull/4375 Thanks for the PR! Since this was already thoroughly discussed, this LGTM. Merging .. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub a

[jira] [Commented] (FLINK-6539) Add automated end-to-end tests

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

[GitHub] flink issue #3911: [FLINK-6539] Add end-to-end tests

2017-07-23 Thread tzulitai
Github user tzulitai commented on the issue: https://github.com/apache/flink/pull/3911 I think this LGTM 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 wishes s

[jira] [Commented] (FLINK-7143) Partition assignment for Kafka consumer is not stable

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

[jira] [Commented] (FLINK-7143) Partition assignment for Kafka consumer is not stable

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

[GitHub] flink pull request #4301: (release-1.3) [FLINK-7143] [kafka] Fix indetermina...

2017-07-23 Thread tzulitai
Github user tzulitai closed the pull request at: https://github.com/apache/flink/pull/4301 --- 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 en

[GitHub] flink issue #4301: (release-1.3) [FLINK-7143] [kafka] Fix indeterminate part...

2017-07-23 Thread tzulitai
Github user tzulitai commented on the issue: https://github.com/apache/flink/pull/4301 This was merged via #4357. Closing .. --- 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

[GitHub] flink issue #4302: (master) [FLINK-7143] [kafka] Stricter tests for determin...

2017-07-23 Thread tzulitai
Github user tzulitai commented on the issue: https://github.com/apache/flink/pull/4302 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 th

[jira] [Commented] (FLINK-7143) Partition assignment for Kafka consumer is not stable

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

[jira] [Commented] (FLINK-7195) FlinkKafkaConsumer should not respect fetched partitions to filter restored partition states

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

[GitHub] flink pull request #4344: (release-1.3) [FLINK-7195] [kafka] Remove partitio...

2017-07-23 Thread tzulitai
Github user tzulitai closed the pull request at: https://github.com/apache/flink/pull/4344 --- 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 en

[jira] [Commented] (FLINK-7143) Partition assignment for Kafka consumer is not stable

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

[GitHub] flink pull request #4357: (release-1.3) [FLINK-7143, FLINK-7195] Collection ...

2017-07-23 Thread tzulitai
Github user tzulitai closed the pull request at: https://github.com/apache/flink/pull/4357 --- 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 en

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

2017-07-23 Thread zjureel
Github user zjureel commented on the issue: https://github.com/apache/flink/pull/4277 Thank you for your merging, thanks --- 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

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

2017-07-23 Thread zjureel
Github user zjureel closed the pull request at: https://github.com/apache/flink/pull/4277 --- 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 ena

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

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

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

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

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

2017-07-23 Thread zjureel
Github user zjureel closed the pull request at: https://github.com/apache/flink/pull/4220 --- 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 ena

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

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

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

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

[GitHub] flink issue #4220: [FLINK-6665] Pass a ScheduledExecutorService to the Resta...

2017-07-23 Thread zjureel
Github user zjureel commented on the issue: https://github.com/apache/flink/pull/4220 @StephanEwen Thank you for your 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 e

[jira] [Updated] (FLINK-7134) Remove hadoop1.x code in mapreduce.utils.HadoopUtils

2017-07-23 Thread mingleizhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7134?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] mingleizhang updated FLINK-7134: Fix Version/s: (was: 1.3.2) 1.4.0 > Remove hadoop1.x code in mapreduce.utils.

[jira] [Commented] (FLINK-4421) Make clocks and time measurements monotonous

2017-07-23 Thread mingleizhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4421?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16097851#comment-16097851 ] mingleizhang commented on FLINK-4421: - We already have {{System.nanoTime}} for measuri

[GitHub] flink issue #4385: wrong parameter check

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

[GitHub] flink pull request #4385: wrong parameter check

2017-07-23 Thread p1tz
GitHub user p1tz opened a pull request: https://github.com/apache/flink/pull/4385 wrong parameter check You can merge this pull request into a Git repository by running: $ git pull https://github.com/p1tz/flink patch-1 Alternatively you can review and apply these changes as t

[jira] [Closed] (FLINK-7225) Cutoff exception message in StateDescriptor

2017-07-23 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7225?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-7225. --- > Cutoff exception message in StateDescriptor > --- > >

[jira] [Resolved] (FLINK-7225) Cutoff exception message in StateDescriptor

2017-07-23 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7225?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-7225. - Resolution: Fixed Assignee: Stephan Ewen Release Note: Fixed in - 1.4.0 via 3c7560

[jira] [Commented] (FLINK-7174) Bump dependency of Kafka 0.10.x to the latest one

2017-07-23 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7174?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16097767#comment-16097767 ] Stephan Ewen commented on FLINK-7174: - Merged for {{1.4.0}} in 02850545e3143600c7265e7

[jira] [Commented] (FLINK-7143) Partition assignment for Kafka consumer is not stable

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

[GitHub] flink issue #4302: (master) [FLINK-7143] [kafka] Stricter tests for determin...

2017-07-23 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/4302 @tzulitai You can 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 your project does not have this feature enabled and wis

[jira] [Commented] (FLINK-7195) FlinkKafkaConsumer should not respect fetched partitions to filter restored partition states

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

[GitHub] flink issue #4344: (release-1.3) [FLINK-7195] [kafka] Remove partition list ...

2017-07-23 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/4344 @tzulitai Could you close this PR since its subsumed by #4357? --- 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

[GitHub] flink pull request #4321: [FLINK-7174] Bump Kafka 0.10 dependency to 0.10.2....

2017-07-23 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/4321 --- 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-7174) Bump dependency of Kafka 0.10.x to the latest one

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

[jira] [Updated] (FLINK-7242) Drop Java 7 Support

2017-07-23 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7242?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-7242: -- Component/s: Build System > Drop Java 7 Support > --- > > Key: F

[jira] [Resolved] (FLINK-7231) SlotSharingGroups are not always released in time for new restarts

2017-07-23 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7231?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-7231. - Resolution: Fixed Release Note: Fixed in - 1.4.0 via 605319b550aeba5612b0e32fa193521081b7a

[jira] [Closed] (FLINK-7231) SlotSharingGroups are not always released in time for new restarts

2017-07-23 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7231?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-7231. --- > SlotSharingGroups are not always released in time for new restarts > ---

[jira] [Closed] (FLINK-7216) ExecutionGraph can perform concurrent global restarts to scheduling

2017-07-23 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7216?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-7216. --- > ExecutionGraph can perform concurrent global restarts to scheduling > --

[jira] [Resolved] (FLINK-7216) ExecutionGraph can perform concurrent global restarts to scheduling

2017-07-23 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7216?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-7216. - Resolution: Fixed Release Note: Fixed in - 1.4.0 via 74a6cbab4e736cdb353d100cdd29f5180932

[GitHub] flink issue #4220: [FLINK-6665] Pass a ScheduledExecutorService to the Resta...

2017-07-23 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/4220 Thank you for the contribution! The code form this PR has been improved and merged in this commit: 65400bd0a0f6a3bdd3e0bad05e2179534eaf6e9e If you agree, could you close this PR? --

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

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

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

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

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

2017-07-23 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/4277 Thank you for the contribution! The code form this PR has been improved and merged in this commit: 65400bd0a0f6a3bdd3e0bad05e2179534eaf6e9e If you agree, could you close this PR? --

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

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

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

2017-07-23 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6667?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-6667. - Resolution: Fixed Fix Version/s: 1.3.2 1.4.0 Release Note: Fixed in

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

2017-07-23 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6665?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-6665. - Resolution: Fixed Fix Version/s: 1.3.2 Release Note: Fixed in - 1.4.0 via 65400bd0a

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

2017-07-23 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6665?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-6665. --- > Pass a ScheduledExecutorService to the RestartStrategy > ---

[jira] [Resolved] (FLINK-7105) Make ActorSystem creation per default non-daemonic

2017-07-23 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7105?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-7105. - Resolution: Fixed Fix Version/s: 1.4.0 Release Note: Fixed in 02bf80cf7108253dfc3444fd3

[jira] [Closed] (FLINK-7105) Make ActorSystem creation per default non-daemonic

2017-07-23 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7105?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-7105. --- > Make ActorSystem creation per default non-daemonic > --

[jira] [Commented] (FLINK-7241) Fix YARN high availability documentation

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

[GitHub] flink issue #4382: [FLINK-7241] Fix YARN high availability documentation

2017-07-23 Thread aljoscha
Github user aljoscha commented on the issue: https://github.com/apache/flink/pull/4382 Thanks 👌 Will update --- 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

[jira] [Resolved] (FLINK-6301) Flink KafkaConnector09 leaks memory on reading compressed messages due to a Kafka consumer bug

2017-07-23 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6301?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-6301. - Resolution: Duplicate Fix Version/s: (was: 1.4.0) (was: 1.2.2)

[jira] [Closed] (FLINK-6301) Flink KafkaConnector09 leaks memory on reading compressed messages due to a Kafka consumer bug

2017-07-23 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6301?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-6301. --- > Flink KafkaConnector09 leaks memory on reading compressed messages due to a > Kafka consumer bug >

[jira] [Updated] (FLINK-7174) Bump dependency of Kafka 0.10.x to the latest one

2017-07-23 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7174?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen updated FLINK-7174: Fix Version/s: 1.3.2 1.4.0 > Bump dependency of Kafka 0.10.x to the latest one >

[jira] [Updated] (FLINK-7174) Bump dependency of Kafka 0.10.x to the latest one

2017-07-23 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7174?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen updated FLINK-7174: Affects Version/s: 1.4.0 1.2.1 1.3.1 > Bump dependency

[jira] [Created] (FLINK-7246) Big latency shown on operator.latency

2017-07-23 Thread yinhua.dai (JIRA)
yinhua.dai created FLINK-7246: - Summary: Big latency shown on operator.latency Key: FLINK-7246 URL: https://issues.apache.org/jira/browse/FLINK-7246 Project: Flink Issue Type: Bug Compo

[jira] [Commented] (FLINK-7241) Fix YARN high availability documentation

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

[GitHub] flink issue #4382: [FLINK-7241] Fix YARN high availability documentation

2017-07-23 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/4382 I would go a bit further in updating this: - The ZooKeeper root node has a default value of `/flink` (I think). You only need to set this when you want to organize your ZooKeeper node t

[jira] [Updated] (FLINK-7242) Drop Java 7 Support

2017-07-23 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7242?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen updated FLINK-7242: Fix Version/s: 1.4.0 > Drop Java 7 Support > --- > > Key: FLINK-7242

[jira] [Commented] (FLINK-4421) Make clocks and time measurements monotonous

2017-07-23 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4421?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16097627#comment-16097627 ] Stephan Ewen commented on FLINK-4421: - The clocks can jump due to re-synchronization,

[jira] [Commented] (FLINK-6301) Flink KafkaConnector09 leaks memory on reading compressed messages due to a Kafka consumer bug

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

[GitHub] flink issue #4015: [FLINK-6301] [flink-connector-kafka-0.10] Upgrading Kafka...

2017-07-23 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/4015 @vidhu5269 The account management from the Apache/Github integration actually means that we cannot manually close pull requests, only via commit messages. So we would need you to close the pull r

[jira] [Created] (FLINK-7245) Enhance the operators to support holding back watermarks

2017-07-23 Thread Xingcan Cui (JIRA)
Xingcan Cui created FLINK-7245: -- Summary: Enhance the operators to support holding back watermarks Key: FLINK-7245 URL: https://issues.apache.org/jira/browse/FLINK-7245 Project: Flink Issue Type

[jira] [Commented] (FLINK-7202) Split supressions for flink-core, flink-java, flink-optimizer per package

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

[GitHub] flink pull request #4384: [FLINK-7202] Split supressions for flink-core, fli...

2017-07-23 Thread dawidwys
GitHub user dawidwys opened a pull request: https://github.com/apache/flink/pull/4384 [FLINK-7202] Split supressions for flink-core, flink-java, flink-opti… …mizer per package Thanks for contributing to Apache Flink. Before you open your pull request, please take the fo

[jira] [Commented] (FLINK-7105) Make ActorSystem creation per default non-daemonic

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

[GitHub] flink pull request #4259: [FLINK-7105] Make ActorSystems non daemonic

2017-07-23 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/4259 --- 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] [Updated] (FLINK-7243) Add ParquetInputFormat

2017-07-23 Thread godfrey he (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7243?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-7243: -- Description: Add a {{ParquetInputFormat}} to read data from a Apache Parquet file. (was: Add a ```Parq

[jira] [Updated] (FLINK-7243) Add ParquetInputFormat

2017-07-23 Thread godfrey he (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7243?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-7243: -- Description: Add a ```ParquetInputFormat``` to read data from a Apache Parquet file. (was: Add a `Parq

[jira] [Updated] (FLINK-7243) Add ParquetInputFormat

2017-07-23 Thread godfrey he (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7243?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-7243: -- Description: Add a `ParquetInputFormat` to read data from a Apache Parquet file. (was: Add a ParquetIn

[jira] [Updated] (FLINK-7243) Add ParquetInputFormat

2017-07-23 Thread godfrey he (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7243?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-7243: -- Description: Add a ParquetInputFormat to read data from a Apache Parquet file. > Add ParquetInputForma

[jira] [Created] (FLINK-7244) Add ParquetTableSource Implementation based on ParquetInputFormat

2017-07-23 Thread godfrey he (JIRA)
godfrey he created FLINK-7244: - Summary: Add ParquetTableSource Implementation based on ParquetInputFormat Key: FLINK-7244 URL: https://issues.apache.org/jira/browse/FLINK-7244 Project: Flink Is

[jira] [Assigned] (FLINK-2169) Add ParquetTableSource

2017-07-23 Thread godfrey he (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2169?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he reassigned FLINK-2169: - Assignee: godfrey he (was: Xu Pingyong) > Add ParquetTableSource > -- > >

  1   2   >