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

2016-03-18 Thread ramkrishna.s.vasudevan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3179?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15202565#comment-15202565 ] ramkrishna.s.vasudevan commented on FLINK-3179: --- bq.Sorry again @ramkrish86

[jira] [Commented] (FLINK-3503) ProjectJoinTransposeRule fails to push down project.

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

[GitHub] flink pull request: [FLINK-3544] Introduce ResourceManager compone...

2016-03-18 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/1741#discussion_r56374742 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/clusterframework/messages/ShutdownClusterAfterJob.java --- @@ -0,0 +1,46 @@ +/* +

[jira] [Resolved] (FLINK-3226) Translate optimized logical Table API plans into physical plans representing DataSet programs

2016-03-18 Thread Vasia Kalavri (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3226?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vasia Kalavri resolved FLINK-3226. -- Resolution: Implemented Fix Version/s: 1.1.0 > Translate optimized logical Table API plan

[jira] [Assigned] (FLINK-3475) DISTINCT aggregate function support

2016-03-18 Thread Chengxiang Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3475?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chengxiang Li reassigned FLINK-3475: Assignee: Chengxiang Li > DISTINCT aggregate function support > ---

[jira] [Commented] (FLINK-2997) Support range partition with user customized data distribution.

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

[jira] [Commented] (FLINK-3544) ResourceManager runtime components

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

[GitHub] flink pull request: [FLINK-3544] Introduce ResourceManager compone...

2016-03-18 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/1741#discussion_r56374504 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/clusterframework/messages/ShutdownClusterAfterJob.java --- @@ -0,0 +1,46 @@ +/* +

[jira] [Commented] (FLINK-3428) Add fixed time trailing timestamp/watermark extractor

2016-03-18 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3428?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15199313#comment-15199313 ] ASF GitHub Bot commented on FLINK-3428: --- Github user kl0u commented on the pull requ

[GitHub] flink pull request: [FLINK-3544] Introduce ResourceManager compone...

2016-03-18 Thread mxm
Github user mxm commented on a diff in the pull request: https://github.com/apache/flink/pull/1741#discussion_r56483788 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/clusterframework/FlinkResourceManager.java --- @@ -0,0 +1,796 @@ +/* + * Licensed to the A

[GitHub] flink pull request: FLINK-3115: Update ElasticSearch connector to ...

2016-03-18 Thread rmetzger
Github user rmetzger commented on the pull request: https://github.com/apache/flink/pull/1792#issuecomment-198313758 I resolved above issue by not using the `embedded Node` mode. I suggest not to document it at all. There is currently no way of disabling the `JarHell` check of ES.

[GitHub] flink pull request: [FLINK-1984] Integrate Flink with Apache Mesos

2016-03-18 Thread ankurcha
Github user ankurcha closed the pull request at: https://github.com/apache/flink/pull/948 --- 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 ena

[jira] [Resolved] (FLINK-3632) Clean up Table API exceptions

2016-03-18 Thread Vasia Kalavri (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3632?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vasia Kalavri resolved FLINK-3632. -- Resolution: Fixed Assignee: Fabian Hueske Fix Version/s: 1.1.0 > Clean up Table

[jira] [Commented] (FLINK-2732) Add access to the TaskManagers' log file and out file in the web dashboard.

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

[GitHub] flink pull request: [FLINK-3621] Improve documentation of memory c...

2016-03-18 Thread fhueske
GitHub user fhueske opened a pull request: https://github.com/apache/flink/pull/1801 [FLINK-3621] Improve documentation of memory configuration parameters PR clarifies that the memory configuration parameters `taskmanager.memory.size` and `taskmanager.memory.fraction` are also used

[jira] [Commented] (FLINK-3544) ResourceManager runtime components

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

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

2016-03-18 Thread shikhar
Github user shikhar commented on a diff in the pull request: https://github.com/apache/flink/pull/1690#discussion_r56450314 --- Diff: flink-streaming-connectors/flink-connector-kafka-0.8/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaConsumer08.java --- @@ -29

[GitHub] flink pull request: [FLINK-3544] Introduce ResourceManager compone...

2016-03-18 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/1741#discussion_r56366895 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/clusterframework/FlinkResourceManager.java --- @@ -0,0 +1,796 @@ +/* + * Licensed

[GitHub] flink pull request: [FLINK-3544] Introduce ResourceManager compone...

2016-03-18 Thread mxm
Github user mxm commented on a diff in the pull request: https://github.com/apache/flink/pull/1741#discussion_r56520101 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/clusterframework/FlinkResourceManager.java --- @@ -0,0 +1,796 @@ +/* + * Licensed to the A

[GitHub] flink pull request: [FLINK-3544] Introduce ResourceManager compone...

2016-03-18 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/1741#discussion_r56373341 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/clusterframework/messages/SetWorkerPoolSize.java --- @@ -0,0 +1,63 @@ +/* + * Lic

[GitHub] flink pull request: [FLINK-2997] Support range partition with user...

2016-03-18 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/1776#discussion_r56669752 --- Diff: flink-tests/src/test/java/org/apache/flink/test/javaApiOperators/CustomDistributionITCase.java --- @@ -0,0 +1,116 @@ +/* + * Licensed to th

[GitHub] flink pull request: [FLINK-2732] Display TM logs in Dashboard

2016-03-18 Thread zentol
Github user zentol commented on the pull request: https://github.com/apache/flink/pull/1790#issuecomment-198348395 It also reduces the number of changed classes, since no new messsages to the jobmanager had to be added. --- If your project is set up for it, you can reply to this emai

[jira] [Commented] (FLINK-3629) In wikiedits Quick Start example, "The first call, .window()" should be "The first call, .timeWindow()"

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

[jira] [Commented] (FLINK-1964) Rework TwitterSource to use a Properties object instead of a file path

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

[jira] [Updated] (FLINK-3633) Job submission silently fails when using user code types

2016-03-18 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3633?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-3633: - Fix Version/s: 1.1.0 > Job submission silently fails when using user code types >

[jira] [Commented] (FLINK-3609) Revisit selection of Calcite rules

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

[GitHub] flink pull request: [FLINK-3544] Introduce ResourceManager compone...

2016-03-18 Thread mxm
Github user mxm commented on a diff in the pull request: https://github.com/apache/flink/pull/1741#discussion_r56508199 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/clusterframework/FlinkResourceManager.java --- @@ -0,0 +1,796 @@ +/* + * Licensed to the A

[GitHub] flink pull request: [docs] typo seperate - separate

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

[GitHub] flink pull request: [FLINK-3609] [tableAPI] Reorganize selection o...

2016-03-18 Thread vasia
Github user vasia commented on the pull request: https://github.com/apache/flink/pull/1797#issuecomment-197357617 and merged! --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enab

[GitHub] flink pull request: [FLINK-3633] Fix user code de/serialization in...

2016-03-18 Thread greghogan
Github user greghogan commented on a diff in the pull request: https://github.com/apache/flink/pull/1818#discussion_r56676581 --- Diff: docs/setup/config.md --- @@ -183,7 +184,7 @@ The following parameters configure Flink's JobManager and TaskManagers. - `akka.transport.thresh

[GitHub] flink pull request: [FLINK-3547] add support for streaming filter,...

2016-03-18 Thread vasia
GitHub user vasia opened a pull request: https://github.com/apache/flink/pull/1820 [FLINK-3547] add support for streaming filter, project, and union in the Table API This PR adds: - Java and Scala stream translators - methods to convert a table to a DataStream and vice

[GitHub] flink pull request: [FLINK-2909] [Gelly] Graph generators

2016-03-18 Thread vasia
Github user vasia commented on the pull request: https://github.com/apache/flink/pull/1807#issuecomment-198336366 Yes, this sounds like a good idea. I would also have the library methods as a separate page. --- If your project is set up for it, you can reply to this email and have yo

[jira] [Commented] (FLINK-3633) Job submission silently fails when using user code types

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

[GitHub] flink pull request: [FLINK-3614] Remove Non-Keyed Window Operator

2016-03-18 Thread aljoscha
GitHub user aljoscha opened a pull request: https://github.com/apache/flink/pull/1805 [FLINK-3614] Remove Non-Keyed Window Operator Instead we use a dummy KeySelector and the regular WindowOperator now. You can merge this pull request into a Git repository by running: $ git pul

[jira] [Commented] (FLINK-3620) Remove DbStateBackend

2016-03-18 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3620?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15197277#comment-15197277 ] ASF GitHub Bot commented on FLINK-3620: --- Github user uce commented on the pull reque

[jira] [Created] (FLINK-3620) Remove DbStateBackend

2016-03-18 Thread Gyula Fora (JIRA)
Gyula Fora created FLINK-3620: - Summary: Remove DbStateBackend Key: FLINK-3620 URL: https://issues.apache.org/jira/browse/FLINK-3620 Project: Flink Issue Type: Task Components: Streamin

[GitHub] flink pull request: [FLINK-2997] Support range partition with user...

2016-03-18 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/1776#discussion_r56344247 --- Diff: flink-tests/src/test/java/org/apache/flink/test/javaApiOperators/CustomDistributionITCase.java --- @@ -0,0 +1,161 @@ +/* + * Licensed to th

[GitHub] flink pull request: [FLINK-3609] [tableAPI] Reorganize selection o...

2016-03-18 Thread vasia
Github user vasia commented on the pull request: https://github.com/apache/flink/pull/1797#issuecomment-197342267 Thanks, will merge. --- 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 feat

[GitHub] flink pull request: [FLINK-2997] Support range partition with user...

2016-03-18 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/1776#discussion_r56669667 --- Diff: flink-tests/src/test/java/org/apache/flink/test/javaApiOperators/CustomDistributionITCase.java --- @@ -0,0 +1,116 @@ +/* + * Licensed to th

[jira] [Commented] (FLINK-3544) ResourceManager runtime components

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

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

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

[jira] [Updated] (FLINK-3637) Change RollingSink Writer interface to allow wider range of outputs

2016-03-18 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3637?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-3637: Assignee: Lasse Dalegaard > Change RollingSink Writer interface to allow wider range of outp

[GitHub] flink pull request: [FLINK-3544] Introduce ResourceManager compone...

2016-03-18 Thread mxm
Github user mxm commented on a diff in the pull request: https://github.com/apache/flink/pull/1741#discussion_r56479540 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/clusterframework/FlinkResourceManager.java --- @@ -0,0 +1,796 @@ +/* + * Licensed to the A

[jira] [Commented] (FLINK-3629) In wikiedits Quick Start example, "The first call, .window()" should be "The first call, .timeWindow()"

2016-03-18 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3629?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15199478#comment-15199478 ] Aljoscha Krettek commented on FLINK-3629: - Nope, you did everything correctly. I j

[jira] [Commented] (FLINK-3633) Job submission silently fails when using user code types

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

[GitHub] flink pull request: [FLINK-3544] Introduce ResourceManager compone...

2016-03-18 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/1741#discussion_r56518228 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/clusterframework/FlinkResourceManager.java --- @@ -0,0 +1,796 @@ +/* + * Licensed

[jira] [Commented] (FLINK-3633) Job submission silently fails when using user code types

2016-03-18 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3633?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15201635#comment-15201635 ] Greg Hogan commented on FLINK-3633: --- I am puzzled why this appears to work for some user

[GitHub] flink pull request: [FLINK-2997] Support range partition with user...

2016-03-18 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/1776#discussion_r56344323 --- Diff: flink-tests/src/test/java/org/apache/flink/test/javaApiOperators/CustomDistributionITCase.java --- @@ -0,0 +1,161 @@ +/* + * Licensed to th

[GitHub] flink pull request: [FLINK-2997] Support range partition with user...

2016-03-18 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/1776#discussion_r56665371 --- Diff: flink-tests/src/test/java/org/apache/flink/test/distribution/TestDataDist.java --- @@ -0,0 +1,77 @@ +/* + * Licensed to the Apache Software

[jira] [Commented] (FLINK-2997) Support range partition with user customized data distribution.

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

[jira] [Commented] (FLINK-3621) Misleading documentation of memory configuration parameters

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

[GitHub] flink pull request: [FLINK-2997] Support range partition with user...

2016-03-18 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/1776#discussion_r56343484 --- Diff: flink-tests/src/test/java/org/apache/flink/test/javaApiOperators/CustomDistributionITCase.java --- @@ -0,0 +1,161 @@ +/* + * Licensed to th

[jira] [Commented] (FLINK-3544) ResourceManager runtime components

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

[jira] [Assigned] (FLINK-3630) Little mistake in documentation

2016-03-18 Thread Vasia Kalavri (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3630?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vasia Kalavri reassigned FLINK-3630: Assignee: Vasia Kalavri > Little mistake in documentation > ---

[jira] [Commented] (FLINK-3544) ResourceManager runtime components

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

[GitHub] flink pull request: [hotfix] Fix typo 'JobManger'

2016-03-18 Thread chiwanpark
Github user chiwanpark commented on the pull request: https://github.com/apache/flink/pull/1812#issuecomment-198181529 Thanks for contribution! :-) --- 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-3544] Introduce ResourceManager compone...

2016-03-18 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/1741#discussion_r56368028 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/clusterframework/FlinkResourceManager.java --- @@ -0,0 +1,796 @@ +/* + * Licensed

[GitHub] flink pull request: [FLINK-3544] Introduce ResourceManager compone...

2016-03-18 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/1741#discussion_r56482752 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/clusterframework/FlinkResourceManager.java --- @@ -0,0 +1,796 @@ +/* + * Licensed

[jira] [Commented] (FLINK-2732) Add access to the TaskManagers' log file and out file in the web dashboard.

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

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

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

[jira] [Commented] (FLINK-1984) Integrate Flink with Apache Mesos

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

[jira] [Commented] (FLINK-3115) Update Elasticsearch connector to 2.X

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

[jira] [Created] (FLINK-3635) Potential null deference in TwitterExample#SelectEnglishAndTokenizeFlatMap#flatMap

2016-03-18 Thread Ted Yu (JIRA)
Ted Yu created FLINK-3635: - Summary: Potential null deference in TwitterExample#SelectEnglishAndTokenizeFlatMap#flatMap Key: FLINK-3635 URL: https://issues.apache.org/jira/browse/FLINK-3635 Project: Flink

[GitHub] flink pull request: [FLINK-2997] Support range partition with user...

2016-03-18 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/1776#discussion_r56664157 --- Diff: flink-tests/src/test/java/org/apache/flink/test/distribution/TestDataDist.java --- @@ -0,0 +1,77 @@ +/* + * Licensed to the Apache Software

[jira] [Comment Edited] (FLINK-3633) Job submission silently fails when using user code types

2016-03-18 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3633?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15201635#comment-15201635 ] Greg Hogan edited comment on FLINK-3633 at 3/18/16 3:33 PM: I

[GitHub] flink pull request: FLINK-3115: Update ElasticSearch connector to ...

2016-03-18 Thread rmetzger
Github user rmetzger commented on a diff in the pull request: https://github.com/apache/flink/pull/1792#discussion_r56637650 --- Diff: docs/apis/streaming/connectors/elasticsearch2.md --- @@ -0,0 +1,207 @@ +--- +title: "Elasticsearch 2.x Connector" + +# Sub-level nav

[GitHub] flink pull request: Flink 3579 Improve String concatenation

2016-03-18 Thread ramkrish86
Github user ramkrish86 commented on the pull request: https://github.com/apache/flink/pull/1788#issuecomment-197681445 Let me close and try to create a new pull request. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If

[GitHub] flink pull request: [hotfix][docs] fs.hdfs.hadoopconf typo

2016-03-18 Thread rmetzger
Github user rmetzger commented on the pull request: https://github.com/apache/flink/pull/1804#issuecomment-197412962 Can you close the issue manually? I forgot to include the close message into the commit --- If your project is set up for it, you can reply to this email and have your

[GitHub] flink pull request: [FLINK-3544] Introduce ResourceManager compone...

2016-03-18 Thread mxm
Github user mxm commented on a diff in the pull request: https://github.com/apache/flink/pull/1741#discussion_r56479509 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/clusterframework/FlinkResourceManager.java --- @@ -0,0 +1,796 @@ +/* + * Licensed to the A

[jira] [Commented] (FLINK-3544) ResourceManager runtime components

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

[jira] [Commented] (FLINK-2997) Support range partition with user customized data distribution.

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

[jira] [Commented] (FLINK-3239) Support for Kerberos enabled Kafka 0.9.0.0

2016-03-18 Thread Stefano Baghino (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3239?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15199162#comment-15199162 ] Stefano Baghino commented on FLINK-3239: If no one is working on this I would assi

[GitHub] flink pull request: [FLINK-3609] [tableAPI] Reorganize selection o...

2016-03-18 Thread fhueske
Github user fhueske commented on the pull request: https://github.com/apache/flink/pull/1797#issuecomment-197340028 Removed `FlinkJoinUnionTransposeRule` and 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.

[GitHub] flink pull request: [docs] typo seperate - separate

2016-03-18 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/1810 --- 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 pull request: [FLINK-3492] Configurable interval between Che...

2016-03-18 Thread zentol
Github user zentol commented on the pull request: https://github.com/apache/flink/pull/1794#issuecomment-197832914 Third time's the charm: * the time of the last triggered checkpoint is stored * when a checkpoint is triggered we check whether the interval has passed, if so we r

[jira] [Created] (FLINK-3632) Clean up Table API exceptions

2016-03-18 Thread Fabian Hueske (JIRA)
Fabian Hueske created FLINK-3632: Summary: Clean up Table API exceptions Key: FLINK-3632 URL: https://issues.apache.org/jira/browse/FLINK-3632 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-3627) Task stuck on lock in StreamSource when cancelling

2016-03-18 Thread Jamie Grier (JIRA)
Jamie Grier created FLINK-3627: -- Summary: Task stuck on lock in StreamSource when cancelling Key: FLINK-3627 URL: https://issues.apache.org/jira/browse/FLINK-3627 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-3544) ResourceManager runtime components

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

[GitHub] flink pull request: [FLINK-3544] Introduce ResourceManager compone...

2016-03-18 Thread mxm
Github user mxm commented on a diff in the pull request: https://github.com/apache/flink/pull/1741#discussion_r56507764 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/clusterframework/FlinkResourceManager.java --- @@ -0,0 +1,796 @@ +/* + * Licensed to the A

[GitHub] flink pull request: FLINK-3428: Adds a fixed time trailing waterma...

2016-03-18 Thread mxm
Github user mxm commented on the pull request: https://github.com/apache/flink/pull/1764#issuecomment-197937643 Thanks @kl0u. In addition to the JavaDoc, we should also document this in the streaming Programming Guide. Here: https://ci.apache.org/projects/flink/flink-docs-master/apis/

[jira] [Commented] (FLINK-3609) Revisit selection of Calcite rules

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

[jira] [Commented] (FLINK-3633) Job submission silently fails when using user code types

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

[jira] [Commented] (FLINK-2997) Support range partition with user customized data distribution.

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

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

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

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

2016-03-18 Thread fhueske
Github user fhueske commented on the pull request: https://github.com/apache/flink/pull/1553#issuecomment-198364412 Hi @ramkrish86, I thought about this PR and came to the conclusion that we should not continue. The optimizer's design does not allow to modify operators in or inject op

[jira] [Updated] (FLINK-3637) Change RollingSink Writer interface to allow wider range of outputs

2016-03-18 Thread Lasse Dalegaard (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3637?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lasse Dalegaard updated FLINK-3637: --- Remaining Estimate: (was: 168h) Original Estimate: (was: 168h) > Change RollingSi

[jira] [Commented] (FLINK-3633) Job submission silently fails when using user code types

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