[jira] [Assigned] (FLINK-29498) Flink Async I/O Retry Strategies Do Not Work for Scala AsyncDataStream API

[ https://issues.apache.org/jira/browse/FLINK-29498?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao reassigned FLINK-29498: --- Assignee: Eric Xiao (was: Yun Gao) > Flink Async I/O Retry Strategies Do Not Work for Scala AsyncD

[jira] [Assigned] (FLINK-29498) Flink Async I/O Retry Strategies Do Not Work for Scala AsyncDataStream API

[ https://issues.apache.org/jira/browse/FLINK-29498?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao reassigned FLINK-29498: --- Assignee: Yun Gao > Flink Async I/O Retry Strategies Do Not Work for Scala AsyncDataStream API > --

[jira] [Commented] (FLINK-29557) The SinkOperator's OutputFormat function is not recognized

[ https://issues.apache.org/jira/browse/FLINK-29557?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17617598#comment-17617598 ] Yun Gao commented on FLINK-29557: - Hi [~aitozi] may I have a double confirmation on the

[jira] [Commented] (FLINK-18647) How to handle processing time timers with bounded input

[ https://issues.apache.org/jira/browse/FLINK-18647?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17617538#comment-17617538 ] Yun Gao commented on FLINK-18647: - Thanks [~pnowojski] for the clarification! Then I hav

[jira] [Commented] (FLINK-18647) How to handle processing time timers with bounded input

[ https://issues.apache.org/jira/browse/FLINK-18647?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17616262#comment-17616262 ] Yun Gao commented on FLINK-18647: - Hi [~pnowojski]  sorry for the long delay due to just

[jira] [Commented] (FLINK-29348) The DPP(dynamic partition pruning) can not work with adaptive batch scheduler

[ https://issues.apache.org/jira/browse/FLINK-29348?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17610805#comment-17610805 ] Yun Gao commented on FLINK-29348: - Merged on master via 7bae0ebb6379c175522bd903838bb373

[jira] [Closed] (FLINK-29348) The DPP(dynamic partition pruning) can not work with adaptive batch scheduler

[ https://issues.apache.org/jira/browse/FLINK-29348?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao closed FLINK-29348. --- Resolution: Fixed > The DPP(dynamic partition pruning) can not work with adaptive batch scheduler >

[jira] [Created] (FLINK-29462) LookupJoinITCase failed on azure due to classloader leaking

Yun Gao created FLINK-29462: --- Summary: LookupJoinITCase failed on azure due to classloader leaking Key: FLINK-29462 URL: https://issues.apache.org/jira/browse/FLINK-29462 Project: Flink Issue Type

[jira] [Commented] (FLINK-29339) JobMasterPartitionTrackerImpl#requestShuffleDescriptorsFromResourceManager blocks main thread

[ https://issues.apache.org/jira/browse/FLINK-29339?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17610779#comment-17610779 ] Yun Gao commented on FLINK-29339: - > The numbers are irrelevant though, as is the size o

[jira] [Updated] (FLINK-29339) JobMasterPartitionTrackerImpl#requestShuffleDescriptorsFromResourceManager blocks main thread

[ https://issues.apache.org/jira/browse/FLINK-29339?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-29339: Fix Version/s: 1.17.0 1.16.1 (was: 1.16.0) > JobMasterPartitionT

[jira] [Updated] (FLINK-29339) JobMasterPartitionTrackerImpl#requestShuffleDescriptorsFromResourceManager blocks main thread

[ https://issues.apache.org/jira/browse/FLINK-29339?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-29339: Affects Version/s: 1.17.0 > JobMasterPartitionTrackerImpl#requestShuffleDescriptorsFromResourceManager >

[jira] [Assigned] (FLINK-29459) Sink v2 has bugs in supporting legacy v1 implementations with global committer

[ https://issues.apache.org/jira/browse/FLINK-29459?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao reassigned FLINK-29459: --- Assignee: Yun Gao > Sink v2 has bugs in supporting legacy v1 implementations with global committer

[jira] [Created] (FLINK-29459) Sink v2 has bugs in supporting legacy v1 implementations with global committer

Yun Gao created FLINK-29459: --- Summary: Sink v2 has bugs in supporting legacy v1 implementations with global committer Key: FLINK-29459 URL: https://issues.apache.org/jira/browse/FLINK-29459 Project: Flink

[jira] [Commented] (FLINK-18647) How to handle processing time timers with bounded input

[ https://issues.apache.org/jira/browse/FLINK-18647?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17610456#comment-17610456 ] Yun Gao commented on FLINK-18647: - Very thanks [~pnowojski] and [~dkapoor1] for the disc

[jira] [Closed] (FLINK-28824) StreamingJobGraphGenerator#triggerSerializationAndReturnFuture might swallow exception

[ https://issues.apache.org/jira/browse/FLINK-28824?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao closed FLINK-28824. --- Resolution: Duplicate > StreamingJobGraphGenerator#triggerSerializationAndReturnFuture might swallow > exce

[jira] [Commented] (FLINK-28824) StreamingJobGraphGenerator#triggerSerializationAndReturnFuture might swallow exception

[ https://issues.apache.org/jira/browse/FLINK-28824?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17610400#comment-17610400 ] Yun Gao commented on FLINK-28824: - Thanks [~Weijie Guo] for looking at this issue! > St

[jira] [Commented] (FLINK-29339) JobMasterPartitionTrackerImpl#requestShuffleDescriptorsFromResourceManager blocks main thread

[ https://issues.apache.org/jira/browse/FLINK-29339?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17610344#comment-17610344 ] Yun Gao commented on FLINK-29339: - Hi [~chesnay] , I'm a bit concern in that we mark thi

[jira] [Assigned] (FLINK-29348) The DPP(dynamic partition pruning) can not work with adaptive batch scheduler

[ https://issues.apache.org/jira/browse/FLINK-29348?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao reassigned FLINK-29348: --- Assignee: Gen Luo > The DPP(dynamic partition pruning) can not work with adaptive batch scheduler >

[jira] [Updated] (FLINK-29348) The DPP(dynamic partition pruning) can not work with adaptive batch scheduler

[ https://issues.apache.org/jira/browse/FLINK-29348?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-29348: Priority: Critical (was: Major) > The DPP(dynamic partition pruning) can not work with adaptive batch sch

[jira] [Updated] (FLINK-29348) The DPP(dynamic partition pruning) can not work with adaptive batch scheduler

[ https://issues.apache.org/jira/browse/FLINK-29348?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-29348: Priority: Blocker (was: Critical) > The DPP(dynamic partition pruning) can not work with adaptive batch s

[jira] [Assigned] (FLINK-29339) JobMasterPartitionTrackerImpl#requestShuffleDescriptorsFromResourceManager blocks main thread

[ https://issues.apache.org/jira/browse/FLINK-29339?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao reassigned FLINK-29339: --- Assignee: Xuannan Su > JobMasterPartitionTrackerImpl#requestShuffleDescriptorsFromResourceManager

[jira] [Commented] (FLINK-951) Reworking of Iteration Synchronization, Accumulators and Aggregators

[ https://issues.apache.org/jira/browse/FLINK-951?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17606936#comment-17606936 ] Yun Gao commented on FLINK-951: --- Since now we have had new iteration library in the flink-ml

[jira] [Closed] (FLINK-951) Reworking of Iteration Synchronization, Accumulators and Aggregators

[ https://issues.apache.org/jira/browse/FLINK-951?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao closed FLINK-951. - Resolution: Won't Fix > Reworking of Iteration Synchronization, Accumulators and Aggregators > ---

[jira] [Commented] (FLINK-29339) JobMasterPartitionTrackerImpl#requestShuffleDescriptorsFromResourceManager blocks main thread

[ https://issues.apache.org/jira/browse/FLINK-29339?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17606839#comment-17606839 ] Yun Gao commented on FLINK-29339: - [~xuannan]  Could you have a look at this issue~? >

[jira] [Commented] (FLINK-18647) How to handle processing time timers with bounded input

[ https://issues.apache.org/jira/browse/FLINK-18647?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17603492#comment-17603492 ] Yun Gao commented on FLINK-18647: - Hi, when discussing the batch-style execution, we als

[jira] [Closed] (FLINK-29132) SubtaskMetricStore causes memory leak.

[ https://issues.apache.org/jira/browse/FLINK-29132?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao closed FLINK-29132. --- Resolution: Fixed > SubtaskMetricStore causes memory leak. > -- > >

[jira] [Commented] (FLINK-29132) SubtaskMetricStore causes memory leak.

[ https://issues.apache.org/jira/browse/FLINK-29132?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17601811#comment-17601811 ] Yun Gao commented on FLINK-29132: - Merged on master via 26eeabfdd1f5f976ed1b5d761a3469bb

[jira] [Closed] (FLINK-28860) CacheITCase.testBatchProduceCacheStreamConsume failed

[ https://issues.apache.org/jira/browse/FLINK-28860?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao closed FLINK-28860. --- Resolution: Fixed > CacheITCase.testBatchProduceCacheStreamConsume failed >

[jira] [Commented] (FLINK-28860) CacheITCase.testBatchProduceCacheStreamConsume failed

[ https://issues.apache.org/jira/browse/FLINK-28860?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17601606#comment-17601606 ] Yun Gao commented on FLINK-28860: - Merged on master via 208f08b406a7fd48890cda16d317a30

[jira] [Closed] (FLINK-14101) Introduce SqlServerDialect

[ https://issues.apache.org/jira/browse/FLINK-14101?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao closed FLINK-14101. --- Release Note: This issue introduce the support of Microsoft SQLSever dialect in the jdbc connector. R

[jira] [Updated] (FLINK-14101) Introduce SqlServerDialect

[ https://issues.apache.org/jira/browse/FLINK-14101?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-14101: Release Note: This issue introduces the support of Microsoft SQLSever dialect in the jdbc connector. (wa

[jira] [Reopened] (FLINK-14101) Introduce SqlServerDialect

[ https://issues.apache.org/jira/browse/FLINK-14101?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao reopened FLINK-14101: - > Introduce SqlServerDialect > -- > > Key: FLINK-14101 >

[jira] [Closed] (FLINK-14101) Introduce SqlServerDialect

[ https://issues.apache.org/jira/browse/FLINK-14101?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao closed FLINK-14101. --- Fix Version/s: 1.17.0 Resolution: Fixed > Introduce SqlServerDialect > -- > >

[jira] [Commented] (FLINK-14101) Introduce SqlServerDialect

[ https://issues.apache.org/jira/browse/FLINK-14101?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17601192#comment-17601192 ] Yun Gao commented on FLINK-14101: - Merge on master via a8ca381c57788cd1a1527e4ebdc19bdbc

[jira] [Assigned] (FLINK-28659) [JUnit5 Migration] Module: flink-java

[ https://issues.apache.org/jira/browse/FLINK-28659?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao reassigned FLINK-28659: --- Assignee: RocMarshal > [JUnit5 Migration] Module: flink-java >

[jira] [Closed] (FLINK-28659) [JUnit5 Migration] Module: flink-java

[ https://issues.apache.org/jira/browse/FLINK-28659?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao closed FLINK-28659. --- Fix Version/s: 1.17.0 Resolution: Fixed > [JUnit5 Migration] Module: flink-java > ---

[jira] [Commented] (FLINK-28659) [JUnit5 Migration] Module: flink-java

[ https://issues.apache.org/jira/browse/FLINK-28659?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17600678#comment-17600678 ] Yun Gao commented on FLINK-28659: - Merged on master via 9955c85a53d10c85fbca57da33777b94

[jira] [Updated] (FLINK-29132) SubtaskMetricStore causes memory leak.

[ https://issues.apache.org/jira/browse/FLINK-29132?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-29132: Affects Version/s: 1.16.0 > SubtaskMetricStore causes memory leak. > -

[jira] [Updated] (FLINK-29132) SubtaskMetricStore causes memory leak.

[ https://issues.apache.org/jira/browse/FLINK-29132?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-29132: Fix Version/s: 1.16.0 > SubtaskMetricStore causes memory leak. > -- >

[jira] [Commented] (FLINK-27341) TaskManager running together with JobManager are bind to 127.0.0.1

[ https://issues.apache.org/jira/browse/FLINK-27341?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17600640#comment-17600640 ] Yun Gao commented on FLINK-27341: - Hi [~nobleyd] If currently no other progress, I'll op

[jira] [Comment Edited] (FLINK-27341) TaskManager running together with JobManager are bind to 127.0.0.1

[ https://issues.apache.org/jira/browse/FLINK-27341?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17600640#comment-17600640 ] Yun Gao edited comment on FLINK-27341 at 9/6/22 7:34 AM: - Hi [~n

[jira] [Commented] (FLINK-28941) Savepoint ignores MaxConcurrentCheckpoint limit in aligned checkpoint case

[ https://issues.apache.org/jira/browse/FLINK-28941?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17599349#comment-17599349 ] Yun Gao commented on FLINK-28941: - [~hxb] I have a double check with [~yunfengzhou] offl

[jira] [Comment Edited] (FLINK-28941) Savepoint ignores MaxConcurrentCheckpoint limit in aligned checkpoint case

[ https://issues.apache.org/jira/browse/FLINK-28941?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17599349#comment-17599349 ] Yun Gao edited comment on FLINK-28941 at 9/2/22 9:05 AM: - [~hxb]

[jira] [Commented] (FLINK-28941) Savepoint ignores MaxConcurrentCheckpoint limit in aligned checkpoint case

[ https://issues.apache.org/jira/browse/FLINK-28941?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17598755#comment-17598755 ] Yun Gao commented on FLINK-28941: - Hi [~hxb] Sorry for the delay, I'm still confirming t

[jira] [Commented] (FLINK-28941) Savepoint ignores MaxConcurrentCheckpoint limit in aligned checkpoint case

[ https://issues.apache.org/jira/browse/FLINK-28941?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17584578#comment-17584578 ] Yun Gao commented on FLINK-28941: - [~hxb] I'll have a look~ > Savepoint ignores MaxConc

[jira] [Commented] (FLINK-28860) CacheITCase.testBatchProduceCacheStreamConsume failed

[ https://issues.apache.org/jira/browse/FLINK-28860?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17577490#comment-17577490 ] Yun Gao commented on FLINK-28860: - Temporarily disabled on master via 208f08b406a7fd4889

[jira] [Closed] (FLINK-27521) FLIP-205: Support Cache in DataStream for Batch Processing

[ https://issues.apache.org/jira/browse/FLINK-27521?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao closed FLINK-27521. --- Release Note: Supports caching the result of a transformation via DataStream#cache(). The cache intermediat

[jira] [Updated] (FLINK-27521) FLIP-205: Support Cache in DataStream for Batch Processing

[ https://issues.apache.org/jira/browse/FLINK-27521?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-27521: Release Note: Supports caching the result of a transformation via DataStream#cache(). The cached intermedi

[jira] [Assigned] (FLINK-27521) FLIP-205: Support Cache in DataStream for Batch Processing

[ https://issues.apache.org/jira/browse/FLINK-27521?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao reassigned FLINK-27521: --- Assignee: Xuannan Su > FLIP-205: Support Cache in DataStream for Batch Processing > ---

[jira] [Closed] (FLINK-28857) Add Document for DataStream Cache API

[ https://issues.apache.org/jira/browse/FLINK-28857?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao closed FLINK-28857. --- Fix Version/s: 1.16] Assignee: Xuannan Su Resolution: Fixed > Add Document for DataStream Ca

[jira] [Commented] (FLINK-28857) Add Document for DataStream Cache API

[ https://issues.apache.org/jira/browse/FLINK-28857?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17577489#comment-17577489 ] Yun Gao commented on FLINK-28857: - Merged on master via 21712c932cdbcc6be26f46a201412646

[jira] [Closed] (FLINK-28871) Make DPP also works if batch shuffle mode is not ALL_BLOCKING

[ https://issues.apache.org/jira/browse/FLINK-28871?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao closed FLINK-28871. --- Resolution: Fixed > Make DPP also works if batch shuffle mode is not ALL_BLOCKING >

[jira] [Commented] (FLINK-28871) Make DPP also works if batch shuffle mode is not ALL_BLOCKING

[ https://issues.apache.org/jira/browse/FLINK-28871?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17577488#comment-17577488 ] Yun Gao commented on FLINK-28871: - Merged on master via 1719ff85b8ed3b90330bd5770a5e4abf

[jira] [Created] (FLINK-28871) Make DPP also works if batch shuffle mode is not ALL_BLOCKING

Yun Gao created FLINK-28871: --- Summary: Make DPP also works if batch shuffle mode is not ALL_BLOCKING Key: FLINK-28871 URL: https://issues.apache.org/jira/browse/FLINK-28871 Project: Flink Issue Ty

[jira] [Closed] (FLINK-27524) Introduce cache API to DataStream

[ https://issues.apache.org/jira/browse/FLINK-27524?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao closed FLINK-27524. --- Fix Version/s: 1.16.0 Resolution: Resolved > Introduce cache API to DataStream >

[jira] [Commented] (FLINK-27524) Introduce cache API to DataStream

[ https://issues.apache.org/jira/browse/FLINK-27524?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17576243#comment-17576243 ] Yun Gao commented on FLINK-27524: - Merged on master via cf1a29d47a5bb4fb92e98a36934e525d

[jira] [Assigned] (FLINK-28824) StreamingJobGraphGenerator#triggerSerializationAndReturnFuture might swallow exception

[ https://issues.apache.org/jira/browse/FLINK-28824?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao reassigned FLINK-28824: --- Assignee: Weijie Guo > StreamingJobGraphGenerator#triggerSerializationAndReturnFuture might swallow

[jira] [Created] (FLINK-28824) StreamingJobGraphGenerator#triggerSerializationAndReturnFuture might swallow exception

Yun Gao created FLINK-28824: --- Summary: StreamingJobGraphGenerator#triggerSerializationAndReturnFuture might swallow exception Key: FLINK-28824 URL: https://issues.apache.org/jira/browse/FLINK-28824 Projec

[jira] [Closed] (FLINK-25545) [JUnit5 Migration] Module: flink-clients

[ https://issues.apache.org/jira/browse/FLINK-25545?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao closed FLINK-25545. --- Fix Version/s: 1.16.0 Resolution: Fixed > [JUnit5 Migration] Module: flink-clients >

[jira] [Commented] (FLINK-25545) [JUnit5 Migration] Module: flink-clients

[ https://issues.apache.org/jira/browse/FLINK-25545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17575198#comment-17575198 ] Yun Gao commented on FLINK-25545: - Merged on master via 6da5d36243329497b3b005b1900ba01f

[jira] [Assigned] (FLINK-28589) Enhance Web UI for Speculative Execution

[ https://issues.apache.org/jira/browse/FLINK-28589?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao reassigned FLINK-28589: --- Assignee: Junhan Yang > Enhance Web UI for Speculative Execution >

[jira] [Commented] (FLINK-28588) Enhance REST API for Speculative Execution

[ https://issues.apache.org/jira/browse/FLINK-28588?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17573685#comment-17573685 ] Yun Gao commented on FLINK-28588: - Merged on master via aae0462cb398f5c58c46a769b25b06a

[jira] [Closed] (FLINK-28588) Enhance REST API for Speculative Execution

[ https://issues.apache.org/jira/browse/FLINK-28588?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao closed FLINK-28588. --- Fix Version/s: 1.16.0 Resolution: Fixed > Enhance REST API for Speculative Execution > --

[jira] [Assigned] (FLINK-28587) FLIP-249: Flink Web UI Enhancement for Speculative Execution

[ https://issues.apache.org/jira/browse/FLINK-28587?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao reassigned FLINK-28587: --- Assignee: Gen Luo > FLIP-249: Flink Web UI Enhancement for Speculative Execution >

[jira] [Closed] (FLINK-27878) [FLIP-232] Add Retry Support For Async I/O In DataStream API

[ https://issues.apache.org/jira/browse/FLINK-27878?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao closed FLINK-27878. --- Resolution: Fixed > [FLIP-232] Add Retry Support For Async I/O In DataStream API > -

[jira] [Commented] (FLINK-27878) [FLIP-232] Add Retry Support For Async I/O In DataStream API

[ https://issues.apache.org/jira/browse/FLINK-27878?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17567427#comment-17567427 ] Yun Gao commented on FLINK-27878: - Merged on master via  e85cf8c4cdf417b47f8d53bf3bb202f

[jira] [Closed] (FLINK-28457) Flink add JobStatusHook support

[ https://issues.apache.org/jira/browse/FLINK-28457?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao closed FLINK-28457. --- Fix Version/s: 1.16.0 Resolution: Fixed > Flink add JobStatusHook support > -

[jira] [Commented] (FLINK-28457) Flink add JobStatusHook support

[ https://issues.apache.org/jira/browse/FLINK-28457?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17566630#comment-17566630 ] Yun Gao commented on FLINK-28457: - Merged on master via  ed236ee19d7bcaa0e09eff5875880e8

[jira] [Assigned] (FLINK-28457) Flink add JobStatusHook support

[ https://issues.apache.org/jira/browse/FLINK-28457?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao reassigned FLINK-28457: --- Assignee: tartarus (was: Yun Gao) > Flink add JobStatusHook support >

[jira] [Assigned] (FLINK-28457) Flink add JobStatusHook support

[ https://issues.apache.org/jira/browse/FLINK-28457?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao reassigned FLINK-28457: --- Assignee: Yun Gao > Flink add JobStatusHook support > --- > >

[jira] [Commented] (FLINK-27703) FileChannelManagerImplTest.testDirectoriesCleanupOnKillWithoutCallerHook failed with The marker file was not found within 10000 msecs

[ https://issues.apache.org/jira/browse/FLINK-27703?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17564796#comment-17564796 ] Yun Gao commented on FLINK-27703: - Hi [~hxbks2ks] it seems to me that the file creation

[jira] [Updated] (FLINK-26265) Support Java algorithm in Python ML API

[ https://issues.apache.org/jira/browse/FLINK-26265?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-26265: Fix Version/s: ml-2.2.0 (was: ml-2.1.0) > Support Java algorithm in Python ML API >

[jira] [Updated] (FLINK-26265) Support Java algorithm in Python ML API

[ https://issues.apache.org/jira/browse/FLINK-26265?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-26265: Affects Version/s: ml-2.2.0 > Support Java algorithm in Python ML API > --

[jira] [Closed] (FLINK-26394) CheckpointCoordinator.isTriggering can not be reset if a checkpoint expires while the checkpointCoordinator task is queuing in the SourceCoordinator executor.

[ https://issues.apache.org/jira/browse/FLINK-26394?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao closed FLINK-26394. --- Fix Version/s: 1.16.0 Resolution: Fixed > CheckpointCoordinator.isTriggering can not be reset if a ch

[jira] [Commented] (FLINK-26394) CheckpointCoordinator.isTriggering can not be reset if a checkpoint expires while the checkpointCoordinator task is queuing in the SourceCoordinator executor.

[ https://issues.apache.org/jira/browse/FLINK-26394?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17564195#comment-17564195 ] Yun Gao commented on FLINK-26394: - Merged on master via 31222b9adf1c354b22fd50c587efc167

[jira] [Assigned] (FLINK-28115) Flink 1.15.0 Parallelism Rebalance causes flink job failure

[ https://issues.apache.org/jira/browse/FLINK-28115?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao reassigned FLINK-28115: --- Assignee: Yun Gao > Flink 1.15.0 Parallelism Rebalance causes flink job failure > -

[jira] [Commented] (FLINK-28115) Flink 1.15.0 Parallelism Rebalance causes flink job failure

[ https://issues.apache.org/jira/browse/FLINK-28115?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17562966#comment-17562966 ] Yun Gao commented on FLINK-28115: - Hi [~huameng] sorry this seems to be a known issue:

[jira] [Closed] (FLINK-28240) NettyShuffleMetricFactory#RequestedMemoryUsageMetric#getValue may throw ArithmeticException when the total segments of NetworkBufferPool is 0

[ https://issues.apache.org/jira/browse/FLINK-28240?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao closed FLINK-28240. --- Fix Version/s: 1.16.0 1.15.2 Assignee: Gen Luo Resolution: Fixed > NettyS

[jira] [Commented] (FLINK-28240) NettyShuffleMetricFactory#RequestedMemoryUsageMetric#getValue may throw ArithmeticException when the total segments of NetworkBufferPool is 0

[ https://issues.apache.org/jira/browse/FLINK-28240?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17562407#comment-17562407 ] Yun Gao commented on FLINK-28240: - Merged on master via c6b3a8aa25607fb62d51b92f11f72778

[jira] [Created] (FLINK-28386) Trigger an immediate checkpoint after all sources finished

Yun Gao created FLINK-28386: --- Summary: Trigger an immediate checkpoint after all sources finished Key: FLINK-28386 URL: https://issues.apache.org/jira/browse/FLINK-28386 Project: Flink Issue Type:

[jira] [Commented] (FLINK-27703) FileChannelManagerImplTest.testDirectoriesCleanupOnKillWithoutCallerHook failed with The marker file was not found within 10000 msecs

Title: Message Title Yun Gao commented on

[jira] [Assigned] (FLINK-27703) FileChannelManagerImplTest.testDirectoriesCleanupOnKillWithoutCallerHook failed with The marker file was not found within 10000 msecs

Title: Message Title Yun Gao assigned an i

[jira] [Assigned] (FLINK-28126) Iteration gets stuck when replayable datastream and its downstream operator have different parallelism

[ https://issues.apache.org/jira/browse/FLINK-28126?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao reassigned FLINK-28126: --- Assignee: Yun Gao > Iteration gets stuck when replayable datastream and its downstream operator >

[jira] [Commented] (FLINK-28126) Iteration gets stuck when replayable datastream and its downstream operator have different parallelism

[ https://issues.apache.org/jira/browse/FLINK-28126?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17557792#comment-17557792 ] Yun Gao commented on FLINK-28126: - Very thanks [~xuannan] for the investigation, I'll ha

[jira] [Assigned] (FLINK-26801) LogisticRegressionTest.testGetModelData» Runtime Failed to fetch next res...

[ https://issues.apache.org/jira/browse/FLINK-26801?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao reassigned FLINK-26801: --- Assignee: Yun Gao > LogisticRegressionTest.testGetModelData» Runtime Failed to fetch next res... >

[jira] [Closed] (FLINK-27910) FileSink not registered the timer to enforce rolling policy if started from scratch

[ https://issues.apache.org/jira/browse/FLINK-27910?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao closed FLINK-27910. --- Resolution: Fixed > FileSink not registered the timer to enforce rolling policy if started from > scratch >

[jira] [Updated] (FLINK-27910) FileSink not registered the timer to enforce rolling policy if started from scratch

[ https://issues.apache.org/jira/browse/FLINK-27910?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-27910: Fix Version/s: 1.16.0 1.15.1 > FileSink not registered the timer to enforce rolling pol

[jira] [Commented] (FLINK-27910) FileSink not registered the timer to enforce rolling policy if started from scratch

[ https://issues.apache.org/jira/browse/FLINK-27910?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17551450#comment-17551450 ] Yun Gao commented on FLINK-27910: - Fix on master via d036c23c0e5c079eaafef250a5a14b7f3ee

[jira] [Closed] (FLINK-25705) Translate "Metric Reporters" page of "Deployment" in to Chinese

[ https://issues.apache.org/jira/browse/FLINK-25705?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao closed FLINK-25705. --- Fix Version/s: 1.16.0 Resolution: Fixed > Translate "Metric Reporters" page of "Deployment" in to Chi

[jira] [Commented] (FLINK-25705) Translate "Metric Reporters" page of "Deployment" in to Chinese

[ https://issues.apache.org/jira/browse/FLINK-25705?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17550785#comment-17550785 ] Yun Gao commented on FLINK-25705: - Merged on master via 5176669bc0ee678f21934f239d2b34a5

[jira] [Commented] (FLINK-27910) FileSink not registered the timer to enforce rolling policy if started from scratch

[ https://issues.apache.org/jira/browse/FLINK-27910?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17550373#comment-17550373 ] Yun Gao commented on FLINK-27910: - Also cc [~pltbkd]  > FileSink not registered the tim

[jira] [Created] (FLINK-27910) FileSink not registered the timer to enforce rolling policy if started from scratch

Yun Gao created FLINK-27910: --- Summary: FileSink not registered the timer to enforce rolling policy if started from scratch Key: FLINK-27910 URL: https://issues.apache.org/jira/browse/FLINK-27910 Project: Fl

[jira] [Comment Edited] (FLINK-27827) StreamExecutionEnvironment method supporting explicit Boundedness

[ https://issues.apache.org/jira/browse/FLINK-27827?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17543800#comment-17543800 ] Yun Gao edited comment on FLINK-27827 at 5/30/22 7:31 AM: -- Hi [

[jira] [Comment Edited] (FLINK-27827) StreamExecutionEnvironment method supporting explicit Boundedness

[ https://issues.apache.org/jira/browse/FLINK-27827?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17543800#comment-17543800 ] Yun Gao edited comment on FLINK-27827 at 5/30/22 7:27 AM: -- Hi [

[jira] [Commented] (FLINK-27827) StreamExecutionEnvironment method supporting explicit Boundedness

[ https://issues.apache.org/jira/browse/FLINK-27827?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17543800#comment-17543800 ] Yun Gao commented on FLINK-27827: - Hi [~ahailu]  sorry I'm also not quite sure there is

[jira] [Commented] (FLINK-24474) Standalone clusters should bind to localhost by default

[ https://issues.apache.org/jira/browse/FLINK-24474?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17542044#comment-17542044 ] Yun Gao commented on FLINK-24474: - Hi [~jark]  very sorry for missing the notification,

[jira] [Commented] (FLINK-26788) AbstractDeserializationSchema should add cause when thow a FlinkRuntimeException

[ https://issues.apache.org/jira/browse/FLINK-26788?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=1754#comment-1754 ] Yun Gao commented on FLINK-26788: - Merged on master via 0eda2cc35a7185592129df8d4b004acc

[jira] [Closed] (FLINK-26788) AbstractDeserializationSchema should add cause when thow a FlinkRuntimeException

[ https://issues.apache.org/jira/browse/FLINK-26788?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao closed FLINK-26788. --- Fix Version/s: 1.14.5 1.15.1 Resolution: Fixed > AbstractDeserializationSchema sho

[jira] [Commented] (FLINK-27492) Flink table scala example does not including the scala-api jars

[ https://issues.apache.org/jira/browse/FLINK-27492?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17533908#comment-17533908 ] Yun Gao commented on FLINK-27492: - For another thing, perhaps we could also including th

[jira] [Updated] (FLINK-27518) Refactor migration tests to support version update automatically

[ https://issues.apache.org/jira/browse/FLINK-27518?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-27518: Summary: Refactor migration tests to support version update automatically (was: Refactor migration tests

<    1   2   3   4   5   6   7   8   9   10   >