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

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

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

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

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

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

[jira] [Commented] (FLINK-2909) Gelly Graph Generators

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

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

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

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

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

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

2016-03-19 Thread rmetzger
Github user rmetzger commented on the pull request: https://github.com/apache/flink/pull/1804#issuecomment-197408073 +1 to 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 feature

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

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

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

2016-03-19 Thread Li Fanxi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3629?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15199408#comment-15199408 ] Li Fanxi edited comment on FLINK-3629 at 3/17/16 12:37 PM: --- I have already

[jira] [Commented] (FLINK-3623) Adjust MurmurHash algorithm

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

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

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

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

2016-03-19 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: - Description: With the changes introduced by FLINK-3327, it is no longer possible to run remote

[jira] [Commented] (FLINK-3636) NoClassDefFoundError while running WindowJoin example

2016-03-19 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3636?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15201314#comment-15201314 ] Chesnay Schepler commented on FLINK-3636: - the problem is that the the ThrottledIterator class is

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

2016-03-19 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/1776#discussion_r56661891 --- Diff: flink-java/src/main/java/org/apache/flink/api/java/operators/PartitionOperator.java --- @@ -82,6 +88,7 @@ public PartitionOperator(DataSet input,

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

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

[jira] [Created] (FLINK-3623) Adjust MurmurHash algorithm

2016-03-19 Thread Greg Hogan (JIRA)
Greg Hogan created FLINK-3623: - Summary: Adjust MurmurHash algorithm Key: FLINK-3623 URL: https://issues.apache.org/jira/browse/FLINK-3623 Project: Flink Issue Type: Improvement

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

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

[GitHub] flink pull request: [hotFix] [tableAPI] Improve naming of DataSetR...

2016-03-19 Thread vasia
Github user vasia commented on the pull request: https://github.com/apache/flink/pull/1799#issuecomment-197357481 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

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

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

[GitHub] flink pull request: [hotfix] [docs] Fix broken link in Windows doc...

2016-03-19 Thread smarthi
GitHub user smarthi opened a pull request: https://github.com/apache/flink/pull/1816 [hotfix] [docs] Fix broken link in Windows docs for time.htm, changed to event_time.html You can merge this pull request into a Git repository by running: $ git pull

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

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

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

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

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

2016-03-19 Thread fhueske
Github user fhueske commented on the pull request: https://github.com/apache/flink/pull/1776#issuecomment-197360737 Hi, I had a few more remarks, mostly regarding the tests. Can you also add the method `TypeInformation[] getKeyTypes()` to `DataDistribution` that I requested in the

[GitHub] flink pull request: [hotfix][examples] Add zookeeper.connect to us...

2016-03-19 Thread stefanobaghino
Github user stefanobaghino commented on a diff in the pull request: https://github.com/apache/flink/pull/1803#discussion_r56365211 --- Diff: flink-examples/flink-examples-streaming/src/main/java/org/apache/flink/streaming/examples/kafka/WriteIntoKafka.java --- @@ -38,7 +38,8 @@

[jira] [Commented] (FLINK-3636) NoClassDefFoundError while running WindowJoin example

2016-03-19 Thread JIRA
[ https://issues.apache.org/jira/browse/FLINK-3636?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15201365#comment-15201365 ] Márton Balassi commented on FLINK-3636: --- Fortunately it does not affect the previous release. Fixing

[GitHub] flink pull request: [hotfix] Update python.md

2016-03-19 Thread zentol
GitHub user zentol opened a pull request: https://github.com/apache/flink/pull/1814 [hotfix] Update python.md updates a few minor things in the python documentation: * mention successful tests on Windows Operating System * set_degree_of_parallelism => set_parallelism *

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

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

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

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

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

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

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

2016-03-19 Thread rmetzger
Github user rmetzger commented on the pull request: https://github.com/apache/flink/pull/1790#issuecomment-198348409 I see --- 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

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

2016-03-19 Thread fhueske
Github user fhueske commented on the pull request: https://github.com/apache/flink/pull/1517#issuecomment-198406921 Hi @ggevay, how are things going? I would like to add this feature soon and will do another review next week. Have you started with the benchmarks or time to do

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

2016-03-19 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3620?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15197209#comment-15197209 ] ASF GitHub Bot commented on FLINK-3620: --- GitHub user gyfora opened a pull request:

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

2016-03-19 Thread Lasse Dalegaard (JIRA)
Lasse Dalegaard created FLINK-3637: -- Summary: Change RollingSink Writer interface to allow wider range of outputs Key: FLINK-3637 URL: https://issues.apache.org/jira/browse/FLINK-3637 Project: Flink

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

2016-03-19 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/1801 --- 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-2997) Support range partition with user customized data distribution.

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

[GitHub] flink pull request: [hotfix][examples] Add zookeeper.connect to us...

