[jira] [Commented] (FLINK-4939) GenericWriteAheadSink: Decouple the creating from the committing subtask for a pending checkpoint

[ https://issues.apache.org/jira/browse/FLINK-4939?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15636586#comment-15636586 ] ASF GitHub Bot commented on FLINK-4939: --- Github user zentol commented on a diff in the pull request:

[jira] [Commented] (FLINK-4174) Enhance Window Evictor

[ https://issues.apache.org/jira/browse/FLINK-4174?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15636619#comment-15636619 ] ASF GitHub Bot commented on FLINK-4174: --- Github user soniclavier commented on the issue:

[GitHub] flink issue #2736: [FLINK-4174] Enhance evictor functionality

Github user soniclavier commented on the issue: https://github.com/apache/flink/pull/2736 @aljoscha I have made the changes, could you please review 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-3930) Implement Service-Level Authorization

[ https://issues.apache.org/jira/browse/FLINK-3930?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15636613#comment-15636613 ] ASF GitHub Bot commented on FLINK-3930: --- Github user StephanEwen commented on a diff in the pull

[GitHub] flink pull request #2425: FLINK-3930 Added shared secret based authorization...

Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/2425#discussion_r86564819 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/netty/NettyMessage.java --- @@ -57,24 +61,37 @@ // constructor in

[jira] [Commented] (FLINK-4997) Extending Window Function Metadata

[ https://issues.apache.org/jira/browse/FLINK-4997?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15636673#comment-15636673 ] ASF GitHub Bot commented on FLINK-4997: --- GitHub user VenturaDelMonte opened a pull request:

[GitHub] flink issue #2740: [FLINK-4964] [ml]

Github user tfournier314 commented on the issue: https://github.com/apache/flink/pull/2740 I've changed my code so that I have now mapping:DataSet[(String,Long)] val mapping = input .mapWith( s => (s, 1) ) .groupBy( 0 ) .reduce( (a, b) => (a._1,

[jira] [Commented] (FLINK-4964) FlinkML - Add StringIndexer

[ https://issues.apache.org/jira/browse/FLINK-4964?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15636993#comment-15636993 ] ASF GitHub Bot commented on FLINK-4964: --- Github user tfournier314 commented on the issue:

[GitHub] flink issue #2758: support specifying an ESCAPE character in LIKE and SIMILA...

Github user miaoever commented on the issue: https://github.com/apache/flink/pull/2758 @twalthr @wuchong Would you please review my pr to flink, thx :) --- 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

[jira] [Closed] (FLINK-3395) Polishing the web UI

[ https://issues.apache.org/jira/browse/FLINK-3395?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan closed FLINK-3395. - Resolution: Later > Polishing the web UI > > > Key: FLINK-3395 >

[jira] [Commented] (FLINK-3767) Show timeline also for running tasks, not only for finished ones

[ https://issues.apache.org/jira/browse/FLINK-3767?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15636907#comment-15636907 ] Greg Hogan commented on FLINK-3767: --- I'm running 1.2-SNAPSHOT and this looks to be implemented.

[jira] [Commented] (FLINK-5020) Make the GenericWriteAheadSink rescalable.

[ https://issues.apache.org/jira/browse/FLINK-5020?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15637222#comment-15637222 ] ASF GitHub Bot commented on FLINK-5020: --- GitHub user kl0u opened a pull request:

[GitHub] flink pull request #2759: [FLINK-5020] Make the GenericWriteAheadSink rescal...

GitHub user kl0u opened a pull request: https://github.com/apache/flink/pull/2759 [FLINK-5020] Make the GenericWriteAheadSink rescalable. As the issue suggests, this is the final commit to make the GenericWriteAheadSink re-scalable. In essence, what it does is that it replaces

[jira] [Commented] (FLINK-5012) Provide Timestamp in TimelyFlatMapFunction

[ https://issues.apache.org/jira/browse/FLINK-5012?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15637246#comment-15637246 ] Stephan Ewen commented on FLINK-5012: - I just wanted the simple way of outputting an element to be

<    1   2   3   4