[jira] [Commented] (FLINK-32963) Make the test "testKeyedMapStateStateMigration" stable

[ https://issues.apache.org/jira/browse/FLINK-32963?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17760699#comment-17760699 ] Hangxiang Yu commented on FLINK-32963: -- This is just a simple improvement to make t

[jira] [Commented] (FLINK-32523) NotifyCheckpointAbortedITCase.testNotifyCheckpointAborted fails with timeout on AZP

[ https://issues.apache.org/jira/browse/FLINK-32523?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17760695#comment-17760695 ] Hangxiang Yu commented on FLINK-32523: -- [~mapohl] Thanks for the reminder. I will m

[jira] [Resolved] (FLINK-32781) Release Testing: Add a metric for back-pressure from the ChangelogStateBackend

[ https://issues.apache.org/jira/browse/FLINK-32781?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hangxiang Yu resolved FLINK-32781. -- Resolution: Fixed Verified the metric in UI, just as [~Yanfei Lei] shows. > Release Testing:

[jira] [Assigned] (FLINK-30217) Use ListState#update() to replace clear + add mode.

[ https://issues.apache.org/jira/browse/FLINK-30217?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hangxiang Yu reassigned FLINK-30217: Assignee: Zakelly Lan > Use ListState#update() to replace clear + add mode. > ---

[jira] [Commented] (FLINK-30217) Use ListState#update() to replace clear + add mode.

[ https://issues.apache.org/jira/browse/FLINK-30217?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17760327#comment-17760327 ] Hangxiang Yu commented on FLINK-30217: -- [~Zakelly] Thanks for volunteering, just as

[jira] [Commented] (FLINK-26586) FileSystem uses unbuffered read I/O

[ https://issues.apache.org/jira/browse/FLINK-26586?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17759885#comment-17759885 ] Hangxiang Yu commented on FLINK-26586: -- [~Matthias Schwalbe]  Fine, Just feel free

[jira] [Resolved] (FLINK-32963) Make the test "testKeyedMapStateStateMigration" stable

[ https://issues.apache.org/jira/browse/FLINK-32963?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hangxiang Yu resolved FLINK-32963. -- Fix Version/s: 1.19.0 Resolution: Fixed merge [ab41e4f4|https://github.com/apache/flin

[jira] [Assigned] (FLINK-32975) Enhance equal() for ChangelogMapState's iterator

[ https://issues.apache.org/jira/browse/FLINK-32975?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hangxiang Yu reassigned FLINK-32975: Assignee: Rui Xia > Enhance equal() for ChangelogMapState's iterator > --

[jira] [Resolved] (FLINK-30457) Introduce period compaction to FRocksDB

[ https://issues.apache.org/jira/browse/FLINK-30457?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hangxiang Yu resolved FLINK-30457. -- Resolution: Fixed > Introduce period compaction to FRocksDB >

[jira] [Commented] (FLINK-32901) Should set initial initialSequenceNumber of StateChangelogWriter after restore

[ https://issues.apache.org/jira/browse/FLINK-32901?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17759500#comment-17759500 ] Hangxiang Yu commented on FLINK-32901: -- Hi, [~Feifan Wang] IIUC, current sequence

[jira] [Assigned] (FLINK-32955) Support state compatibility between enabling TTL and disabling TTL

[ https://issues.apache.org/jira/browse/FLINK-32955?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hangxiang Yu reassigned FLINK-32955: Assignee: Jinzhong Li > Support state compatibility between enabling TTL and disabling TT

[jira] [Assigned] (FLINK-32953) [State TTL]resolve data correctness problem after ttl was changed

[ https://issues.apache.org/jira/browse/FLINK-32953?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hangxiang Yu reassigned FLINK-32953: Assignee: Jinzhong Li > [State TTL]resolve data correctness problem after ttl was changed

[jira] [Commented] (FLINK-27681) Improve the availability of Flink when the RocksDB file is corrupted.

[ https://issues.apache.org/jira/browse/FLINK-27681?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17759475#comment-17759475 ] Hangxiang Yu commented on FLINK-27681: -- [~mayuehappy] Do you mean calling db.Verify

[jira] [Commented] (FLINK-32953) [State TTL]resolve data correctness problem after ttl was changed

[ https://issues.apache.org/jira/browse/FLINK-32953?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17759465#comment-17759465 ] Hangxiang Yu commented on FLINK-32953: -- Thanks. [~lijinzhong]  Would you like to fi

[jira] [Commented] (FLINK-32957) Add current timer trigger lag to metrics

[ https://issues.apache.org/jira/browse/FLINK-32957?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17759463#comment-17759463 ] Hangxiang Yu commented on FLINK-32957: -- IMO, This metric is not so necessary. User

[jira] [Commented] (FLINK-32963) Make the test "testKeyedMapStateStateMigration" stable

[ https://issues.apache.org/jira/browse/FLINK-32963?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17759413#comment-17759413 ] Hangxiang Yu commented on FLINK-32963: -- Thanks for reporting this. You're right. J

[jira] [Assigned] (FLINK-32963) Make the test "testKeyedMapStateStateMigration" stable

[ https://issues.apache.org/jira/browse/FLINK-32963?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hangxiang Yu reassigned FLINK-32963: Assignee: Asha Boyapati > Make the test "testKeyedMapStateStateMigration" stable > --

[jira] [Assigned] (FLINK-32954) Metrics expose number of heap timer

[ https://issues.apache.org/jira/browse/FLINK-32954?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hangxiang Yu reassigned FLINK-32954: Assignee: Rui Xia (was: Hangxiang Yu) > Metrics expose number of heap timer > --

[jira] [Commented] (FLINK-32954) Metrics expose number of heap timer

[ https://issues.apache.org/jira/browse/FLINK-32954?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17758835#comment-17758835 ] Hangxiang Yu commented on FLINK-32954: -- Thanks for reporting this. Heap timer coul

[jira] [Assigned] (FLINK-32954) Metrics expose number of heap timer

[ https://issues.apache.org/jira/browse/FLINK-32954?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hangxiang Yu reassigned FLINK-32954: Assignee: Hangxiang Yu > Metrics expose number of heap timer > --

[jira] [Commented] (FLINK-32953) [State TTL]resolve data correctness problem after ttl was changed

[ https://issues.apache.org/jira/browse/FLINK-32953?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17758820#comment-17758820 ] Hangxiang Yu commented on FLINK-32953: -- [~lijinzhong] Thanks for reporting this, th

[jira] [Assigned] (FLINK-29775) [JUnit5 Migration] Module: flink-statebackend-rocksdb

[ https://issues.apache.org/jira/browse/FLINK-29775?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hangxiang Yu reassigned FLINK-29775: Assignee: Yangyang ZHANG (was: Hangxiang Yu) > [JUnit5 Migration] Module: flink-statebac

[jira] [Resolved] (FLINK-30854) Expose periodic compaction to RocksdbCompactFilterCleanupStrategy

[ https://issues.apache.org/jira/browse/FLINK-30854?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hangxiang Yu resolved FLINK-30854. -- Fix Version/s: 1.19.0 Resolution: Fixed merge [435ae4ff|https://github.com/apache/flin

[jira] [Resolved] (FLINK-32523) NotifyCheckpointAbortedITCase.testNotifyCheckpointAborted fails with timeout on AZP

[ https://issues.apache.org/jira/browse/FLINK-32523?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hangxiang Yu resolved FLINK-32523. -- Fix Version/s: 1.18.0 Resolution: Fixed merge commits 5bbdc469d7f313768cb2d23e1e069fbf5

[jira] [Resolved] (FLINK-15014) Refactor KeyedStateInputFormat to support multiple types of user functions

[ https://issues.apache.org/jira/browse/FLINK-15014?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hangxiang Yu resolved FLINK-15014. -- Resolution: Fixed I saw the pr has been merged and the probelm should have been resolved, just

[jira] [Closed] (FLINK-19917) RocksDBInitTest.testTempLibFolderDeletedOnFail fails on Windows

[ https://issues.apache.org/jira/browse/FLINK-19917?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hangxiang Yu closed FLINK-19917. Resolution: Cannot Reproduce I closed this as it has not been reproduced more than one year, pleas

[jira] [Commented] (FLINK-20772) RocksDBValueState with TTL occurs NullPointerException when calling update(null) method

[ https://issues.apache.org/jira/browse/FLINK-20772?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17757776#comment-17757776 ] Hangxiang Yu commented on FLINK-20772: -- Hi, [~dorbae]  Sorry for the late reply.

[jira] [Closed] (FLINK-25814) AdaptiveSchedulerITCase.testStopWithSavepointFailOnFirstSavepointSucceedOnSecond failed due to stop-with-savepoint failed

[ https://issues.apache.org/jira/browse/FLINK-25814?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hangxiang Yu closed FLINK-25814. Resolution: Cannot Reproduce Closed this as not reproduced more than one year. Please reopen it if

[jira] [Commented] (FLINK-26490) Adjust the MaxParallelism or remove the MaxParallelism check when unnecessary.

[ https://issues.apache.org/jira/browse/FLINK-26490?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17757774#comment-17757774 ] Hangxiang Yu commented on FLINK-26490: -- Hi, [~liufangqi] . Just kindly ping, are y

[jira] [Closed] (FLINK-31678) NonHAQueryableStateFsBackendITCase.testAggregatingState: Query did no succeed

[ https://issues.apache.org/jira/browse/FLINK-31678?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hangxiang Yu closed FLINK-31678. Resolution: Cannot Reproduce Closed this because: # not reproduced more than 5 months # Querabl

[jira] [Commented] (FLINK-17755) Support side-output of expiring states with TTL.

[ https://issues.apache.org/jira/browse/FLINK-17755?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17757772#comment-17757772 ] Hangxiang Yu commented on FLINK-17755: -- Hi, [~roeyshemtov]  Could you also share t

[jira] [Commented] (FLINK-31970) "Key group 0 is not in KeyGroupRange" when using CheckpointedFunction

[ https://issues.apache.org/jira/browse/FLINK-31970?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17757770#comment-17757770 ] Hangxiang Yu commented on FLINK-31970: -- Hi, [~YordanPavlov]  Just kindly ping. I

[jira] [Commented] (FLINK-31053) Example Repair the log output format of the CheckpointCoordinator

[ https://issues.apache.org/jira/browse/FLINK-31053?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17757768#comment-17757768 ] Hangxiang Yu commented on FLINK-31053: -- Hi, [~xzw0223]  I saw you closed your pr,

[jira] [Commented] (FLINK-31685) Checkpoint job folder not deleted after job is cancelled

[ https://issues.apache.org/jira/browse/FLINK-31685?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17757767#comment-17757767 ] Hangxiang Yu commented on FLINK-31685: -- I just linked many related tickets. It's v

[jira] [Commented] (FLINK-31573) Nexmark performance drops in 1.17 compared to 1.13

[ https://issues.apache.org/jira/browse/FLINK-31573?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17757765#comment-17757765 ] Hangxiang Yu commented on FLINK-31573: -- Hi, [~renqs]  Just kindly ping. What's the

[jira] [Commented] (FLINK-6485) Use buffering to avoid frequent memtable flushes for short intervals in RockdDB incremental checkpoints

[ https://issues.apache.org/jira/browse/FLINK-6485?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17757764#comment-17757764 ] Hangxiang Yu commented on FLINK-6485: - IIUC, ChangelogStateBackend ([Generalized incr

[jira] [Closed] (FLINK-22937) rocksdb cause jvm to crash

[ https://issues.apache.org/jira/browse/FLINK-22937?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hangxiang Yu closed FLINK-22937. Resolution: Cannot Reproduce Closed this as no response more than two years and lacking enough inf

[jira] [Commented] (FLINK-32781) Release Testing: Add a metric for back-pressure from the ChangelogStateBackend

[ https://issues.apache.org/jira/browse/FLINK-32781?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17757313#comment-17757313 ] Hangxiang Yu commented on FLINK-32781: -- [~Yanfei Lei] Sure, I will help to verify t

[jira] [Commented] (FLINK-26586) FileSystem uses unbuffered read I/O

[ https://issues.apache.org/jira/browse/FLINK-26586?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17756767#comment-17756767 ] Hangxiang Yu commented on FLINK-26586: -- [~fanrui] Thanks for the quick reply, That

[jira] [Commented] (FLINK-26586) FileSystem uses unbuffered read I/O

[ https://issues.apache.org/jira/browse/FLINK-26586?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17756705#comment-17756705 ] Hangxiang Yu commented on FLINK-26586: -- [~Matthias Schwalbe]  Thanks for the remind

[jira] [Commented] (FLINK-32275) The return value of PartitionableListState#get is inconsistent with the requirements of AppendingState

[ https://issues.apache.org/jira/browse/FLINK-32275?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17755842#comment-17755842 ] Hangxiang Yu commented on FLINK-32275: -- I looked into related interface and impleme

[jira] [Closed] (FLINK-6814) Store information about whether or not a registered state is queryable in checkpoints

[ https://issues.apache.org/jira/browse/FLINK-6814?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hangxiang Yu closed FLINK-6814. --- Resolution: Won't Fix Besides [~mapohl] said, The Querable State is marked as deprecated in 1.18, I

[jira] [Resolved] (FLINK-15719) Exceptions when using scala types directly with the State Process API

[ https://issues.apache.org/jira/browse/FLINK-15719?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hangxiang Yu resolved FLINK-15719. -- Resolution: Fixed I saw the pr is merged and the problem should have been resolved, I just mar

[jira] [Commented] (FLINK-32658) State should not be silently removed when ignore-unclaimed-state is false

[ https://issues.apache.org/jira/browse/FLINK-32658?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17755792#comment-17755792 ] Hangxiang Yu commented on FLINK-32658: -- Thanks a lot for the proposal, I think it m

[jira] [Resolved] (FLINK-6027) Ignore the exception thrown by the subsuming of old completed checkpoints

[ https://issues.apache.org/jira/browse/FLINK-6027?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hangxiang Yu resolved FLINK-6027. - Resolution: Fixed I saw the pr is merged and the problem has been resolved, just marked as resol

[jira] [Closed] (FLINK-4620) Automatically creating savepoints

[ https://issues.apache.org/jira/browse/FLINK-4620?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hangxiang Yu closed FLINK-4620. --- Resolution: Not A Problem Close this as no intention in this direction just like FLINK-4511. Consider

[jira] [Commented] (FLINK-4620) Automatically creating savepoints

[ https://issues.apache.org/jira/browse/FLINK-4620?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17755783#comment-17755783 ] Hangxiang Yu commented on FLINK-4620: - Close this as no intention in this direction j

[jira] (FLINK-4620) Automatically creating savepoints

[ https://issues.apache.org/jira/browse/FLINK-4620 ] Hangxiang Yu deleted comment on FLINK-4620: - was (Author: masteryhx): Close this as no intention in this direction just like FLINK-4511. Considering current design of checkpoint and savepoint,

[jira] [Closed] (FLINK-26196) error when Incremental Checkpoints by RocksDb

[ https://issues.apache.org/jira/browse/FLINK-26196?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hangxiang Yu closed FLINK-26196. Resolution: Cannot Reproduce Hi, [~hjw]  I closed this due to lacking more specific information an

[jira] [Commented] (FLINK-15424) Make all AppendingState#add respect the java doc

[ https://issues.apache.org/jira/browse/FLINK-15424?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17755777#comment-17755777 ] Hangxiang Yu commented on FLINK-15424: -- Hi, [~klion26]  I saw this problem still e

[jira] [Commented] (FLINK-13194) Add explicit clarification about thread-safety of state in document

[ https://issues.apache.org/jira/browse/FLINK-13194?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17755776#comment-17755776 ] Hangxiang Yu commented on FLINK-13194: -- Hi, [~yunta]  Kindly ping. Are you still wo

[jira] [Commented] (FLINK-26586) FileSystem uses unbuffered read I/O

[ https://issues.apache.org/jira/browse/FLINK-26586?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17755775#comment-17755775 ] Hangxiang Yu commented on FLINK-26586: -- Hi, [~Matthias Schwalbe] , I think it makes

[jira] [Comment Edited] (FLINK-29328) 【Flink is having problems using the status expiration setting】

[ https://issues.apache.org/jira/browse/FLINK-29328?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17755772#comment-17755772 ] Hangxiang Yu edited comment on FLINK-29328 at 8/18/23 2:31 AM: ---

[jira] [Closed] (FLINK-29328) 【Flink is having problems using the status expiration setting】

[ https://issues.apache.org/jira/browse/FLINK-29328?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hangxiang Yu closed FLINK-29328. Resolution: Not A Bug Hi, [~Jason_H]  I aggree with [~yunta] , this exception is only be thrown wh

[jira] [Commented] (FLINK-28819) The natural time of day TTL

[ https://issues.apache.org/jira/browse/FLINK-28819?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17755768#comment-17755768 ] Hangxiang Yu commented on FLINK-28819: -- Hi，[~kcz]  Could you also share your speci

[jira] [Commented] (FLINK-27681) Improve the availability of Flink when the RocksDB file is corrupted.

[ https://issues.apache.org/jira/browse/FLINK-27681?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17755766#comment-17755766 ] Hangxiang Yu commented on FLINK-27681: -- Hi, [~Ming Li] Thanks for reporting this. W

[jira] [Commented] (FLINK-32881) Client supports making savepoints in detach mode

[ https://issues.apache.org/jira/browse/FLINK-32881?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17755763#comment-17755763 ] Hangxiang Yu commented on FLINK-32881: -- [~zhourenxiang] Sure, assigned to you, plea

[jira] [Assigned] (FLINK-32881) Client supports making savepoints in detach mode

[ https://issues.apache.org/jira/browse/FLINK-32881?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hangxiang Yu reassigned FLINK-32881: Assignee: Renxiang Zhou (was: Hangxiang Yu) > Client supports making savepoints in detac

[jira] [Assigned] (FLINK-32881) Client supports making savepoints in detach mode

[ https://issues.apache.org/jira/browse/FLINK-32881?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hangxiang Yu reassigned FLINK-32881: Assignee: Hangxiang Yu > Client supports making savepoints in detach mode > -

[jira] [Closed] (FLINK-23636) NotifyCheckpointAbortedITCase.testNotifyCheckpointAborted fails on azure

[ https://issues.apache.org/jira/browse/FLINK-23636?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hangxiang Yu closed FLINK-23636. Fix Version/s: (was: 1.13.7) Resolution: Duplicate It's duplicated by FLINK-32523 All c

[jira] [Commented] (FLINK-32881) Client supports making savepoints in detach mode

[ https://issues.apache.org/jira/browse/FLINK-32881?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17755391#comment-17755391 ] Hangxiang Yu commented on FLINK-32881: -- Hi, [~zhourenxiang]  We often use asyc thre

[jira] [Updated] (FLINK-32881) Client supports making savepoints in detach mode

[ https://issues.apache.org/jira/browse/FLINK-32881?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hangxiang Yu updated FLINK-32881: - Component/s: Runtime / Checkpointing (was: API / State Processor) > Client

[jira] [Updated] (FLINK-27481) Flink checkpoints are very slow after upgrading from Flink 1.13.1 to Flink 1.14.3

[ https://issues.apache.org/jira/browse/FLINK-27481?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hangxiang Yu updated FLINK-27481: - Component/s: Connectors / Kafka > Flink checkpoints are very slow after upgrading from Flink 1.1

[jira] [Commented] (FLINK-31474) Add failure information for out-of-order checkpoints

[ https://issues.apache.org/jira/browse/FLINK-31474?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17755019#comment-17755019 ] Hangxiang Yu commented on FLINK-31474: -- Hi, [~Ming Li]  I think it makes sense.  Wo

[jira] [Closed] (FLINK-26154) SavepointFormatITCase times out on azure

[ https://issues.apache.org/jira/browse/FLINK-26154?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hangxiang Yu closed FLINK-26154. Resolution: Cannot Reproduce Since it has not been reproduced beyond one year, I closed it. Please

[jira] [Commented] (FLINK-26585) State Processor API: Loading a state set buffers the whole state set in memory before starting to process

[ https://issues.apache.org/jira/browse/FLINK-26585?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17754928#comment-17754928 ] Hangxiang Yu commented on FLINK-26585: -- [~Matthias Schwalbe]  Sure, That is great.

[jira] [Assigned] (FLINK-26585) State Processor API: Loading a state set buffers the whole state set in memory before starting to process

[ https://issues.apache.org/jira/browse/FLINK-26585?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hangxiang Yu reassigned FLINK-26585: Assignee: Matthias Schwalbe > State Processor API: Loading a state set buffers the whole

[jira] [Commented] (FLINK-32485) Flink State Backend Changelog should support build test-jar

[ https://issues.apache.org/jira/browse/FLINK-32485?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17754874#comment-17754874 ] Hangxiang Yu commented on FLINK-32485: -- Hi, [~taoran]  Changelog test code has not

[jira] [Closed] (FLINK-27311) Rocksdb mapstate behaves unexpectedly

[ https://issues.apache.org/jira/browse/FLINK-27311?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hangxiang Yu closed FLINK-27311. Resolution: Not A Bug Hi [~JonathanDiamant] , I think it should not happen IIUC. Just as [~yunta]

[jira] [Closed] (FLINK-32599) Benchmarks in Slack have failed consistently since 2023-07-14

[ https://issues.apache.org/jira/browse/FLINK-32599?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hangxiang Yu closed FLINK-32599. Resolution: Fixed Since it has been fixed and #flink-dev-benchmarks channel works well now, I clo

[jira] [Closed] (FLINK-25938) SynchronousCheckpointITCase.taskDispatcherThreadPoolAllowsForSynchronousCheckpoints fails on AZP

[ https://issues.apache.org/jira/browse/FLINK-25938?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hangxiang Yu closed FLINK-25938. Resolution: Cannot Reproduce Since the issue was not reproduced beyond one year, I just closed it.

[jira] [Commented] (FLINK-25835) The task initialization duration is recorded in logs

[ https://issues.apache.org/jira/browse/FLINK-25835?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17754663#comment-17754663 ] Hangxiang Yu commented on FLINK-25835: -- Hi, [~Bo Cui]  FLINK-19010 has added the re

[jira] [Closed] (FLINK-25747) UdfStreamOperatorCheckpointingITCase hangs on AZP

[ https://issues.apache.org/jira/browse/FLINK-25747?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hangxiang Yu closed FLINK-25747. Resolution: Cannot Reproduce Since the issue was not reproduced beyond one year, I just closed it.

[jira] [Closed] (FLINK-25675) UnalignedCheckpointCompatibilityITCase.test hangs on AZP

[ https://issues.apache.org/jira/browse/FLINK-25675?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hangxiang Yu closed FLINK-25675. Resolution: Cannot Reproduce Since the issue was not reproduced beyond one year, I just closed it.

[jira] [Closed] (FLINK-27918) SavepointITCase.testStopWithSavepointFailingAfterSnapshotCreation failed with Expected RuntimeException after snapshot creation

[ https://issues.apache.org/jira/browse/FLINK-27918?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hangxiang Yu closed FLINK-27918. Resolution: Cannot Reproduce Since the issue was not reproduced beyond one year, I just closed it.

[jira] [Closed] (FLINK-25621) LegacyStatefulJobSavepointMigrationITCase failed on azure with exit code 127

[ https://issues.apache.org/jira/browse/FLINK-25621?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hangxiang Yu closed FLINK-25621. Resolution: Cannot Reproduce Since the issue was not reproduced beyond one year, I just closed it.

[jira] [Closed] (FLINK-27073) HAQueryableStateFsBackendITCase hangs on azure

[ https://issues.apache.org/jira/browse/FLINK-27073?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hangxiang Yu closed FLINK-27073. Resolution: Cannot Reproduce Since the issue was not reproduced beyond one year, and the querable

[jira] [Commented] (FLINK-22805) Dynamic configuration of Flink checkpoint interval

[ https://issues.apache.org/jira/browse/FLINK-22805?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17754495#comment-17754495 ] Hangxiang Yu commented on FLINK-22805: -- [~okowr]  Hi, I think FLINK-32514 could hel

[jira] [Updated] (FLINK-26585) State Processor API: Loading a state set buffers the whole state set in memory before starting to process

[ https://issues.apache.org/jira/browse/FLINK-26585?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hangxiang Yu updated FLINK-26585: - Issue Type: Improvement (was: Bug) > State Processor API: Loading a state set buffers the whole

[jira] [Commented] (FLINK-26585) State Processor API: Loading a state set buffers the whole state set in memory before starting to process

[ https://issues.apache.org/jira/browse/FLINK-26585?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17754401#comment-17754401 ] Hangxiang Yu commented on FLINK-26585: -- [~Matthias Schwalbe]  Hi, Thanks for report

[jira] [Commented] (FLINK-32523) NotifyCheckpointAbortedITCase.testNotifyCheckpointAborted fails with timeout on AZP

[ https://issues.apache.org/jira/browse/FLINK-32523?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17750368#comment-17750368 ] Hangxiang Yu commented on FLINK-32523: -- >From the exception stack and attached logs

[jira] [Commented] (FLINK-25322) Support no-claim mode in changelog state backend

[ https://issues.apache.org/jira/browse/FLINK-25322?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17750150#comment-17750150 ] Hangxiang Yu commented on FLINK-25322: -- {quote}But I don't think this adds complexi

[jira] [Commented] (FLINK-31238) Use IngestDB to speed up Rocksdb rescaling recovery

[ https://issues.apache.org/jira/browse/FLINK-31238?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17750127#comment-17750127 ] Hangxiang Yu commented on FLINK-31238: -- [~mayuehappy] Thanks a lot for your efforts

[jira] [Commented] (FLINK-25322) Support no-claim mode in changelog state backend

[ https://issues.apache.org/jira/browse/FLINK-25322?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17746184#comment-17746184 ] Hangxiang Yu commented on FLINK-25322: -- Hi, [~Feifan Wang]. Sorry for the late repl

[jira] [Commented] (FLINK-32643) Introduce off-heap shared state cache across stateful operators in TM

[ https://issues.apache.org/jira/browse/FLINK-32643?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17746180#comment-17746180 ] Hangxiang Yu commented on FLINK-32643: -- Hi, Thanks for the proposal. I have some qu

[jira] [Commented] (FLINK-32599) Benchmarks in Slack have failed consistently since 2023-07-14

[ https://issues.apache.org/jira/browse/FLINK-32599?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17743684#comment-17743684 ] Hangxiang Yu commented on FLINK-32599: -- The later PR has been merged, the CI has be

[jira] [Created] (FLINK-32601) Unstable RemoteChannelThroughputBenchmark_remoteRebalance_jmhTest

Hangxiang Yu created FLINK-32601: Summary: Unstable RemoteChannelThroughputBenchmark_remoteRebalance_jmhTest Key: FLINK-32601 URL: https://issues.apache.org/jira/browse/FLINK-32601 Project: Flink

[jira] [Commented] (FLINK-32480) Keyed State always returns new value instance

[ https://issues.apache.org/jira/browse/FLINK-32480?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17740004#comment-17740004 ] Hangxiang Yu commented on FLINK-32480: -- Hi, The object cannot be reused as default.

[jira] [Assigned] (FLINK-23485) Add a benchmark for the Changelog DFS writer

[ https://issues.apache.org/jira/browse/FLINK-23485?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hangxiang Yu reassigned FLINK-23485: Assignee: Hangxiang Yu > Add a benchmark for the Changelog DFS writer > -

[jira] [Assigned] (FLINK-23484) Add benchmarks for the ChangelogStateBackend

[ https://issues.apache.org/jira/browse/FLINK-23484?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hangxiang Yu reassigned FLINK-23484: Assignee: Hangxiang Yu > Add benchmarks for the ChangelogStateBackend > -

[jira] [Assigned] (FLINK-23485) Add a benchmark for the Changelog DFS writer

[ https://issues.apache.org/jira/browse/FLINK-23485?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hangxiang Yu reassigned FLINK-23485: Assignee: (was: Hangxiang Yu) > Add a benchmark for the Changelog DFS writer > --

[jira] [Created] (FLINK-32364) Add Rescaling benchmark for ChangelogStateBackend

Hangxiang Yu created FLINK-32364: Summary: Add Rescaling benchmark for ChangelogStateBackend Key: FLINK-32364 URL: https://issues.apache.org/jira/browse/FLINK-32364 Project: Flink Issue Type:

[jira] [Comment Edited] (FLINK-32275) The return value of PartitionableListState#get is inconsistent with the requirements of AppendingState

[ https://issues.apache.org/jira/browse/FLINK-32275?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17730070#comment-17730070 ] Hangxiang Yu edited comment on FLINK-32275 at 6/8/23 2:21 AM:

[jira] [Commented] (FLINK-32275) The return value of PartitionableListState#get is inconsistent with the requirements of AppendingState

[ https://issues.apache.org/jira/browse/FLINK-32275?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17730070#comment-17730070 ] Hangxiang Yu commented on FLINK-32275: -- Thanks for reporting this. I think it's rea

[jira] [Comment Edited] (FLINK-32241) UnsupportedFileSystemException when using the ABFS Hadoop driver for checkpointing in Flink 1.17

[ https://issues.apache.org/jira/browse/FLINK-32241?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17729240#comment-17729240 ] Hangxiang Yu edited comment on FLINK-32241 at 6/6/23 2:28 AM:

[jira] [Commented] (FLINK-32241) UnsupportedFileSystemException when using the ABFS Hadoop driver for checkpointing in Flink 1.17

[ https://issues.apache.org/jira/browse/FLINK-32241?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17729240#comment-17729240 ] Hangxiang Yu commented on FLINK-32241: -- +1 it's similar to FLINK-30635. setting {{f

[jira] [Updated] (FLINK-30635) Fail to recover for row-format when writing to OSS using FileSystemTable connector

[ https://issues.apache.org/jira/browse/FLINK-30635?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hangxiang Yu updated FLINK-30635: - Component/s: FileSystems > Fail to recover for row-format when writing to OSS using FileSystemTa

[jira] [Commented] (FLINK-30635) Fail to recover for row-format when writing to OSS using FileSystemTable connector

[ https://issues.apache.org/jira/browse/FLINK-30635?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17729239#comment-17729239 ] Hangxiang Yu commented on FLINK-30635: -- Hi, [~luoyuxia] , LocalFileSystem of hadoop

[jira] [Updated] (FLINK-32241) UnsupportedFileSystemException when using the ABFS Hadoop driver for checkpointing in Flink 1.17

[ https://issues.apache.org/jira/browse/FLINK-32241?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hangxiang Yu updated FLINK-32241: - Component/s: FileSystems > UnsupportedFileSystemException when using the ABFS Hadoop driver for

[jira] [Commented] (FLINK-32227) Optimize code styles

[ https://issues.apache.org/jira/browse/FLINK-32227?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17728548#comment-17728548 ] Hangxiang Yu commented on FLINK-32227: -- Hi, [~zhihao song] Could you add more descr

<    1   2   3   4   5   >