[
https://issues.apache.org/jira/browse/FLINK-35382?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17847783#comment-17847783
]
Jinzhong Li commented on FLINK-35382:
-
1. Because FLINK-32085 has not been resolved,
[
https://issues.apache.org/jira/browse/FLINK-32955?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17855470#comment-17855470
]
Jinzhong Li commented on FLINK-32955:
-
[~xiangyu0xf] Thanks for your volunteering.
[
https://issues.apache.org/jira/browse/FLINK-35853?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17867159#comment-17867159
]
Jinzhong Li commented on FLINK-35853:
-
[~leekeiabstraction]
I think this is due to
Jinzhong Li created FLINK-35897:
---
Summary: Some checkpoint files and localState files can't be
cleanUp when checkpoint is aborted
Key: FLINK-35897
URL: https://issues.apache.org/jira/browse/FLINK-35897
[
https://issues.apache.org/jira/browse/FLINK-35897?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jinzhong Li updated FLINK-35897:
Description:
h2. Problem
When the job checkpoint is canceled
([asyncsnapshotcallable.java/#L129|
[
https://issues.apache.org/jira/browse/FLINK-35897?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jinzhong Li updated FLINK-35897:
Description:
h2. Problem
When the job checkpoint is canceled
([asyncsnapshotcallable.java/#L129|
[
https://issues.apache.org/jira/browse/FLINK-35897?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jinzhong Li updated FLINK-35897:
Description:
h2. Problem
When the job checkpoint is canceled
([asyncsnapshotcallable.java/#L129|
[
https://issues.apache.org/jira/browse/FLINK-18255?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17826962#comment-17826962
]
Jinzhong Li commented on FLINK-18255:
-
I don't have permission to change the fix ver
Jinzhong Li created FLINK-34670:
---
Summary: Use SynchronousQueue to create asyncOperationsThreadPool
for SubtaskCheckpointCoordinatorImpl
Key: FLINK-34670
URL: https://issues.apache.org/jira/browse/FLINK-34670
[
https://issues.apache.org/jira/browse/FLINK-34670?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jinzhong Li updated FLINK-34670:
Description:
Now, the asyncOperations ThreadPoolExecutor of SubtaskCheckpointCoordinatorImpl
is c
[
https://issues.apache.org/jira/browse/FLINK-34670?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jinzhong Li updated FLINK-34670:
Description:
Now, the asyncOperations ThreadPoolExecutor of SubtaskCheckpointCoordinatorImpl
is c
[
https://issues.apache.org/jira/browse/FLINK-34670?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17827083#comment-17827083
]
Jinzhong Li commented on FLINK-34670:
-
This issue seems to be a bug from
[FLINK-302
[
https://issues.apache.org/jira/browse/FLINK-34670?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jinzhong Li updated FLINK-34670:
Priority: Critical (was: Major)
> Use SynchronousQueue to create asyncOperationsThreadPool for
>
[
https://issues.apache.org/jira/browse/FLINK-34670?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jinzhong Li updated FLINK-34670:
Summary: The asyncOperationsThreadPool in SubtaskCheckpointCoordinatorImpl
can only create one wor
[
https://issues.apache.org/jira/browse/FLINK-34670?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jinzhong Li updated FLINK-34670:
Description:
Now, the asyncOperations ThreadPoolExecutor of SubtaskCheckpointCoordinatorImpl
is c
[
https://issues.apache.org/jira/browse/FLINK-34670?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jinzhong Li updated FLINK-34670:
Description:
Now, the asyncOperations ThreadPoolExecutor of SubtaskCheckpointCoordinatorImpl
is c
Jinzhong Li created FLINK-34936:
---
Summary: Register shared state files to FileMergingSnapshotManager
Key: FLINK-34936
URL: https://issues.apache.org/jira/browse/FLINK-34936
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-34936?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jinzhong Li updated FLINK-34936:
Parent: FLINK-32070
Issue Type: Sub-task (was: New Feature)
> Register shared state files
[
https://issues.apache.org/jira/browse/FLINK-34670?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jinzhong Li updated FLINK-34670:
Description:
Now, the asyncOperations ThreadPoolExecutor of SubtaskCheckpointCoordinatorImpl
is c
[
https://issues.apache.org/jira/browse/FLINK-34670?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17831334#comment-17831334
]
Jinzhong Li commented on FLINK-34670:
-
[~roman] [~pnowojski] I think this is a c
[
https://issues.apache.org/jira/browse/FLINK-34670?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17831334#comment-17831334
]
Jinzhong Li edited comment on FLINK-34670 at 3/27/24 12:57 PM:
---
Jinzhong Li created FLINK-34981:
---
Summary: FLIP-426: Grouping Remote State Access
Key: FLINK-34981
URL: https://issues.apache.org/jira/browse/FLINK-34981
Project: Flink
Issue Type: New Feature
Jinzhong Li created FLINK-34982:
---
Summary: FLIP-428: Fault Tolerance/Rescale Integration for
Disaggregated State
Key: FLINK-34982
URL: https://issues.apache.org/jira/browse/FLINK-34982
Project: Flink
Jinzhong Li created FLINK-35069:
---
Summary: ContinuousProcessingTimeTrigger continuously registers
timers in a loop at the end of the window
Key: FLINK-35069
URL: https://issues.apache.org/jira/browse/FLINK-35069
[
https://issues.apache.org/jira/browse/FLINK-35069?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jinzhong Li updated FLINK-35069:
Affects Version/s: 1.7.2
> ContinuousProcessingTimeTrigger continuously registers timers in a loop
[
https://issues.apache.org/jira/browse/FLINK-35069?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jinzhong Li updated FLINK-35069:
Affects Version/s: 1.17.0
(was: 1.7.2)
> ContinuousProcessingTimeTrigge
[
https://issues.apache.org/jira/browse/FLINK-35069?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jinzhong Li updated FLINK-35069:
Description:
In our production environment, when TumblingEventTimeWindows and
ContinuousProcessi
[
https://issues.apache.org/jira/browse/FLINK-35069?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17835406#comment-17835406
]
Jinzhong Li commented on FLINK-35069:
-
cc [~guoweijie] Could you please take a look
[
https://issues.apache.org/jira/browse/FLINK-35069?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17835406#comment-17835406
]
Jinzhong Li edited comment on FLINK-35069 at 4/9/24 12:51 PM:
Jinzhong Li created FLINK-35125:
---
Summary: Implement ValueState for ForStStateBackend
Key: FLINK-35125
URL: https://issues.apache.org/jira/browse/FLINK-35125
Project: Flink
Issue Type: Sub-task
Jinzhong Li created FLINK-35161:
---
Summary: Implement StateExecutor for ForStStateBackend
Key: FLINK-35161
URL: https://issues.apache.org/jira/browse/FLINK-35161
Project: Flink
Issue Type: Sub-t
Jinzhong Li created FLINK-35162:
---
Summary: Support grouping state get and put access
Key: FLINK-35162
URL: https://issues.apache.org/jira/browse/FLINK-35162
Project: Flink
Issue Type: Sub-task
Jinzhong Li created FLINK-35163:
---
Summary: Utilize ForSt's native MultiGet API to optimize remote
state access
Key: FLINK-35163
URL: https://issues.apache.org/jira/browse/FLINK-35163
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-35162?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jinzhong Li updated FLINK-35162:
Component/s: Runtime / State Backends
> Support grouping state get and put access
> --
[
https://issues.apache.org/jira/browse/FLINK-35163?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jinzhong Li updated FLINK-35163:
Component/s: Runtime / State Backends
> Utilize ForSt's native MultiGet API to optimize remote sta
[
https://issues.apache.org/jira/browse/FLINK-35161?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jinzhong Li updated FLINK-35161:
Component/s: Runtime / State Backends
> Implement StateExecutor for ForStStateBackend
> --
[
https://issues.apache.org/jira/browse/FLINK-35178?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17839458#comment-17839458
]
Jinzhong Li commented on FLINK-35178:
-
[~elon] Thanks for reporting this.
For case
[
https://issues.apache.org/jira/browse/FLINK-25094?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jinzhong Li updated FLINK-25094:
Description:
In LatencyTrackingMapStateTest,
iterator()/entries().iterator()/keys().iterator()/va
Jinzhong Li created FLINK-25094:
---
Summary: The verify code in
LatencyTrackingMapStateTest#verifyIterator is not actually executed
Key: FLINK-25094
URL: https://issues.apache.org/jira/browse/FLINK-25094
[
https://issues.apache.org/jira/browse/FLINK-28863?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17625402#comment-17625402
]
Jinzhong Li commented on FLINK-28863:
-
In my opinion, for Rocksdb native savepoint S
[
https://issues.apache.org/jira/browse/FLINK-28863?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17627484#comment-17627484
]
Jinzhong Li commented on FLINK-28863:
-
[~yunta]
1. I found that the changes I meti
[
https://issues.apache.org/jira/browse/FLINK-28863?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17627484#comment-17627484
]
Jinzhong Li edited comment on FLINK-28863 at 11/2/22 6:45 AM:
[
https://issues.apache.org/jira/browse/FLINK-28863?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17648326#comment-17648326
]
Jinzhong Li commented on FLINK-28863:
-
[~yunta] Yes, that is. And +1 for keeping th
[
https://issues.apache.org/jira/browse/FLINK-28515?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17569789#comment-17569789
]
Jinzhong Li commented on FLINK-28515:
-
Thanks for reply [~roman]
>> "if the AsyncS
[
https://issues.apache.org/jira/browse/FLINK-28515?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jinzhong Li updated FLINK-28515:
Description:
In my case, i found that some files in local recovery directory hasn't be
clean up
[
https://issues.apache.org/jira/browse/FLINK-28515?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jinzhong Li updated FLINK-28515:
Description:
In my case, i found that some files in local recovery directory hasn't be
clean up
[
https://issues.apache.org/jira/browse/FLINK-28515?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17569936#comment-17569936
]
Jinzhong Li commented on FLINK-28515:
-
Thanks for reply [~roman]
I'd like to expla
[
https://issues.apache.org/jira/browse/FLINK-28515?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17569936#comment-17569936
]
Jinzhong Li edited comment on FLINK-28515 at 7/22/22 10:36 AM:
---
[
https://issues.apache.org/jira/browse/FLINK-28515?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17569936#comment-17569936
]
Jinzhong Li edited comment on FLINK-28515 at 7/22/22 10:38 AM:
---
[
https://issues.apache.org/jira/browse/FLINK-28515?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17569936#comment-17569936
]
Jinzhong Li edited comment on FLINK-28515 at 7/22/22 10:38 AM:
---
Jinzhong Li created FLINK-28515:
---
Summary: The files in local recovery directory hasn't be clean up
properly after checkpoint abort
Key: FLINK-28515
URL: https://issues.apache.org/jira/browse/FLINK-28515
[
https://issues.apache.org/jira/browse/FLINK-28515?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17566131#comment-17566131
]
Jinzhong Li commented on FLINK-28515:
-
[~roman] [~yunta] Could you please take a loo
[
https://issues.apache.org/jira/browse/FLINK-28515?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17566293#comment-17566293
]
Jinzhong Li commented on FLINK-28515:
-
Thanks for your reply [~roman] . For your co
[ https://issues.apache.org/jira/browse/FLINK-28515 ]
Jinzhong Li deleted comment on FLINK-28515:
-
was (Author: lijinzhong):
Thanks for your reply [~roman] . For your concerns, i think:
1. Because the taskStateSnapshot of aborted checkpoint m
[
https://issues.apache.org/jira/browse/FLINK-28515?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jinzhong Li updated FLINK-28515:
Attachment: image-2022-07-19-18-28-20-239.png
> The files in local recovery directory hasn't be cl
[
https://issues.apache.org/jira/browse/FLINK-28515?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17568458#comment-17568458
]
Jinzhong Li commented on FLINK-28515:
-
[~roman] I thought about this problem again
[
https://issues.apache.org/jira/browse/FLINK-28515?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17568458#comment-17568458
]
Jinzhong Li edited comment on FLINK-28515 at 7/19/22 10:32 AM:
---
Jinzhong Li created FLINK-25314:
---
Summary: Update log4j2 version to 2.16.0
Key: FLINK-25314
URL: https://issues.apache.org/jira/browse/FLINK-25314
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-25314?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jinzhong Li closed FLINK-25314.
---
Resolution: Fixed
> Update log4j2 version to 2.16.0
> ---
>
>
[
https://issues.apache.org/jira/browse/FLINK-25314?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jinzhong Li updated FLINK-25314:
Priority: Not a Priority (was: Major)
> Update log4j2 version to 2.16.0
> ---
[
https://issues.apache.org/jira/browse/FLINK-25314?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17459637#comment-17459637
]
Jinzhong Li commented on FLINK-25314:
-
duplicate with FLINK-25295 and close it
> Up
[
https://issues.apache.org/jira/browse/FLINK-34050?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17819257#comment-17819257
]
Jinzhong Li commented on FLINK-34050:
-
[~srichter] Thanks for your comments. I thi
[
https://issues.apache.org/jira/browse/FLINK-18255?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17819478#comment-17819478
]
Jinzhong Li commented on FLINK-18255:
-
[~yunta] [~Yanfei Lei] I have drafted a f
[
https://issues.apache.org/jira/browse/FLINK-34050?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17819579#comment-17819579
]
Jinzhong Li commented on FLINK-34050:
-
Here are the benchmark results before and aft
[
https://issues.apache.org/jira/browse/FLINK-34050?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17819579#comment-17819579
]
Jinzhong Li edited comment on FLINK-34050 at 2/22/24 10:24 AM:
---
[
https://issues.apache.org/jira/browse/FLINK-34050?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17819579#comment-17819579
]
Jinzhong Li edited comment on FLINK-34050 at 2/22/24 10:28 AM:
---
[
https://issues.apache.org/jira/browse/FLINK-34050?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17819579#comment-17819579
]
Jinzhong Li edited comment on FLINK-34050 at 2/22/24 10:29 AM:
---
[
https://issues.apache.org/jira/browse/FLINK-34050?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17819579#comment-17819579
]
Jinzhong Li edited comment on FLINK-34050 at 2/22/24 10:30 AM:
---
[
https://issues.apache.org/jira/browse/FLINK-34050?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17819579#comment-17819579
]
Jinzhong Li edited comment on FLINK-34050 at 2/22/24 10:31 AM:
---
[
https://issues.apache.org/jira/browse/FLINK-34050?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17819579#comment-17819579
]
Jinzhong Li edited comment on FLINK-34050 at 2/22/24 10:33 AM:
---
[
https://issues.apache.org/jira/browse/FLINK-34050?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17819579#comment-17819579
]
Jinzhong Li edited comment on FLINK-34050 at 2/22/24 10:36 AM:
---
[
https://issues.apache.org/jira/browse/FLINK-34050?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17821623#comment-17821623
]
Jinzhong Li commented on FLINK-34050:
-
commit 534ea31 and b048a9c has been merged
[
https://issues.apache.org/jira/browse/FLINK-34050?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jinzhong Li resolved FLINK-34050.
-
Fix Version/s: 1.20.0
Resolution: Fixed
> Rocksdb state has space amplification after res
[
https://issues.apache.org/jira/browse/FLINK-32953?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jinzhong Li updated FLINK-32953:
Fix Version/s: (was: 1.20.0)
> [State TTL]resolve data correctness problem after ttl was chang
[
https://issues.apache.org/jira/browse/FLINK-34032?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17804570#comment-17804570
]
Jinzhong Li commented on FLINK-34032:
-
Hi [~masteryhx] , would you please clarify th
[
https://issues.apache.org/jira/browse/FLINK-33881?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17804975#comment-17804975
]
Jinzhong Li commented on FLINK-33881:
-
[~Zakelly] [~masteryhx]
I have published a
[
https://issues.apache.org/jira/browse/FLINK-33881?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17805110#comment-17805110
]
Jinzhong Li commented on FLINK-33881:
-
[~Zakelly] I have done the performance testi
[
https://issues.apache.org/jira/browse/FLINK-33881?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17805110#comment-17805110
]
Jinzhong Li edited comment on FLINK-33881 at 1/10/24 12:29 PM:
---
Jinzhong Li created FLINK-34050:
---
Summary: Rocksdb state has space amplification after rescaling
with DeleteRange
Key: FLINK-34050
URL: https://issues.apache.org/jira/browse/FLINK-34050
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-34050?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17806599#comment-17806599
]
Jinzhong Li commented on FLINK-34050:
-
Thanks for your reply. [~mayuehappy] [~mast
Jinzhong Li created FLINK-34078:
---
Summary: Move InternalKeyContext classes from
o.a.f.runtime.state.heap to o.a.f.runtime.state package
Key: FLINK-34078
URL: https://issues.apache.org/jira/browse/FLINK-34078
[
https://issues.apache.org/jira/browse/FLINK-18255?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17807522#comment-17807522
]
Jinzhong Li commented on FLINK-18255:
-
I think this issue still exist in 1.19. I wan
[
https://issues.apache.org/jira/browse/FLINK-25400?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17784691#comment-17784691
]
Jinzhong Li commented on FLINK-25400:
-
I think this issue still exits in 1.19.
The
Jinzhong Li created FLINK-33881:
---
Summary: [TtlListState]Avoid copy and update value when
TtlListState don‘t have expired element
Key: FLINK-33881
URL: https://issues.apache.org/jira/browse/FLINK-33881
[
https://issues.apache.org/jira/browse/FLINK-33881?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jinzhong Li updated FLINK-33881:
Summary: [TtlListState]Avoid copy and update value in
TtlListState#getUnexpiredOrNull (was: [TtlL
[
https://issues.apache.org/jira/browse/FLINK-33881?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jinzhong Li updated FLINK-33881:
Description:
In some scenarios, 'TtlListState#getUnexpiredOrNull ->
elementSerializer.copy(ttlVal
[
https://issues.apache.org/jira/browse/FLINK-33881?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jinzhong Li updated FLINK-33881:
Description:
In some scenarios, 'TtlListState#getUnexpiredOrNull ->
elementSerializer.copy(ttlVal
[
https://issues.apache.org/jira/browse/FLINK-33881?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17798799#comment-17798799
]
Jinzhong Li commented on FLINK-33881:
-
[~Zakelly] Thanks for your reply.
I think t
[
https://issues.apache.org/jira/browse/FLINK-33881?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jinzhong Li updated FLINK-33881:
Description:
In some scenarios, 'TtlListState#getUnexpiredOrNull ->
elementSerializer.copy(ttlVal
[
https://issues.apache.org/jira/browse/FLINK-33881?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17799012#comment-17799012
]
Jinzhong Li commented on FLINK-33881:
-
[~Zakelly] Sorry for my typo, I don't think
[
https://issues.apache.org/jira/browse/FLINK-3755?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17775998#comment-17775998
]
Jinzhong Li commented on FLINK-3755:
[~trohrmann] [~martijnvisser]
I want to take
[
https://issues.apache.org/jira/browse/FLINK-3755?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17776466#comment-17776466
]
Jinzhong Li commented on FLINK-3755:
[~srichter] [~aljoscha]
Could you help me
Jinzhong Li created FLINK-32953:
---
Summary: [State TTL]resolve data correctness problem after ttl was
changed
Key: FLINK-32953
URL: https://issues.apache.org/jira/browse/FLINK-32953
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-32953?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jinzhong Li updated FLINK-32953:
Description:
Because expired data is cleaned up in background on a best effort basis
(hashmap use
[
https://issues.apache.org/jira/browse/FLINK-32953?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17758823#comment-17758823
]
Jinzhong Li commented on FLINK-32953:
-
Thanks for your reply and advice. [~masteryh
Jinzhong Li created FLINK-32955:
---
Summary: Support state compatibility between enabling TTL and
disabling TTL
Key: FLINK-32955
URL: https://issues.apache.org/jira/browse/FLINK-32955
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-32953?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17759485#comment-17759485
]
Jinzhong Li commented on FLINK-32953:
-
[~masteryhx] Yes, I want to do this work. Th
[
https://issues.apache.org/jira/browse/FLINK-14032?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17761246#comment-17761246
]
Jinzhong Li commented on FLINK-14032:
-
hi, [~yunta] , are you still working on this
[
https://issues.apache.org/jira/browse/FLINK-33055?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17762948#comment-17762948
]
Jinzhong Li commented on FLINK-33055:
-
hi，[~masteryhx] ， I would like to take this t
[
https://issues.apache.org/jira/browse/FLINK-32953?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17764016#comment-17764016
]
Jinzhong Li commented on FLINK-32953:
-
[~masteryhx] Currently, the stateBackend lay
1 - 100 of 103 matches
Mail list logo
