[jira] [Resolved] (FLINK-37222) Table planner exception when sql client submit job

[ https://issues.apache.org/jira/browse/FLINK-37222?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zakelly Lan resolved FLINK-37222. - Fix Version/s: 2.0.0 Assignee: Dawid Wysakowicz Resolution: Fixed > Table planne

[jira] [Commented] (FLINK-37222) Table planner exception when sql client submit job

[ https://issues.apache.org/jira/browse/FLINK-37222?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17924034#comment-17924034 ] Zakelly Lan commented on FLINK-37222: - Master: * ac4f5952d5dd47e09644681b8f0fbf2b46a

[jira] [Comment Edited] (FLINK-37021) Implement fast checkpoint/rescaling for ForStKeyedStateBackend

[ https://issues.apache.org/jira/browse/FLINK-37021?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17923962#comment-17923962 ] Zakelly Lan edited comment on FLINK-37021 at 2/5/25 11:38 AM:

[jira] [Commented] (FLINK-37021) Implement fast checkpoint/rescaling for ForStKeyedStateBackend

[ https://issues.apache.org/jira/browse/FLINK-37021?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17923962#comment-17923962 ] Zakelly Lan commented on FLINK-37021: - Follow up PR: * master: f975783ce9a688a99e2f7

[jira] [Comment Edited] (FLINK-37206) Initialization issue of batching timer service in async state operators

[ https://issues.apache.org/jira/browse/FLINK-37206?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17922411#comment-17922411 ] Zakelly Lan edited comment on FLINK-37206 at 2/5/25 2:17 AM: -

[jira] [Resolved] (FLINK-37206) Initialization issue of batching timer service in async state operators

[ https://issues.apache.org/jira/browse/FLINK-37206?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zakelly Lan resolved FLINK-37206. - Resolution: Fixed > Initialization issue of batching timer service in async state operators > --

[jira] [Commented] (FLINK-37222) Table planner exception when sql client submit job

[ https://issues.apache.org/jira/browse/FLINK-37222?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17922438#comment-17922438 ] Zakelly Lan commented on FLINK-37222: - [~dwysakowicz] I wrote a simple test reproduc

[jira] [Updated] (FLINK-37222) Table planner exception when sql client submit job

[ https://issues.apache.org/jira/browse/FLINK-37222?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zakelly Lan updated FLINK-37222: Priority: Blocker (was: Major) > Table planner exception when sql client submit job > ---

[jira] [Updated] (FLINK-37222) Table planner exception when sql client submit job

[ https://issues.apache.org/jira/browse/FLINK-37222?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zakelly Lan updated FLINK-37222: Attachment: flink-root-sql-client-master-1-1.c-76646bdbb8bdab89.log > Table planner exception when

[jira] [Commented] (FLINK-37222) Table planner exception when sql client submit job

[ https://issues.apache.org/jira/browse/FLINK-37222?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17916796#comment-17916796 ] Zakelly Lan commented on FLINK-37222: - [~dwysakowicz] [~twalthr] Would you please ta

[jira] [Created] (FLINK-37222) Table planner exception when sql client submit job

Zakelly Lan created FLINK-37222: --- Summary: Table planner exception when sql client submit job Key: FLINK-37222 URL: https://issues.apache.org/jira/browse/FLINK-37222 Project: Flink Issue Type:

[jira] [Commented] (FLINK-37208) Properly notify a new key is selected for async state operators

[ https://issues.apache.org/jira/browse/FLINK-37208?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17916725#comment-17916725 ] Zakelly Lan commented on FLINK-37208: - 1.20: 6a5fab8036f534409d774e8724f2cd01ca5d24f

[jira] [Resolved] (FLINK-37208) Properly notify a new key is selected for async state operators

[ https://issues.apache.org/jira/browse/FLINK-37208?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zakelly Lan resolved FLINK-37208. - Fix Version/s: 2.0.0 Resolution: Fixed > Properly notify a new key is selected for async

[jira] [Created] (FLINK-37208) Properly notify a new key is selected for async state operators

Zakelly Lan created FLINK-37208: --- Summary: Properly notify a new key is selected for async state operators Key: FLINK-37208 URL: https://issues.apache.org/jira/browse/FLINK-37208 Project: Flink

[jira] [Created] (FLINK-37206) Initialization issue of batching timer service in async state operators

Zakelly Lan created FLINK-37206: --- Summary: Initialization issue of batching timer service in async state operators Key: FLINK-37206 URL: https://issues.apache.org/jira/browse/FLINK-37206 Project: Flink

[jira] [Commented] (FLINK-36838) [state] Join background threads when ForSt state backend quit

[ https://issues.apache.org/jira/browse/FLINK-36838?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17916258#comment-17916258 ] Zakelly Lan commented on FLINK-36838: - follow-up merge: * master: 7b2e9c410344126a26

[jira] [Assigned] (FLINK-35578) Release Frocksdb-8.10.0 official products

[ https://issues.apache.org/jira/browse/FLINK-35578?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zakelly Lan reassigned FLINK-35578: --- Assignee: Yanfei Lei (was: Zakelly Lan) > Release Frocksdb-8.10.0 official products >

[jira] [Commented] (FLINK-35578) Release Frocksdb-8.10.0 official products

[ https://issues.apache.org/jira/browse/FLINK-35578?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17914835#comment-17914835 ] Zakelly Lan commented on FLINK-35578: - [~mayuehappy] We will release this before 2.0

[jira] [Resolved] (FLINK-37021) Implement fast checkpoint/rescaling for ForStKeyedStateBackend

[ https://issues.apache.org/jira/browse/FLINK-37021?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zakelly Lan resolved FLINK-37021. - Fix Version/s: 2.0.0 Assignee: Han Yin Resolution: Fixed > Implement fast checkp

[jira] [Commented] (FLINK-37021) Implement fast checkpoint/rescaling for ForStKeyedStateBackend

[ https://issues.apache.org/jira/browse/FLINK-37021?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17914620#comment-17914620 ] Zakelly Lan commented on FLINK-37021: - Merge into master via: * 25d34b996aaecb35d55

[jira] [Commented] (FLINK-37045) Expose state v2 creation APIs to datastream user

[ https://issues.apache.org/jira/browse/FLINK-37045?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17914523#comment-17914523 ] Zakelly Lan commented on FLINK-37045: - Follow-up commit 7964466016daea1f53bf14821c85

[jira] [Resolved] (FLINK-37028) Datastream Window operator with async state processing

[ https://issues.apache.org/jira/browse/FLINK-37028?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zakelly Lan resolved FLINK-37028. - Fix Version/s: 2.0.0 Resolution: Fixed > Datastream Window operator with async state proc

[jira] [Commented] (FLINK-37028) Datastream Window operator with async state processing

[ https://issues.apache.org/jira/browse/FLINK-37028?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17914522#comment-17914522 ] Zakelly Lan commented on FLINK-37028: - Merge into master via : ab791f9eb0c55134a25de

[jira] [Commented] (FLINK-37164) Speed up state v2 synchronous methods execution

[ https://issues.apache.org/jira/browse/FLINK-37164?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17914286#comment-17914286 ] Zakelly Lan commented on FLINK-37164: - Merge 180d587717ba0997c35f89e080974851eea7a93

[jira] [Resolved] (FLINK-37164) Speed up state v2 synchronous methods execution

[ https://issues.apache.org/jira/browse/FLINK-37164?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zakelly Lan resolved FLINK-37164. - Fix Version/s: 2.0.0 Resolution: Fixed > Speed up state v2 synchronous methods execution

[jira] [Created] (FLINK-37164) Speed up state v2 synchronous methods execution

Zakelly Lan created FLINK-37164: --- Summary: Speed up state v2 synchronous methods execution Key: FLINK-37164 URL: https://issues.apache.org/jira/browse/FLINK-37164 Project: Flink Issue Type: Sub

[jira] [Updated] (FLINK-37157) Enable daily benchmark for Java 21

[ https://issues.apache.org/jira/browse/FLINK-37157?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zakelly Lan updated FLINK-37157: Issue Type: Improvement (was: Bug) > Enable daily benchmark for Java 21 > ---

[jira] [Created] (FLINK-37157) Enable daily benchmark for Java 21

Zakelly Lan created FLINK-37157: --- Summary: Enable daily benchmark for Java 21 Key: FLINK-37157 URL: https://issues.apache.org/jira/browse/FLINK-37157 Project: Flink Issue Type: Bug Co

[jira] [Commented] (FLINK-36293) RocksDBWriteBatchWrapperTest.testAsyncCancellation

[ https://issues.apache.org/jira/browse/FLINK-36293?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17913921#comment-17913921 ] Zakelly Lan commented on FLINK-36293: - Merge into master via 4be6d6923036813c721ce30

[jira] [Resolved] (FLINK-36293) RocksDBWriteBatchWrapperTest.testAsyncCancellation

[ https://issues.apache.org/jira/browse/FLINK-36293?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zakelly Lan resolved FLINK-36293. - Fix Version/s: 2.0.0 Resolution: Fixed > RocksDBWriteBatchWrapperTest.testAsyncCancellati

[jira] [Closed] (FLINK-37107) Allow buffer overdraft in async state processing

[ https://issues.apache.org/jira/browse/FLINK-37107?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zakelly Lan closed FLINK-37107. --- Fix Version/s: 2.0.0 Resolution: Fixed > Allow buffer overdraft in async state processing > -

[jira] [Commented] (FLINK-37107) Allow buffer overdraft in async state processing

[ https://issues.apache.org/jira/browse/FLINK-37107?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17913536#comment-17913536 ] Zakelly Lan commented on FLINK-37107: - Merge into master via e3c28414...9da368d6 >

[jira] [Commented] (FLINK-37130) Provide a util converting future of StateIterator to Iterable

[ https://issues.apache.org/jira/browse/FLINK-37130?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17913344#comment-17913344 ] Zakelly Lan commented on FLINK-37130: - Merge into master via: * d0165dee9e0281c53221

[jira] [Resolved] (FLINK-37130) Provide a util converting future of StateIterator to Iterable

[ https://issues.apache.org/jira/browse/FLINK-37130?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zakelly Lan resolved FLINK-37130. - Fix Version/s: 2.0.0 Resolution: Fixed > Provide a util converting future of StateIterato

[jira] [Closed] (FLINK-33699) Verify the snapshot migration on Java21

[ https://issues.apache.org/jira/browse/FLINK-33699?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zakelly Lan closed FLINK-33699. --- Resolution: Won't Do > Verify the snapshot migration on Java21 > ---

[jira] [Commented] (FLINK-33699) Verify the snapshot migration on Java21

[ https://issues.apache.org/jira/browse/FLINK-33699?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17913218#comment-17913218 ] Zakelly Lan commented on FLINK-33699: - I think only 1.x versions are related, since

[jira] [Created] (FLINK-37130) Provide a util converting future of StateIterator to Iterable

Zakelly Lan created FLINK-37130: --- Summary: Provide a util converting future of StateIterator to Iterable Key: FLINK-37130 URL: https://issues.apache.org/jira/browse/FLINK-37130 Project: Flink

[jira] [Commented] (FLINK-36167) testSinkDisorderChangeLog failed on AZP

[ https://issues.apache.org/jira/browse/FLINK-36167?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17913137#comment-17913137 ] Zakelly Lan commented on FLINK-36167: - https://dev.azure.com/apache-flink/apache-fli

[jira] [Resolved] (FLINK-37115) [Benchmark] Compile error related with SerializerConfig

[ https://issues.apache.org/jira/browse/FLINK-37115?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zakelly Lan resolved FLINK-37115. - Fix Version/s: 2.0.0 Resolution: Fixed > [Benchmark] Compile error related with Serialize

[jira] [Commented] (FLINK-37115) [Benchmark] Compile error related with SerializerConfig

[ https://issues.apache.org/jira/browse/FLINK-37115?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17912825#comment-17912825 ] Zakelly Lan commented on FLINK-37115: - Merge into flink-benchmark(master) via 481ff9

[jira] [Commented] (FLINK-37115) [Benchmark] Compile error related with SerializerConfig

[ https://issues.apache.org/jira/browse/FLINK-37115?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17912751#comment-17912751 ] Zakelly Lan commented on FLINK-37115: - [~Zhanghao Chen] Would you please take a look

[jira] [Assigned] (FLINK-37115) [Benchmark] Compile error related with SerializerConfig

[ https://issues.apache.org/jira/browse/FLINK-37115?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zakelly Lan reassigned FLINK-37115: --- Assignee: Zhanghao Chen (was: Zakelly Lan) > [Benchmark] Compile error related with Serial

[jira] [Assigned] (FLINK-37115) [Benchmark] Compile error related with SerializerConfig

[ https://issues.apache.org/jira/browse/FLINK-37115?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zakelly Lan reassigned FLINK-37115: --- Assignee: Zakelly Lan > [Benchmark] Compile error related with SerializerConfig > -

[jira] [Created] (FLINK-37115) [Benchmark] Compile error related with SerializerConfig

Zakelly Lan created FLINK-37115: --- Summary: [Benchmark] Compile error related with SerializerConfig Key: FLINK-37115 URL: https://issues.apache.org/jira/browse/FLINK-37115 Project: Flink Issue T

[jira] [Updated] (FLINK-37115) [Benchmark] Compile error related with SerializerConfig

[ https://issues.apache.org/jira/browse/FLINK-37115?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zakelly Lan updated FLINK-37115: Description: {code:java} 12:43:54 [INFO] ---

[jira] [Resolved] (FLINK-37003) Implement async state version of Datastream Interval join

[ https://issues.apache.org/jira/browse/FLINK-37003?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zakelly Lan resolved FLINK-37003. - Fix Version/s: 2.0.0 Resolution: Fixed > Implement async state version of Datastream Inte

[jira] [Commented] (FLINK-37003) Implement async state version of Datastream Interval join

[ https://issues.apache.org/jira/browse/FLINK-37003?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17912481#comment-17912481 ] Zakelly Lan commented on FLINK-37003: - Merge into master via: * 5df3e4a8abbb0d11022

[jira] [Updated] (FLINK-37107) Allow buffer overdraft in async state processing

[ https://issues.apache.org/jira/browse/FLINK-37107?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zakelly Lan updated FLINK-37107: Description: In FLINK-37089, we resolved the deadlock of derived requests waiting on draining curr

[jira] [Created] (FLINK-37107) Allow buffer overdraft in async state processing

Zakelly Lan created FLINK-37107: --- Summary: Allow buffer overdraft in async state processing Key: FLINK-37107 URL: https://issues.apache.org/jira/browse/FLINK-37107 Project: Flink Issue Type: Su

[jira] [Commented] (FLINK-35412) Batch execution of async state request callback

[ https://issues.apache.org/jira/browse/FLINK-35412?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17912425#comment-17912425 ] Zakelly Lan commented on FLINK-35412: - We found this problematic by only leaving one

[jira] [Assigned] (FLINK-37028) Datastream Window operator with async state processing

[ https://issues.apache.org/jira/browse/FLINK-37028?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zakelly Lan reassigned FLINK-37028: --- Assignee: Rui Xia (was: Zakelly Lan) > Datastream Window operator with async state process

[jira] [Resolved] (FLINK-37045) Expose state v2 creation APIs to datastream user

[ https://issues.apache.org/jira/browse/FLINK-37045?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zakelly Lan resolved FLINK-37045. - Fix Version/s: 2.0.0 Resolution: Fixed > Expose state v2 creation APIs to datastream user

[jira] [Commented] (FLINK-37045) Expose state v2 creation APIs to datastream user

[ https://issues.apache.org/jira/browse/FLINK-37045?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17912331#comment-17912331 ] Zakelly Lan commented on FLINK-37045: - Merge into master via: * c999e7e9a5da54d4033

[jira] [Commented] (FLINK-37089) Advanced scheduling for derived async state processing

[ https://issues.apache.org/jira/browse/FLINK-37089?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17912242#comment-17912242 ] Zakelly Lan commented on FLINK-37089: - Merge into master via: * 0bfbef664fcd4aee359

[jira] [Resolved] (FLINK-37089) Advanced scheduling for derived async state processing

[ https://issues.apache.org/jira/browse/FLINK-37089?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zakelly Lan resolved FLINK-37089. - Fix Version/s: 2.0.0 Resolution: Fixed > Advanced scheduling for derived async state proc

[jira] [Created] (FLINK-37089) Advanced scheduling for derived async state processing

Zakelly Lan created FLINK-37089: --- Summary: Advanced scheduling for derived async state processing Key: FLINK-37089 URL: https://issues.apache.org/jira/browse/FLINK-37089 Project: Flink Issue Ty

[jira] [Commented] (FLINK-37030) Support lazy initialization for state serializer in State V2

[ https://issues.apache.org/jira/browse/FLINK-37030?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17911460#comment-17911460 ] Zakelly Lan commented on FLINK-37030: - Merge into master via : 7597fe34dbc5bc74ed51b

[jira] [Resolved] (FLINK-37030) Support lazy initialization for state serializer in State V2

[ https://issues.apache.org/jira/browse/FLINK-37030?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zakelly Lan resolved FLINK-37030. - Fix Version/s: 2.0.0 Resolution: Fixed > Support lazy initialization for state serializer

[jira] [Created] (FLINK-37045) Expose state v2 creation APIs to datastream user

Zakelly Lan created FLINK-37045: --- Summary: Expose state v2 creation APIs to datastream user Key: FLINK-37045 URL: https://issues.apache.org/jira/browse/FLINK-37045 Project: Flink Issue Type: Su

[jira] [Commented] (FLINK-37031) Core dump in StateBackendTestV2Base.testAsyncStateBackendScaleDown

[ https://issues.apache.org/jira/browse/FLINK-37031?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17910935#comment-17910935 ] Zakelly Lan commented on FLINK-37031: - [~Yanfei Lei] would you please take a look? t

[jira] [Assigned] (FLINK-37031) Core dump in StateBackendTestV2Base.testAsyncStateBackendScaleDown

[ https://issues.apache.org/jira/browse/FLINK-37031?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zakelly Lan reassigned FLINK-37031: --- Assignee: Yanfei Lei > Core dump in StateBackendTestV2Base.testAsyncStateBackendScaleDown >

[jira] [Created] (FLINK-37030) Support lazy initialization for state serializer in State V2

Zakelly Lan created FLINK-37030: --- Summary: Support lazy initialization for state serializer in State V2 Key: FLINK-37030 URL: https://issues.apache.org/jira/browse/FLINK-37030 Project: Flink I

[jira] [Created] (FLINK-37028) Datastream Window operator with async state processing

Zakelly Lan created FLINK-37028: --- Summary: Datastream Window operator with async state processing Key: FLINK-37028 URL: https://issues.apache.org/jira/browse/FLINK-37028 Project: Flink Issue Ty

[jira] [Closed] (FLINK-37010) Unify KeyedProcessFunction and the async one

[ https://issues.apache.org/jira/browse/FLINK-37010?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zakelly Lan closed FLINK-37010. --- Fix Version/s: 2.0.0 Resolution: Fixed > Unify KeyedProcessFunction and the async one > -

[jira] [Commented] (FLINK-37010) Unify KeyedProcessFunction and the async one

[ https://issues.apache.org/jira/browse/FLINK-37010?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17910892#comment-17910892 ] Zakelly Lan commented on FLINK-37010: - merge 9720dcc into master > Unify KeyedProce

[jira] [Created] (FLINK-37010) Unify KeyedProcessFunction and the async one

Zakelly Lan created FLINK-37010: --- Summary: Unify KeyedProcessFunction and the async one Key: FLINK-37010 URL: https://issues.apache.org/jira/browse/FLINK-37010 Project: Flink Issue Type: Sub-ta

[jira] [Created] (FLINK-37003) Implement async state version of Datastream Interval join

Zakelly Lan created FLINK-37003: --- Summary: Implement async state version of Datastream Interval join Key: FLINK-37003 URL: https://issues.apache.org/jira/browse/FLINK-37003 Project: Flink Issue

[jira] [Commented] (FLINK-36120) Internal APIs for declaring and defining the record processing

[ https://issues.apache.org/jira/browse/FLINK-36120?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17909272#comment-17909272 ] Zakelly Lan commented on FLINK-36120: - Merge into master via b50a25f...4952b58 > In

[jira] [Resolved] (FLINK-36120) Internal APIs for declaring and defining the record processing

[ https://issues.apache.org/jira/browse/FLINK-36120?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zakelly Lan resolved FLINK-36120. - Fix Version/s: 2.0.0 Resolution: Fixed > Internal APIs for declaring and defining the rec

[jira] [Created] (FLINK-36989) Scheduler benchmark regression since Dec.25th

Zakelly Lan created FLINK-36989: --- Summary: Scheduler benchmark regression since Dec.25th Key: FLINK-36989 URL: https://issues.apache.org/jira/browse/FLINK-36989 Project: Flink Issue Type: Bug

[jira] [Resolved] (FLINK-36963) Wrong context maintain around `asyncProcessWithKey`

[ https://issues.apache.org/jira/browse/FLINK-36963?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zakelly Lan resolved FLINK-36963. - Fix Version/s: 2.0.0 Resolution: Fixed > Wrong context maintain around `asyncProcessWithK

[jira] [Commented] (FLINK-36963) Wrong context maintain around `asyncProcessWithKey`

[ https://issues.apache.org/jira/browse/FLINK-36963?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17908289#comment-17908289 ] Zakelly Lan commented on FLINK-36963: - Merge 19bc0b3 into master > Wrong context ma

[jira] [Commented] (FLINK-35904) Test harness for async state processing operators

[ https://issues.apache.org/jira/browse/FLINK-35904?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17908288#comment-17908288 ] Zakelly Lan commented on FLINK-35904: - Merge 3165f94 into master > Test harness for

[jira] [Updated] (FLINK-36853) Support getOrCreateKeyedState for AsyncKeyedStateBackend

[ https://issues.apache.org/jira/browse/FLINK-36853?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zakelly Lan updated FLINK-36853: Fix Version/s: 2.0.0 > Support getOrCreateKeyedState for AsyncKeyedStateBackend >

[jira] [Resolved] (FLINK-36853) Support getOrCreateKeyedState for AsyncKeyedStateBackend

[ https://issues.apache.org/jira/browse/FLINK-36853?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zakelly Lan resolved FLINK-36853. - Resolution: Fixed > Support getOrCreateKeyedState for AsyncKeyedStateBackend > -

[jira] [Commented] (FLINK-36853) Support getOrCreateKeyedState for AsyncKeyedStateBackend

[ https://issues.apache.org/jira/browse/FLINK-36853?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17908251#comment-17908251 ] Zakelly Lan commented on FLINK-36853: - Resolved by https://github.com/apache/flink/p

[jira] [Created] (FLINK-36963) Wrong context maintain around `asyncProcessWithKey`

Zakelly Lan created FLINK-36963: --- Summary: Wrong context maintain around `asyncProcessWithKey` Key: FLINK-36963 URL: https://issues.apache.org/jira/browse/FLINK-36963 Project: Flink Issue Type:

[jira] [Commented] (FLINK-36949) Make getCurrentKey of async state operators return the ground truth

[ https://issues.apache.org/jira/browse/FLINK-36949?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17907851#comment-17907851 ] Zakelly Lan commented on FLINK-36949: - Merge f8014b6 into master > Make getCurrentK

[jira] [Closed] (FLINK-36949) Make getCurrentKey of async state operators return the ground truth

[ https://issues.apache.org/jira/browse/FLINK-36949?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zakelly Lan closed FLINK-36949. --- Resolution: Fixed > Make getCurrentKey of async state operators return the ground truth > --

[jira] [Resolved] (FLINK-36944) Introduce 'enableAsycState' in KeyedStream interfaces

[ https://issues.apache.org/jira/browse/FLINK-36944?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zakelly Lan resolved FLINK-36944. - Resolution: Fixed > Introduce 'enableAsycState' in KeyedStream interfaces >

[jira] [Commented] (FLINK-36944) Introduce 'enableAsycState' in KeyedStream interfaces

[ https://issues.apache.org/jira/browse/FLINK-36944?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17907846#comment-17907846 ] Zakelly Lan commented on FLINK-36944: - Merge 2904c4c2...5b655399 into master > Intr

[jira] [Created] (FLINK-36949) Make getCurrentKey of async state operators return the ground truth

Zakelly Lan created FLINK-36949: --- Summary: Make getCurrentKey of async state operators return the ground truth Key: FLINK-36949 URL: https://issues.apache.org/jira/browse/FLINK-36949 Project: Flink

[jira] [Commented] (FLINK-36938) Provide hooks before and after the watermark processing

[ https://issues.apache.org/jira/browse/FLINK-36938?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17907367#comment-17907367 ] Zakelly Lan commented on FLINK-36938: - Merge 7fa4f78 into master > Provide hooks be

[jira] [Resolved] (FLINK-36938) Provide hooks before and after the watermark processing

[ https://issues.apache.org/jira/browse/FLINK-36938?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zakelly Lan resolved FLINK-36938. - Fix Version/s: 2.0.0 Resolution: Fixed > Provide hooks before and after the watermark pro

[jira] [Updated] (FLINK-36944) Introduce 'enableAsycState' in KeyedStream interfaces

[ https://issues.apache.org/jira/browse/FLINK-36944?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zakelly Lan updated FLINK-36944: Summary: Introduce 'enableAsycState' in KeyedStream interfaces (was: Introduce 'enableAsycState'

[jira] [Commented] (FLINK-36942) Unable to trigger onEventTime() when using the async state API in RowTimestamportOperator

[ https://issues.apache.org/jira/browse/FLINK-36942?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17907333#comment-17907333 ] Zakelly Lan commented on FLINK-36942: - [~au_miner] Thanks for your contribution! The

[jira] [Updated] (FLINK-36943) FLIP-488: Expose Async State Processing and New State APIs in Datastream(V1) APIs

[ https://issues.apache.org/jira/browse/FLINK-36943?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zakelly Lan updated FLINK-36943: Component/s: API / DataStream Runtime / Async State Processing > FLIP-488: Expose

[jira] [Created] (FLINK-36944) Introduce 'enableAsycState' in DataStream v1 interfaces

Zakelly Lan created FLINK-36944: --- Summary: Introduce 'enableAsycState' in DataStream v1 interfaces Key: FLINK-36944 URL: https://issues.apache.org/jira/browse/FLINK-36944 Project: Flink Issue T

[jira] [Created] (FLINK-36943) FLIP-488: Expose Async State Processing and New State APIs in Datastream(V1) APIs

Zakelly Lan created FLINK-36943: --- Summary: FLIP-488: Expose Async State Processing and New State APIs in Datastream(V1) APIs Key: FLINK-36943 URL: https://issues.apache.org/jira/browse/FLINK-36943 Proje

[jira] [Created] (FLINK-36938) Provide hooks before and after the watermark processing

Zakelly Lan created FLINK-36938: --- Summary: Provide hooks before and after the watermark processing Key: FLINK-36938 URL: https://issues.apache.org/jira/browse/FLINK-36938 Project: Flink Issue T

[jira] [Resolved] (FLINK-36928) Split the action of Epoch into two parts (trigger & final)

[ https://issues.apache.org/jira/browse/FLINK-36928?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zakelly Lan resolved FLINK-36928. - Fix Version/s: 2.0.0 Resolution: Fixed > Split the action of Epoch into two parts (trigge

[jira] [Commented] (FLINK-36928) Split the action of Epoch into two parts (trigger & final)

[ https://issues.apache.org/jira/browse/FLINK-36928?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17906989#comment-17906989 ] Zakelly Lan commented on FLINK-36928: - Merge 9e38f32 into master. > Split the actio

[jira] [Updated] (FLINK-36892) Properly handle the watermark status

[ https://issues.apache.org/jira/browse/FLINK-36892?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zakelly Lan updated FLINK-36892: Fix Version/s: 2.0.0 > Properly handle the watermark status >

[jira] [Updated] (FLINK-36875) Complete timer before emiting watermark

[ https://issues.apache.org/jira/browse/FLINK-36875?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zakelly Lan updated FLINK-36875: Fix Version/s: 2.0.0 > Complete timer before emiting watermark > -

[jira] [Commented] (FLINK-36928) Split the action of Epoch into two parts (trigger & final)

[ https://issues.apache.org/jira/browse/FLINK-36928?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17906640#comment-17906640 ] Zakelly Lan commented on FLINK-36928: - This is a complete solution & abstraction of

[jira] [Created] (FLINK-36928) Split the action of Epoch into two parts (trigger & final)

Zakelly Lan created FLINK-36928: --- Summary: Split the action of Epoch into two parts (trigger & final) Key: FLINK-36928 URL: https://issues.apache.org/jira/browse/FLINK-36928 Project: Flink Issu

[jira] [Resolved] (FLINK-36892) Properly handle the watermark status

[ https://issues.apache.org/jira/browse/FLINK-36892?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zakelly Lan resolved FLINK-36892. - Resolution: Fixed > Properly handle the watermark status >

[jira] [Commented] (FLINK-36892) Properly handle the watermark status

[ https://issues.apache.org/jira/browse/FLINK-36892?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17905873#comment-17905873 ] Zakelly Lan commented on FLINK-36892: - Merged 8aeb2ff into master. > Properly handl

[jira] [Resolved] (FLINK-36897) Error executing processElement when inheriting from AbstractAsyncStateStreamOperator

[ https://issues.apache.org/jira/browse/FLINK-36897?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zakelly Lan resolved FLINK-36897. - Resolution: Won't Do > Error executing processElement when inheriting from > AbstractAsyncState

[jira] [Commented] (FLINK-36897) Error executing processElement when inheriting from AbstractAsyncStateStreamOperator

[ https://issues.apache.org/jira/browse/FLINK-36897?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17905361#comment-17905361 ] Zakelly Lan commented on FLINK-36897: - I had a glance at your commit, in `AsyncStat

  1   2   3   4   5   6   7   >