[jira] [Closed] (FLINK-4998) ResourceManager fails when num task slots > Yarn vcores

[ https://issues.apache.org/jira/browse/FLINK-4998?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels closed FLINK-4998. - Resolution: Fixed Fix Version/s: 1.1.4 master:

[jira] [Commented] (FLINK-4221) Show metrics in WebFrontend

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

[GitHub] flink issue #2757: [FLINK-5022] Suppress RejectedExecutionExceptions if the ...

Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/2757 Looks good, +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 wishes so,

[jira] [Commented] (FLINK-4221) Show metrics in WebFrontend

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

[jira] [Resolved] (FLINK-4221) Show metrics in WebFrontend

[ https://issues.apache.org/jira/browse/FLINK-4221?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger resolved FLINK-4221. --- Resolution: Fixed Fix Version/s: 1.2.0 Resolved in

[jira] [Commented] (FLINK-4998) ResourceManager fails when num task slots > Yarn vcores

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

[jira] [Resolved] (FLINK-3813) YARNSessionFIFOITCase.testDetachedMode failed on Travis

[ https://issues.apache.org/jira/browse/FLINK-3813?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels resolved FLINK-3813. --- Resolution: Fixed Fix Version/s: 1.1.4 1.2.0 master:

[jira] [Commented] (FLINK-3813) YARNSessionFIFOITCase.testDetachedMode failed on Travis

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

[GitHub] flink pull request #2749: [FLINK-3813][yarn] wait for CLI to complete before...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/2749 --- 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 #2741: [FLINK-4998][yarn] fail if too many task slots are...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/2741 --- 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 issue #2724: [FLINK-4221] Show metrics in WebFrontend + general improv...

Github user rmetzger commented on the issue: https://github.com/apache/flink/pull/2724 I'll merge the change ... --- 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 #2724: [FLINK-4221] Show metrics in WebFrontend + general...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/2724 --- 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-5022) Suppress RejectedExecutionException when the Executor is shut down

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

[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=15638048#comment-15638048 ] ASF GitHub Bot commented on FLINK-4469: --- Github user sunjincheng121 commented on a diff in the pull

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

Github user sunjincheng121 commented on a diff in the pull request: https://github.com/apache/flink/pull/2653#discussion_r86649434 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/TableEnvironment.scala --- @@ -152,21 +153,40 @@ abstract class

[jira] [Commented] (FLINK-5017) Introduce WatermarkStatus stream element to allow for temporarily idle streaming sources

[ https://issues.apache.org/jira/browse/FLINK-5017?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15638540#comment-15638540 ] Tzu-Li (Gordon) Tai commented on FLINK-5017: If we want to extend {{Watermark}}, to aid with

[jira] [Comment Edited] (FLINK-5017) Introduce WatermarkStatus stream element to allow for temporarily idle streaming sources

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

[jira] [Commented] (FLINK-4282) Add Offset Parameter to WindowAssigners

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

[GitHub] flink pull request #2355: [FLINK-4282]Add Offset Parameter to WindowAssigner...

Github user soniclavier commented on a diff in the pull request: https://github.com/apache/flink/pull/2355#discussion_r86656836 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/windows/TimeWindow.java --- @@ -236,6 +236,6 @@ public int

[jira] [Resolved] (FLINK-4938) Unnecessary update() call for Views to be removed in ViewUpdater#run()

[ https://issues.apache.org/jira/browse/FLINK-4938?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu resolved FLINK-4938. --- Resolution: Not A Problem > Unnecessary update() call for Views to be removed in ViewUpdater#run() >

[jira] [Comment Edited] (FLINK-4848) keystoreFilePath should be checked against null in SSLUtils#createSSLServerContext

[ https://issues.apache.org/jira/browse/FLINK-4848?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15582930#comment-15582930 ] Ted Yu edited comment on FLINK-4848 at 11/5/16 4:41 AM: There is similar issue

[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=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=15635719#comment-15635719 ] Tzu-Li (Gordon) Tai commented on FLINK-4576: Yes, that's true. In general, if all input

[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 @@ +/*

[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 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-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=15635754#comment-15635754 ] ASF GitHub Bot commented on FLINK-3702: --- Github user fhueske 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=15635780#comment-15635780 ] ASF GitHub Bot commented on FLINK-4174: --- Github user aljoscha commented on a diff in the pull

[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

[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=15635776#comment-15635776 ] Fabian Hueske commented on FLINK-3617: -- I agree, {{Option}}'s purpose is to avoid {{null}} values and

[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 @@

[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=15635796#comment-15635796 ] ASF GitHub Bot commented on FLINK-4391: --- Github user tillrohrmann commented on a diff in the pull

[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=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_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=15635947#comment-15635947 ] ASF GitHub Bot commented on FLINK-4391: --- Github user bjlovegithub commented on a diff in the pull

[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 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=15635695#comment-15635695 ] ASF GitHub Bot commented on FLINK-4391: --- Github user bjlovegithub commented on a diff in the pull

[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] [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=15635719#comment-15635719 ] Tzu-Li (Gordon) Tai edited comment on FLINK-4576 at 11/4/16 9:40 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_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=15635830#comment-15635830 ] ASF GitHub Bot commented on FLINK-4391: --- Github user bjlovegithub commented on a diff in the pull

[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=15635861#comment-15635861 ] ASF GitHub Bot commented on FLINK-4391: --- Github user tillrohrmann commented on a diff in the pull

[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 @@ +/*

[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] [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 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=15635723#comment-15635723 ] ASF GitHub Bot commented on FLINK-4391: --- Github user bjlovegithub commented on a diff in the pull

[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=15635719#comment-15635719 ] Tzu-Li (Gordon) Tai edited comment on FLINK-4576 at 11/4/16 8:59 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=15635736#comment-15635736 ] ASF GitHub Bot commented on FLINK-4391: --- Github user bjlovegithub commented on a diff in the pull

[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=15635770#comment-15635770 ] ASF GitHub Bot commented on FLINK-4391: --- Github user bjlovegithub commented on a diff in the pull

[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] [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=15635798#comment-15635798 ] ASF GitHub Bot commented on FLINK-4391: --- Github user bjlovegithub commented on a diff in the pull

[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=15635800#comment-15635800 ] ASF GitHub Bot commented on FLINK-4391: --- Github user bjlovegithub commented on a diff in the pull

[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=15635840#comment-15635840 ] ASF GitHub Bot commented on FLINK-4391: --- Github user bjlovegithub commented on a diff in the pull

[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] [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:

[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

[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=15635893#comment-15635893 ] ASF GitHub Bot commented on FLINK-4391: --- Github user bjlovegithub commented on a diff in the pull

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

Ufuk Celebi created FLINK-5016: -- Summary: EventTimeWindowCheckpointingITCase testTumblingTimeWindowWithKVStateMaxMaxParallelism with RocksDB hangs Key: FLINK-5016 URL:

[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=15635915#comment-15635915 ] ASF GitHub Bot commented on FLINK-4391: --- Github user bjlovegithub commented on a diff in the pull

[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

[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=15635965#comment-15635965 ] ASF GitHub Bot commented on FLINK-4391: --- Github user bjlovegithub commented on the issue:

[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

[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=15635990#comment-15635990 ] Aljoscha Krettek commented on FLINK-4576: - Without a timeout, when is a source considered idle?

[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=15635684#comment-15635684 ] Aljoscha Krettek commented on FLINK-4576: - Scratch that, maybe we just need to add the idle

[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=15635735#comment-15635735 ] ASF GitHub Bot commented on FLINK-4391: --- Github user tillrohrmann commented on a diff in the pull

[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=15635732#comment-15635732 ] ASF GitHub Bot commented on FLINK-4391: --- Github user bjlovegithub commented on a diff in the pull

[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

[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=15635787#comment-15635787 ] ASF GitHub Bot commented on FLINK-4391: --- Github user tillrohrmann commented on the issue:

[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

[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

[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 @@ +/* +

[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 >

[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

[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=15635964#comment-15635964 ] ASF GitHub Bot commented on FLINK-4391: --- Github user bjlovegithub commented on the 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=15635969#comment-15635969 ] ASF GitHub Bot commented on FLINK-4391: --- Github user bjlovegithub commented on the issue:

[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=15635727#comment-15635727 ] Tzu-Li (Gordon) Tai commented on FLINK-4576: If we let sources emit "watermark idle" and

[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=15635745#comment-15635745 ] ASF GitHub Bot commented on FLINK-4391: --- Github user bjlovegithub commented on a diff in the pull

[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=15635744#comment-15635744 ] ASF GitHub Bot commented on FLINK-4391: --- Github user bjlovegithub commented on a diff in the pull

[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 @@ +/*

[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=15635844#comment-15635844 ] ASF GitHub Bot commented on FLINK-4391: --- Github user bjlovegithub commented on a diff in the pull

[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

[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

[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=15635640#comment-15635640 ] Aljoscha Krettek commented on FLINK-4576: - Yes, that could work. It seems there has to be some

[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=15635687#comment-15635687 ] Aljoscha Krettek commented on FLINK-4576: - Scratch that, maybe we just need to add the idle

[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] [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=15635711#comment-15635711 ] ASF GitHub Bot commented on FLINK-4391: --- Github user bjlovegithub commented on a diff in the pull

[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=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=15635740#comment-15635740 ] ASF GitHub Bot commented on FLINK-4391: --- Github user tillrohrmann commented on a diff in the pull

[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=15635756#comment-15635756 ] ASF GitHub Bot commented on FLINK-4469: --- Github user fhueske commented on the issue:

[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=15635775#comment-15635775 ] ASF GitHub Bot commented on FLINK-4960: --- Github user aljoscha commented on the issue:

[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=15635815#comment-15635815 ] ASF GitHub Bot commented on FLINK-4960: --- Github user kl0u closed the pull request at:

  1   2   3   4   >