[jira] [Commented] (FLINK-3397) Failed streaming jobs should fall back to the most recent checkpoint/savepoint

2016-07-07 Thread ramkrishna.s.vasudevan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3397?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15367226#comment-15367226 ] ramkrishna.s.vasudevan commented on FLINK-3397: --- [~uce] Any feedback here on

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

2016-07-07 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4022?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15367094#comment-15367094 ] Tzu-Li (Gordon) Tai edited comment on FLINK-4022 at 7/8/16 2:05 AM:

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

2016-07-07 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4022?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15367094#comment-15367094 ] Tzu-Li (Gordon) Tai edited comment on FLINK-4022 at 7/8/16 2:04 AM:

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

2016-07-07 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4022?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15367094#comment-15367094 ] Tzu-Li (Gordon) Tai edited comment on FLINK-4022 at 7/8/16 2:04 AM:

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

2016-07-07 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4022?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15367094#comment-15367094 ] Tzu-Li (Gordon) Tai edited comment on FLINK-4022 at 7/8/16 2:02 AM:

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

2016-07-07 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4022?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15367094#comment-15367094 ] Tzu-Li (Gordon) Tai edited comment on FLINK-4022 at 7/8/16 2:01 AM:

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

2016-07-07 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4022?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15367094#comment-15367094 ] Tzu-Li (Gordon) Tai commented on FLINK-4022: Related: https://issues.apache.or

[jira] [Commented] (FLINK-3924) Remove protobuf shading from Kinesis connector

2016-07-07 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3924?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15367087#comment-15367087 ] Tzu-Li (Gordon) Tai commented on FLINK-3924: Will this be resolved for 1.1? >

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

2016-07-07 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4022?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15367086#comment-15367086 ] Tzu-Li (Gordon) Tai commented on FLINK-4022: [~rmetzger] I can start working o

[jira] [Commented] (FLINK-3231) Handle Kinesis-side resharding in Kinesis streaming consumer

2016-07-07 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3231?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15367080#comment-15367080 ] Tzu-Li (Gordon) Tai commented on FLINK-3231: :) No problem, thank you for merg

[jira] [Comment Edited] (FLINK-4170) Remove `CONFIG_` prefix from KinesisConfigConstants variables

2016-07-07 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4170?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15367075#comment-15367075 ] Tzu-Li (Gordon) Tai edited comment on FLINK-4170 at 7/8/16 1:40 AM:

[jira] [Commented] (FLINK-4170) Remove `CONFIG_` prefix from KinesisConfigConstants variables

2016-07-07 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4170?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15367075#comment-15367075 ] Tzu-Li (Gordon) Tai commented on FLINK-4170: [~uce]: If you want, I'll have ti

[jira] [Commented] (FLINK-4019) Expose approximateArrivalTimestamp through the KinesisDeserializationSchema interface

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

[GitHub] flink issue #2214: [FLINK-4019][kinesis-connector] Use Kinesis records' appr...

2016-07-07 Thread tzulitai
Github user tzulitai commented on the issue: https://github.com/apache/flink/pull/2214 @rmetzger can you also help review this PR for the Kinesis connector too? 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

[jira] [Commented] (FLINK-4018) Configurable idle time between getRecords requests to Kinesis shards

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

[GitHub] flink issue #2071: [FLINK-4018][streaming-connectors] Configurable idle time...

2016-07-07 Thread tzulitai
Github user tzulitai commented on the issue: https://github.com/apache/flink/pull/2071 @rmetzger Rebased + addressed your comment. Please review, 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 d

[jira] [Commented] (FLINK-4019) Expose approximateArrivalTimestamp through the KinesisDeserializationSchema interface

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

[GitHub] flink pull request #2214: [FLINK-4019][kinesis-connector] Use Kinesis record...

2016-07-07 Thread tzulitai
GitHub user tzulitai opened a pull request: https://github.com/apache/flink/pull/2214 [FLINK-4019][kinesis-connector] Use Kinesis records' approximateArrivalTimestamp This Kinesis-provided timestamp is used in the following: 1) Exposed through the KinesisDeserializationSchema fo

