[jira] [Commented] (FLINK-3179) Combiner is not injected if Reduce or GroupReduce input is explicitly partitioned

2016-01-29 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3179?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15123471#comment-15123471 ] ASF GitHub Bot commented on FLINK-3179: --- Github user fhueske commented on the pull request:

[GitHub] flink pull request: FLINK-3179 Combiner is not injected if Reduce ...

2016-01-29 Thread fhueske
Github user fhueske commented on the pull request: https://github.com/apache/flink/pull/1553#issuecomment-176754489 You identified the right classes and methods for the fix, but the place within the method is not correct. Let me explain the issue. In the common case as for

[GitHub] flink pull request: Enhance Partitioned State and use it in Window...

2016-01-29 Thread aljoscha
GitHub user aljoscha opened a pull request: https://github.com/apache/flink/pull/1562 Enhance Partitioned State and use it in WindowOperator The commits in this are self-contained. The first one enhances the partitioned state such that it can be used by the WindowOperator. The

[jira] [Created] (FLINK-3303) Move all non-batch specific classes in flink-java to flink-core

2016-01-29 Thread Stephan Ewen (JIRA)
Stephan Ewen created FLINK-3303: --- Summary: Move all non-batch specific classes in flink-java to flink-core Key: FLINK-3303 URL: https://issues.apache.org/jira/browse/FLINK-3303 Project: Flink

[jira] [Commented] (FLINK-1509) Streaming Group Reduce Combiner

