[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

[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

[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

[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

[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

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

2017-07-23 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7118?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16097533#comment-16097533 ] Aljoscha Krettek commented on FLINK-7118: - Agreed, it doesn't hurt to have these in 1.3.x. >

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

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

[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

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

2017-07-23 Thread mingleizhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7118?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16097542#comment-16097542 ] mingleizhang commented on FLINK-7118: - Thanks to [~greghogan] and [~aljoscha]. Nice! > Remove

[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=16097627#comment-16097627 ] Stephan Ewen commented on FLINK-4421: - The clocks can jump due to re-synchronization, and also due to

[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

[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=16097624#comment-16097624 ] ASF GitHub Bot commented on FLINK-6301: --- Github user StephanEwen commented on the issue:

[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

[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:

[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=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

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

2017-07-23 Thread godfrey he (JIRA)
godfrey he created FLINK-7243: - Summary: Add ParquetInputFormat Key: FLINK-7243 URL: https://issues.apache.org/jira/browse/FLINK-7243 Project: Flink Issue Type: Sub-task Reporter:

[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 > -- > >

[jira] [Commented] (FLINK-4849) trustStorePassword should be checked against null in SSLUtils#createSSLClientContext

2017-07-23 Thread mingleizhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4849?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16097548#comment-16097548 ] mingleizhang commented on FLINK-4849: - There already has a NULL check condition before this , which

[jira] [Commented] (FLINK-4849) trustStorePassword should be checked against null in SSLUtils#createSSLClientContext

2017-07-23 Thread mingleizhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4849?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16097549#comment-16097549 ] mingleizhang commented on FLINK-4849: - It probably not a problem. > trustStorePassword should be

[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=16097612#comment-16097612 ] ASF GitHub Bot commented on FLINK-7105: --- Github user asfgit closed the pull request at:

[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

[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-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

[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=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

[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

[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

[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=16097740#comment-16097740 ] ASF GitHub Bot commented on FLINK-7143: --- Github user zentol commented on the issue:

[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

[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] [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

[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-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=16097641#comment-16097641 ] ASF GitHub Bot commented on FLINK-6667: --- Github user StephanEwen commented on the issue:

[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=16097642#comment-16097642 ] ASF GitHub Bot commented on FLINK-6665: --- Github user StephanEwen commented on the issue:

[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] [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 >

[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] [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:

[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=16097708#comment-16097708 ] ASF GitHub Bot commented on FLINK-7174: --- Github user asfgit closed the pull request at:

[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

[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=16097635#comment-16097635 ] ASF GitHub Bot commented on FLINK-7241: --- Github user StephanEwen commented on the issue:

[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

[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=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] [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] [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

[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=16097767#comment-16097767 ] Stephan Ewen commented on FLINK-7174: - Merged for {{1.4.0}} in

[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

[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

[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] [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=16097916#comment-16097916 ] ASF GitHub Bot commented on FLINK-7143: --- Github user asfgit closed the pull request at:

[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

[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

[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

[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=16097917#comment-16097917 ] Tzu-Li (Gordon) Tai commented on FLINK-7224: Fixed for {{master}} via

[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

[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

[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

[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=16097956#comment-16097956 ] Tzu-Li (Gordon) Tai commented on FLINK-6365: Thanks for the discussions and contribution

[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] [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=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

[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

[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=16097928#comment-16097928 ] ASF GitHub Bot commented on FLINK-6301: --- Github user vidhu5269 commented on the issue:

[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=16097930#comment-16097930 ] ASF GitHub Bot commented on FLINK-6301: --- Github user vidhu5269 commented on the issue:

[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=16097927#comment-16097927 ] ASF GitHub Bot commented on FLINK-7224: --- Github user tzulitai closed the pull request at:

[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=16097953#comment-16097953 ] Rahul Yadav commented on FLINK-6301: [~StephanEwen]: https://github.com/apache/flink/pull/4321 takes

[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

[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=16097955#comment-16097955 ] ASF GitHub Bot commented on FLINK-6301: --- Github user vidhu5269 closed the pull request at:

[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-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=16097851#comment-16097851 ] mingleizhang commented on FLINK-4421: - We already have {{System.nanoTime}} for measuring with a

[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=16097875#comment-16097875 ] ASF GitHub Bot commented on FLINK-7143: --- Github user tzulitai closed the pull request at:

[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

[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

[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=16097879#comment-16097879 ] ASF GitHub Bot commented on FLINK-7143: --- Github user tzulitai commented on the issue:

[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

[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=16097861#comment-16097861 ] ASF GitHub Bot commented on FLINK-6665: --- 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=16097864#comment-16097864 ] ASF GitHub Bot commented on FLINK-6667: --- Github user zjureel closed the pull request at:

[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

[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=16097862#comment-16097862 ] ASF GitHub Bot commented on FLINK-6665: --- Github user zjureel closed the pull request at:

[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

[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=16097863#comment-16097863 ] ASF GitHub Bot commented on FLINK-6667: --- Github user zjureel commented on the issue:

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

2017-07-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 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

[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

[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

[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=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

[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=16097883#comment-16097883 ] ASF GitHub Bot commented on FLINK-6539: --- Github user tzulitai commented on the issue:

[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=16097882#comment-16097882 ] ASF GitHub Bot commented on FLINK-7143: --- Github user tzulitai closed the pull request at:

[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

[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

[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

  1   2   >