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

2016-07-13 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4035?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15376417#comment-15376417 ] Tzu-Li (Gordon) Tai commented on FLINK-4035: Hi [~elevy], do you have any feed

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

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

[GitHub] flink issue #2231: [FLINK-4035] Bump Kafka producer in Kafka sink to Kafka 0...

2016-07-13 Thread tzulitai
Github user tzulitai commented on the issue: https://github.com/apache/flink/pull/2231 Hi @radekg , thank you for opening a PR for this! From a first look it seems that there isn't much changes to the code of `flink-connector-kafka-0.9` and this PR. Also, from the original discussi

[jira] [Commented] (FLINK-3034) Redis SInk Connector

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

[GitHub] flink issue #1813: [FLINK-3034] Redis Sink Connector

2016-07-13 Thread subhankarb
Github user subhankarb commented on the issue: https://github.com/apache/flink/pull/1813 Hi @kl0u, IMO that is the expected behavior. The sink would not know that if the Redis is down or not unless it tries to send the next data to the Redis. When ever a new message reaches the sink i

[jira] [Updated] (FLINK-4214) JobExceptionsHandler will return all exceptions

2016-07-13 Thread Sumit Chawla (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4214?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sumit Chawla updated FLINK-4214: Priority: Minor (was: Major) > JobExceptionsHandler will return all exceptions > --

[jira] [Commented] (FLINK-4214) JobExceptionsHandler will return all exceptions

2016-07-13 Thread Sumit Chawla (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4214?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15376269#comment-15376269 ] Sumit Chawla commented on FLINK-4214: - Change added in https://github.com/apache/flink

[jira] [Created] (FLINK-4214) JobExceptionsHandler will return all exceptions

2016-07-13 Thread Sumit Chawla (JIRA)
Sumit Chawla created FLINK-4214: --- Summary: JobExceptionsHandler will return all exceptions Key: FLINK-4214 URL: https://issues.apache.org/jira/browse/FLINK-4214 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-4213) Provide CombineHint in Gelly algorithms

2016-07-13 Thread Greg Hogan (JIRA)
Greg Hogan created FLINK-4213: - Summary: Provide CombineHint in Gelly algorithms Key: FLINK-4213 URL: https://issues.apache.org/jira/browse/FLINK-4213 Project: Flink Issue Type: Improvement

[jira] [Closed] (FLINK-3477) Add hash-based combine strategy for ReduceFunction

2016-07-13 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3477?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan closed FLINK-3477. - Resolution: Implemented Implemented in 52e191a5067322e82192314c16e70ae9e937ae2c > Add hash-based combine

[jira] [Closed] (FLINK-2246) Add chained combine driver strategy for ReduceFunction

2016-07-13 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2246?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan closed FLINK-2246. - Resolution: Implemented Implemented in 0db804b936efd8631f1a08db37753dad7f1f71ea > Add chained combine dri

[jira] [Commented] (FLINK-3477) Add hash-based combine strategy for ReduceFunction

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

[GitHub] flink pull request #1517: [FLINK-3477] [runtime] Add hash-based combine stra...

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

[jira] [Commented] (FLINK-3874) Add a Kafka TableSink with JSON serialization

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

[GitHub] flink issue #2244: [FLINK-3874] Add a Kafka TableSink with JSON serializatio...

2016-07-13 Thread mushketyk
Github user mushketyk commented on the issue: https://github.com/apache/flink/pull/2244 I tried to inherit TableSink trait in Java code but it seems that it is impossible to inherit traits with vars in Java, therefor I had to change class structures there somewhat. --- If your proj

[GitHub] flink pull request #2244: Kafka json

2016-07-13 Thread mushketyk
GitHub user mushketyk opened a pull request: https://github.com/apache/flink/pull/2244 Kafka json Thanks for contributing to Apache Flink. Before you open your pull request, please take the following check list into consideration. If your changes take all of the items into accou

[jira] [Commented] (FLINK-3477) Add hash-based combine strategy for ReduceFunction

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

[GitHub] flink issue #1517: [FLINK-3477] [runtime] Add hash-based combine strategy fo...

2016-07-13 Thread greghogan
Github user greghogan commented on the issue: https://github.com/apache/flink/pull/1517 CI tests are passing. I've been testing Gelly algorithms with this without error. I will merge this ... --- If your project is set up for it, you can reply to this email and have your reply appear

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

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

[GitHub] flink pull request #2243: [FLINK-4196] [runtime] Remove recovery timestamp f...

2016-07-13 Thread StephanEwen
GitHub user StephanEwen opened a pull request: https://github.com/apache/flink/pull/2243 [FLINK-4196] [runtime] Remove recovery timestamp from checkpoint restores The 'recoveryTimestamp' was an unsafe wall clock timestamp attached by the master upon recovery. Because this timestamp

[GitHub] flink pull request #2242: ExceptionHandler keep count of exceptions

2016-07-13 Thread sumitchawla
GitHub user sumitchawla opened a pull request: https://github.com/apache/flink/pull/2242 ExceptionHandler keep count of exceptions This is just a bug identified while going through exception handler. There is no JIRA ticket for this. You can merge this pull request into a Git repos

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

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

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

2016-07-13 Thread delding
Github user delding commented on the issue: https://github.com/apache/flink/pull/2233 Hi @zentol , thanks for your comments. I have updated this PR. Please let me know if there are further improvements that need to be done. --- If your project is set up for it, you can reply to this

[GitHub] flink issue #2237: [FLINK-4206][metrics] Remove alphanumeric name restrictio...

2016-07-13 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/2237 Actually, I just wrote a more efficient version of a check that was there before. --- 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-4206) Metric names should allow special characters

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

[GitHub] flink issue #2228: [FLINK-4170][kinesis-connector] Simplify Kinesis connecte...

2016-07-13 Thread tzulitai
Github user tzulitai commented on the issue: https://github.com/apache/flink/pull/2228 Rebased again on the new endpoint config merged in https://github.com/apache/flink/pull/2227. This PR should be ready for a final review now. --- If your project is set up for it, you can reply

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

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

[jira] [Commented] (FLINK-3466) Job might get stuck in restoreState() from HDFS due to interrupt

2016-07-13 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3466?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15375397#comment-15375397 ] Stephan Ewen commented on FLINK-3466: - Here is a Unit test that minimally reproduces g

[GitHub] flink issue #2237: [FLINK-4206][metrics] Remove alphanumeric name restrictio...

2016-07-13 Thread rmetzger
Github user rmetzger commented on the issue: https://github.com/apache/flink/pull/2237 I stumbled across this and I found the limitation quite annoying, so if there are no good reasons for the check, I agree to remove it. Since @StephanEwen wrote this, it might be good if he could

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

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

[GitHub] flink pull request #2234: [hotfix][kinesis-connector] Remove duplicate info ...

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

[GitHub] flink issue #2234: [hotfix][kinesis-connector] Remove duplicate info in Kine...

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

[jira] [Resolved] (FLINK-4197) Allow Kinesis Endpoint to be Overridden via Config

2016-07-13 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4197?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger resolved FLINK-4197. --- Resolution: Fixed Assignee: Scott Kidder Fix Version/s: (was: 1.0.4)

[GitHub] flink pull request #2227: [FLINK-4197] Allow Kinesis endpoint to be overridd...

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

[jira] [Commented] (FLINK-4197) Allow Kinesis Endpoint to be Overridden via Config

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

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

2016-07-13 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4152?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15375296#comment-15375296 ] Till Rohrmann edited comment on FLINK-4152 at 7/13/16 4:24 PM: -

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

2016-07-13 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4152?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15375296#comment-15375296 ] Till Rohrmann commented on FLINK-4152: -- [~mxm]The restarted registration attempts are

[jira] [Created] (FLINK-4212) Lock on pid file when starting daemons

2016-07-13 Thread Greg Hogan (JIRA)
Greg Hogan created FLINK-4212: - Summary: Lock on pid file when starting daemons Key: FLINK-4212 URL: https://issues.apache.org/jira/browse/FLINK-4212 Project: Flink Issue Type: Improvement

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

2016-07-13 Thread iemejia
Github user iemejia commented on the issue: https://github.com/apache/flink/pull/2239 Hi, Yes, this is exactly the situation, in a previous pull request I was optimizing the flink docker image, however I found that the image used supervisord to catch and keep alive those daemons, so I

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

2016-07-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4208?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15375216#comment-15375216 ] 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...

2016-07-13 Thread greghogan
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 mi

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

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

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

2016-07-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4149?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=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...

2016-07-13 Thread aljoscha
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] [Assigned] (FLINK-4152) TaskManager registration exponential backoff doesn't work

