[jira] [Commented] (FLINK-3579) Improve String concatenation

2016-03-20 Thread ramkrishna.s.vasudevan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3579?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15203687#comment-15203687 ] ramkrishna.s.vasudevan commented on FLINK-3579: --- [~twalthr] - This PR got closed not sure

[GitHub] flink pull request: [FLINK-3579] Improve String concatenation

2016-03-20 Thread ramkrish86
Github user ramkrish86 commented on the pull request: https://github.com/apache/flink/pull/1808#issuecomment-199109373 @hsaputra I am waiting for @tillrohrmann reviews. Why did this get closed am not sure. Any way to open it back? --- If your project is set up for it, you can

[jira] [Commented] (FLINK-3579) Improve String concatenation

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

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

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

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

2016-03-20 Thread wangyangjun
Github user wangyangjun commented on the pull request: https://github.com/apache/flink/pull/1527#issuecomment-199043205 Hi StephanEwen, sorry for replying this late. This will join two window streams as long as slide size of these two windows are equal. It can be two

[jira] [Commented] (FLINK-3579) Improve String concatenation

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

[GitHub] flink pull request: [FLINK-3579] Improve String concatenation

2016-03-20 Thread hsaputra
Github user hsaputra commented on the pull request: https://github.com/apache/flink/pull/1808#issuecomment-199026680 Anyone merged this PR as part of commit to Flink ASF Git repo? I wonder why asfgit close this PR --- If your project is set up for it, you can reply to this

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

2016-03-20 Thread JIRA
[ https://issues.apache.org/jira/browse/FLINK-3636?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi resolved FLINK-3636. --- Resolution: Fixed Fix Version/s: 1.1.0 Fixed via f09d68a. > NoClassDefFoundError

[GitHub] flink pull request: [FLINK-3579] Improve String concatenation

2016-03-20 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/1808 --- 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-3579) Improve String concatenation

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

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

2016-03-20 Thread rmetzger
Github user rmetzger commented on the pull request: https://github.com/apache/flink/pull/1790#issuecomment-198344319 I just tested the change on a cluster, also with larger log files, and it seems to work very well. The only thing I found was that clicking the "Download" button on

[jira] [Updated] (FLINK-3628) ChainingOutput and CopyingChainingOutput setKeyContextElement1 is no use

2016-03-20 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3628?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-3628: Assignee: MaGuowei (was: Aljoscha Krettek) > ChainingOutput and CopyingChainingOutput

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

2016-03-20 Thread Vasia Kalavri (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3609?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vasia Kalavri resolved FLINK-3609. -- Resolution: Fixed Fix Version/s: 1.1.0 > Revisit selection of Calcite rules >

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

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

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

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

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

2016-03-20 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1964?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger resolved FLINK-1964. --- Resolution: Fixed Assignee: Robert Metzger (was: Carlos Curotto) Fix

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

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

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

2016-03-20 Thread uce
Github user uce commented on the pull request: https://github.com/apache/flink/pull/1800#issuecomment-197318751 +1 from ML discussion. I guess you can close this together with #1627 when merging. --- If your project is set up for it, you can reply to this email and have your

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

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

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

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

[jira] [Commented] (FLINK-3579) Improve String concatenation

2016-03-20 Thread ramkrishna.s.vasudevan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3579?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15201316#comment-15201316 ] ramkrishna.s.vasudevan commented on FLINK-3579: --- [~twalthr]? > Improve String concatenation

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

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

[jira] [Assigned] (FLINK-3628) ChainingOutput and CopyingChainingOutput setKeyContextElement1 is no use

2016-03-20 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3628?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reassigned FLINK-3628: --- Assignee: Aljoscha Krettek > ChainingOutput and CopyingChainingOutput

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

2016-03-20 Thread tillrohrmann
Github user tillrohrmann commented on the pull request: https://github.com/apache/flink/pull/1790#issuecomment-198358391 We could also have passed the `BlobServer` of the `JobManager` to the `TaskManagerLogHandler` to avoid the extra copying. But this would mean that we would have to

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

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

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

2016-03-20 Thread Vasia Kalavri (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3630?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15199322#comment-15199322 ] Vasia Kalavri commented on FLINK-3630: -- Great! I've assigned the issue to you. Make sure to read the

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

2016-03-20 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 commented on FLINK-3629: - I have already submitted a full request on Github after submitting this

[GitHub] flink pull request: Flink-3429: adds a histogram-based watermark e...

2016-03-20 Thread kl0u
GitHub user kl0u opened a pull request: https://github.com/apache/flink/pull/1819 Flink-3429: adds a histogram-based watermark emitter. When processing a stream, and for the lateness to be as low as possible, the watermark should be as close to processing time as possible.

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

2016-03-20 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3524?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-3524: Description: (I don't want to include this into 1.0.0) Currently, there is no standardized

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

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