[jira] [Created] (FLINK-3474) Partial aggregate interface design and sort-based implementation

2016-02-22 Thread Chengxiang Li (JIRA)
Chengxiang Li created FLINK-3474: Summary: Partial aggregate interface design and sort-based implementation Key: FLINK-3474 URL: https://issues.apache.org/jira/browse/FLINK-3474 Project: Flink

[jira] [Created] (FLINK-3473) Add partial aggregate support in Flink

2016-02-22 Thread Chengxiang Li (JIRA)
Chengxiang Li created FLINK-3473: Summary: Add partial aggregate support in Flink Key: FLINK-3473 URL: https://issues.apache.org/jira/browse/FLINK-3473 Project: Flink Issue Type: Improvement

[jira] [Comment Edited] (FLINK-3253) deserializeObject exception on WindowOperator

2016-02-22 Thread godfrey he (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3253?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15158264#comment-15158264 ] godfrey he edited comment on FLINK-3253 at 2/23/16 6:18 AM: is

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

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

[GitHub] flink pull request: [FLINK-3034][Streaming Connectors] Redis Sink ...

2016-02-22 Thread subhankarb
Github user subhankarb commented on the pull request: https://github.com/apache/flink/pull/1580#issuecomment-187546037 hi matthias, i was on vacation for 1 week. I'll update the pr once i get some input from robert about my design. On 22-Feb-2016 7:21 PM, "Robert Metzger"

[jira] [Comment Edited] (FLINK-1502) Expose metrics to graphite, ganglia and JMX.

2016-02-22 Thread Dongwon Kim (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1502?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15158023#comment-15158023 ] Dongwon Kim edited comment on FLINK-1502 at 2/23/16 4:44 AM: -

[jira] [Commented] (FLINK-3253) deserializeObject exception on WindowOperator

2016-02-22 Thread godfrey he (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3253?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15158264#comment-15158264 ] godfrey he commented on FLINK-3253: --- 0.10.1 ? > deserializeObject exception on WindowOp

[jira] [Commented] (FLINK-3035) Redis as State Backend

2016-02-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3035?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15158238#comment-15158238 ] ASF GitHub Bot commented on FLINK-3035: --- Github user sbcd90 commented on the pull re

[GitHub] flink pull request: [FLINK-3035] Redis as State Backend

2016-02-22 Thread sbcd90
Github user sbcd90 commented on the pull request: https://github.com/apache/flink/pull/1617#issuecomment-187515384 Hello @mjsax , it is possible to use Travis for testing the redis. Travis can start Redis during build. Please check out an example [here](https://github.com/sbcd90/redis

[jira] [Commented] (FLINK-2118) Table API fails on composite filter conditions

2016-02-22 Thread sahitya pavurala (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2118?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15158138#comment-15158138 ] sahitya pavurala commented on FLINK-2118: - Isn't this because && has a higher prec

[jira] [Comment Edited] (FLINK-1502) Expose metrics to graphite, ganglia and JMX.

2016-02-22 Thread Jamie Grier (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1502?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15158090#comment-15158090 ] Jamie Grier edited comment on FLINK-1502 at 2/23/16 1:30 AM: -

[jira] [Commented] (FLINK-1502) Expose metrics to graphite, ganglia and JMX.

2016-02-22 Thread Jamie Grier (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1502?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15158090#comment-15158090 ] Jamie Grier commented on FLINK-1502: [~eastcirclek] Let's define our terms to make su

[jira] [Comment Edited] (FLINK-1502) Expose metrics to graphite, ganglia and JMX.

2016-02-22 Thread Dongwon Kim (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1502?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15158023#comment-15158023 ] Dongwon Kim edited comment on FLINK-1502 at 2/23/16 12:43 AM: --

[jira] [Comment Edited] (FLINK-1502) Expose metrics to graphite, ganglia and JMX.

2016-02-22 Thread Dongwon Kim (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1502?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15158023#comment-15158023 ] Dongwon Kim edited comment on FLINK-1502 at 2/23/16 12:41 AM: --

[jira] [Commented] (FLINK-1502) Expose metrics to graphite, ganglia and JMX.

2016-02-22 Thread Dongwon Kim (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1502?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15158023#comment-15158023 ] Dongwon Kim commented on FLINK-1502: Let's consider the following scenario:

[jira] [Commented] (FLINK-3385) Fix outer join skipping unprobed partitions

2016-02-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3385?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15158005#comment-15158005 ] ASF GitHub Bot commented on FLINK-3385: --- Github user fhueske commented on the pull r

[GitHub] flink pull request: [FLINK-3385] [runtime] Fix outer join skipping...

2016-02-22 Thread fhueske
Github user fhueske commented on the pull request: https://github.com/apache/flink/pull/1680#issuecomment-187448014 Thanks for the fix! Will merge 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

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

2016-02-22 Thread fhueske
Github user fhueske commented on the pull request: https://github.com/apache/flink/pull/1517#issuecomment-187439412 Thanks @aalexandrov. I added a few comments to the document. Looking forward to the results :-) --- If your project is set up for it, you can reply to this email and

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

2016-02-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2237?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15157950#comment-15157950 ] ASF GitHub Bot commented on FLINK-2237: --- Github user fhueske commented on the pull r

[jira] [Created] (FLINK-3472) JDBCInputFormat.nextRecord(..) has misleading message on NPE

2016-02-22 Thread Ken Geis (JIRA)
Ken Geis created FLINK-3472: --- Summary: JDBCInputFormat.nextRecord(..) has misleading message on NPE Key: FLINK-3472 URL: https://issues.apache.org/jira/browse/FLINK-3472 Project: Flink Issue Type:

[jira] [Created] (FLINK-3471) JDBCInputFormat cannot handle null fields of certain types

2016-02-22 Thread Ken Geis (JIRA)
Ken Geis created FLINK-3471: --- Summary: JDBCInputFormat cannot handle null fields of certain types Key: FLINK-3471 URL: https://issues.apache.org/jira/browse/FLINK-3471 Project: Flink Issue Type: Bu

[jira] [Commented] (FLINK-3340) Fix object juggling in drivers

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

[GitHub] flink pull request: [FLINK-3340][Kafka 0.8] Commit also offsets re...

2016-02-22 Thread greghogan
Github user greghogan commented on the pull request: https://github.com/apache/flink/pull/1692#issuecomment-187376965 Is this FLINK-3440? --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this

[jira] [Commented] (FLINK-3455) Bump Kafka 0.9 connector dependency to Kafka 0.9.0.1

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

[GitHub] flink pull request: [FLINK-3455] Bump Kafka to 0.9.0.1 and 0.8.2.2

2016-02-22 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/1684 --- 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] [Resolved] (FLINK-3455) Bump Kafka 0.9 connector dependency to Kafka 0.9.0.1

2016-02-22 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3455?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger resolved FLINK-3455. --- Resolution: Fixed Fix Version/s: 1.0.0 Resolved in http://git-wip-us.apache.org/repos/a

[jira] [Commented] (FLINK-3340) Fix object juggling in drivers

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

[jira] [Commented] (FLINK-3455) Bump Kafka 0.9 connector dependency to Kafka 0.9.0.1

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

[GitHub] flink pull request: [FLINK-3455] Bump Kafka to 0.9.0.1 and 0.8.2.2

2016-02-22 Thread rmetzger
Github user rmetzger commented on the pull request: https://github.com/apache/flink/pull/1684#issuecomment-187366906 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 e

[GitHub] flink pull request: [FLINK-3340][Kafka 0.8] Commit also offsets re...

2016-02-22 Thread rmetzger
GitHub user rmetzger opened a pull request: https://github.com/apache/flink/pull/1692 [FLINK-3340][Kafka 0.8] Commit also offsets retrieved from Kafka into the OffsetStore (ZK) Before this change, offsets were only committed to Zookeeper if something was read from the TopicPartitio

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

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

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

2016-02-22 Thread rmetzger
Github user rmetzger commented on the pull request: https://github.com/apache/flink/pull/1581#issuecomment-187364918 Hi, the error is not related to your changes. Its an issue of our build system (an inconsistent file has been cached). From a CI point of view, the changes look good

[GitHub] flink pull request: [FLINK-3443] [runtime] Prevent cancelled jobs ...

2016-02-22 Thread StephanEwen
Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/1669#discussion_r53678441 --- Diff: flink-runtime/src/main/scala/org/apache/flink/runtime/jobmanager/JobManager.scala --- @@ -1487,7 +1487,7 @@ class JobManager( }

[jira] [Commented] (FLINK-3443) JobManager cancel and clear everything fails jobs instead of cancelling

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

[jira] [Commented] (FLINK-3443) JobManager cancel and clear everything fails jobs instead of cancelling

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

[GitHub] flink pull request: [FLINK-3443] [runtime] Prevent cancelled jobs ...

2016-02-22 Thread uce
Github user uce commented on a diff in the pull request: https://github.com/apache/flink/pull/1669#discussion_r53677748 --- Diff: flink-runtime/src/main/scala/org/apache/flink/runtime/jobmanager/JobManager.scala --- @@ -1487,7 +1487,7 @@ class JobManager( }

[jira] [Commented] (FLINK-3418) RocksDB HDFSCopyFromLocal util doesn't respect our Hadoop security configuration

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

[GitHub] flink pull request: [FLINK-3418] Don't run RocksDB copy utils in e...

2016-02-22 Thread aljoscha
Github user aljoscha commented on the pull request: https://github.com/apache/flink/pull/1687#issuecomment-187328780 Ahh, stupid beginners mistake. Fixed it. --- 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

[jira] [Commented] (FLINK-3418) RocksDB HDFSCopyFromLocal util doesn't respect our Hadoop security configuration

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

[GitHub] flink pull request: [FLINK-3418] Don't run RocksDB copy utils in e...

2016-02-22 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/1687#issuecomment-187323846 Fails on checkstyle, otherwise looks 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-3443] [runtime] Prevent cancelled jobs ...

2016-02-22 Thread StephanEwen
Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/1669#discussion_r53673891 --- Diff: flink-runtime/src/main/scala/org/apache/flink/runtime/jobmanager/JobManager.scala --- @@ -1487,7 +1487,7 @@ class JobManager( }

[jira] [Commented] (FLINK-3443) JobManager cancel and clear everything fails jobs instead of cancelling

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

[jira] [Created] (FLINK-3470) EventTime WindowAssigners should error on negative timestamps

2016-02-22 Thread Stephan Ewen (JIRA)
Stephan Ewen created FLINK-3470: --- Summary: EventTime WindowAssigners should error on negative timestamps Key: FLINK-3470 URL: https://issues.apache.org/jira/browse/FLINK-3470 Project: Flink Is

[jira] [Commented] (FLINK-3467) Remove superfluous objects from DataSourceTask.invoke

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

[GitHub] flink pull request: [FLINK-3467] Remove superfluous objects from D...

2016-02-22 Thread greghogan
GitHub user greghogan opened a pull request: https://github.com/apache/flink/pull/1691 [FLINK-3467] Remove superfluous objects from DataSourceTask.invoke This reverts the object reuse logic to that of commit e8734b24. You can merge this pull request into a Git repository by running:

[jira] [Commented] (FLINK-3398) Flink Kafka consumer should support auto-commit opt-outs

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

[GitHub] flink pull request: FLINK-3398: Allow for opting-out from Kafka of...

2016-02-22 Thread shikhar
GitHub user shikhar opened a pull request: https://github.com/apache/flink/pull/1690 FLINK-3398: Allow for opting-out from Kafka offset auto-commit You can merge this pull request into a Git repository by running: $ git pull https://github.com/shikhar/flink kafka-autocommit-op

[GitHub] flink pull request: Make DataStream property methods properly Scal...

2016-02-22 Thread StephanEwen
GitHub user StephanEwen opened a pull request: https://github.com/apache/flink/pull/1689 Make DataStream property methods properly Scalaesk This is a suggestion on how to make the `DataStream` Scala code (particular the property methods) more scalaesk. For example: -

[jira] [Created] (FLINK-3469) Fix documentation for grouping keys

2016-02-22 Thread Greg Hogan (JIRA)
Greg Hogan created FLINK-3469: - Summary: Fix documentation for grouping keys Key: FLINK-3469 URL: https://issues.apache.org/jira/browse/FLINK-3469 Project: Flink Issue Type: Bug Compone

[jira] [Commented] (FLINK-3375) Allow Watermark Generation in the Kafka Source

2016-02-22 Thread Shikhar Bhushan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3375?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15157377#comment-15157377 ] Shikhar Bhushan commented on FLINK-3375: We are also on Kafka 0.8 for now > Allow

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

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

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

2016-02-22 Thread ramkrish86
Github user ramkrish86 commented on a diff in the pull request: https://github.com/apache/flink/pull/1553#discussion_r53659684 --- Diff: flink-tests/src/test/java/org/apache/flink/test/javaApiOperators/GroupReduceITCase.java --- @@ -434,6 +431,95 @@ public void testCorrectnessOfG

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

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

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

2016-02-22 Thread ramkrish86
Github user ramkrish86 commented on a diff in the pull request: https://github.com/apache/flink/pull/1553#discussion_r53659650 --- Diff: flink-optimizer/src/main/java/org/apache/flink/optimizer/operators/GroupReduceWithCombineProperties.java --- @@ -87,19 +92,39 @@ public DriverSt

[jira] [Commented] (FLINK-3375) Allow Watermark Generation in the Kafka Source

2016-02-22 Thread Zach Cox (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3375?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15157295#comment-15157295 ] Zach Cox commented on FLINK-3375: - Our specific app is currently using Kafka 0.8 (we plan

[jira] [Created] (FLINK-3468) Change Timestamp Extractors to not support negative timestamps

2016-02-22 Thread Stephan Ewen (JIRA)
Stephan Ewen created FLINK-3468: --- Summary: Change Timestamp Extractors to not support negative timestamps Key: FLINK-3468 URL: https://issues.apache.org/jira/browse/FLINK-3468 Project: Flink I

[jira] [Commented] (FLINK-3458) Shading broken in flink-shaded-hadoop

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

[GitHub] flink pull request: [FLINK-3458] [build] Disable shade-flink execu...

2016-02-22 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/1681#issuecomment-187265742 +1 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled

[jira] [Commented] (FLINK-3375) Allow Watermark Generation in the Kafka Source

2016-02-22 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3375?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15157270#comment-15157270 ] Stephan Ewen commented on FLINK-3375: - I think we could use some contributor help to g

[jira] [Commented] (FLINK-3331) Test instability: LocalFlinkMiniClusterITCase.testLocalFlinkMiniClusterWithMultipleTaskManagers

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

[GitHub] flink pull request: [FLINK-3331] TupleSerializer.getLength() can r...

2016-02-22 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/1654#issuecomment-187262614 Looks good, +1 to merge 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

[jira] [Commented] (FLINK-3425) DataSinkTaskTest.Failing[Sorting]DataSinkTask fails on Windows

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

[GitHub] flink pull request: [FLINK-3425] FileOutputFormat closes outStream...

2016-02-22 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/1652#issuecomment-187261145 Sorry, I confused the diff. This looks actually good, +1 to merge --- If your project is set up for it, you can reply to this email and have your reply appe

[jira] [Commented] (FLINK-3385) Fix outer join skipping unprobed partitions

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

[GitHub] flink pull request: [FLINK-3385] [runtime] Fix outer join skipping...

2016-02-22 Thread greghogan
Github user greghogan commented on the pull request: https://github.com/apache/flink/pull/1680#issuecomment-187258482 Unprobed, spilled partitions are now retained when performing a build-side outer join (and still discarded in all other cases). When these unprobed, spilled pa

[GitHub] flink pull request: [FLINK-3385] [runtime] Fix outer join skipping...

2016-02-22 Thread hsaputra
Github user hsaputra commented on the pull request: https://github.com/apache/flink/pull/1680#issuecomment-187253798 Could add description on how is the fix being done and proposed result. Thanks --- If your project is set up for it, you can reply to this email and have your reply ap

[jira] [Commented] (FLINK-3385) Fix outer join skipping unprobed partitions

2016-02-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3385?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15157232#comment-15157232 ] ASF GitHub Bot commented on FLINK-3385: --- Github user hsaputra commented on the pull

[jira] [Commented] (FLINK-3438) ExternalProcessRunner fails to detect ClassNotFound exception because of locale settings

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

[jira] [Created] (FLINK-3467) Remove superfluous objects from DataSourceTask.invoke

2016-02-22 Thread Greg Hogan (JIRA)
Greg Hogan created FLINK-3467: - Summary: Remove superfluous objects from DataSourceTask.invoke Key: FLINK-3467 URL: https://issues.apache.org/jira/browse/FLINK-3467 Project: Flink Issue Type: Imp

[GitHub] flink pull request: [FLINK-3438] ExternalProcessRunner fails to de...

2016-02-22 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/1665#issuecomment-187250281 The test failure looks unrelated to this fix. +1 to merge this --- If your project is set up for it, you can reply to this email and have your reply appear

[GitHub] flink pull request: [FLINK-3438] ExternalProcessRunner fails to de...

2016-02-22 Thread stefanobaghino
Github user stefanobaghino commented on the pull request: https://github.com/apache/flink/pull/1665#issuecomment-187248829 Running the test locally with the same `PROFILE` as the failing tests do not yield the same results (i.e. all tests pass). Is there a way to determine if this was

[GitHub] flink pull request: [FLINK-3335] [runtime] Fix DataSourceTask obje...

2016-02-22 Thread greghogan
Github user greghogan closed the pull request at: https://github.com/apache/flink/pull/1616 --- 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 e

[GitHub] flink pull request: [FLINK-3335] [runtime] Fix DataSourceTask obje...

2016-02-22 Thread greghogan
Github user greghogan commented on the pull request: https://github.com/apache/flink/pull/1616#issuecomment-187240850 Considering this and other recent discussions I agree that introducing a high-level copy would be detrimental and that there are better solutions. I would still like t

[jira] [Commented] (FLINK-3438) ExternalProcessRunner fails to detect ClassNotFound exception because of locale settings

2016-02-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3438?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15157212#comment-15157212 ] ASF GitHub Bot commented on FLINK-3438: --- Github user stefanobaghino commented on the

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

2016-02-22 Thread aalexandrov
Github user aalexandrov commented on the pull request: https://github.com/apache/flink/pull/1517#issuecomment-187243415 I've added a [Google Doc](https://docs.google.com/document/d/12yx7olVrkooceaQPoR1nkk468lIq0xOObY5ukWuNEcM/edit?usp=sharing) where we can collaborate on the design of

[GitHub] flink pull request: [FLINK-3455] Bump Kafka to 0.9.0.1 and 0.8.2.2

2016-02-22 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/1684#issuecomment-187246143 Looks good, +1 to merge 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

[jira] [Updated] (FLINK-3467) Remove superfluous objects from DataSourceTask.invoke

2016-02-22 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3467?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan updated FLINK-3467: -- Description: In the object reuse case we cycle between three objects. This is a vestige of an earlier bu

[jira] [Commented] (FLINK-3455) Bump Kafka 0.9 connector dependency to Kafka 0.9.0.1

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

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

2016-02-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2237?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15157179#comment-15157179 ] ASF GitHub Bot commented on FLINK-2237: --- Github user aalexandrov commented on the pu

[jira] [Commented] (FLINK-3335) Fix DataSourceTask object reuse when disabled

2016-02-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3335?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15157174#comment-15157174 ] ASF GitHub Bot commented on FLINK-3335: --- Github user greghogan closed the pull reque

[jira] [Commented] (FLINK-3335) Fix DataSourceTask object reuse when disabled

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

[jira] [Closed] (FLINK-3335) Fix DataSourceTask object reuse when disabled

2016-02-22 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3335?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan closed FLINK-3335. - Resolution: Won't Fix > Fix DataSourceTask object reuse when disabled > --

[GitHub] flink pull request: [FLINK-3315] Fix Slot Sharing in Streaming API

2016-02-22 Thread aljoscha
Github user aljoscha commented on the pull request: https://github.com/apache/flink/pull/1641#issuecomment-187190568 Updated on top of master again. This should have the behavior that we want for 1.0. --- If your project is set up for it, you can reply to this email and have your rep

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

2016-02-22 Thread stefanobaghino
Github user stefanobaghino commented on the pull request: https://github.com/apache/flink/pull/1581#issuecomment-187221864 Was this a hiccup in the build or an issue related to my changes? I really can't tell from the error message. --- If your project is set up for it, you can reply

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

2016-02-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2021?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15157102#comment-15157102 ] ASF GitHub Bot commented on FLINK-2021: --- Github user stefanobaghino commented on the

[GitHub] flink pull request: [FLINK-3464] [docs] Add SBT template documenta...

2016-02-22 Thread tillrohrmann
GitHub user tillrohrmann opened a pull request: https://github.com/apache/flink/pull/1688 [FLINK-3464] [docs] Add SBT template documentation to the quickstart documentation This PR also changes the order of the shown tabs for the java api quickstart guide. Now the maven archetype i

[jira] [Commented] (FLINK-3464) Add SBT build tool description to quickstart documentation

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

[GitHub] flink pull request: [FLINK-3418] Don't run RocksDB copy utils in e...

2016-02-22 Thread aljoscha
Github user aljoscha commented on the pull request: https://github.com/apache/flink/pull/1687#issuecomment-187202268 Should be the correct code now. :smile: --- 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

[GitHub] flink pull request: [FLINK-3418] Don't run RocksDB copy utils in e...

2016-02-22 Thread aljoscha
Github user aljoscha commented on a diff in the pull request: https://github.com/apache/flink/pull/1687#discussion_r53629014 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/util/HDFSCopyFromLocal.java --- @@ -26,32 +25,46 @@ import java.io.File; i

[jira] [Created] (FLINK-3463) Implement Calc Support

2016-02-22 Thread Vasia Kalavri (JIRA)
Vasia Kalavri created FLINK-3463: Summary: Implement Calc Support Key: FLINK-3463 URL: https://issues.apache.org/jira/browse/FLINK-3463 Project: Flink Issue Type: Sub-task Component

[jira] [Commented] (FLINK-3418) RocksDB HDFSCopyFromLocal util doesn't respect our Hadoop security configuration

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

[jira] [Created] (FLINK-3465) Add SBT template script

2016-02-22 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-3465: Summary: Add SBT template script Key: FLINK-3465 URL: https://issues.apache.org/jira/browse/FLINK-3465 Project: Flink Issue Type: Improvement Rep

[GitHub] flink pull request: [FLINK-3035] Redis as State Backend

2016-02-22 Thread aljoscha
Github user aljoscha commented on the pull request: https://github.com/apache/flink/pull/1617#issuecomment-187201289 I don't know enough about redis. Not sure how we can deal with the testing situation. --- If your project is set up for it, you can reply to this email and have your r

[jira] [Created] (FLINK-3464) Add SBT build tool description to quickstart documentation

2016-02-22 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-3464: Summary: Add SBT build tool description to quickstart documentation Key: FLINK-3464 URL: https://issues.apache.org/jira/browse/FLINK-3464 Project: Flink Issu

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

2016-02-22 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-3466: - Summary: Job might get stuck in restoreState() from HDFS due to interrupt Key: FLINK-3466 URL: https://issues.apache.org/jira/browse/FLINK-3466 Project: Flink

[GitHub] flink pull request: [FLINK-3035] Redis as State Backend

2016-02-22 Thread mjsax
Github user mjsax commented on the pull request: https://github.com/apache/flink/pull/1617#issuecomment-187199830 I guess we can just move on here by assuming that Redis must be started manually before it can be uses as state backend. We still need to figure out how to test this: it i

[jira] [Commented] (FLINK-3418) RocksDB HDFSCopyFromLocal util doesn't respect our Hadoop security configuration

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

[GitHub] flink pull request: [FLINK-3418] Don't run RocksDB copy utils in e...

2016-02-22 Thread rmetzger
Github user rmetzger commented on a diff in the pull request: https://github.com/apache/flink/pull/1687#discussion_r53628814 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/util/HDFSCopyFromLocal.java --- @@ -26,32 +25,46 @@ import java.io.File; i

[jira] [Commented] (FLINK-3035) Redis as State Backend

2016-02-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3035?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15157039#comment-15157039 ] ASF GitHub Bot commented on FLINK-3035: --- Github user mjsax commented on the pull req

[jira] [Commented] (FLINK-3035) Redis as State Backend

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

  1   2   >