[jira] [Created] (FLINK-7290) Make release scripts modular

2017-07-28 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-7290: --- Summary: Make release scripts modular Key: FLINK-7290 URL: https://issues.apache.org/jira/browse/FLINK-7290 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-7291) Incorrect return value of getArity() in ListTypeInfo and MapTypeInfo

2017-07-28 Thread Fabian Hueske (JIRA)
Fabian Hueske created FLINK-7291: Summary: Incorrect return value of getArity() in ListTypeInfo and MapTypeInfo Key: FLINK-7291 URL: https://issues.apache.org/jira/browse/FLINK-7291 Project: Flink

[GitHub] flink pull request #4289: [FLINK-7092] [mesos] Shutdown ResourceManager comp...

2017-07-28 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/4289#discussion_r130078259 --- Diff: flink-mesos/src/main/java/org/apache/flink/mesos/runtime/clusterframework/MesosResourceManager.java --- @@ -312,6 +318,114 @@ private void

[GitHub] flink pull request #4417: [hotfix][tests] fix Invokable subclasses being pri...

2017-07-28 Thread NicoK
GitHub user NicoK opened a pull request: https://github.com/apache/flink/pull/4417 [hotfix][tests] fix Invokable subclasses being private ## What is the purpose of the change Recently, some `Invokable` subclasses became `private` and thus failed to be executed at the task

[jira] [Created] (FLINK-7292) Fix EMPTY MATCH bug in CEP.

2017-07-28 Thread zhangxiaoyu (JIRA)
zhangxiaoyu created FLINK-7292: -- Summary: Fix EMPTY MATCH bug in CEP. Key: FLINK-7292 URL: https://issues.apache.org/jira/browse/FLINK-7292 Project: Flink Issue Type: Bug Components:

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

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

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

2017-07-28 Thread Dian Fu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7293?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-7293: --- Description: Currently, when {{ProcessingTime}} is configured, the events are fed to NFA in the order of the

[jira] [Comment Edited] (FLINK-7292) Fix EMPTY MATCH bug in CEP.