[jira] [Created] (FLINK-4175) Broadcast data sent increases with # slots per TM

2016-07-07 Thread Felix Neutatz (JIRA)
Felix Neutatz created FLINK-4175: Summary: Broadcast data sent increases with # slots per TM Key: FLINK-4175 URL: https://issues.apache.org/jira/browse/FLINK-4175 Project: Flink Issue Type: I

[jira] [Commented] (FLINK-3190) Retry rate limits for DataStream API

2016-07-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15366951#comment-15366951 ] ASF GitHub Bot commented on FLINK-3190: --- Github user fijolekProjects commented on a

[GitHub] flink pull request #1954: [FLINK-3190] failure rate restart strategy

2016-07-07 Thread fijolekProjects
Github user fijolekProjects commented on a diff in the pull request: https://github.com/apache/flink/pull/1954#discussion_r70004152 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/restart/FixedDelayRestartStrategy.java --- @@ -108,22 +87,7 @@ public s

[jira] [Commented] (FLINK-3943) Add support for EXCEPT (set minus)

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

[GitHub] flink issue #2169: [FLINK-3943] Add support for EXCEPT operator

2016-07-07 Thread mushketyk
Github user mushketyk commented on the issue: https://github.com/apache/flink/pull/2169 @fhueske Hey. Sorry for bothering you. Do I need to change something else in this PR? --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well

[jira] [Commented] (FLINK-3599) GSoC: Code Generation in Serializers

2016-07-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3599?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15366482#comment-15366482 ] ASF GitHub Bot commented on FLINK-3599: --- Github user greghogan commented on a diff i

[GitHub] flink pull request #2211: [WIP][FLINK-3599] Code generation for PojoSerializ...

2016-07-07 Thread greghogan
Github user greghogan commented on a diff in the pull request: https://github.com/apache/flink/pull/2211#discussion_r69953281 --- Diff: flink-core/src/main/java/org/apache/flink/api/java/typeutils/PojoTypeInfo.java --- @@ -419,4 +470,47 @@ public String toString() {

[jira] [Commented] (FLINK-3599) GSoC: Code Generation in Serializers

2016-07-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3599?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15366478#comment-15366478 ] ASF GitHub Bot commented on FLINK-3599: --- Github user greghogan commented on a diff i

[GitHub] flink pull request #2211: [WIP][FLINK-3599] Code generation for PojoSerializ...

2016-07-07 Thread greghogan
Github user greghogan commented on a diff in the pull request: https://github.com/apache/flink/pull/2211#discussion_r69952548 --- Diff: flink-core/src/main/java/org/apache/flink/api/java/typeutils/PojoTypeInfo.java --- @@ -70,10 +75,21 @@ private static final Pattern PATTE

[jira] [Commented] (FLINK-3599) GSoC: Code Generation in Serializers

2016-07-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3599?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15366470#comment-15366470 ] ASF GitHub Bot commented on FLINK-3599: --- Github user greghogan commented on a diff i

[GitHub] flink pull request #2211: [WIP][FLINK-3599] Code generation for PojoSerializ...

2016-07-07 Thread greghogan
Github user greghogan commented on a diff in the pull request: https://github.com/apache/flink/pull/2211#discussion_r69951927 --- Diff: flink-core/src/main/java/org/apache/flink/api/java/typeutils/PojoTypeInfo.java --- @@ -70,10 +75,21 @@ private static final Pattern PATTE

[jira] [Commented] (FLINK-3599) GSoC: Code Generation in Serializers

2016-07-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3599?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15366458#comment-15366458 ] ASF GitHub Bot commented on FLINK-3599: --- Github user greghogan commented on a diff i

[GitHub] flink pull request #2211: [WIP][FLINK-3599] Code generation for PojoSerializ...

2016-07-07 Thread greghogan
Github user greghogan commented on a diff in the pull request: https://github.com/apache/flink/pull/2211#discussion_r69951075 --- Diff: flink-core/src/main/java/org/apache/flink/api/java/typeutils/PojoTypeInfo.java --- @@ -315,6 +331,23 @@ public int getFieldIndex(String fieldName

[jira] [Commented] (FLINK-3599) GSoC: Code Generation in Serializers

