[jira] [Commented] (FLINK-4840) Measure latency of record processing and expose it as a metric

[ https://issues.apache.org/jira/browse/FLINK-4840?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15635541#comment-15635541 ] ASF GitHub Bot commented on FLINK-4840: --- GitHub user zhuhaifengleon opened a pull re

[GitHub] flink pull request #2753: [FLINK-4840] [metrics] Measure latency of record p...

GitHub user zhuhaifengleon opened a pull request: https://github.com/apache/flink/pull/2753 [FLINK-4840] [metrics] Measure latency of record processing and expose it as a metric This PR introduce record processing time metric for measuring a task running performance. The latency is

[jira] [Commented] (FLINK-4576) Low Watermark Service in JobManager for Streaming Sources

[ https://issues.apache.org/jira/browse/FLINK-4576?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15635640#comment-15635640 ] Aljoscha Krettek commented on FLINK-4576: - Yes, that could work. It seems there h

[jira] [Commented] (FLINK-4576) Low Watermark Service in JobManager for Streaming Sources

[ https://issues.apache.org/jira/browse/FLINK-4576?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15635684#comment-15635684 ] Aljoscha Krettek commented on FLINK-4576: - Scratch that, maybe we just need to add

[jira] [Commented] (FLINK-4576) Low Watermark Service in JobManager for Streaming Sources

[ https://issues.apache.org/jira/browse/FLINK-4576?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15635687#comment-15635687 ] Aljoscha Krettek commented on FLINK-4576: - Scratch that, maybe we just need to add

[GitHub] flink pull request #2629: [FLINK-4391] Provide support for asynchronous oper...

Github user bjlovegithub commented on a diff in the pull request: https://github.com/apache/flink/pull/2629#discussion_r86505374 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/async/AsyncCollectorBuffer.java --- @@ -0,0 +1,494 @@ +/*

[jira] [Commented] (FLINK-4391) Provide support for asynchronous operations over streams

[ https://issues.apache.org/jira/browse/FLINK-4391?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15635695#comment-15635695 ] ASF GitHub Bot commented on FLINK-4391: --- Github user bjlovegithub commented on a dif

[jira] [Commented] (FLINK-4391) Provide support for asynchronous operations over streams

[ https://issues.apache.org/jira/browse/FLINK-4391?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15635711#comment-15635711 ] ASF GitHub Bot commented on FLINK-4391: --- Github user bjlovegithub commented on a dif

[GitHub] flink pull request #2629: [FLINK-4391] Provide support for asynchronous oper...

Github user bjlovegithub commented on a diff in the pull request: https://github.com/apache/flink/pull/2629#discussion_r86506096 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/async/AsyncCollectorBuffer.java --- @@ -0,0 +1,494 @@ +/*

[jira] [Comment Edited] (FLINK-4576) Low Watermark Service in JobManager for Streaming Sources

[ https://issues.apache.org/jira/browse/FLINK-4576?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15635719#comment-15635719 ] Tzu-Li (Gordon) Tai edited comment on FLINK-4576 at 11/4/16 8:58 AM: ---

[jira] [Commented] (FLINK-4576) Low Watermark Service in JobManager for Streaming Sources

[ https://issues.apache.org/jira/browse/FLINK-4576?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15635719#comment-15635719 ] Tzu-Li (Gordon) Tai commented on FLINK-4576: Yes, that's true. In general, if

[jira] [Comment Edited] (FLINK-4576) Low Watermark Service in JobManager for Streaming Sources

[ https://issues.apache.org/jira/browse/FLINK-4576?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15635719#comment-15635719 ] Tzu-Li (Gordon) Tai edited comment on FLINK-4576 at 11/4/16 8:59 AM: ---

[GitHub] flink pull request #2629: [FLINK-4391] Provide support for asynchronous oper...

Github user bjlovegithub commented on a diff in the pull request: https://github.com/apache/flink/pull/2629#discussion_r86507065 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/async/AsyncCollectorBuffer.java --- @@ -0,0 +1,494 @@ +/*

[jira] [Commented] (FLINK-4391) Provide support for asynchronous operations over streams

[ https://issues.apache.org/jira/browse/FLINK-4391?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15635723#comment-15635723 ] ASF GitHub Bot commented on FLINK-4391: --- Github user bjlovegithub commented on a dif

[jira] [Commented] (FLINK-4576) Low Watermark Service in JobManager for Streaming Sources

[ https://issues.apache.org/jira/browse/FLINK-4576?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15635727#comment-15635727 ] Tzu-Li (Gordon) Tai commented on FLINK-4576: If we let sources emit "watermark

[GitHub] flink pull request #2629: [FLINK-4391] Provide support for asynchronous oper...

Github user bjlovegithub commented on a diff in the pull request: https://github.com/apache/flink/pull/2629#discussion_r86507678 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/async/AsyncCollectorBuffer.java --- @@ -0,0 +1,494 @@ +/*

[jira] [Commented] (FLINK-4391) Provide support for asynchronous operations over streams

[ https://issues.apache.org/jira/browse/FLINK-4391?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15635732#comment-15635732 ] ASF GitHub Bot commented on FLINK-4391: --- Github user bjlovegithub commented on a dif

[GitHub] flink pull request #2629: [FLINK-4391] Provide support for asynchronous oper...

Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/2629#discussion_r86507794 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/async/AsyncCollectorBuffer.java --- @@ -0,0 +1,494 @@ +/*

[GitHub] flink pull request #2629: [FLINK-4391] Provide support for asynchronous oper...

Github user bjlovegithub commented on a diff in the pull request: https://github.com/apache/flink/pull/2629#discussion_r86507829 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/async/AsyncCollectorBuffer.java --- @@ -0,0 +1,494 @@ +/*

[jira] [Commented] (FLINK-4391) Provide support for asynchronous operations over streams

[ https://issues.apache.org/jira/browse/FLINK-4391?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15635735#comment-15635735 ] ASF GitHub Bot commented on FLINK-4391: --- Github user tillrohrmann commented on a dif

[jira] [Commented] (FLINK-4391) Provide support for asynchronous operations over streams

[ https://issues.apache.org/jira/browse/FLINK-4391?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15635736#comment-15635736 ] ASF GitHub Bot commented on FLINK-4391: --- Github user bjlovegithub commented on a dif

[jira] [Comment Edited] (FLINK-4576) Low Watermark Service in JobManager for Streaming Sources

[ https://issues.apache.org/jira/browse/FLINK-4576?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15635719#comment-15635719 ] Tzu-Li (Gordon) Tai edited comment on FLINK-4576 at 11/4/16 9:08 AM: ---

[jira] [Commented] (FLINK-4391) Provide support for asynchronous operations over streams

[ https://issues.apache.org/jira/browse/FLINK-4391?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15635740#comment-15635740 ] ASF GitHub Bot commented on FLINK-4391: --- Github user tillrohrmann commented on a dif

[GitHub] flink pull request #2629: [FLINK-4391] Provide support for asynchronous oper...

Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/2629#discussion_r86507941 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/async/AsyncCollectorBuffer.java --- @@ -0,0 +1,494 @@ +/*

[GitHub] flink pull request #2629: [FLINK-4391] Provide support for asynchronous oper...

Github user bjlovegithub commented on a diff in the pull request: https://github.com/apache/flink/pull/2629#discussion_r86508318 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/async/AsyncCollectorBuffer.java --- @@ -0,0 +1,494 @@ +/*

[jira] [Commented] (FLINK-4391) Provide support for asynchronous operations over streams

[ https://issues.apache.org/jira/browse/FLINK-4391?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15635744#comment-15635744 ] ASF GitHub Bot commented on FLINK-4391: --- Github user bjlovegithub commented on a dif

[GitHub] flink pull request #2629: [FLINK-4391] Provide support for asynchronous oper...

Github user bjlovegithub commented on a diff in the pull request: https://github.com/apache/flink/pull/2629#discussion_r86508413 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/async/AsyncCollectorBuffer.java --- @@ -0,0 +1,494 @@ +/*

[jira] [Commented] (FLINK-4391) Provide support for asynchronous operations over streams

[ https://issues.apache.org/jira/browse/FLINK-4391?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15635745#comment-15635745 ] ASF GitHub Bot commented on FLINK-4391: --- Github user bjlovegithub commented on a dif

[jira] [Commented] (FLINK-3702) DataStream API PojoFieldAccessor doesn't support nested POJOs

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

[GitHub] flink issue #2094: [FLINK-3702] Make FieldAccessors support nested field exp...

Github user fhueske commented on the issue: https://github.com/apache/flink/pull/2094 Thanks for the update @mbalassi. Will have a look at the PR next week. --- 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-4469) Add support for user defined table function in Table API & SQL

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

[GitHub] flink issue #2653: [FLINK-4469] [table] Add support for user defined table f...

Github user fhueske commented on the issue: https://github.com/apache/flink/pull/2653 Thanks for the update @wuchong! Will have a look at this PR. --- 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 h

[jira] [Commented] (FLINK-4391) Provide support for asynchronous operations over streams

[ https://issues.apache.org/jira/browse/FLINK-4391?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15635770#comment-15635770 ] ASF GitHub Bot commented on FLINK-4391: --- Github user bjlovegithub commented on a dif

[GitHub] flink pull request #2629: [FLINK-4391] Provide support for asynchronous oper...

Github user bjlovegithub commented on a diff in the pull request: https://github.com/apache/flink/pull/2629#discussion_r8650 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/async/AsyncCollectorBuffer.java --- @@ -0,0 +1,494 @@ +/*

[jira] [Commented] (FLINK-4960) Allow the AbstractStreamOperatorTestHarness to test scaling down

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

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

[ https://issues.apache.org/jira/browse/FLINK-4174?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15635780#comment-15635780 ] ASF GitHub Bot commented on FLINK-4174: --- Github user aljoscha commented on a diff in

[GitHub] flink issue #2747: [FLINK-4960] Allow the AbstractStreamOperatorTestHarness ...

Github user aljoscha commented on the issue: https://github.com/apache/flink/pull/2747 I merged this. Thanks for your work! 😃 Could you please close this and the Jira issue? --- If your project is set up for it, you can reply to this email and have your reply appear on Gi

[jira] [Commented] (FLINK-3617) NPE from CaseClassSerializer when dealing with null Option field

[ https://issues.apache.org/jira/browse/FLINK-3617?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15635776#comment-15635776 ] Fabian Hueske commented on FLINK-3617: -- I agree, {{Option}}'s purpose is to avoid {{n

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

Github user aljoscha commented on a diff in the pull request: https://github.com/apache/flink/pull/2736#discussion_r86510390 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/windowing/EvictingWindowOperator.java --- @@ -273,32 +284,93 @@ pu

[GitHub] flink issue #2629: [FLINK-4391] Provide support for asynchronous operations ...

Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/2629 The combination of `UNORDERED` with event time is not strictly meaningless. The only thing which one has to do respect is that only those elements in the queue from the beginning to the first wa

[jira] [Commented] (FLINK-4391) Provide support for asynchronous operations over streams

[ https://issues.apache.org/jira/browse/FLINK-4391?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15635787#comment-15635787 ] ASF GitHub Bot commented on FLINK-4391: --- Github user tillrohrmann commented on the i

[jira] [Commented] (FLINK-4391) Provide support for asynchronous operations over streams

[ https://issues.apache.org/jira/browse/FLINK-4391?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15635796#comment-15635796 ] ASF GitHub Bot commented on FLINK-4391: --- Github user tillrohrmann commented on a dif

[GitHub] flink pull request #2629: [FLINK-4391] Provide support for asynchronous oper...

Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/2629#discussion_r86511575 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/async/AsyncCollectorBuffer.java --- @@ -0,0 +1,494 @@ +/*

[jira] [Commented] (FLINK-4391) Provide support for asynchronous operations over streams

[ https://issues.apache.org/jira/browse/FLINK-4391?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15635798#comment-15635798 ] ASF GitHub Bot commented on FLINK-4391: --- Github user bjlovegithub commented on a dif

[jira] [Commented] (FLINK-4391) Provide support for asynchronous operations over streams

[ https://issues.apache.org/jira/browse/FLINK-4391?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15635800#comment-15635800 ] ASF GitHub Bot commented on FLINK-4391: --- Github user bjlovegithub commented on a dif

[GitHub] flink pull request #2629: [FLINK-4391] Provide support for asynchronous oper...

Github user bjlovegithub commented on a diff in the pull request: https://github.com/apache/flink/pull/2629#discussion_r86511685 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/async/AsyncCollectorBuffer.java --- @@ -0,0 +1,494 @@ +/*

[jira] [Comment Edited] (FLINK-4576) Low Watermark Service in JobManager for Streaming Sources

[ https://issues.apache.org/jira/browse/FLINK-4576?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15635727#comment-15635727 ] Tzu-Li (Gordon) Tai edited comment on FLINK-4576 at 11/4/16 9:38 AM: ---

[GitHub] flink pull request #2629: [FLINK-4391] Provide support for asynchronous oper...

Github user bjlovegithub commented on a diff in the pull request: https://github.com/apache/flink/pull/2629#discussion_r86511814 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/async/AsyncCollectorBuffer.java --- @@ -0,0 +1,494 @@ +/*

[jira] [Comment Edited] (FLINK-4576) Low Watermark Service in JobManager for Streaming Sources

[ https://issues.apache.org/jira/browse/FLINK-4576?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15635719#comment-15635719 ] Tzu-Li (Gordon) Tai edited comment on FLINK-4576 at 11/4/16 9:40 AM: ---

[GitHub] flink pull request #2747: [FLINK-4960] Allow the AbstractStreamOperatorTestH...

Github user kl0u closed the pull request at: https://github.com/apache/flink/pull/2747 --- 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 enable

[jira] [Commented] (FLINK-4960) Allow the AbstractStreamOperatorTestHarness to test scaling down

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

[jira] [Closed] (FLINK-4960) Allow the AbstractStreamOperatorTestHarness to test scaling down

[ https://issues.apache.org/jira/browse/FLINK-4960?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas closed FLINK-4960. - Resolution: Fixed > Allow the AbstractStreamOperatorTestHarness to test scaling down > ---

[GitHub] flink issue #2747: [FLINK-4960] Allow the AbstractStreamOperatorTestHarness ...

Github user kl0u commented on the issue: https://github.com/apache/flink/pull/2747 Thanks @aljoscha . Will do that. --- 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 wi

[jira] [Commented] (FLINK-4960) Allow the AbstractStreamOperatorTestHarness to test scaling down

[ https://issues.apache.org/jira/browse/FLINK-4960?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15635815#comment-15635815 ] ASF GitHub Bot commented on FLINK-4960: --- Github user kl0u closed the pull request at

[GitHub] flink pull request #2629: [FLINK-4391] Provide support for asynchronous oper...

Github user bjlovegithub commented on a diff in the pull request: https://github.com/apache/flink/pull/2629#discussion_r86513230 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/async/AsyncCollectorBuffer.java --- @@ -0,0 +1,494 @@ +/*

[jira] [Commented] (FLINK-4391) Provide support for asynchronous operations over streams

[ https://issues.apache.org/jira/browse/FLINK-4391?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15635830#comment-15635830 ] ASF GitHub Bot commented on FLINK-4391: --- Github user bjlovegithub commented on a dif

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

Aljoscha Krettek created FLINK-5012: --- Summary: Provide Timestamp in TimelyFlatMapFunction Key: FLINK-5012 URL: https://issues.apache.org/jira/browse/FLINK-5012 Project: Flink Issue Type: Im

[GitHub] flink pull request #2629: [FLINK-4391] Provide support for asynchronous oper...

Github user bjlovegithub commented on a diff in the pull request: https://github.com/apache/flink/pull/2629#discussion_r86514152 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/async/AsyncWaitOperator.java --- @@ -0,0 +1,256 @@ +/* + *

[jira] [Commented] (FLINK-4391) Provide support for asynchronous operations over streams

[ https://issues.apache.org/jira/browse/FLINK-4391?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15635840#comment-15635840 ] ASF GitHub Bot commented on FLINK-4391: --- Github user bjlovegithub commented on a dif

[GitHub] flink pull request #2629: [FLINK-4391] Provide support for asynchronous oper...

Github user bjlovegithub commented on a diff in the pull request: https://github.com/apache/flink/pull/2629#discussion_r86514286 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/async/AsyncWaitOperator.java --- @@ -0,0 +1,256 @@ +/* + *

[jira] [Commented] (FLINK-4391) Provide support for asynchronous operations over streams

[ https://issues.apache.org/jira/browse/FLINK-4391?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15635844#comment-15635844 ] ASF GitHub Bot commented on FLINK-4391: --- Github user bjlovegithub commented on a dif

[jira] [Created] (FLINK-5013) Flink Kinesis connector doesn't work on old EMR versions

Robert Metzger created FLINK-5013: - Summary: Flink Kinesis connector doesn't work on old EMR versions Key: FLINK-5013 URL: https://issues.apache.org/jira/browse/FLINK-5013 Project: Flink Issu

[jira] [Commented] (FLINK-4391) Provide support for asynchronous operations over streams

[ https://issues.apache.org/jira/browse/FLINK-4391?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15635861#comment-15635861 ] ASF GitHub Bot commented on FLINK-4391: --- Github user tillrohrmann commented on a dif

[GitHub] flink pull request #2629: [FLINK-4391] Provide support for asynchronous oper...

Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/2629#discussion_r86515304 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/async/AsyncCollectorBuffer.java --- @@ -0,0 +1,494 @@ +/*

[jira] [Created] (FLINK-5014) RocksDBStateBackend misses good toString

Ufuk Celebi created FLINK-5014: -- Summary: RocksDBStateBackend misses good toString Key: FLINK-5014 URL: https://issues.apache.org/jira/browse/FLINK-5014 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-4391) Provide support for asynchronous operations over streams

[ https://issues.apache.org/jira/browse/FLINK-4391?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15635884#comment-15635884 ] ASF GitHub Bot commented on FLINK-4391: --- Github user tillrohrmann commented on a dif

[GitHub] flink pull request #2629: [FLINK-4391] Provide support for asynchronous oper...

Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/2629#discussion_r86516426 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/async/AsyncCollectorBuffer.java --- @@ -0,0 +1,494 @@ +/*

[jira] [Created] (FLINK-5015) Add Tests/ITCase for Kafka Per-Partition Watermarks

Aljoscha Krettek created FLINK-5015: --- Summary: Add Tests/ITCase for Kafka Per-Partition Watermarks Key: FLINK-5015 URL: https://issues.apache.org/jira/browse/FLINK-5015 Project: Flink Issue

[jira] [Commented] (FLINK-4391) Provide support for asynchronous operations over streams

[ https://issues.apache.org/jira/browse/FLINK-4391?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15635893#comment-15635893 ] ASF GitHub Bot commented on FLINK-4391: --- Github user bjlovegithub commented on a dif

[GitHub] flink pull request #2629: [FLINK-4391] Provide support for asynchronous oper...

Github user bjlovegithub commented on a diff in the pull request: https://github.com/apache/flink/pull/2629#discussion_r86517044 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/async/AsyncWaitOperator.java --- @@ -0,0 +1,256 @@ +/* + *

[GitHub] flink pull request #2629: [FLINK-4391] Provide support for asynchronous oper...

Github user bjlovegithub commented on a diff in the pull request: https://github.com/apache/flink/pull/2629#discussion_r86517940 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/StreamTask.java --- @@ -540,15 +540,12 @@ private boolean performC

[jira] [Commented] (FLINK-4391) Provide support for asynchronous operations over streams

[ https://issues.apache.org/jira/browse/FLINK-4391?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15635910#comment-15635910 ] ASF GitHub Bot commented on FLINK-4391: --- Github user bjlovegithub commented on a dif

[GitHub] flink pull request #2629: [FLINK-4391] Provide support for asynchronous oper...

Github user bjlovegithub commented on a diff in the pull request: https://github.com/apache/flink/pull/2629#discussion_r86518429 --- Diff: flink-streaming-java/src/test/java/org/apache/flink/streaming/api/operators/async/AsyncCollectorBufferTest.java --- @@ -0,0 +1,293 @@ +/*

[jira] [Commented] (FLINK-4391) Provide support for asynchronous operations over streams

[ https://issues.apache.org/jira/browse/FLINK-4391?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15635915#comment-15635915 ] ASF GitHub Bot commented on FLINK-4391: --- Github user bjlovegithub commented on a dif

[jira] [Created] (FLINK-5016) EventTimeWindowCheckpointingITCase testTumblingTimeWindowWithKVStateMaxMaxParallelism with RocksDB hangs

Ufuk Celebi created FLINK-5016: -- Summary: EventTimeWindowCheckpointingITCase testTumblingTimeWindowWithKVStateMaxMaxParallelism with RocksDB hangs Key: FLINK-5016 URL: https://issues.apache.org/jira/browse/FLINK-5016

[jira] [Updated] (FLINK-5016) EventTimeWindowCheckpointingITCase testTumblingTimeWindowWithKVStateMaxMaxParallelism with RocksDB hangs

[ https://issues.apache.org/jira/browse/FLINK-5016?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi updated FLINK-5016: --- Attachment: flink_5016_logs.txt Relevant parts of the log. > EventTimeWindowCheckpointingITCase > te

[jira] [Commented] (FLINK-4391) Provide support for asynchronous operations over streams

[ https://issues.apache.org/jira/browse/FLINK-4391?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15635947#comment-15635947 ] ASF GitHub Bot commented on FLINK-4391: --- Github user bjlovegithub commented on a dif

[GitHub] flink pull request #2629: [FLINK-4391] Provide support for asynchronous oper...

Github user bjlovegithub commented on a diff in the pull request: https://github.com/apache/flink/pull/2629#discussion_r86520537 --- Diff: flink-tests/src/test/java/org/apache/flink/test/streaming/api/StreamingOperatorsITCase.java --- @@ -195,6 +202,70 @@ public Integer map(NonSer

[jira] [Updated] (FLINK-4469) Add support for user defined table function in Table API & SQL

[ https://issues.apache.org/jira/browse/FLINK-4469?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-4469: --- Description: Normal user-defined functions, such as concat(), take in a single input row and output a single

[jira] [Updated] (FLINK-4469) Add support for user defined table function in Table API & SQL

[ https://issues.apache.org/jira/browse/FLINK-4469?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-4469: --- Description: Normal user-defined functions, such as concat(), take in a single input row and output a single

[GitHub] flink issue #2629: [FLINK-4391] Provide support for asynchronous operations ...

Github user bjlovegithub commented on the issue: https://github.com/apache/flink/pull/2629 For exactly once processing guarantees, when `AsyncCollectorBuffer.getStreamElementsInBuffer` has finished, `isCheckpointing` will be set to true, while will idle `Emitter Thread` while checki

[jira] [Commented] (FLINK-4391) Provide support for asynchronous operations over streams

[ https://issues.apache.org/jira/browse/FLINK-4391?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15635965#comment-15635965 ] ASF GitHub Bot commented on FLINK-4391: --- Github user bjlovegithub commented on the i

[GitHub] flink issue #2629: [FLINK-4391] Provide support for asynchronous operations ...

Github user bjlovegithub commented on the issue: https://github.com/apache/flink/pull/2629 For exactly once processing guarantees, when `AsyncCollectorBuffer.getStreamElementsInBuffer` has finished, `isCheckpointing` will be set to true, while will idle `Emitter Thread` while checki

[jira] [Commented] (FLINK-4391) Provide support for asynchronous operations over streams

[ https://issues.apache.org/jira/browse/FLINK-4391?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15635964#comment-15635964 ] ASF GitHub Bot commented on FLINK-4391: --- Github user bjlovegithub commented on the i

[jira] [Updated] (FLINK-4469) Add support for user defined table function in Table API & SQL

[ https://issues.apache.org/jira/browse/FLINK-4469?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-4469: --- Description: Normal user-defined functions, such as concat(), take in a single input row and output a single

[GitHub] flink issue #2629: [FLINK-4391] Provide support for asynchronous operations ...

Github user bjlovegithub commented on the issue: https://github.com/apache/flink/pull/2629 For exactly once processing guarantees, when `AsyncCollectorBuffer.getStreamElementsInBuffer` has finished, `isCheckpointing` will be set to true, while will idle `Emitter Thread` while checki

[jira] [Commented] (FLINK-4391) Provide support for asynchronous operations over streams

[ https://issues.apache.org/jira/browse/FLINK-4391?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15635969#comment-15635969 ] ASF GitHub Bot commented on FLINK-4391: --- Github user bjlovegithub commented on the i

[jira] [Commented] (FLINK-4469) Add support for user defined table function in Table API & SQL

[ https://issues.apache.org/jira/browse/FLINK-4469?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15635970#comment-15635970 ] Jark Wu commented on FLINK-4469: The issue description and design doc have been updated.

[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&focusedCommentId=15635973#comment-15635973 ] ASF GitHub Bot commented on FLINK-3930: --- Github user mxm commented on the issue:

[GitHub] flink issue #2425: FLINK-3930 Added shared secret based authorization for Fl...

Github user mxm commented on the issue: https://github.com/apache/flink/pull/2425 Thank you for the changes. I wonder, could we remove the cookie header completely for Netty or the BlobServer in case the authorization is turned off? The Netty protocol has a `MAGIC_NUMBER` which is che

[jira] [Commented] (FLINK-4576) Low Watermark Service in JobManager for Streaming Sources

[ https://issues.apache.org/jira/browse/FLINK-4576?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15635990#comment-15635990 ] Aljoscha Krettek commented on FLINK-4576: - Without a timeout, when is a source con

[jira] [Commented] (FLINK-4576) Low Watermark Service in JobManager for Streaming Sources

[ https://issues.apache.org/jira/browse/FLINK-4576?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15635986#comment-15635986 ] Aljoscha Krettek commented on FLINK-4576: - Yes, that was my thinking as well. The

[jira] [Commented] (FLINK-4576) Low Watermark Service in JobManager for Streaming Sources

[ https://issues.apache.org/jira/browse/FLINK-4576?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15636003#comment-15636003 ] Tzu-Li (Gordon) Tai commented on FLINK-4576: Oh, I see what you mean by timeou

[jira] [Comment Edited] (FLINK-4576) Low Watermark Service in JobManager for Streaming Sources

[ https://issues.apache.org/jira/browse/FLINK-4576?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15636003#comment-15636003 ] Tzu-Li (Gordon) Tai edited comment on FLINK-4576 at 11/4/16 11:00 AM: --

[jira] [Commented] (FLINK-4391) Provide support for asynchronous operations over streams

[ https://issues.apache.org/jira/browse/FLINK-4391?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15636006#comment-15636006 ] ASF GitHub Bot commented on FLINK-4391: --- Github user tillrohrmann commented on a dif

[GitHub] flink pull request #2629: [FLINK-4391] Provide support for asynchronous oper...

Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/2629#discussion_r86524130 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/StreamTask.java --- @@ -540,15 +540,12 @@ private boolean performC

[jira] [Commented] (FLINK-4576) Low Watermark Service in JobManager for Streaming Sources

[ https://issues.apache.org/jira/browse/FLINK-4576?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15636021#comment-15636021 ] Tzu-Li (Gordon) Tai commented on FLINK-4576: Thanks for all the input, [~aljos

[jira] [Commented] (FLINK-4391) Provide support for asynchronous operations over streams

[ https://issues.apache.org/jira/browse/FLINK-4391?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15636060#comment-15636060 ] ASF GitHub Bot commented on FLINK-4391: --- Github user tillrohrmann commented on the i

[GitHub] flink issue #2629: [FLINK-4391] Provide support for asynchronous operations ...

Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/2629 Ah, I think now I understand. Upon checkpointing you disable the output emission. The emission can only be reactivated when adding a `StreamRecord`, a `Watermark` or a `LatencyMarker` to the `As

[GitHub] flink pull request #2724: [FLINK-4221] Show metrics in WebFrontend + general...

Github user uce commented on a diff in the pull request: https://github.com/apache/flink/pull/2724#discussion_r86526289 --- Diff: flink-runtime-web/web-dashboard/app/partials/jobs/job.jade --- @@ -50,19 +50,15 @@ nav.navbar.navbar-default.navbar-fixed-top.navbar-main(ng-if="job")

  1   2   3   4   >