[jira] [Closed] (FLINK-4200) Kafka consumers should log the offset from which they restore

[ https://issues.apache.org/jira/browse/FLINK-4200?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-4200. --- Resolution: Fixed Fixed in 435ffd9c06c435af382323963cd04a850e0148de > Kafka consumers should

[jira] [Commented] (FLINK-4159) Quickstart poms exclude unused dependencies

[ https://issues.apache.org/jira/browse/FLINK-4159?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15374710#comment-15374710 ] ASF GitHub Bot commented on FLINK-4159: --- Github user zentol commented on the issue:

[GitHub] flink issue #2217: [FLINK-4159] Remove Quickstart exclusions for unused depe...

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

[jira] [Commented] (FLINK-4143) Configurable delimiter for metric identifier

[ https://issues.apache.org/jira/browse/FLINK-4143?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15374725#comment-15374725 ] ASF GitHub Bot commented on FLINK-4143: --- Github user zentol commented on the issue:

[GitHub] flink issue #2220: [FLINK-4184] [metrics] Replace invalid characters in Sche...

Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/2220 True, it conflicts with your proposed changes for the definable metric group delimiter. I will rebase and adapt this PR wrt #2219. --- If your project is set up for it, you can reply to this

[jira] [Commented] (FLINK-2125) String delimiter for SocketTextStream

[ https://issues.apache.org/jira/browse/FLINK-2125?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15374911#comment-15374911 ] ASF GitHub Bot commented on FLINK-2125: --- Github user zentol commented on a diff in the pull request:

[GitHub] flink pull request #2233: [FLINK-2125][streaming] Delimiter change from char...

Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/2233#discussion_r70614809 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/SocketTextStreamFunction.java --- @@ -96,19 +96,21 @@ public

[jira] [Commented] (FLINK-4192) Move Metrics API to separate module

[ https://issues.apache.org/jira/browse/FLINK-4192?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15374910#comment-15374910 ] ASF GitHub Bot commented on FLINK-4192: --- Github user StephanEwen commented on the issue:

[jira] [Commented] (FLINK-4204) Clean up gelly-examples

[ https://issues.apache.org/jira/browse/FLINK-4204?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15374877#comment-15374877 ] Greg Hogan commented on FLINK-4204: --- We should also add a {{Main-Class}} to {{flink-gelly-examples}} to

[jira] [Commented] (FLINK-4207) WindowOperator becomes very slow with allowed lateness

[ https://issues.apache.org/jira/browse/FLINK-4207?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15374897#comment-15374897 ] Stephan Ewen commented on FLINK-4207: - What is happening different now than before? > WindowOperator

[jira] [Comment Edited] (FLINK-4207) WindowOperator becomes very slow with allowed lateness

[ https://issues.apache.org/jira/browse/FLINK-4207?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15374897#comment-15374897 ] Stephan Ewen edited comment on FLINK-4207 at 7/13/16 12:20 PM: --- Is the

[GitHub] flink pull request #2233: [FLINK-2125][streaming] Delimiter change from char...

Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/2233#discussion_r70614465 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/SocketTextStreamFunction.java --- @@ -96,19 +96,21 @@ public

[GitHub] flink issue #2226: [FLINK-4192] - Move Metrics API to separate module

Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/2226 The point of using `Properties` is that users of the API can use a class they are familiar with and maybe even reuse configurations and tools they internally that work with `Properties` types.

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

[ https://issues.apache.org/jira/browse/FLINK-4167?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15374907#comment-15374907 ] ASF GitHub Bot commented on FLINK-4167: --- Github user tillrohrmann commented on a diff in the pull

[GitHub] flink pull request #2210: [FLINK-4167] [metrics] Close IOMetricGroup in Task...

Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/2210#discussion_r70614548 --- Diff: flink-core/src/main/java/org/apache/flink/metrics/groups/ProxyMetricGroup.java --- @@ -0,0 +1,100 @@ +/* + * Licensed to the Apache

[jira] [Commented] (FLINK-3729) Several SQL tests fail on Windows OS

[ https://issues.apache.org/jira/browse/FLINK-3729?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15374889#comment-15374889 ] ASF GitHub Bot commented on FLINK-3729: --- GitHub user zentol opened a pull request:

[GitHub] flink pull request #2235: [hotfix] removed duplicated code

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/2235 --- 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 #2235: [hotfix] removed duplicated code

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

[GitHub] flink pull request #2238: [FLINK-3729] Fix Several SQL tests on Windows OS

GitHub user zentol opened a pull request: https://github.com/apache/flink/pull/2238 [FLINK-3729] Fix Several SQL tests on Windows OS - fixed ExplainTest by replacing all occurrences of `\r\n` with `\n` before comparing the output - replaced usages of `\n` in

[jira] [Commented] (FLINK-2125) String delimiter for SocketTextStream

[ https://issues.apache.org/jira/browse/FLINK-2125?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15374902#comment-15374902 ] ASF GitHub Bot commented on FLINK-2125: --- Github user zentol commented on a diff in the pull request:

[jira] [Created] (FLINK-4210) Move close()/isClosed() out of MetricGroup interface

Chesnay Schepler created FLINK-4210: --- Summary: Move close()/isClosed() out of MetricGroup interface Key: FLINK-4210 URL: https://issues.apache.org/jira/browse/FLINK-4210 Project: Flink

[GitHub] flink pull request #2239: [FLINK-4208] Support Running Flink processes in fo...

GitHub user iemejia opened a pull request: https://github.com/apache/flink/pull/2239 [FLINK-4208] Support Running Flink processes in foreground mode Thanks for contributing to Apache Flink. Before you open your pull request, please take the following check list into consideration.

[GitHub] flink pull request #2240: [FLINK-4209] Docker image breaks with multiple NIC...

GitHub user iemejia opened a pull request: https://github.com/apache/flink/pull/2240 [FLINK-4209] Docker image breaks with multiple NICs Thanks for contributing to Apache Flink. Before you open your pull request, please take the following check list into consideration. If your

[jira] [Commented] (FLINK-4209) Docker image breaks with multiple NICs

[ https://issues.apache.org/jira/browse/FLINK-4209?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15375062#comment-15375062 ] ASF GitHub Bot commented on FLINK-4209: --- Github user iemejia commented on the issue:

[GitHub] flink issue #2240: [FLINK-4209] Docker image breaks with multiple NICs

Github user iemejia commented on the issue: https://github.com/apache/flink/pull/2240 I added some additional fixes for example to exclude build dependencies from the final image, and to make the docker-compose script simpler. @aljoscha This is a set of small fixes that I missed

[jira] [Created] (FLINK-4208) Support Running Flink processes in foreground mode

Ismaël Mejía created FLINK-4208: --- Summary: Support Running Flink processes in foreground mode Key: FLINK-4208 URL: https://issues.apache.org/jira/browse/FLINK-4208 Project: Flink Issue Type:

[GitHub] flink issue #2233: [FLINK-2125][streaming] Delimiter change from char to str...

Github user zentol commented on the issue: https://github.com/apache/flink/pull/2233 Only had 2 small comments, otherwise this looks good to me. --- 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-2125) String delimiter for SocketTextStream

[ https://issues.apache.org/jira/browse/FLINK-2125?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15375020#comment-15375020 ] ASF GitHub Bot commented on FLINK-2125: --- Github user zentol commented on the issue:

[jira] [Commented] (FLINK-4208) Support Running Flink processes in foreground mode

[ https://issues.apache.org/jira/browse/FLINK-4208?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15375063#comment-15375063 ] ASF GitHub Bot commented on FLINK-4208: --- Github user iemejia commented on the issue:

[GitHub] flink issue #2239: [FLINK-4208] Support Running Flink processes in foregroun...

Github user iemejia commented on the issue: https://github.com/apache/flink/pull/2239 @aljoscha As discussed in FLINK-4118 I am doing this to support this use case and eventually remove the dependency on python and supervisord from the docker image. --- If your project is set up

[jira] [Commented] (FLINK-4208) Support Running Flink processes in foreground mode

[ https://issues.apache.org/jira/browse/FLINK-4208?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15375068#comment-15375068 ] ASF GitHub Bot commented on FLINK-4208: --- Github user iemejia commented on the issue:

[jira] [Commented] (FLINK-4192) Move Metrics API to separate module

[ https://issues.apache.org/jira/browse/FLINK-4192?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15374919#comment-15374919 ] ASF GitHub Bot commented on FLINK-4192: --- Github user zentol commented on the issue:

[GitHub] flink issue #2226: [FLINK-4192] - Move Metrics API to separate module

Github user zentol commented on the issue: https://github.com/apache/flink/pull/2226 Alright, although I am curious why this wasn't an issue when we merged the metric system initially. Since you mentioned that we should/could add additional helper methods, please provide a

[jira] [Created] (FLINK-4209) Docker image breaks with multiple NICs

Ismaël Mejía created FLINK-4209: --- Summary: Docker image breaks with multiple NICs Key: FLINK-4209 URL: https://issues.apache.org/jira/browse/FLINK-4209 Project: Flink Issue Type: Improvement

[GitHub] flink issue #2210: [FLINK-4167] [metrics] Close IOMetricGroup in TaskMetricG...

Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/2210 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

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

[ https://issues.apache.org/jira/browse/FLINK-4167?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15375173#comment-15375173 ] ASF GitHub Bot commented on FLINK-4167: --- Github user tillrohrmann commented on the issue:

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

[ https://issues.apache.org/jira/browse/FLINK-4167?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-4167. Resolution: Fixed Fixed via d17fe4f636b56f2200444c59a0dead9010dfaa5d > TaskMetricGroup does not

[GitHub] flink pull request #2210: [FLINK-4167] [metrics] Close IOMetricGroup in Task...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/2210 --- 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-4184) Ganglia and GraphiteReporter report metric names with invalid characters

[ https://issues.apache.org/jira/browse/FLINK-4184?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15375162#comment-15375162 ] ASF GitHub Bot commented on FLINK-4184: --- Github user tillrohrmann commented on the issue:

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

[ https://issues.apache.org/jira/browse/FLINK-4167?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15375178#comment-15375178 ] ASF GitHub Bot commented on FLINK-4167: --- Github user asfgit closed the pull request at:

[GitHub] flink issue #2220: [FLINK-4184] [metrics] Replace invalid characters in Sche...

Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/2220 I rebased on the latest master and introduced a `CharacterFilter` interface. The `CharacterFilter` allows to filter out invalid characters while generating the fully qualified metric name.

[jira] [Assigned] (FLINK-4152) TaskManager registration exponential backoff doesn't work

[ https://issues.apache.org/jira/browse/FLINK-4152?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-4152: Assignee: Till Rohrmann > TaskManager registration exponential backoff doesn't work >

[GitHub] flink issue #2210: [FLINK-4167] [metrics] Close IOMetricGroup in TaskMetricG...

Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/2210 Ah ok, I see the underlying problem now. I will adapt my PR wrt your feedback. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well.

[jira] [Updated] (FLINK-4206) Metric names should allow special characters

[ https://issues.apache.org/jira/browse/FLINK-4206?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-4206: -- Summary: Metric names should allow special characters (was: Metric names should alle special

[jira] [Commented] (FLINK-4186) Expose Kafka metrics through Flink metrics

[ https://issues.apache.org/jira/browse/FLINK-4186?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15374624#comment-15374624 ] ASF GitHub Bot commented on FLINK-4186: --- Github user rmetzger commented on the issue:

[GitHub] flink issue #2226: [FLINK-4192] - Move Metrics API to separate module

Github user zentol commented on the issue: https://github.com/apache/flink/pull/2226 I've reverted moving of the MetricRegistry; it was in fact not necessary. --- 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

[jira] [Commented] (FLINK-4192) Move Metrics API to separate module

[ https://issues.apache.org/jira/browse/FLINK-4192?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15374633#comment-15374633 ] ASF GitHub Bot commented on FLINK-4192: --- Github user zentol commented on the issue:

[jira] [Commented] (FLINK-4186) Expose Kafka metrics through Flink metrics

[ https://issues.apache.org/jira/browse/FLINK-4186?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15374680#comment-15374680 ] ASF GitHub Bot commented on FLINK-4186: --- Github user zentol commented on a diff in the pull request:

[GitHub] flink pull request #2236: [FLINK-4186] Use Flink metrics to report Kafka met...

Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/2236#discussion_r70591379 --- Diff: flink-streaming-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/metrics/KafkaMetricGetter.java

[jira] [Commented] (FLINK-4186) Expose Kafka metrics through Flink metrics

[ https://issues.apache.org/jira/browse/FLINK-4186?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15374679#comment-15374679 ] ASF GitHub Bot commented on FLINK-4186: --- Github user zentol commented on a diff in the pull request:

[jira] [Commented] (FLINK-4200) Kafka consumers should log the offset from which they restore

[ https://issues.apache.org/jira/browse/FLINK-4200?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15374685#comment-15374685 ] ASF GitHub Bot commented on FLINK-4200: --- Github user zentol commented on the issue:

[GitHub] flink issue #2230: [FLINK-4200] [Kafka Connector] Kafka consumers logs the o...

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

[jira] [Commented] (FLINK-4200) Kafka consumers should log the offset from which they restore

[ https://issues.apache.org/jira/browse/FLINK-4200?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15374691#comment-15374691 ] ASF GitHub Bot commented on FLINK-4200: --- Github user asfgit closed the pull request at:

[GitHub] flink pull request #2217: [FLINK-4159] Remove Quickstart exclusions for unus...

Github user zentol closed the pull request at: https://github.com/apache/flink/pull/2217 --- 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-4209) Docker image breaks with multiple NICs

[ https://issues.apache.org/jira/browse/FLINK-4209?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15375058#comment-15375058 ] ASF GitHub Bot commented on FLINK-4209: --- GitHub user iemejia opened a pull request:

[jira] [Commented] (FLINK-4207) WindowOperator becomes very slow with allowed lateness

[ https://issues.apache.org/jira/browse/FLINK-4207?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15375072#comment-15375072 ] Aljoscha Krettek commented on FLINK-4207: - It is somehow caused by the new cleanup timers. If the

[GitHub] flink pull request #2241: [FLINK-3666] Remove all remaining Nephele referenc...

GitHub user zentol opened a pull request: https://github.com/apache/flink/pull/2241 [FLINK-3666] Remove all remaining Nephele references You can merge this pull request into a Git repository by running: $ git pull https://github.com/zentol/flink 3666_bye_bye_nephele

[jira] [Assigned] (FLINK-3666) Remove Nephele references

[ https://issues.apache.org/jira/browse/FLINK-3666?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reassigned FLINK-3666: --- Assignee: Chesnay Schepler > Remove Nephele references > - >

[jira] [Commented] (FLINK-4035) Bump Kafka producer in Kafka sink to Kafka 0.10.0.0

[ https://issues.apache.org/jira/browse/FLINK-4035?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15375102#comment-15375102 ] Radoslaw Gruchalski commented on FLINK-4035: The tests are passing. > Bump Kafka producer in

[jira] [Created] (FLINK-4211) Dynamic Properties not working for jobs submitted to Yarn session

Stefan Richter created FLINK-4211: - Summary: Dynamic Properties not working for jobs submitted to Yarn session Key: FLINK-4211 URL: https://issues.apache.org/jira/browse/FLINK-4211 Project: Flink

[GitHub] flink issue #2239: [FLINK-4208] Support Running Flink processes in foregroun...

Github user iemejia commented on the issue: https://github.com/apache/flink/pull/2239 I hope this gets into 1.1.0 so I can push the changes to the docker image once this is available in the official binary distribution. --- If your project is set up for it, you can reply to this

[jira] [Commented] (FLINK-3666) Remove Nephele references

[ https://issues.apache.org/jira/browse/FLINK-3666?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15375078#comment-15375078 ] ASF GitHub Bot commented on FLINK-3666: --- GitHub user zentol opened a pull request:

[jira] [Assigned] (FLINK-4196) Remove "recoveryTimestamp"

[ https://issues.apache.org/jira/browse/FLINK-4196?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen reassigned FLINK-4196: --- Assignee: Stephan Ewen > Remove "recoveryTimestamp" > -- > >

[jira] [Commented] (FLINK-4149) Fix Serialization of NFA in AbstractKeyedCEPPatternOperator

[ https://issues.apache.org/jira/browse/FLINK-4149?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15375195#comment-15375195 ] ASF GitHub Bot commented on FLINK-4149: --- Github user aljoscha commented on the issue:

[GitHub] flink issue #2202: [FLINK-4149] Fix Serialization of NFA in AbstractKeyedCEP...

Github user aljoscha commented on the issue: https://github.com/apache/flink/pull/2202 Thanks for the review @tillrohrmann! The `commons.io` was just an IDE mess-up. The `equals` I will fix. --- If your project is set up for it, you can reply to this email and have your reply appear

[jira] [Commented] (FLINK-4208) Support Running Flink processes in foreground mode

[ https://issues.apache.org/jira/browse/FLINK-4208?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15375204#comment-15375204 ] ASF GitHub Bot commented on FLINK-4208: --- Github user greghogan commented on the issue:

[GitHub] flink issue #2239: [FLINK-4208] Support Running Flink processes in foregroun...

Github user greghogan commented on the issue: https://github.com/apache/flink/pull/2239 Hi @iemejia, is the situation with Docker that if the Flink processes are started as daemons and the script returns that Docker assumes the process has terminated? Skipping the pid file

[jira] [Commented] (FLINK-4208) Support Running Flink processes in foreground mode

[ https://issues.apache.org/jira/browse/FLINK-4208?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15375216#comment-15375216 ] ASF GitHub Bot commented on FLINK-4208: --- Github user iemejia commented on the issue:

<    1   2