[
https://issues.apache.org/jira/browse/FLINK-35382?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17847783#comment-17847783
]
Jinzhong Li commented on FLINK-35382:
-
1. Because FLINK-32085 has not been resolved, the changelog
[
https://issues.apache.org/jira/browse/FLINK-35178?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17839458#comment-17839458
]
Jinzhong Li commented on FLINK-35178:
-
[~elon] Thanks for reporting this.
For case 1: Let me
[
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-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
[
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
>
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
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-35161:
---
Summary: Implement StateExecutor for ForStStateBackend
Key: FLINK-35161
URL: https://issues.apache.org/jira/browse/FLINK-35161
Project: Flink
Issue Type:
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:
[
https://issues.apache.org/jira/browse/FLINK-35069?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17835406#comment-17835406
]
Jinzhong Li edited comment on FLINK-35069 at 4/9/24 12:51 PM:
--
cc [~Weijie
[
https://issues.apache.org/jira/browse/FLINK-35069?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17835406#comment-17835406
]
Jinzhong Li commented on FLINK-35069:
-
cc [~guoweijie] Could you please take a look at this issue?
[
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
[
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)
>
[
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
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
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-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
[
https://issues.apache.org/jira/browse/FLINK-34670?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17831334#comment-17831334
]
Jinzhong Li edited comment on FLINK-34670 at 3/27/24 12:57 PM:
---
[~roman]
[
https://issues.apache.org/jira/browse/FLINK-34670?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17831334#comment-17831334
]
Jinzhong Li commented on FLINK-34670:
-
[~roman] [~pnowojski] I think this is a critical bug that
[
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
[
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
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
[
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
[
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
[
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
[
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:comment-tabpanel=17827083#comment-17827083
]
Jinzhong Li commented on FLINK-34670:
-
This issue seems to be a bug from
[
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
[
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
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-18255?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17826962#comment-17826962
]
Jinzhong Li commented on FLINK-18255:
-
I don't have permission to change the fix version of issue,
[
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
[
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
[
https://issues.apache.org/jira/browse/FLINK-34050?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17821623#comment-17821623
]
Jinzhong Li commented on FLINK-34050:
-
commit 534ea31 and b048a9c has been merged into
[
https://issues.apache.org/jira/browse/FLINK-34050?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17819579#comment-17819579
]
Jinzhong Li edited comment on FLINK-34050 at 2/22/24 10:36 AM:
---
Here are
[
https://issues.apache.org/jira/browse/FLINK-34050?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17819579#comment-17819579
]
Jinzhong Li edited comment on FLINK-34050 at 2/22/24 10:33 AM:
---
Here are
[
https://issues.apache.org/jira/browse/FLINK-34050?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17819579#comment-17819579
]
Jinzhong Li edited comment on FLINK-34050 at 2/22/24 10:31 AM:
---
Here are
[
https://issues.apache.org/jira/browse/FLINK-34050?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17819579#comment-17819579
]
Jinzhong Li edited comment on FLINK-34050 at 2/22/24 10:30 AM:
---
Here are
[
https://issues.apache.org/jira/browse/FLINK-34050?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17819579#comment-17819579
]
Jinzhong Li edited comment on FLINK-34050 at 2/22/24 10:29 AM:
---
Here are
[
https://issues.apache.org/jira/browse/FLINK-34050?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17819579#comment-17819579
]
Jinzhong Li edited comment on FLINK-34050 at 2/22/24 10:28 AM:
---
Here are
[
https://issues.apache.org/jira/browse/FLINK-34050?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17819579#comment-17819579
]
Jinzhong Li edited comment on FLINK-34050 at 2/22/24 10:24 AM:
---
Here are
[
https://issues.apache.org/jira/browse/FLINK-34050?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17819579#comment-17819579
]
Jinzhong Li commented on FLINK-34050:
-
Here are the benchmark results before and after applying this
[
https://issues.apache.org/jira/browse/FLINK-18255?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17819478#comment-17819478
]
Jinzhong Li commented on FLINK-18255:
-
[~yunta] [~Yanfei Lei] I have drafted a flip
[
https://issues.apache.org/jira/browse/FLINK-34050?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17819257#comment-17819257
]
Jinzhong Li commented on FLINK-34050:
-
[~srichter] Thanks for your comments. I think:
1. The
[
https://issues.apache.org/jira/browse/FLINK-18255?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17807522#comment-17807522
]
Jinzhong Li commented on FLINK-18255:
-
I think this issue still exist in 1.19. I want to take this
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-34050?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17806599#comment-17806599
]
Jinzhong Li commented on FLINK-34050:
-
Thanks for your reply. [~mayuehappy] [~masteryhx]
IMO, it
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-33881?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17805110#comment-17805110
]
Jinzhong Li edited comment on FLINK-33881 at 1/10/24 12:29 PM:
---
[~Zakelly]
[
https://issues.apache.org/jira/browse/FLINK-33881?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17805110#comment-17805110
]
Jinzhong Li commented on FLINK-33881:
-
[~Zakelly] I have done the performance testing with
[
https://issues.apache.org/jira/browse/FLINK-33881?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17804975#comment-17804975
]
Jinzhong Li commented on FLINK-33881:
-
[~Zakelly] [~masteryhx]
I have published a pr, could you
[
https://issues.apache.org/jira/browse/FLINK-34032?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17804570#comment-17804570
]
Jinzhong Li commented on FLINK-34032:
-
Hi [~masteryhx] , would you please clarify the specific
[
https://issues.apache.org/jira/browse/FLINK-33881?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17799012#comment-17799012
]
Jinzhong Li commented on FLINK-33881:
-
[~Zakelly] Sorry for my typo, I don't think we should change
[
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 ->
[
https://issues.apache.org/jira/browse/FLINK-33881?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17798799#comment-17798799
]
Jinzhong Li commented on FLINK-33881:
-
[~Zakelly] Thanks for your reply.
I think this ticket is
[
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 ->
[
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 ->
[
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:
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-25400?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17784691#comment-17784691
]
Jinzhong Li commented on FLINK-25400:
-
I think this issue still exits in 1.19.
The task
[
https://issues.apache.org/jira/browse/FLINK-3755?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17776466#comment-17776466
]
Jinzhong Li commented on FLINK-3755:
[~srichter] [~aljoscha]
Could you help me copy the design
[
https://issues.apache.org/jira/browse/FLINK-3755?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17775998#comment-17775998
]
Jinzhong Li commented on FLINK-3755:
[~trohrmann] [~martijnvisser]
I want to take a look at the
[
https://issues.apache.org/jira/browse/FLINK-32953?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17764518#comment-17764518
]
Jinzhong Li commented on FLINK-32953:
-
[~masteryhx] I publish a pr which add some notes about this
[
https://issues.apache.org/jira/browse/FLINK-32953?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17764016#comment-17764016
]
Jinzhong Li edited comment on FLINK-32953 at 9/12/23 5:39 AM:
--
[~masteryhx]
[
https://issues.apache.org/jira/browse/FLINK-32953?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17764016#comment-17764016
]
Jinzhong Li edited comment on FLINK-32953 at 9/12/23 5:38 AM:
--
[~masteryhx]
[
https://issues.apache.org/jira/browse/FLINK-32953?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17764016#comment-17764016
]
Jinzhong Li commented on FLINK-32953:
-
[~masteryhx] Currently, the stateBackend layer
[
https://issues.apache.org/jira/browse/FLINK-33055?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17762948#comment-17762948
]
Jinzhong Li commented on FLINK-33055:
-
hi，[~masteryhx] ， I would like to take this trivial work.
>
[
https://issues.apache.org/jira/browse/FLINK-14032?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17761246#comment-17761246
]
Jinzhong Li commented on FLINK-14032:
-
hi, [~yunta] , are you still working on this ticket? If not,
[
https://issues.apache.org/jira/browse/FLINK-32953?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17759485#comment-17759485
]
Jinzhong Li commented on FLINK-32953:
-
[~masteryhx] Yes, I want to do this work. Thanks.
> [State
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=17758823#comment-17758823
]
Jinzhong Li commented on FLINK-32953:
-
Thanks for your reply and advice. [~masteryhx]
I also
[
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
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-28863?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17648326#comment-17648326
]
Jinzhong Li commented on FLINK-28863:
-
[~yunta] Yes, that is. And +1 for keeping the logic as it
[
https://issues.apache.org/jira/browse/FLINK-28863?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17627484#comment-17627484
]
Jinzhong Li edited comment on FLINK-28863 at 11/2/22 6:45 AM:
--
[~yunta]
[
https://issues.apache.org/jira/browse/FLINK-28863?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17627484#comment-17627484
]
Jinzhong Li commented on FLINK-28863:
-
[~yunta]
1. I found that the changes I metioned above would
[
https://issues.apache.org/jira/browse/FLINK-28863?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17625402#comment-17625402
]
Jinzhong Li commented on FLINK-28863:
-
In my opinion, for Rocksdb native savepoint SnapshotResult,
[
https://issues.apache.org/jira/browse/FLINK-28515?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17569936#comment-17569936
]
Jinzhong Li edited comment on FLINK-28515 at 7/22/22 10:38 AM:
---
Thanks for
[
https://issues.apache.org/jira/browse/FLINK-28515?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17569936#comment-17569936
]
Jinzhong Li edited comment on FLINK-28515 at 7/22/22 10:38 AM:
---
Thanks for
[
https://issues.apache.org/jira/browse/FLINK-28515?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17569936#comment-17569936
]
Jinzhong Li edited comment on FLINK-28515 at 7/22/22 10:36 AM:
---
Thanks for
[
https://issues.apache.org/jira/browse/FLINK-28515?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17569936#comment-17569936
]
Jinzhong Li commented on FLINK-28515:
-
Thanks for reply [~roman]
I'd like to explain the reason
[
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=17569789#comment-17569789
]
Jinzhong Li commented on FLINK-28515:
-
Thanks for reply [~roman]
>> "if the AsyncSnapshotCallable
[
https://issues.apache.org/jira/browse/FLINK-28515?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17568458#comment-17568458
]
Jinzhong Li edited comment on FLINK-28515 at 7/19/22 10:32 AM:
---
[~roman]
[
https://issues.apache.org/jira/browse/FLINK-28515?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17568458#comment-17568458
]
Jinzhong Li commented on FLINK-28515:
-
[~roman] I thought about this problem again these days.
I
[
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
[ 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
[
https://issues.apache.org/jira/browse/FLINK-28515?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17566293#comment-17566293
]
Jinzhong Li commented on FLINK-28515:
-
Thanks for your reply [~roman] . For your concerns, i think:
[
https://issues.apache.org/jira/browse/FLINK-28515?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17566131#comment-17566131
]
Jinzhong Li commented on FLINK-28515:
-
[~roman] [~yunta] Could you please take a look at this
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-25314?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17459637#comment-17459637
]
Jinzhong Li commented on FLINK-25314:
-
duplicate with FLINK-25295 and close it
> Update log4j2
[
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:all-tabpanel
]
Jinzhong Li closed FLINK-25314.
---
Resolution: Fixed
> Update log4j2 version to 2.16.0
> ---
>
>
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
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-25094?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jinzhong Li updated FLINK-25094:
Description:
In LatencyTrackingMapStateTest,
97 matches
Mail list logo