2016-07-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3599?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15366439#comment-15366439 ] ASF GitHub Bot commented on FLINK-3599: --- Github user greghogan commented on a diff i

[GitHub] flink pull request #2211: [WIP][FLINK-3599] Code generation for PojoSerializ...

2016-07-07 Thread greghogan
Github user greghogan commented on a diff in the pull request: https://github.com/apache/flink/pull/2211#discussion_r69949156 --- Diff: flink-core/src/main/java/org/apache/flink/api/common/ExecutionConfig.java --- @@ -99,6 +99,8 @@ private boolean forceAvro = false;

[jira] [Commented] (FLINK-4116) Document metrics

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

[jira] [Commented] (FLINK-3673) Annotations for code generation

2016-07-07 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3673?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15366425#comment-15366425 ] Greg Hogan commented on FLINK-3673: --- Could we file a ticket for this with a fix version

[GitHub] flink pull request #2158: [FLINK-4116] Metrics documentation

2016-07-07 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/2158#discussion_r69947337 --- Diff: docs/apis/metrics.md --- @@ -0,0 +1,441 @@ +--- +title: "Metrics" +# Top-level navigation +top-nav-group: apis +top-nav-pos:

[jira] [Created] (FLINK-4174) Enhance Window Evictor

2016-07-07 Thread vishnu viswanath (JIRA)
vishnu viswanath created FLINK-4174: --- Summary: Enhance Window Evictor Key: FLINK-4174 URL: https://issues.apache.org/jira/browse/FLINK-4174 Project: Flink Issue Type: Sub-task Com

[jira] [Updated] (FLINK-3734) Unclosed DataInputView in AbstractAlignedProcessingTimeWindowOperator#restoreState()

2016-07-07 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3734?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated FLINK-3734: -- Description: {code} DataInputView in = inputState.getState(getUserCodeClassloader()); final long nextEv

[jira] [Closed] (FLINK-3648) Introduce Trigger Test Harness