2016-01-29 Thread Jeyhun Karimov (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1509?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15123577#comment-15123577 ] Jeyhun Karimov commented on FLINK-1509: --- I will give a try to this problem > Streaming Group Reduce

[jira] [Created] (FLINK-3304) AvroOutputFormat.setSchema() doesn't work in yarn-cluster mode

2016-01-29 Thread Sebastian Klemke (JIRA)
Sebastian Klemke created FLINK-3304: --- Summary: AvroOutputFormat.setSchema() doesn't work in yarn-cluster mode Key: FLINK-3304 URL: https://issues.apache.org/jira/browse/FLINK-3304 Project: Flink

[jira] [Assigned] (FLINK-2184) Cannot get last element with maxBy/minBy

2016-01-29 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2184?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske reassigned FLINK-2184: Assignee: Fabian Hueske > Cannot get last element with maxBy/minBy >

[jira] [Commented] (FLINK-3201) Enhance Partitioned State Interface with State Types

2016-01-29 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3201?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15123556#comment-15123556 ] ASF GitHub Bot commented on FLINK-3201: --- GitHub user aljoscha opened a pull request:

[jira] [Updated] (FLINK-2184) Cannot get last element with maxBy/minBy

2016-01-29 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2184?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-2184: - Assignee: Jeyhun Karimov > Cannot get last element with maxBy/minBy >

[jira] [Updated] (FLINK-2184) Cannot get last element with maxBy/minBy

2016-01-29 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2184?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-2184: - Assignee: (was: Fabian Hueske) > Cannot get last element with maxBy/minBy >

[jira] [Commented] (FLINK-2184) Cannot get last element with maxBy/minBy

2016-01-29 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2184?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15123473#comment-15123473 ] Fabian Hueske commented on FLINK-2184: -- Hi [~jeyhunkarimov], sure. Thanks for picking the issue up.

[jira] [Commented] (FLINK-2184) Cannot get last element with maxBy/minBy

2016-01-29 Thread Jeyhun Karimov (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2184?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15123469#comment-15123469 ] Jeyhun Karimov commented on FLINK-2184: --- If no one is working on this issue, I can give a try >

[jira] [Commented] (FLINK-3302) Save Taskmanager Metrics per Job

2016-01-29 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3302?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15123589#comment-15123589 ] Greg Hogan commented on FLINK-3302: --- Hi, Pieter! I had filed FLINK-3263 about a week ago with a similar

[jira] [Assigned] (FLINK-3300) Concurrency Bug in Yarn JobManager

2016-01-29 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3300?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels reassigned FLINK-3300: - Assignee: Maximilian Michels > Concurrency Bug in Yarn JobManager >

[jira] [Commented] (FLINK-3225) Optimize logical Table API plans in Calcite

2016-01-29 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3225?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15123348#comment-15123348 ] ASF GitHub Bot commented on FLINK-3225: --- Github user fhueske commented on the pull request:

[jira] [Commented] (FLINK-3300) Concurrency Bug in Yarn JobManager

2016-01-29 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3300?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15123401#comment-15123401 ] ASF GitHub Bot commented on FLINK-3300: --- Github user mxm commented on the pull request:

[GitHub] flink pull request: [FLINK-3300] fix concurrency bug in YarnJobMan...

2016-01-29 Thread mxm
Github user mxm commented on the pull request: https://github.com/apache/flink/pull/1561#issuecomment-176723782 Test failures unrelated to the changes. Yarn tests pass in this build: https://travis-ci.org/apache/flink/jobs/105645193 --- If your project is set up for it, you can

[jira] [Commented] (FLINK-3300) Concurrency Bug in Yarn JobManager

2016-01-29 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3300?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15123438#comment-15123438 ] ASF GitHub Bot commented on FLINK-3300: --- Github user tillrohrmann commented on the pull request:

[GitHub] flink pull request: [FLINK-3300] fix concurrency bug in YarnJobMan...

2016-01-29 Thread tillrohrmann
Github user tillrohrmann commented on the pull request: https://github.com/apache/flink/pull/1561#issuecomment-176737933 As far as I can tell the changes look good to me. Good work @mxm :-) --- If your project is set up for it, you can reply to this email and have your reply appear

[jira] [Commented] (FLINK-3300) Concurrency Bug in Yarn JobManager

2016-01-29 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3300?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15123338#comment-15123338 ] ASF GitHub Bot commented on FLINK-3300: --- GitHub user mxm opened a pull request:

[GitHub] flink pull request: [FLINK-3300] fix concurrency bug in YarnJobMan...

2016-01-29 Thread mxm
GitHub user mxm opened a pull request: https://github.com/apache/flink/pull/1561 [FLINK-3300] fix concurrency bug in YarnJobManager Adds message passing between Hadoop's async resource manager client and the YarnJobManager actor. It helps to view the diff with ignored

[GitHub] flink pull request: [FLINK-3225] Implemented optimization of Table...

2016-01-29 Thread fhueske
Github user fhueske commented on the pull request: https://github.com/apache/flink/pull/1559#issuecomment-176693988 Updated the PR --- 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

[GitHub] flink pull request: [FLINK-2021] Rework examples to use ParameterT...

2016-01-29 Thread stefanobaghino
Github user stefanobaghino commented on the pull request: https://github.com/apache/flink/pull/1536#issuecomment-176700143 It works, I'll be pushing the code in a few minutes. If everything looks good I can move on to the other examples. Thank you all the precious feedback provided

[jira] [Commented] (FLINK-2021) Rework examples to use ParameterTool

2016-01-29 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2021?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15123359#comment-15123359 ] ASF GitHub Bot commented on FLINK-2021: --- Github user stefanobaghino commented on the pull request:

[jira] [Commented] (FLINK-3300) Concurrency Bug in Yarn JobManager

2016-01-29 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3300?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15123326#comment-15123326 ] Stephan Ewen commented on FLINK-3300: - +1 for the actor messages. That would be the cleanest approach!

[jira] [Commented] (FLINK-3179) Combiner is not injected if Reduce or GroupReduce input is explicitly partitioned

2016-01-29 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3179?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15123463#comment-15123463 ] ASF GitHub Bot commented on FLINK-3179: --- Github user fhueske commented on a diff in the pull

[jira] [Commented] (FLINK-3179) Combiner is not injected if Reduce or GroupReduce input is explicitly partitioned

2016-01-29 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3179?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15123461#comment-15123461 ] ASF GitHub Bot commented on FLINK-3179: --- Github user fhueske commented on a diff in the pull

[GitHub] flink pull request: FLINK-3179 Combiner is not injected if Reduce ...

2016-01-29 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/1553#discussion_r51259067 --- Diff: flink-optimizer/src/main/java/org/apache/flink/optimizer/operators/GroupReduceWithCombineProperties.java --- @@ -102,36 +107,72 @@ public

[GitHub] flink pull request: FLINK-3179 Combiner is not injected if Reduce ...

2016-01-29 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/1553#discussion_r51259080 --- Diff: flink-optimizer/src/main/java/org/apache/flink/optimizer/operators/ReduceProperties.java --- @@ -66,30 +70,62 @@ public SingleInputPlanNode

[jira] [Commented] (FLINK-3089) OperatorState timeout

2016-01-29 Thread Jeyhun Karimov (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3089?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15123391#comment-15123391 ] Jeyhun Karimov commented on FLINK-3089: --- If nobody works on this issue, I would like to give a try.

[jira] [Commented] (FLINK-3225) Optimize logical Table API plans in Calcite

2016-01-29 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3225?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15123416#comment-15123416 ] ASF GitHub Bot commented on FLINK-3225: --- Github user twalthr commented on the pull request:

[GitHub] flink pull request: [FLINK-3225] Implemented optimization of Table...

2016-01-29 Thread twalthr
Github user twalthr commented on the pull request: https://github.com/apache/flink/pull/1559#issuecomment-176727999 +1 for 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

[jira] [Issue Comment Deleted] (FLINK-3089) OperatorState timeout

2016-01-29 Thread Jeyhun Karimov (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3089?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jeyhun Karimov updated FLINK-3089: -- Comment: was deleted (was: If nobody works on this issue, I would like to give a try.) >

[jira] [Commented] (FLINK-3225) Optimize logical Table API plans in Calcite

2016-01-29 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3225?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15123267#comment-15123267 ] ASF GitHub Bot commented on FLINK-3225: --- Github user twalthr commented on a diff in the pull

[GitHub] flink pull request: [FLINK-3225] Implemented optimization of Table...

2016-01-29 Thread twalthr
Github user twalthr commented on a diff in the pull request: https://github.com/apache/flink/pull/1559#discussion_r51241929 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/plan/nodes/dataset/DataSetRel.scala --- @@ -0,0 +1,33 @@ +/* + *

[jira] [Commented] (FLINK-2678) DataSet API does not support multi-dimensional arrays as keys

2016-01-29 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2678?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15123279#comment-15123279 ] Till Rohrmann commented on FLINK-2678: -- It should work for arbitrary dimensional arrays and not only

[jira] [Commented] (FLINK-2021) Rework examples to use ParameterTool

2016-01-29 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2021?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15123289#comment-15123289 ] ASF GitHub Bot commented on FLINK-2021: --- Github user fhueske commented on the pull request:

[jira] [Created] (FLINK-3302) Save Taskmanager Metrics per Job

2016-01-29 Thread Pieter Hameete (JIRA)
Pieter Hameete created FLINK-3302: - Summary: Save Taskmanager Metrics per Job Key: FLINK-3302 URL: https://issues.apache.org/jira/browse/FLINK-3302 Project: Flink Issue Type: Wish

[GitHub] flink pull request: [FLINK-2021] Rework examples to use ParameterT...

2016-01-29 Thread fhueske
Github user fhueske commented on the pull request: https://github.com/apache/flink/pull/1536#issuecomment-176675459 Thanks for the update! +1 using case classes in the Scala example. Can you also check if we can directly read the CSV file into the case classes (not sure if that

[jira] [Commented] (FLINK-3225) Optimize logical Table API plans in Calcite

2016-01-29 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3225?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15123294#comment-15123294 ] ASF GitHub Bot commented on FLINK-3225: --- Github user twalthr commented on the pull request:

[GitHub] flink pull request: [FLINK-3225] Implemented optimization of Table...

2016-01-29 Thread twalthr
Github user twalthr commented on the pull request: https://github.com/apache/flink/pull/1559#issuecomment-176676353 Except for the comments it looks very good. --- 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

[GitHub] flink pull request: [FLINK-3225] Implemented optimization of Table...

2016-01-29 Thread twalthr
Github user twalthr commented on a diff in the pull request: https://github.com/apache/flink/pull/1559#discussion_r51241130 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/api/java/table/JavaBatchTranslator.scala --- @@ -41,21 +44,13 @@ class

[jira] [Commented] (FLINK-3300) Concurrency Bug in Yarn JobManager

2016-01-29 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3300?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15123284#comment-15123284 ] Maximilian Michels commented on FLINK-3300: --- Thanks for reporting. Quick fix would be to just

[GitHub] flink pull request: FLINK-3301 Ineffective synchronization in Mess...

2016-01-29 Thread ramkrish86
Github user ramkrish86 commented on a diff in the pull request: https://github.com/apache/flink/pull/1560#discussion_r51240892 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/MessageAcknowledgingSourceBase.java --- @@ -177,21 +177,19

[jira] [Commented] (FLINK-3301) Ineffective synchronization in MessageAcknowledgingSourceBase#restoreState

2016-01-29 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3301?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15123251#comment-15123251 ] ASF GitHub Bot commented on FLINK-3301: --- Github user ramkrish86 commented on a diff in the pull

[jira] [Commented] (FLINK-3225) Optimize logical Table API plans in Calcite

2016-01-29 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3225?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15123260#comment-15123260 ] ASF GitHub Bot commented on FLINK-3225: --- Github user twalthr commented on a diff in the pull

[GitHub] flink pull request: [FLINK-3225] Implemented optimization of Table...

2016-01-29 Thread twalthr
Github user twalthr commented on a diff in the pull request: https://github.com/apache/flink/pull/1559#discussion_r51241424 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/plan/nodes/dataset/DataSetExchange.scala --- @@ -0,0 +1,63 @@ +/* +

[jira] [Commented] (FLINK-3225) Optimize logical Table API plans in Calcite

2016-01-29 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3225?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15123253#comment-15123253 ] ASF GitHub Bot commented on FLINK-3225: --- Github user twalthr commented on a diff in the pull

[jira] [Commented] (FLINK-3225) Optimize logical Table API plans in Calcite

2016-01-29 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3225?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15123314#comment-15123314 ] ASF GitHub Bot commented on FLINK-3225: --- Github user fhueske commented on a diff in the pull

[GitHub] flink pull request: [FLINK-3225] Implemented optimization of Table...

2016-01-29 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/1559#discussion_r51245443 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/api/java/table/JavaBatchTranslator.scala --- @@ -41,21 +44,13 @@ class

[GitHub] flink pull request: [FLINK-3225] Implemented optimization of Table...

2016-01-29 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/1559#discussion_r51245496 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/plan/nodes/dataset/DataSetRel.scala --- @@ -0,0 +1,33 @@ +/* + *

[jira] [Commented] (FLINK-3300) Concurrency Bug in Yarn JobManager

2016-01-29 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3300?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15123269#comment-15123269 ] Till Rohrmann commented on FLINK-3300: -- +1 for actor messages > Concurrency Bug in Yarn JobManager >

[jira] [Commented] (FLINK-3225) Optimize logical Table API plans in Calcite

2016-01-29 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3225?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15123316#comment-15123316 ] ASF GitHub Bot commented on FLINK-3225: --- Github user fhueske commented on a diff in the pull

[GitHub] flink pull request: [FLINK-2445] Add tests for HadoopOutputFormats

2016-01-29 Thread aljoscha
Github user aljoscha commented on the pull request: https://github.com/apache/flink/pull/1486#issuecomment-176839542 @ajaybhat Do you have any updates on 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. If your

[jira] [Commented] (FLINK-2445) Add tests for HadoopOutputFormats

2016-01-29 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2445?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15123648#comment-15123648 ] ASF GitHub Bot commented on FLINK-2445: --- Github user aljoscha commented on the pull request:

[jira] [Commented] (FLINK-2522) Integrate Streaming Api into Flink-scala-shell

2016-01-29 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2522?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15123693#comment-15123693 ] ASF GitHub Bot commented on FLINK-2522: --- Github user aljoscha commented on the pull request:

[GitHub] flink pull request: [FLINK-3161][dist] Externalize cluster start-u...

2016-01-29 Thread greghogan
Github user greghogan commented on the pull request: https://github.com/apache/flink/pull/1523#issuecomment-176858076 New commit which passes FLINK_SSH_OPTS to pdsh. Also, some sample timings starting and stopping an AWS cluster of various sizes, with ssh and pdsh comparable

[jira] [Commented] (FLINK-3161) Externalize cluster start-up and tear-down when available

2016-01-29 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3161?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15123744#comment-15123744 ] ASF GitHub Bot commented on FLINK-3161: --- Github user greghogan commented on the pull request:

[jira] [Commented] (FLINK-3161) Externalize cluster start-up and tear-down when available

2016-01-29 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3161?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15123718#comment-15123718 ] ASF GitHub Bot commented on FLINK-3161: --- Github user greghogan commented on the pull request:

[jira] [Assigned] (FLINK-1509) Streaming Group Reduce Combiner

2016-01-29 Thread Jeyhun Karimov (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1509?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jeyhun Karimov reassigned FLINK-1509: - Assignee: Jeyhun Karimov > Streaming Group Reduce Combiner >

[jira] [Assigned] (FLINK-2390) Replace iteration timeout with algorithm for detecting termination

2016-01-29 Thread Jeyhun Karimov (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2390?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jeyhun Karimov reassigned FLINK-2390: - Assignee: Jeyhun Karimov > Replace iteration timeout with algorithm for detecting

[GitHub] flink pull request: [FLINK-2935] [scala-shell] Allow Scala shell t...

2016-01-29 Thread aljoscha
Github user aljoscha commented on the pull request: https://github.com/apache/flink/pull/1500#issuecomment-176839108 @tillrohrmann do you have any comments on @chiwanpark's updates? --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub

[GitHub] flink pull request: [FLINK-1870] Reintroduce indexed reader functi...

2016-01-29 Thread aljoscha
Github user aljoscha commented on the pull request: https://github.com/apache/flink/pull/1483#issuecomment-176839873 @mjsax What is the status on this PR? Can it be closed since the feature in Storm will be implemented another way? --- If your project is set up for it, you can

[jira] [Commented] (FLINK-3150) Make YARN container invocation configurable

2016-01-29 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3150?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15123686#comment-15123686 ] ASF GitHub Bot commented on FLINK-3150: --- Github user aljoscha commented on the pull request:

[GitHub] flink pull request: [FLINK-3150] Make the YARN container start inv...

2016-01-29 Thread aljoscha
Github user aljoscha commented on the pull request: https://github.com/apache/flink/pull/1446#issuecomment-176845053 What's the state of this? Who do we need it? Is it still valid with the (planned) reworking of Yarn/Mesos integration? --- If your project is set up for it, you can

[GitHub] flink pull request: [FLINK-3161][dist] Externalize cluster start-u...

2016-01-29 Thread greghogan
Github user greghogan commented on the pull request: https://github.com/apache/flink/pull/1523#issuecomment-176853645 New commit that passes FLINK_SSH_OPTS to pdsh. 64 x c4.large 0m4.210s0m4.181s 0m4.203s0m4.283s 0m4.262s0m4.196s 0m13.969s

[jira] [Commented] (FLINK-2935) Allow scala shell to read yarn properties

2016-01-29 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2935?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15123644#comment-15123644 ] ASF GitHub Bot commented on FLINK-2935: --- Github user aljoscha commented on the pull request:

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

2016-01-29 Thread aljoscha
Github user aljoscha commented on the pull request: https://github.com/apache/flink/pull/1491#issuecomment-176839361 @ajaybhat Do you have any updates on 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. If your

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

2016-01-29 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2125?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15123646#comment-15123646 ] ASF GitHub Bot commented on FLINK-2125: --- Github user aljoscha commented on the pull request:

[GitHub] flink pull request: [FLINK-3097] [table] Add support for custom fu...

2016-01-29 Thread aljoscha
Github user aljoscha commented on the pull request: https://github.com/apache/flink/pull/1429#issuecomment-176845490 @twalthr Is this in the calcite branch now? Can this PR then be closed? --- If your project is set up for it, you can reply to this email and have your reply appear on

[jira] [Created] (FLINK-3305) Remove JavaKaffee serializer util

2016-01-29 Thread Stephan Ewen (JIRA)
Stephan Ewen created FLINK-3305: --- Summary: Remove JavaKaffee serializer util Key: FLINK-3305 URL: https://issues.apache.org/jira/browse/FLINK-3305 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-1870) Reintroduce Indexed reader functionality to streaming

2016-01-29 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1870?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15123651#comment-15123651 ] ASF GitHub Bot commented on FLINK-1870: --- Github user aljoscha commented on the pull request:

[GitHub] flink pull request: [FLINK-3300] fix concurrency bug in YarnJobMan...

2016-01-29 Thread mxm
Github user mxm commented on the pull request: https://github.com/apache/flink/pull/1561#issuecomment-176838676 Thanks for the review @tillrohrmann. Going to merge this soon as it is a release critical fix. --- If your project is set up for it, you can reply to this email and have

[jira] [Commented] (FLINK-3208) Rename Gelly vertex-centric model to scatter-gather

2016-01-29 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3208?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15123640#comment-15123640 ] ASF GitHub Bot commented on FLINK-3208: --- Github user aljoscha commented on the pull request:

[GitHub] flink pull request: [FLINK-3208] [gelly] rename vertex-centric ite...

2016-01-29 Thread aljoscha
Github user aljoscha commented on the pull request: https://github.com/apache/flink/pull/1514#issuecomment-176838607 Are there any objections to merging this? I think the arguments on mailing list/jira sounded reasonable and you probably know this part of Flink best, @vasia. ---

[jira] [Commented] (FLINK-3300) Concurrency Bug in Yarn JobManager

2016-01-29 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3300?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15123641#comment-15123641 ] ASF GitHub Bot commented on FLINK-3300: --- Github user mxm commented on the pull request:

[jira] [Commented] (FLINK-3097) Add support for custom functions in Table API

2016-01-29 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3097?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15123689#comment-15123689 ] ASF GitHub Bot commented on FLINK-3097: --- Github user aljoscha commented on the pull request:

[GitHub] flink pull request: [FLINK-2522] Streaming support for Flink-Scala...

2016-01-29 Thread aljoscha
Github user aljoscha commented on the pull request: https://github.com/apache/flink/pull/1412#issuecomment-176847731 @nikste Any updates on this? --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not

[GitHub] flink pull request: [FLINK-3109]Join two streams with two differen...

2016-01-29 Thread aljoscha
Github user aljoscha commented on the pull request: https://github.com/apache/flink/pull/1527#issuecomment-176869415 Hi @wangyangjun, sorry for the long wait but I think we can get this PR in after some modifications. I'd like to change the API a bit to separate it from the other

[jira] [Commented] (FLINK-3109) Join two streams with two different buffer time

2016-01-29 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3109?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15123809#comment-15123809 ] ASF GitHub Bot commented on FLINK-3109: --- Github user aljoscha commented on the pull request:

[jira] [Commented] (FLINK-3302) Save Taskmanager Metrics per Job

2016-01-29 Thread Pieter Hameete (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3302?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15123857#comment-15123857 ] Pieter Hameete commented on FLINK-3302: --- Hi Greg, nice, I did not see your ticket, but good to see

[jira] [Comment Edited] (FLINK-3302) Save Taskmanager Metrics per Job

2016-01-29 Thread Pieter Hameete (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3302?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15123857#comment-15123857 ] Pieter Hameete edited comment on FLINK-3302 at 1/29/16 5:44 PM: Hi Greg,

[GitHub] flink pull request: [FLINK-3225] Implemented optimization of Table...

2016-01-29 Thread ChengXiangLi
Github user ChengXiangLi commented on the pull request: https://github.com/apache/flink/pull/1559#issuecomment-176891835 Yes, @fhueske , i saw you rewrite the DataSetRelNodes on scala, i would continue my work based on your PR. --- If your project is set up for it, you can reply to

[jira] [Commented] (FLINK-3225) Optimize logical Table API plans in Calcite

2016-01-29 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3225?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15123896#comment-15123896 ] ASF GitHub Bot commented on FLINK-3225: --- Github user ChengXiangLi commented on the pull request:

[GitHub] flink pull request: [Flink-3226] Implement project and filter tran...

2016-01-29 Thread ChengXiangLi
Github user ChengXiangLi commented on the pull request: https://github.com/apache/flink/pull/1556#issuecomment-176894471 Thanks for the comments, i would create a new PR based on Fabian's work. Besides, @twalthr , what's the scope of your code generation, previous Table API code

[jira] [Commented] (FLINK-3109) Join two streams with two different buffer time

2016-01-29 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3109?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15124398#comment-15124398 ] ASF GitHub Bot commented on FLINK-3109: --- Github user wangyangjun commented on the pull request:

[GitHub] flink pull request: [FLINK-3109]Join two streams with two differen...

2016-01-29 Thread wangyangjun
Github user wangyangjun commented on the pull request: https://github.com/apache/flink/pull/1527#issuecomment-177007794 Hello @aljoscha , As I mentioned in last comment, I will reimplement it with [Guava

[jira] [Commented] (FLINK-1870) Reintroduce Indexed reader functionality to streaming

2016-01-29 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1870?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15124736#comment-15124736 ] ASF GitHub Bot commented on FLINK-1870: --- Github user mjsax commented on the pull request:

[GitHub] flink pull request: [FLINK-3296] Remove 'flushing' behavior of the...

2016-01-29 Thread mbalassi
Github user mbalassi commented on the pull request: https://github.com/apache/flink/pull/1563#issuecomment-177088061 With the `RollingHDFSSink` this functionality is not needed any more and as you suggested apparently was a misleading implmentation anyway. I like your not to the

[jira] [Created] (FLINK-3307) RMQSourceTest failure

2016-01-29 Thread JIRA
Márton Balassi created FLINK-3307: - Summary: RMQSourceTest failure Key: FLINK-3307 URL: https://issues.apache.org/jira/browse/FLINK-3307 Project: Flink Issue Type: Bug Components:

[GitHub] flink pull request: [streaming] [scala] Exposed environment from D...

2016-01-29 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/1480 --- 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-3307) RMQSourceTest failure

2016-01-29 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3307?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15124797#comment-15124797 ] Chesnay Schepler commented on FLINK-3307: - i would assume that FLINK-3301 is related. >

[GitHub] flink pull request: [FLINK-1870] Reintroduce indexed reader functi...

2016-01-29 Thread mjsax
Github user mjsax commented on the pull request: https://github.com/apache/flink/pull/1483#issuecomment-177069344 I would like to keep this open, until [FLINK-2721](https://issues.apache.org/jira/browse/FLINK-2721) is merged. To make sure, we do not need this -- for this case, we can

[GitHub] flink pull request: FLINK-3179 Combiner is not injected if Reduce ...

2016-01-29 Thread ramkrish86
Github user ramkrish86 commented on the pull request: https://github.com/apache/flink/pull/1553#issuecomment-177080713 Thank you very much for the feedback. Let me try to understand this thing better and update the PR sooner. I will reach out here in case of any questions or doubts

[jira] [Commented] (FLINK-2237) Add hash-based Aggregation

2016-01-29 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2237?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15124790#comment-15124790 ] ASF GitHub Bot commented on FLINK-2237: --- Github user mbalassi commented on the pull request:

[GitHub] flink pull request: [FLINK-2237] [runtime] Add hash-based combiner...

2016-01-29 Thread mbalassi
Github user mbalassi commented on the pull request: https://github.com/apache/flink/pull/1517#issuecomment-177094172 I think exposing the feature through the API similarly to the way join strategies are exposed is the way to properly make this feature available for users. I would

[jira] [Commented] (FLINK-3179) Combiner is not injected if Reduce or GroupReduce input is explicitly partitioned

2016-01-29 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3179?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15124755#comment-15124755 ] ASF GitHub Bot commented on FLINK-3179: --- Github user ramkrish86 commented on the pull request:

[jira] [Commented] (FLINK-3296) DataStream.write*() methods are not flushing properly

2016-01-29 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3296?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15124777#comment-15124777 ] ASF GitHub Bot commented on FLINK-3296: --- Github user mbalassi commented on the pull request:

[GitHub] flink pull request: [FLINK-3225] Implemented optimization of Table...

2016-01-29 Thread fhueske
Github user fhueske closed the pull request at: https://github.com/apache/flink/pull/1559 --- 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-3225) Optimize logical Table API plans in Calcite

2016-01-29 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3225?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15124250#comment-15124250 ] ASF GitHub Bot commented on FLINK-3225: --- Github user fhueske closed the pull request at:

  1   2   >