2016-07-13 Thread Till Rohrmann (JIRA)
[ 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 > -

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

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

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

2016-07-13 Thread tillrohrmann
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] [Commented] (FLINK-4184) Ganglia and GraphiteReporter report metric names with invalid characters

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

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

2016-07-13 Thread Till Rohrmann (JIRA)
[ 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 clo

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

2016-07-13 Thread asfgit
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 enab

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

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

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

2016-07-13 Thread tillrohrmann
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 if

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

2016-07-13 Thread Stefan Richter (JIRA)
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

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

2016-07-13 Thread Radoslaw Gruchalski (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4035?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15375102#comment-15375102 ] Radoslaw Gruchalski commented on FLINK-4035: The tests are passing. > Bump Ka

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

2016-07-13 Thread Stephan Ewen (JIRA)
[ 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-3666) Remove Nephele references

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

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

2016-07-13 Thread Chesnay Schepler (JIRA)
[ 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 > - >

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

2016-07-13 Thread zentol
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 Alternati

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

2016-07-13 Thread iemejia
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 emai

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

2016-07-13 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4207?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15375072#comment-15375072 ] Aljoscha Krettek commented on FLINK-4207: - It is somehow caused by the new cleanup

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

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

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

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

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

2016-07-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4208?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15375068#comment-15375068 ] 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...

2016-07-13 Thread iemejia
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 for

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

2016-07-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4209?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=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

2016-07-13 Thread iemejia
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 at

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

2016-07-13 Thread iemejia
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 c

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

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

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

2016-07-13 Thread iemejia
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.

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

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

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

2016-07-13 Thread zentol
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 hav

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

2016-07-13 Thread Chesnay Schepler (JIRA)
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 Issu

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

2016-07-13 Thread JIRA
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: Im

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

2016-07-13 Thread JIRA
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 #2226: [FLINK-4192] - Move Metrics API to separate module

2016-07-13 Thread zentol
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 fu

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

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

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

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

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

2016-07-13 Thread zentol
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 void

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

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

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

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

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

2016-07-13 Thread StephanEwen
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. Ad

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

2016-07-13 Thread tillrohrmann
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 So

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

2016-07-13 Thread zentol
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 void

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

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

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

2016-07-13 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4207?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15374897#comment-15374897 ] Stephan Ewen edited comment on FLINK-4207 at 7/13/16 12:20 PM: -

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

2016-07-13 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4207?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15374897#comment-15374897 ] Stephan Ewen commented on FLINK-4207: - What is happening different now than before? >

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

2016-07-13 Thread asfgit
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 enab

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

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

[GitHub] flink issue #2235: [hotfix] removed duplicated code

2016-07-13 Thread zentol
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 feat

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

2016-07-13 Thread zentol
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 BatchTableEnvironme

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

2016-07-13 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4204?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15374877#comment-15374877 ] Greg Hogan commented on FLINK-4204: --- We should also add a {{Main-Class}} to {{flink-gell

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

2016-07-13 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3729?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reassigned FLINK-3729: --- Assignee: Chesnay Schepler > Several SQL tests fail on Windows OS > -

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

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

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

2016-07-13 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/2210 Only had a small comment, otherwise +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 enabl

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

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

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

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

[jira] [Commented] (FLINK-4184) Ganglia and GraphiteReporter report metric names with invalid characters

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

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

2016-07-13 Thread tillrohrmann
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 em

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

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

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

2016-07-13 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4143?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-4143. --- Resolution: Fixed Implemented in 790a654c5e08e0e54f3e02499be4dd8c4006227a > Configurable deli

  1   2   >