2016-07-07 Thread Kostas Kloudas (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3648?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas closed FLINK-3648. - Resolution: Fixed > Introduce Trigger Test Harness > -- > >

[jira] [Commented] (FLINK-3648) Introduce Trigger Test Harness

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

[GitHub] flink pull request #2199: [FLINK-3648] Introduce Trigger Test Harness

2016-07-07 Thread kl0u
Github user kl0u closed the pull request at: https://github.com/apache/flink/pull/2199 --- 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 enable

[jira] [Commented] (FLINK-3648) Introduce Trigger Test Harness

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

[GitHub] flink issue #2199: [FLINK-3648] Introduce Trigger Test Harness

2016-07-07 Thread aljoscha
Github user aljoscha commented on the issue: https://github.com/apache/flink/pull/2199 Thanks for your work. 😃 I merged it. Could you please take care of closing this PR and the issue? --- If your project is set up for it, you can reply to this email and have your reply appear on

[jira] [Commented] (FLINK-4127) Clean up configuration and check breaking API changes

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

[GitHub] flink issue #2177: [FLINK-4127] Check API compatbility for 1.1 in flink-core

2016-07-07 Thread aljoscha
Github user aljoscha commented on the issue: https://github.com/apache/flink/pull/2177 Yeah, then let's leave them as they were since we don't know yet what mesos will require there. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHu

[jira] [Commented] (FLINK-4169) CEP Does Not Work with RocksDB StateBackend

2016-07-07 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4169?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15366224#comment-15366224 ] Aljoscha Krettek commented on FLINK-4169: - I added a fix for this to my CEP PR: ht

[jira] [Created] (FLINK-4173) Replace maven-assembly-plugin by maven-shade-plugin in flink-metrics

2016-07-07 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-4173: Summary: Replace maven-assembly-plugin by maven-shade-plugin in flink-metrics Key: FLINK-4173 URL: https://issues.apache.org/jira/browse/FLINK-4173 Project: Flink

[jira] [Commented] (FLINK-4127) Clean up configuration and check breaking API changes

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

[GitHub] flink issue #2177: [FLINK-4127] Check API compatbility for 1.1 in flink-core

2016-07-07 Thread rmetzger
Github user rmetzger commented on the issue: https://github.com/apache/flink/pull/2177 But with this argument, it would be even better to leave the configuration parameters as they are in 1.0 until we are 100% certain that mesos needs a similar mechanism. --- If your project is set

[jira] [Commented] (FLINK-4116) Document metrics

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

[jira] [Commented] (FLINK-4116) Document metrics

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

[GitHub] flink pull request #2158: [FLINK-4116] Metrics documentation

2016-07-07 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/2158#discussion_r69913367 --- Diff: docs/apis/metrics.md --- @@ -0,0 +1,441 @@ +--- +title: "Metrics" +# Top-level navigation +top-nav-group: apis +top-nav-pos:

[GitHub] flink pull request #2158: [FLINK-4116] Metrics documentation

2016-07-07 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/2158#discussion_r69913430 --- Diff: docs/apis/metrics.md --- @@ -0,0 +1,441 @@ +--- +title: "Metrics" +# Top-level navigation +top-nav-group: apis +top-nav-pos:

[jira] [Commented] (FLINK-4116) Document metrics

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

[GitHub] flink pull request #2158: [FLINK-4116] Metrics documentation

2016-07-07 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/2158#discussion_r69913171 --- Diff: docs/apis/metrics.md --- @@ -0,0 +1,441 @@ +--- +title: "Metrics" +# Top-level navigation +top-nav-group: apis +top-nav-pos: 13

[jira] [Commented] (FLINK-4127) Clean up configuration and check breaking API changes

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

[jira] [Commented] (FLINK-3295) Flink Kafka consumer fails with NoNodeException if zkConnect string contains chroot-path

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

[jira] [Commented] (FLINK-4116) Document metrics

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

[GitHub] flink pull request #2158: [FLINK-4116] Metrics documentation

2016-07-07 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/2158#discussion_r69910710 --- Diff: docs/apis/metrics.md --- @@ -0,0 +1,441 @@ +--- +title: "Metrics" +# Top-level navigation +top-nav-group: apis +top-nav-pos: 13

[GitHub] flink pull request #1555: [FLINK-3295][Kafka 0.8] Improve ZK error behavior

2016-07-07 Thread rmetzger
Github user rmetzger closed the pull request at: https://github.com/apache/flink/pull/1555 --- 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 #2210: [FLINK-4167] [metrics] Close IOMetricGroup in TaskMetricG...

2016-07-07 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/2210 It gets an IOMG because in the past it would forward this group to its deserializers, for Input byte counting etc. . I didn't change it cause i forgot about my own convention on how to use the IOMG.

[GitHub] flink issue #2177: [FLINK-4127] Check API compatbility for 1.1 in flink-core

2016-07-07 Thread rmetzger
Github user rmetzger commented on the issue: https://github.com/apache/flink/pull/2177 So you are suggesting to use the heap cutoff also for the JVM started in standalone mode? The cutoff was introduced for YARN because there is a difference in the amount of used memory for a cont

[jira] [Commented] (FLINK-4127) Clean up configuration and check breaking API changes

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

[GitHub] flink issue #2177: [FLINK-4127] Check API compatbility for 1.1 in flink-core

2016-07-07 Thread aljoscha
Github user aljoscha commented on the issue: https://github.com/apache/flink/pull/2177 My thinking was that Mesos maybe didn't require this, yes. Having it for Yarn only makes for a better user experience right now. So we could leave it under the "container" namespace. --- If your p

[jira] [Commented] (FLINK-4167) TaskMetricGroup does not close IOMetricGroup

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

[jira] [Commented] (FLINK-3295) Flink Kafka consumer fails with NoNodeException if zkConnect string contains chroot-path

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

[GitHub] flink issue #1555: [FLINK-3295][Kafka 0.8] Improve ZK error behavior

2016-07-07 Thread rmetzger
Github user rmetzger commented on the issue: https://github.com/apache/flink/pull/1555 Closing this PR. It's outdated by 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 enab

[jira] [Commented] (FLINK-4156) Job with -m yarn-cluster registers TaskManagers to another running Yarn session

2016-07-07 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4156?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15366126#comment-15366126 ] Robert Metzger commented on FLINK-4156: --- Isn't this issue the same as FLINK-4166? >

[GitHub] flink pull request #2213: [FLINK-4172] [gelly] Don't proxy a ProxiedObject

2016-07-07 Thread greghogan
GitHub user greghogan opened a pull request: https://github.com/apache/flink/pull/2213 [FLINK-4172] [gelly] Don't proxy a ProxiedObject Retrieve the proxied object and wrap in a new proxy. You can merge this pull request into a Git repository by running: $ git pull https://gith

[jira] [Commented] (FLINK-4171) StatsD does not accept metrics whose name contains ":"

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

[GitHub] flink issue #2212: [FLINK-4171] [metrics] Replace : chars in StatsD metric n...

2016-07-07 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/2212 +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 feature i

[jira] [Commented] (FLINK-4171) StatsD does not accept metrics whose name contains ":"

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

[GitHub] flink pull request #2212: [FLINK-4171] [metrics] Replace : chars in StatsD m...

2016-07-07 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/2212#discussion_r69907899 --- Diff: flink-core/src/main/java/org/apache/flink/metrics/reporter/AbstractReporter.java --- @@ -74,4 +74,14 @@ public void notifyOfRemovedMetric(Metric met

[GitHub] flink issue #2071: [FLINK-4018][streaming-connectors] Configurable idle time...

2016-07-07 Thread rmetzger
Github user rmetzger commented on the issue: https://github.com/apache/flink/pull/2071 Great, thank you. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or

[jira] [Commented] (FLINK-4018) Configurable idle time between getRecords requests to Kinesis shards

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

[jira] [Commented] (FLINK-4171) StatsD does not accept metrics whose name contains ":"

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

[GitHub] flink pull request #2212: [FLINK-4171] [metrics] Replace : chars in StatsD m...

2016-07-07 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/2212#discussion_r69907730 --- Diff: flink-core/src/main/java/org/apache/flink/metrics/reporter/AbstractReporter.java --- @@ -74,4 +74,14 @@ public void notifyOfRemovedMetric(Metric met

[GitHub] flink issue #2071: [FLINK-4018][streaming-connectors] Configurable idle time...

2016-07-07 Thread tzulitai
Github user tzulitai commented on the issue: https://github.com/apache/flink/pull/2071 I'll try to update this PR tomorrow. --- 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 enable

[jira] [Commented] (FLINK-4018) Configurable idle time between getRecords requests to Kinesis shards

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

[jira] [Commented] (FLINK-4172) Don't proxy a ProxiedObject

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

[GitHub] flink issue #2177: [FLINK-4127] Check API compatbility for 1.1 in flink-core

2016-07-07 Thread aljoscha
Github user aljoscha commented on the issue: https://github.com/apache/flink/pull/2177 Sorry for chiming in late, but can't - `heap-cutoff-ratio` and `heap-cutoff-min` be general parameters that apply to all VMs we start? Same for `master.env.*` and `taskmanager.env.*`. Should

[jira] [Commented] (FLINK-4171) StatsD does not accept metrics whose name contains ":"

2016-07-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4171?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15366093#comment-15366093 ] ASF GitHub Bot commented on FLINK-4171: --- GitHub user tillrohrmann opened a pull requ

[jira] [Commented] (FLINK-4127) Clean up configuration and check breaking API changes

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

[GitHub] flink pull request #2212: [FLINK-4171] [metrics] Replace : chars in StatsD m...

2016-07-07 Thread tillrohrmann
GitHub user tillrohrmann opened a pull request: https://github.com/apache/flink/pull/2212 [FLINK-4171] [metrics] Replace : chars in StatsD metric names The StatsD server rejects metrics whose names contain the : character. Therefore, metric names which contain : chars will be al

[jira] [Created] (FLINK-4172) Don't proxy a ProxiedObject

2016-07-07 Thread Greg Hogan (JIRA)
Greg Hogan created FLINK-4172: - Summary: Don't proxy a ProxiedObject Key: FLINK-4172 URL: https://issues.apache.org/jira/browse/FLINK-4172 Project: Flink Issue Type: Bug Components: Gel

[jira] [Commented] (FLINK-4169) CEP Does Not Work with RocksDB StateBackend

2016-07-07 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4169?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15366088#comment-15366088 ] Robert Metzger commented on FLINK-4169: --- Adding rocksdb as test-scoped dependency to

[jira] [Commented] (FLINK-4170) Remove `CONFIG_` prefix from KinesisConfigConstants variables

2016-07-07 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4170?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15366086#comment-15366086 ] Robert Metzger commented on FLINK-4170: --- +1 > Remove `CONFIG_` prefix from KinesisC

[jira] [Commented] (FLINK-4127) Clean up configuration and check breaking API changes

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

[GitHub] flink issue #2177: [FLINK-4127] Check API compatbility for 1.1 in flink-core

2016-07-07 Thread rmetzger
Github user rmetzger commented on the issue: https://github.com/apache/flink/pull/2177 I'll rename `containerized` to `container` once I got a third confirmation from a committer on this issue. --- If your project is set up for it, you can reply to this email and have your reply appe

[jira] [Assigned] (FLINK-4154) Correction of murmur hash breaks backwards compatibility

2016-07-07 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4154?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan reassigned FLINK-4154: - Assignee: Greg Hogan > Correction of murmur hash breaks backwards compatibility > ---

[jira] [Commented] (FLINK-4165) Event-Time CEP Job Sometimes Fails After Restart

2016-07-07 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4165?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15366073#comment-15366073 ] Aljoscha Krettek commented on FLINK-4165: - I added a commit for adding the doc in

[jira] [Created] (FLINK-4171) StatsD does not accept metrics whose name contains ":"

2016-07-07 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-4171: Summary: StatsD does not accept metrics whose name contains ":" Key: FLINK-4171 URL: https://issues.apache.org/jira/browse/FLINK-4171 Project: Flink Issue Ty

[jira] [Comment Edited] (FLINK-4170) Remove `CONFIG_` prefix from KinesisConfigConstants variables

2016-07-07 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4170?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15366067#comment-15366067 ] Tzu-Li (Gordon) Tai edited comment on FLINK-4170 at 7/7/16 1:10 PM:

[jira] [Commented] (FLINK-4170) Remove `CONFIG_` prefix from KinesisConfigConstants variables

2016-07-07 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4170?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15366067#comment-15366067 ] Tzu-Li (Gordon) Tai commented on FLINK-4170: I had this in mind too, especiall

[jira] [Commented] (FLINK-4170) Remove `CONFIG_` prefix from KinesisConfigConstants variables

2016-07-07 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4170?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15366062#comment-15366062 ] Ufuk Celebi commented on FLINK-4170: [~tzulitai] what do you think? > Remove `CONFIG_

[jira] [Created] (FLINK-4170) Remove `CONFIG_` prefix from KinesisConfigConstants variables

2016-07-07 Thread Ufuk Celebi (JIRA)
Ufuk Celebi created FLINK-4170: -- Summary: Remove `CONFIG_` prefix from KinesisConfigConstants variables Key: FLINK-4170 URL: https://issues.apache.org/jira/browse/FLINK-4170 Project: Flink Issu

[GitHub] flink issue #2209: [FLINK-4111] [table] Flink Table & SQL doesn't work in ve...

2016-07-07 Thread rmetzger
Github user rmetzger commented on the issue: https://github.com/apache/flink/pull/2209 Are all the dependencies you removed really not needed or are they needed, but present because they are pulled in transitively? In general, it makes sense to define all needed dependencies, inste

[jira] [Commented] (FLINK-4111) Flink Table & SQL doesn't work in very simple example

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

[jira] [Commented] (FLINK-4111) Flink Table & SQL doesn't work in very simple example

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

[GitHub] flink pull request #2209: [FLINK-4111] [table] Flink Table & SQL doesn't wor...

2016-07-07 Thread rmetzger
Github user rmetzger commented on a diff in the pull request: https://github.com/apache/flink/pull/2209#discussion_r69900431 --- Diff: flink-libraries/flink-table/pom.xml --- @@ -239,23 +181,4 @@ under the License. - - -

  1   2   >