2017-07-28 Thread Dawid Wysakowicz (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7292?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16104917#comment-16104917 ] Dawid Wysakowicz edited comment on FLINK-7292 at 7/28/17 1:05 PM: -- I

[jira] [Commented] (FLINK-7292) Fix EMPTY MATCH bug in CEP.

2017-07-28 Thread Dawid Wysakowicz (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7292?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16104917#comment-16104917 ] Dawid Wysakowicz commented on FLINK-7292: - I would not say it is a bug. It is a architectural

[jira] [Commented] (FLINK-7287) test instability in Kafka010ITCase.testCommitOffsetsToKafka

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

[GitHub] flink pull request #4360: [FLINK-7220] [checkpoints] Update RocksDB dependen...

2017-07-28 Thread StefanRRichter
Github user StefanRRichter closed the pull request at: https://github.com/apache/flink/pull/4360 --- 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-7220) Update RocksDB dependency to 5.5.5

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

[jira] [Commented] (FLINK-6998) Kafka connector needs to expose metrics for failed/successful offset commits in the Kafka Consumer callback

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

[GitHub] flink issue #4360: [FLINK-7220] [checkpoints] Update RocksDB dependency to 5...

2017-07-28 Thread greghogan
Github user greghogan commented on the issue: https://github.com/apache/flink/pull/4360 @uce @StephanEwen we had a bit of continued discussion in the JIRA. Can we add a pre-commit hook to the Apache repo to validate the format of the summary line? --- If your project is set up for

[jira] [Commented] (FLINK-7125) Remove configuration loading from AbstractYarnClusterDescriptor

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

[GitHub] flink issue #4280: [FLINK-7125] [yarn] Remove Configuration loading from Abs...

2017-07-28 Thread tillrohrmann
Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/4280 Thanks for your review @pnowojski. The PR passed on [Travis](https://travis-ci.org/tillrohrmann/flink/builds/258473756). Merging it. --- If your project is set up for it, you can reply to this

[jira] [Closed] (FLINK-7125) Remove configuration loading from AbstractYarnClusterDescriptor

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

[GitHub] flink pull request #4280: [FLINK-7125] [yarn] Remove Configuration loading f...

2017-07-28 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/4280 --- 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-7125) Remove configuration loading from AbstractYarnClusterDescriptor

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

[GitHub] flink issue #4407: [FLINK-7281] Fix various issues in (Maven) release infras...

2017-07-28 Thread aljoscha
Github user aljoscha commented on the issue: https://github.com/apache/flink/pull/4407 @zentol I will remove some changes from this so that only the Quickstart changes remain and the removal of the old release script and README. I think using `maven-release-plugin` is currently not a

[jira] [Commented] (FLINK-7281) Fix various issues in (Maven) release infrastructure

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

[jira] [Closed] (FLINK-7220) Update RocksDB dependency to 5.5.5

2017-07-28 Thread Stefan Richter (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7220?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter closed FLINK-7220. - Resolution: Fixed Merged in 219ae33d36 > Update RocksDB dependency to 5.5.5 >

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

2017-07-28 Thread litrain
Github user litrain commented on the issue: https://github.com/apache/flink/pull/4331 @dawidwys @yestinchen Thanks for your discussion, I am also working on the empty match issue now. Please have a look at https://issues.apache.org/jira/browse/FLINK-7292. --- If your project is

[GitHub] flink pull request #4281: [FLINK-7108] [yarn] Add YARN entry points based on...

2017-07-28 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/4281 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is

[jira] [Closed] (FLINK-7108) Implement Session cluster entry point

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

[jira] [Commented] (FLINK-7108) Implement Session cluster entry point

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

[jira] [Commented] (FLINK-7265) FileSystems should describe their kind and consistency level

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

[jira] [Commented] (FLINK-7265) FileSystems should describe their kind and consistency level

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

[GitHub] flink issue #4410: [FLINK-7268] [checkpoints] Scope SharedStateRegistry obje...

2017-07-28 Thread aljoscha
Github user aljoscha commented on the issue: https://github.com/apache/flink/pull/4410 I also reviewed `CheckpointCoordinatorTest.testSharedStateRegistrationOnRestore()`. Looks good 👍 The rest is the same as in #4410 so let's wait until #4353 is merged and then we can merge this

[GitHub] flink issue #4397: [FLINK-7265] [FLINK-7266] Introduce FileSystemKind and Co...

2017-07-28 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/4397 Want to see how we proceed with master. Same minimal version, or the more extensive version here? --- If your project is set up for it, you can reply to this email and have your reply appear on

[GitHub] flink issue #4397: [FLINK-7265] [FLINK-7266] Introduce FileSystemKind and Co...

2017-07-28 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/4397 Merged a minimal version of this into `release-1.3` in 854b05376a459a6197e41e141bb28a9befe481ad --- If your project is set up for it, you can reply to this email and have your reply appear on

[jira] [Commented] (FLINK-7220) Update RocksDB dependency to 5.5.5

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

[GitHub] flink pull request #4187: [FLINK-6998][Kafka Connector] Add kafka offset com...

2017-07-28 Thread tzulitai
Github user tzulitai commented on a diff in the pull request: https://github.com/apache/flink/pull/4187#discussion_r130058523 --- Diff: flink-connectors/flink-connector-kafka-0.9/src/main/java/org/apache/flink/streaming/connectors/kafka/internal/KafkaConsumerThread.java --- @@

[GitHub] flink pull request #4187: [FLINK-6998][Kafka Connector] Add kafka offset com...

2017-07-28 Thread tzulitai
Github user tzulitai commented on a diff in the pull request: https://github.com/apache/flink/pull/4187#discussion_r130058404 --- Diff: flink-connectors/flink-connector-kafka-0.8/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/Kafka08Fetcher.java --- @@

[GitHub] flink pull request #4187: [FLINK-6998][Kafka Connector] Add kafka offset com...

2017-07-28 Thread tzulitai
Github user tzulitai commented on a diff in the pull request: https://github.com/apache/flink/pull/4187#discussion_r130058545 --- Diff: flink-connectors/flink-connector-kafka-0.9/src/main/java/org/apache/flink/streaming/connectors/kafka/internal/KafkaConsumerThread.java --- @@

[jira] [Commented] (FLINK-6998) Kafka connector needs to expose metrics for failed/successful offset commits in the Kafka Consumer callback

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

[jira] [Commented] (FLINK-6998) Kafka connector needs to expose metrics for failed/successful offset commits in the Kafka Consumer callback

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

[jira] [Commented] (FLINK-6998) Kafka connector needs to expose metrics for failed/successful offset commits in the Kafka Consumer callback

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

[GitHub] flink pull request #4187: [FLINK-6998][Kafka Connector] Add kafka offset com...

2017-07-28 Thread tzulitai
Github user tzulitai commented on a diff in the pull request: https://github.com/apache/flink/pull/4187#discussion_r130058480 --- Diff: flink-connectors/flink-connector-kafka-0.8/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/Kafka08Fetcher.java --- @@

[GitHub] flink pull request #4187: [FLINK-6998][Kafka Connector] Add kafka offset com...

2017-07-28 Thread tzulitai
Github user tzulitai commented on a diff in the pull request: https://github.com/apache/flink/pull/4187#discussion_r130058073 --- Diff: flink-connectors/flink-connector-kafka-0.9/src/main/java/org/apache/flink/streaming/connectors/kafka/internal/KafkaConsumerThread.java --- @@

[GitHub] flink pull request #3669: [FLINK-6215] Make the StatefulSequenceSource scala...

2017-07-28 Thread tzulitai
Github user tzulitai commented on a diff in the pull request: https://github.com/apache/flink/pull/3669#discussion_r130080485 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/StatefulSequenceSource.java --- @@ -61,52 +65,89 @@

[GitHub] flink pull request #3669: [FLINK-6215] Make the StatefulSequenceSource scala...

2017-07-28 Thread tzulitai
Github user tzulitai commented on a diff in the pull request: https://github.com/apache/flink/pull/3669#discussion_r130081876 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/StatefulSequenceSource.java --- @@ -61,52 +65,89 @@

[GitHub] flink pull request #3669: [FLINK-6215] Make the StatefulSequenceSource scala...

2017-07-28 Thread tzulitai
Github user tzulitai commented on a diff in the pull request: https://github.com/apache/flink/pull/3669#discussion_r130081125 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/StatefulSequenceSource.java --- @@ -61,52 +65,89 @@

[GitHub] flink pull request #4419: [hotfix][tests] fix IncrementalRocksDbBackendEvent...

2017-07-28 Thread NicoK
GitHub user NicoK opened a pull request: https://github.com/apache/flink/pull/4419 [hotfix][tests] fix IncrementalRocksDbBackendEventTimeWindowCheckpointingITCase taking too long for the TravisCI output check ## What is the purpose of the change Fix test failures due to

[jira] [Commented] (FLINK-7220) Update RocksDB dependency to 5.5.5

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

[jira] [Commented] (FLINK-7220) Update RocksDB dependency to 5.5.5

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

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

2017-07-28 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-7295: Summary: Add callback for proper RpcEndpoint shut down Key: FLINK-7295 URL: https://issues.apache.org/jira/browse/FLINK-7295 Project: Flink Issue Type:

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

2017-07-28 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/4398 @greghogan Nice catch, i completely forgot about possible references in the docs. I modified the files you mentioned. --- If your project is set up for it, you can reply to this email and have your

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

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

[jira] [Commented] (FLINK-6215) Make the StatefulSequenceSource scalable.

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

[jira] [Commented] (FLINK-6215) Make the StatefulSequenceSource scalable.

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

[jira] [Commented] (FLINK-6215) Make the StatefulSequenceSource scalable.

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

[GitHub] flink issue #4360: [FLINK-7220] [checkpoints] Update RocksDB dependency to 5...

2017-07-28 Thread StefanRRichter
Github user StefanRRichter commented on the issue: https://github.com/apache/flink/pull/4360 @uce I know, but this was not intentional. I squashed them but pushed the wrong (unsquashed) branch because of my shell history. --- If your project is set up for it, you can reply to this

[GitHub] flink issue #4360: [FLINK-7220] [checkpoints] Update RocksDB dependency to 5...

2017-07-28 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/4360 Agree. There are two very non-descriptive commits in the master now. Let's try to avoid that in the future... --- If your project is set up for it, you can reply to this email and have your

[jira] [Commented] (FLINK-7220) Update RocksDB dependency to 5.5.5

2017-07-28 Thread Stefan Richter (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7220?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16104894#comment-16104894 ] Stefan Richter commented on FLINK-7220: --- Yes, I know. Accidentally pushed the wrong branch that was

[GitHub] flink pull request #4418: [FLINK-7293] [cep] Support custom order by in Patt...

2017-07-28 Thread dianfu
GitHub user dianfu opened a pull request: https://github.com/apache/flink/pull/4418 [FLINK-7293] [cep] Support custom order by in PatternStream *Thank you very much for contributing to Apache Flink - we are happy that you want to help us improve Flink. To help the community review

[GitHub] flink issue #4413: [BACKPORT-1.3][FLINK-7268] [checkpoints] Scope SharedStat...

2017-07-28 Thread aljoscha
Github user aljoscha commented on the issue: https://github.com/apache/flink/pull/4413 Forgot to mention, good to merge, modulo the nitpicks and the additional commit that introduces the delaying `Executor`. --- If your project is set up for it, you can reply to this email and have

[jira] [Updated] (FLINK-7291) Incorrect return value of getArity() in ListTypeInfo and MapTypeInfo

2017-07-28 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7291?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-7291: - Description: The implementation of {{getArity()}} in {{ListTypeInfo}} and {{MapTypeInfo}}

[GitHub] flink pull request #4413: [BACKPORT-1.3][FLINK-7268] [checkpoints] Scope Sha...

2017-07-28 Thread StefanRRichter
Github user StefanRRichter closed the pull request at: https://github.com/apache/flink/pull/4413 --- 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 #4413: [BACKPORT-1.3][FLINK-7268] [checkpoints] Scope SharedStat...

2017-07-28 Thread StefanRRichter
Github user StefanRRichter commented on the issue: https://github.com/apache/flink/pull/4413 Thanks a lot for the review @aljoscha ! Merging to 1.3 ... --- 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

[GitHub] flink pull request #4387: [FLINK-7143] [kafka] Forward ports of new Kafka te...

2017-07-28 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/4387 --- 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 #4414: [FLINK-7287][tests] fix test instabilities in Kafk...

2017-07-28 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/4414 --- 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 #4187: [FLINK-6998][Kafka Connector] Add kafka offset com...

2017-07-28 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/4187 --- 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-7265) FileSystems should describe their kind and consistency level

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

[GitHub] flink issue #4397: [FLINK-7265] [FLINK-7266] Introduce FileSystemKind and Co...

2017-07-28 Thread aljoscha
Github user aljoscha commented on the issue: https://github.com/apache/flink/pull/4397 Yes, I think either is fine because it's not user facing. --- 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] [Commented] (FLINK-6336) Placement Constraints for Mesos

2017-07-28 Thread Bhumika Bayani (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6336?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16104775#comment-16104775 ] Bhumika Bayani commented on FLINK-6336: --- Is it possible to have constraints such as hostname:UNIQUE

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

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

[jira] [Updated] (FLINK-7292) Fix EMPTY MATCH bug in CEP.

2017-07-28 Thread zhangxiaoyu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7292?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhangxiaoyu updated FLINK-7292: --- Description: Currently, with the pattern {quote}a? {quote}and the event{quote} a1{quote}, the result

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

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

[GitHub] flink issue #4285: [FLINK-7118] [hadoop] Remove hadoop1.x code in HadoopUtil...

2017-07-28 Thread tillrohrmann
Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/4285 Thanks for your contribution @zhangminglei. Changes look good to me. Merging this PR together with #4362. --- If your project is set up for it, you can reply to this email and have your reply

[jira] [Updated] (FLINK-7292) Fix EMPTY MATCH bug in CEP.

2017-07-28 Thread Dawid Wysakowicz (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7292?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-7292: Issue Type: New Feature (was: Bug) > Fix EMPTY MATCH bug in CEP. >

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

2017-07-28 Thread Bhumika Bayani (JIRA)
Bhumika Bayani created FLINK-7294: - Summary: mesos.resourcemanager.framework.role not working Key: FLINK-7294 URL: https://issues.apache.org/jira/browse/FLINK-7294 Project: Flink Issue Type:

[GitHub] flink issue #4360: [FLINK-7220] [checkpoints] Update RocksDB dependency to 5...

2017-07-28 Thread uce
Github user uce commented on the issue: https://github.com/apache/flink/pull/4360 @StefanRRichter As mentioned by Greg, we should either squash follow up commits like `Stephan's comments` into their parent or tag them similar to the main commit with a more descriptive message. ---

[jira] [Commented] (FLINK-7220) Update RocksDB dependency to 5.5.5

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

[GitHub] flink pull request #4397: [FLINK-7265] [FLINK-7266] Introduce FileSystemKind...

2017-07-28 Thread aljoscha
Github user aljoscha commented on a diff in the pull request: https://github.com/apache/flink/pull/4397#discussion_r130058934 --- Diff: flink-core/src/main/java/org/apache/flink/core/fs/ConsistencyLevel.java --- @@ -0,0 +1,119 @@ +/* + * Licensed to the Apache Software

[jira] [Commented] (FLINK-6998) Kafka connector needs to expose metrics for failed/successful offset commits in the Kafka Consumer callback

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

[jira] [Commented] (FLINK-6998) Kafka connector needs to expose metrics for failed/successful offset commits in the Kafka Consumer callback

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

[jira] [Commented] (FLINK-7265) FileSystems should describe their kind and consistency level

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

[GitHub] flink issue #4360: [FLINK-7220] [checkpoints] Update RocksDB dependency to 5...

2017-07-28 Thread StefanRRichter
Github user StefanRRichter commented on the issue: https://github.com/apache/flink/pull/4360 Thanks for the review @StephanEwen . I changed my PR according to your comments. Will merge now. --- If your project is set up for it, you can reply to this email and have your reply appear

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

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

[jira] [Updated] (FLINK-6215) Make the StatefulSequenceSource scalable.

2017-07-28 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6215?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-6215: --- Fix Version/s: 1.3.3 > Make the StatefulSequenceSource scalable. >

[jira] [Closed] (FLINK-4055) EventTimeWindowCheckpointingITCase.testPreAggregatedSlidingTimeWindow fails on Travis

2017-07-28 Thread Nico Kruber (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4055?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber closed FLINK-4055. -- Resolution: Cannot Reproduce let's close this for now as it does not seem to be occurring anymore

[GitHub] flink pull request #4413: [BACKPORT-1.3][FLINK-7268] [checkpoints] Scope Sha...

2017-07-28 Thread aljoscha
Github user aljoscha commented on a diff in the pull request: https://github.com/apache/flink/pull/4413#discussion_r130075732 --- Diff: flink-runtime/src/test/java/org/apache/flink/runtime/state/IncrementalKeyedStateHandleTest.java --- @@ -186,6 +187,77 @@ public void

[GitHub] flink pull request #4413: [BACKPORT-1.3][FLINK-7268] [checkpoints] Scope Sha...

2017-07-28 Thread aljoscha
Github user aljoscha commented on a diff in the pull request: https://github.com/apache/flink/pull/4413#discussion_r130075052 --- Diff: flink-runtime/src/test/java/org/apache/flink/runtime/state/IncrementalKeyedStateHandleTest.java --- @@ -186,6 +187,77 @@ public void

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

2017-07-28 Thread Dawid Wysakowicz (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7293?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16104922#comment-16104922 ] Dawid Wysakowicz commented on FLINK-7293: - Hmm, I can't see a way to sort an unbounded stream of

[GitHub] flink pull request #4413: [BACKPORT-1.3][FLINK-7268] [checkpoints] Scope Sha...

2017-07-28 Thread aljoscha
Github user aljoscha commented on a diff in the pull request: https://github.com/apache/flink/pull/4413#discussion_r130073387 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/state/IncrementalKeyedStateHandle.java --- @@ -202,10 +208,21 @@ public long getStateSize()

[GitHub] flink pull request #4413: [BACKPORT-1.3][FLINK-7268] [checkpoints] Scope Sha...

2017-07-28 Thread aljoscha
Github user aljoscha commented on a diff in the pull request: https://github.com/apache/flink/pull/4413#discussion_r130072157 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointCoordinator.java --- @@ -1044,10 +1050,23 @@ public boolean

[GitHub] flink pull request #4413: [BACKPORT-1.3][FLINK-7268] [checkpoints] Scope Sha...

2017-07-28 Thread aljoscha
Github user aljoscha commented on a diff in the pull request: https://github.com/apache/flink/pull/4413#discussion_r130074735 --- Diff: flink-runtime/src/test/java/org/apache/flink/runtime/checkpoint/ZooKeeperCompletedCheckpointStoreTest.java --- @@ -162,11 +161,7 @@ public Void

[GitHub] flink issue #4239: [FLINK-6988] flink-connector-kafka-0.11 with exactly-once...

2017-07-28 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/4239 please add an entry to the `MODULES_CONNECTORS' variable in the `tools/travis_mvn_watchdog` sh script. --- If your project is set up for it, you can reply to this email and have your reply appear

[jira] [Commented] (FLINK-6988) Add Apache Kafka 0.11 connector

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

[jira] [Commented] (FLINK-6336) Placement Constraints for Mesos

2017-07-28 Thread Bhumika Bayani (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6336?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16104778#comment-16104778 ] Bhumika Bayani commented on FLINK-6336: --- Can we use any other way to such as env-variables /

[jira] [Commented] (FLINK-7220) Update RocksDB dependency to 5.5.5

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

[jira] [Updated] (FLINK-7292) Fix EMPTY MATCH bug in CEP.

2017-07-28 Thread zhangxiaoyu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7292?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhangxiaoyu updated FLINK-7292: --- Description: Currently, with the pattern {quote}a? {quote}and the event{quote} a1{quote}, the result

[jira] [Updated] (FLINK-7292) Fix EMPTY MATCH bug in CEP.

2017-07-28 Thread zhangxiaoyu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7292?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhangxiaoyu updated FLINK-7292: --- Description: Currently, with the pattern {quote}a? {quote}and the event{quote} a1{quote}, the result

[GitHub] flink issue #4360: [FLINK-7220] [checkpoints] Update RocksDB dependency to 5...

2017-07-28 Thread greghogan
Github user greghogan commented on the issue: https://github.com/apache/flink/pull/4360 The merge looks to have not been squashed. --- 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-7220) Update RocksDB dependency to 5.5.5

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

[jira] [Commented] (FLINK-7220) Update RocksDB dependency to 5.5.5

2017-07-28 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7220?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16104898#comment-16104898 ] Greg Hogan commented on FLINK-7220: --- Ah, just a small thing. Unfortunate that we can't fix this but good

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

2017-07-28 Thread Dian Fu (JIRA)
Dian Fu created FLINK-7293: -- Summary: Support custom order by in PatternStream Key: FLINK-7293 URL: https://issues.apache.org/jira/browse/FLINK-7293 Project: Flink Issue Type: Sub-task

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

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

[GitHub] flink issue #4187: [FLINK-6998][Kafka Connector] Add kafka offset commit met...

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

  1   2   3   4   >