2016-03-19 Thread rmetzger
Github user rmetzger commented on the pull request: https://github.com/apache/flink/pull/1803#issuecomment-197410235 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

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

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

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

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

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

2016-03-19 Thread Vasia Kalavri (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3503?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vasia Kalavri resolved FLINK-3503. -- Resolution: Fixed Fix Version/s: 1.1.0 > ProjectJoinTransposeRule fails to push down

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

2016-03-19 Thread Gyula Fora (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3620?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-3620. - Resolution: Fixed > Remove DbStateBackend > - > > Key: FLINK-3620 >

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

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

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

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

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

2016-03-19 Thread zentol
Github user zentol commented on the pull request: https://github.com/apache/flink/pull/1790#issuecomment-197322838 second batch of changes coming in. * TaskManager checks whether blobService is defined * new class: RuntimeMonitorHandlerBase *

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

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

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

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

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

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

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

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

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

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

[jira] [Assigned] (FLINK-3622) Improve error messages for invalid joins

2016-03-19 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3622?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske reassigned FLINK-3622: Assignee: Fabian Hueske > Improve error messages for invalid joins >

[GitHub] flink pull request: [hotFix] [tableAPI] Improve naming of DataSetR...

2016-03-19 Thread vasia
Github user vasia commented on the pull request: https://github.com/apache/flink/pull/1799#issuecomment-197320894 This looks good. I'll merge 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 does not

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

2016-03-19 Thread rmetzger
Github user rmetzger commented on the pull request: https://github.com/apache/flink/pull/1790#issuecomment-198345651 Also, I'm not sure if this log message is correct: ``` 2016-03-18 12:59:43,376 INFO org.apache.flink.runtime.blob.BlobCache - Downloading

[jira] [Commented] (FLINK-2909) Gelly Graph Generators

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

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

2016-03-19 Thread smarthi
Github user smarthi commented on the pull request: https://github.com/apache/flink/pull/1792#issuecomment-198110028 @rmetzger @mxm This PR is good to merge now --- 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] [Resolved] (FLINK-3221) Move Table API on top of Apache Calcite

2016-03-19 Thread Vasia Kalavri (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3221?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vasia Kalavri resolved FLINK-3221. -- Resolution: Implemented Fix Version/s: 1.1.0 > Move Table API on top of Apache Calcite >

[jira] [Assigned] (FLINK-3524) Provide a JSONSerialisationSchema in the kafka connector package

2016-03-19 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3524?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reassigned FLINK-3524: --- Assignee: Chesnay Schepler > Provide a JSONSerialisationSchema in the kafka

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

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

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

2016-03-19 Thread zentol
Github user zentol commented on the pull request: https://github.com/apache/flink/pull/1812#issuecomment-197857475 +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-2997] Support range partition with user...

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

[GitHub] flink pull request: [FLINK-3623] [runtime] Adjust MurmurHash Algor...

2016-03-19 Thread greghogan
GitHub user greghogan opened a pull request: https://github.com/apache/flink/pull/1806 [FLINK-3623] [runtime] Adjust MurmurHash Algorithm Fix "hash *= n" to be "hash = hash * m + n". You can merge this pull request into a Git repository by running: $ git pull

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

2016-03-19 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3239?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15199221#comment-15199221 ] Robert Metzger commented on FLINK-3239: --- I'm not aware of anybody working on it, so go ahead. >

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

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

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

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

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

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

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

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

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

2016-03-19 Thread Vasia Kalavri (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3632?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vasia Kalavri reopened FLINK-3632: -- Assignee: (was: Fabian Hueske) > Clean up Table API exceptions >

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

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

[jira] [Created] (FLINK-3624) Use camelCase naming of JSON attributes generated by the REST API instead of dash

2016-03-19 Thread JIRA
Zoltán Zvara created FLINK-3624: --- Summary: Use camelCase naming of JSON attributes generated by the REST API instead of dash Key: FLINK-3624 URL: https://issues.apache.org/jira/browse/FLINK-3624

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

2016-03-19 Thread chiwanpark
Github user chiwanpark commented on the pull request: https://github.com/apache/flink/pull/1810#issuecomment-198181543 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-1964] Reimplement TwitterSource

2016-03-19 Thread rmetzger
Github user rmetzger commented on the pull request: https://github.com/apache/flink/pull/1796#issuecomment-197410357 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

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

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

[jira] [Commented] (FLINK-3547) Add support for streaming projection, selection, and union

2016-03-19 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3547?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15201967#comment-15201967 ] ASF GitHub Bot commented on FLINK-3547: --- GitHub user vasia opened a pull request:

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

2016-03-19 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/1797#discussion_r56329514 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/plan/rules/FlinkRuleSets.scala --- @@ -29,50 +29,45 @@ object FlinkRuleSets

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

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

[GitHub] flink pull request: [FLINK-3492] Configurable interval between Che...

2016-03-19 Thread zentol
Github user zentol commented on the pull request: https://github.com/apache/flink/pull/1794#issuecomment-197462397 I had a feeling that this solution was too simple to be correct, and in fact it is the case. on the bright side, i have a pretty good idea on how to solve this

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

2016-03-19 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3633?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15201654#comment-15201654 ] Till Rohrmann commented on FLINK-3633: -- It works for all user classes which are also available to the

[jira] [Resolved] (FLINK-3622) Improve error messages for invalid joins

2016-03-19 Thread Vasia Kalavri (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3622?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vasia Kalavri resolved FLINK-3622. -- Resolution: Fixed Fix Version/s: 1.1.0 > Improve error messages for invalid joins >

[jira] [Created] (FLINK-3631) CodeGenerator does not check type compatibility for equality expressions

2016-03-19 Thread Fabian Hueske (JIRA)
Fabian Hueske created FLINK-3631: Summary: CodeGenerator does not check type compatibility for equality expressions Key: FLINK-3631 URL: https://issues.apache.org/jira/browse/FLINK-3631 Project:

[jira] [Commented] (FLINK-3631) CodeGenerator does not check type compatibility for equality expressions

2016-03-19 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3631?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15201210#comment-15201210 ] Fabian Hueske commented on FLINK-3631: -- Sure [~ram_krish]. Maybe [~twalthr] can give some advice for

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

2016-03-19 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2997?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15199107#comment-15199107 ] ASF GitHub Bot commented on FLINK-2997: --- Github user gallenvara commented on the pull request:

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

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

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

2016-03-19 Thread zentol
Github user zentol commented on the pull request: https://github.com/apache/flink/pull/1790#issuecomment-198348202 the files are currently loaded twice. First, the logs are copied from the Taskmanager to the JobManager blob store. They are then copied again from the JobManager blob

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

2016-03-19 Thread alkagin
GitHub user alkagin opened a pull request: https://github.com/apache/flink/pull/1810 [docs] typo seperate - separate Hi guys, Fixed a couple of typo's in JobManager High Availability (HA). You can merge this pull request into a Git repository by running: $ git pull

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

2016-03-19 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3629?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15199252#comment-15199252 ] Aljoscha Krettek commented on FLINK-3629: - Good catch, would you like to prepare a Pull request to

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

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

[GitHub] flink pull request: [hotfix] [docs] Flink hotfix windows docs

2016-03-19 Thread smarthi
GitHub user smarthi opened a pull request: https://github.com/apache/flink/pull/1815 [hotfix] [docs] Flink hotfix windows docs Fix broken link in windows docs to 'time' You can merge this pull request into a Git repository by running: $ git pull

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

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

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

2016-03-19 Thread kl0u
Github user kl0u commented on the pull request: https://github.com/apache/flink/pull/1764#issuecomment-197821005 Thanks a lot @mxm @rmetzger and @StephanEwen . I agree with @mxm , that is why I added references to the new timestampExtractor in the javadocs of the

[jira] [Updated] (FLINK-3636) NoClassDefFoundError while running WindowJoin example

2016-03-19 Thread JIRA
[ https://issues.apache.org/jira/browse/FLINK-3636?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zoltán Zvara updated FLINK-3636: Assignee: Márton Balassi > NoClassDefFoundError while running WindowJoin example >

[jira] [Assigned] (FLINK-3586) Risk of data overflow while use sum/count to calculate AVG value

2016-03-19 Thread Chengxiang Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3586?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chengxiang Li reassigned FLINK-3586: Assignee: Chengxiang Li > Risk of data overflow while use sum/count to calculate AVG value

[jira] [Commented] (FLINK-2909) Gelly Graph Generators

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

[GitHub] flink pull request: [FLINK-3620] [streaming] Remove DbStateBackend

2016-03-19 Thread gyfora
GitHub user gyfora opened a pull request: https://github.com/apache/flink/pull/1800 [FLINK-3620] [streaming] Remove DbStateBackend You can merge this pull request into a Git repository by running: $ git pull https://github.com/gyfora/flink remove-dbbackend Alternatively you

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

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

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

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

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

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

[GitHub] flink pull request: [FLINK-3503] [tableAPI] Add cost model for Dat...

2016-03-19 Thread fhueske
Github user fhueske closed the pull request at: https://github.com/apache/flink/pull/1798 --- 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-3492) Allow users to define a min pause between checkpoints

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

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

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

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

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

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

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

[jira] [Commented] (FLINK-3631) CodeGenerator does not check type compatibility for equality expressions

2016-03-19 Thread ramkrishna.s.vasudevan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3631?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15201221#comment-15201221 ] ramkrishna.s.vasudevan commented on FLINK-3631: --- Thank you [~fhueske]. I was able to spot

  1   2   3   4   >