[
https://issues.apache.org/jira/browse/FLINK-20044?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17436634#comment-17436634
]
Jiayi Liao commented on FLINK-20044:
[~liyu] We haven't upgrade our Flink version re
[
https://issues.apache.org/jira/browse/FLINK-22672?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jiayi Liao updated FLINK-22672:
---
Comment: was deleted
(was: Hi [~maguowei], [~jinxing6...@126.com], [~kevin.cyj],
Currently we're tr
[
https://issues.apache.org/jira/browse/FLINK-24148?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jiayi Liao updated FLINK-24148:
---
Description: Bloom filter can efficiently enhance the read on RocksDB,
especially for the reading am
[
https://issues.apache.org/jira/browse/FLINK-24148?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17409412#comment-17409412
]
Jiayi Liao commented on FLINK-24148:
[~yunta] Hi, could you have a look on this ? I
Jiayi Liao created FLINK-24148:
--
Summary: Add bloom filter policy option in RocksDBConfiguredOptions
Key: FLINK-24148
URL: https://issues.apache.org/jira/browse/FLINK-24148
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-23180?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17409403#comment-17409403
]
Jiayi Liao commented on FLINK-23180:
[~pnowojski] I can work on this.
Okay, we ca
[
https://issues.apache.org/jira/browse/FLINK-20684?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jiayi Liao updated FLINK-20684:
---
Labels: (was: auto-deprioritized-major)
> Add compression type option in RocksDBConfigurableOption
[
https://issues.apache.org/jira/browse/FLINK-23180?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17409368#comment-17409368
]
Jiayi Liao commented on FLINK-23180:
[~yunta][~pnowojski] I think this might be a v
[
https://issues.apache.org/jira/browse/FLINK-23180?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jiayi Liao updated FLINK-23180:
---
Description: Currently batch jobs will initialize checkpoint location
eagerly when {{CheckpointCoord
[
https://issues.apache.org/jira/browse/FLINK-24120?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17409257#comment-17409257
]
Jiayi Liao commented on FLINK-24120:
[~trohrmann] Okay, will add this today.
> The
[
https://issues.apache.org/jira/browse/FLINK-24120?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17408497#comment-17408497
]
Jiayi Liao commented on FLINK-24120:
Try add an environment variable for taskmanager
[
https://issues.apache.org/jira/browse/FLINK-22672?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17407870#comment-17407870
]
Jiayi Liao commented on FLINK-22672:
Hi [~maguowei], [~jinxing6...@126.com], [~kevin
[
https://issues.apache.org/jira/browse/FLINK-22672?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17407870#comment-17407870
]
Jiayi Liao edited comment on FLINK-22672 at 9/1/21, 6:40 AM:
-
Jiayi Liao created FLINK-23690:
--
Summary: Processing timers can be triggered more efficiently
Key: FLINK-23690
URL: https://issues.apache.org/jira/browse/FLINK-23690
Project: Flink
Issue Type: I
[
https://issues.apache.org/jira/browse/FLINK-23689?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jiayi Liao updated FLINK-23689:
---
Description:
FLINK-9857 enabled {{SystemProcessingTimeService}} to fire processing timers
by 1ms d
Jiayi Liao created FLINK-23689:
--
Summary: TestProcessingTimeService.setCurrentTime(long) not delay
the firing timer by 1ms delay
Key: FLINK-23689
URL: https://issues.apache.org/jira/browse/FLINK-23689
Pr
[
https://issues.apache.org/jira/browse/FLINK-23208?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17393563#comment-17393563
]
Jiayi Liao commented on FLINK-23208:
[~pnowojski] Yes. It's in-progress, I'm pretty
[
https://issues.apache.org/jira/browse/FLINK-23208?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17385255#comment-17385255
]
Jiayi Liao edited comment on FLINK-23208 at 7/22/21, 5:35 AM:
[
https://issues.apache.org/jira/browse/FLINK-23208?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17385255#comment-17385255
]
Jiayi Liao commented on FLINK-23208:
[~pnowojski] Before the change, we need to fix
[
https://issues.apache.org/jira/browse/FLINK-23208?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17380948#comment-17380948
]
Jiayi Liao commented on FLINK-23208:
[~pnowojski] I can work on this.
Should the b
[
https://issues.apache.org/jira/browse/FLINK-23208?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17380670#comment-17380670
]
Jiayi Liao commented on FLINK-23208:
[~pnowojski] You mean something like this ?
{
[
https://issues.apache.org/jira/browse/FLINK-23208?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17379991#comment-17379991
]
Jiayi Liao commented on FLINK-23208:
[~pnowojski] Exactly!
> the first/next trigge
[
https://issues.apache.org/jira/browse/FLINK-23208?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17379901#comment-17379901
]
Jiayi Liao edited comment on FLINK-23208 at 7/13/21, 1:58 PM:
[
https://issues.apache.org/jira/browse/FLINK-23208?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17379901#comment-17379901
]
Jiayi Liao commented on FLINK-23208:
[~pnowojski]
>Why registering and firing t
[
https://issues.apache.org/jira/browse/FLINK-23208?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17379810#comment-17379810
]
Jiayi Liao edited comment on FLINK-23208 at 7/13/21, 10:31 AM:
---
[
https://issues.apache.org/jira/browse/FLINK-23208?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17379810#comment-17379810
]
Jiayi Liao commented on FLINK-23208:
[~pnowojski], sorry for making this unclear, it
[
https://issues.apache.org/jira/browse/FLINK-23208?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17379237#comment-17379237
]
Jiayi Liao commented on FLINK-23208:
[~pnowojski] Yes. I've read FLINK-9857 before,
[
https://issues.apache.org/jira/browse/FLINK-23208?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jiayi Liao updated FLINK-23208:
---
Labels: critical (was: )
> Late processing timers need to wait 1ms at least to be fired
> -
[
https://issues.apache.org/jira/browse/FLINK-23208?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jiayi Liao updated FLINK-23208:
---
Affects Version/s: 1.14.0
1.11.3
1.13.0
[
https://issues.apache.org/jira/browse/FLINK-23208?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jiayi Liao updated FLINK-23208:
---
Description:
The problem is from the codes below:
{code:java}
public static long getProcessingTime
[
https://issues.apache.org/jira/browse/FLINK-23208?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jiayi Liao updated FLINK-23208:
---
Attachment: screenshot-1.png
> Late processing timers need to wait 1ms at least to be fired
> --
[
https://issues.apache.org/jira/browse/FLINK-23208?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jiayi Liao updated FLINK-23208:
---
Description:
The problem is from the codes below:
{code:java}
public static long getProcessingTime
[
https://issues.apache.org/jira/browse/FLINK-23208?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jiayi Liao updated FLINK-23208:
---
Description:
The problem is from the codes below:
{code:java}
public static long getProcessingTime
[
https://issues.apache.org/jira/browse/FLINK-23208?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jiayi Liao updated FLINK-23208:
---
Description:
The problem is from the codes below:
{code:java}
public static long getProcessingTime
[
https://issues.apache.org/jira/browse/FLINK-23208?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jiayi Liao updated FLINK-23208:
---
Description:
The problem is from the codes below:
```
public static long getProcessingTimeDelay(lon
Jiayi Liao created FLINK-23208:
--
Summary: Late processing timers need to wait 1ms at least to be
fired
Key: FLINK-23208
URL: https://issues.apache.org/jira/browse/FLINK-23208
Project: Flink
Iss
[
https://issues.apache.org/jira/browse/FLINK-23208?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jiayi Liao updated FLINK-23208:
---
Priority: Critical (was: Major)
> Late processing timers need to wait 1ms at least to be fired
> --
Jiayi Liao created FLINK-23180:
--
Summary: Initialize checkpoint location lazily in DataStream Batch
Jobs
Key: FLINK-23180
URL: https://issues.apache.org/jira/browse/FLINK-23180
Project: Flink
I
[
https://issues.apache.org/jira/browse/FLINK-22887?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17368803#comment-17368803
]
Jiayi Liao commented on FLINK-22887:
[~akalashnikov] I've implemented this optimizat
[
https://issues.apache.org/jira/browse/FLINK-22887?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17368697#comment-17368697
]
Jiayi Liao commented on FLINK-22887:
[~pnowojski] In my implementation, the optimiz
[
https://issues.apache.org/jira/browse/FLINK-22887?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17366931#comment-17366931
]
Jiayi Liao commented on FLINK-22887:
[~pnowojski][~akalashnikov] Thanks for the feed
[
https://issues.apache.org/jira/browse/FLINK-23003?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17364018#comment-17364018
]
Jiayi Liao commented on FLINK-23003:
[~Yanfei Lei] This looks like a duplicate of
h
[
https://issues.apache.org/jira/browse/FLINK-22886?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17358338#comment-17358338
]
Jiayi Liao commented on FLINK-22886:
[~yunta] Hi Yun, [~mayuehappy] is solving this
[
https://issues.apache.org/jira/browse/FLINK-22886?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jiayi Liao updated FLINK-22886:
---
Labels: critical (was: )
> Thread leak in RocksDBStateUploader
> --
Jiayi Liao created FLINK-22887:
--
Summary: Backlog based optimizations for RebalancePartitioner and
RescalePartitioner
Key: FLINK-22887
URL: https://issues.apache.org/jira/browse/FLINK-22887
Project: Flin
[
https://issues.apache.org/jira/browse/FLINK-22886?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jiayi Liao updated FLINK-22886:
---
Description:
{{ExecutorService}} in {{RocksDBStateUploader}} is not shut down, which may
leak threa
[
https://issues.apache.org/jira/browse/FLINK-22886?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jiayi Liao updated FLINK-22886:
---
Description:
{{ExecutorService}} in {{RocksDBStateUploader}} is not shut down, which may
leak threa
[
https://issues.apache.org/jira/browse/FLINK-22886?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jiayi Liao updated FLINK-22886:
---
Attachment: image-2021-06-06-13-46-34-604.png
> Thread leak in RocksDBStateUploader
> --
Jiayi Liao created FLINK-22886:
--
Summary: Thread leak in RocksDBStateUploader
Key: FLINK-22886
URL: https://issues.apache.org/jira/browse/FLINK-22886
Project: Flink
Issue Type: Bug
Com
[
https://issues.apache.org/jira/browse/FLINK-22805?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17354188#comment-17354188
]
Jiayi Liao commented on FLINK-22805:
This is a good point. But I think the root prob
[
https://issues.apache.org/jira/browse/FLINK-10644?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17337040#comment-17337040
]
Jiayi Liao commented on FLINK-10644:
Yes. We also implement our own speculation in B
[
https://issues.apache.org/jira/browse/FLINK-15160?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17328809#comment-17328809
]
Jiayi Liao commented on FLINK-15160:
We've met the problem recently. To solve this,
[
https://issues.apache.org/jira/browse/FLINK-19016?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jiayi Liao updated FLINK-19016:
---
Labels: (was: stale-major)
> Checksum mismatch when restore from RocksDB
> ---
[
https://issues.apache.org/jira/browse/FLINK-18203?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jiayi Liao closed FLINK-18203.
--
Resolution: Won't Fix
Close this because union state is going to be deprecated in the future.
> Reduc
[
https://issues.apache.org/jira/browse/FLINK-15923?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jiayi Liao closed FLINK-15923.
--
Resolution: Won't Fix
> Remove DISCARDED in TaskAcknowledgeResult
> --
[
https://issues.apache.org/jira/browse/FLINK-18572?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17328188#comment-17328188
]
Jiayi Liao commented on FLINK-18572:
+1 on this feature.
> Flink web UI doesn't di
[
https://issues.apache.org/jira/browse/FLINK-17320?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jiayi Liao closed FLINK-17320.
--
Resolution: Won't Fix
Close this since this is not a Flink related problem.
> Java8 lambda expression
[
https://issues.apache.org/jira/browse/FLINK-19016?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17328078#comment-17328078
]
Jiayi Liao commented on FLINK-19016:
A quick update.
We've met this issue again af
[
https://issues.apache.org/jira/browse/FLINK-19016?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jiayi Liao updated FLINK-19016:
---
Affects Version/s: 1.13.1
1.13.0
1.12.2
> Checksum mis
[
https://issues.apache.org/jira/browse/FLINK-19011?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jiayi Liao closed FLINK-19011.
--
Resolution: Won't Fix
> Parallelize the restore operation in OperatorStateBackend
> -
[
https://issues.apache.org/jira/browse/FLINK-13247?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17325805#comment-17325805
]
Jiayi Liao commented on FLINK-13247:
[~trohrmann][~zjwang] It's okay for me. I'll dr
[
https://issues.apache.org/jira/browse/FLINK-5601?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17324800#comment-17324800
]
Jiayi Liao commented on FLINK-5601:
---
[~liyu] Yes. My idea is to add watermark as state
[
https://issues.apache.org/jira/browse/FLINK-13247?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17324189#comment-17324189
]
Jiayi Liao commented on FLINK-13247:
Actually we've already implemented Yarn shuffle
[
https://issues.apache.org/jira/browse/FLINK-16193?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17323641#comment-17323641
]
Jiayi Liao commented on FLINK-16193:
Maybe I'm a bit late for this discussion... I'v
[
https://issues.apache.org/jira/browse/FLINK-21990?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jiayi Liao updated FLINK-21990:
---
Priority: Critical (was: Major)
> SourceStreamTask will always hang if the CheckpointedFunction#sna
[
https://issues.apache.org/jira/browse/FLINK-21990?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17310341#comment-17310341
]
Jiayi Liao commented on FLINK-21990:
[~pnowojski] We've encountered the problem when
[
https://issues.apache.org/jira/browse/FLINK-21413?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17288266#comment-17288266
]
Jiayi Liao commented on FLINK-21413:
[~liyu] Yes. I'll submit a PR soon.
> TtlMapS
[
https://issues.apache.org/jira/browse/FLINK-21413?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17288147#comment-17288147
]
Jiayi Liao commented on FLINK-21413:
[~liyu] Oops... I didn't notice that the #remov
[
https://issues.apache.org/jira/browse/FLINK-21413?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17287600#comment-17287600
]
Jiayi Liao commented on FLINK-21413:
Sure. I'm still thinking about the solution. I'
[
https://issues.apache.org/jira/browse/FLINK-21413?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jiayi Liao updated FLINK-21413:
---
Description:
Take the #TtlMapState as an example,
{code:java}
public Map> getUnexpiredOrNull(@Non
[
https://issues.apache.org/jira/browse/FLINK-21413?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jiayi Liao updated FLINK-21413:
---
Attachment: image-2021-02-19-11-13-58-672.png
> TtlMapState and TtlListState cannot be clean complet
Jiayi Liao created FLINK-21413:
--
Summary: TtlMapState and TtlListState cannot be clean completely
with Filesystem StateBackend
Key: FLINK-21413
URL: https://issues.apache.org/jira/browse/FLINK-21413
Proj
[
https://issues.apache.org/jira/browse/FLINK-21321?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17281075#comment-17281075
]
Jiayi Liao commented on FLINK-21321:
[~legojoey17] We've met the same problem recent
[
https://issues.apache.org/jira/browse/FLINK-20684?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jiayi Liao updated FLINK-20684:
---
Description:
Currently RocksDB uses snappy compression by default, but this could be a huge
cost on
Jiayi Liao created FLINK-20684:
--
Summary: Add compression type option in RocksDBConfigurableOptions
Key: FLINK-20684
URL: https://issues.apache.org/jira/browse/FLINK-20684
Project: Flink
Issue T
[
https://issues.apache.org/jira/browse/FLINK-19150?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jiayi Liao closed FLINK-19150.
--
Resolution: Invalid
> Behaviour change after migration from 1.9 to 1.11
>
[
https://issues.apache.org/jira/browse/FLINK-16597?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jiayi Liao updated FLINK-16597:
---
Priority: Minor (was: Major)
> Handle exception thrown from close method in OutputFormat
>
[
https://issues.apache.org/jira/browse/FLINK-17571?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17245142#comment-17245142
]
Jiayi Liao commented on FLINK-17571:
[~klion26] Is it necessary to list the checkpoi
[
https://issues.apache.org/jira/browse/FLINK-19970?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17242914#comment-17242914
]
Jiayi Liao commented on FLINK-19970:
[~dwysakowicz] Does this bug affect all the pat
[
https://issues.apache.org/jira/browse/FLINK-19970?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17241426#comment-17241426
]
Jiayi Liao commented on FLINK-19970:
[~Jamalarm] Do you figure out the root cause o
[
https://issues.apache.org/jira/browse/FLINK-20269?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jiayi Liao closed FLINK-20269.
--
Resolution: Duplicate
> The flush happens too frequent in SavepoinV2Serializer
> -
[
https://issues.apache.org/jira/browse/FLINK-20269?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17236888#comment-17236888
]
Jiayi Liao commented on FLINK-20269:
[~liyu] Thanks for the remind. I'll close this
[
https://issues.apache.org/jira/browse/FLINK-20269?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jiayi Liao updated FLINK-20269:
---
Description:
The reason I notice this is, I find that the metadata's persistence can be very
slow (
Jiayi Liao created FLINK-20269:
--
Summary: The flush happens too frequent in SavepoinV2Serializer
Key: FLINK-20269
URL: https://issues.apache.org/jira/browse/FLINK-20269
Project: Flink
Issue Type
[
https://issues.apache.org/jira/browse/FLINK-6984?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jiayi Liao closed FLINK-6984.
-
Resolution: Duplicate
Resoloved in FLINK-19596.
> Do not recover CompletedCheckpointStore on every resto
[
https://issues.apache.org/jira/browse/FLINK-6984?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jiayi Liao updated FLINK-6984:
--
Fix Version/s: 1.12.0
> Do not recover CompletedCheckpointStore on every restore
>
[
https://issues.apache.org/jira/browse/FLINK-16753?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17231938#comment-17231938
]
Jiayi Liao commented on FLINK-16753:
[~zjwang] [~NicoK] The change is simple. I've s
[
https://issues.apache.org/jira/browse/FLINK-20099?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17230469#comment-17230469
]
Jiayi Liao commented on FLINK-20099:
Is this a duplicate issue of https://issues.apa
Jiayi Liao created FLINK-20087:
--
Summary: CheckpointCoordinator waits until all tasks finish
initialization of states to trigger checkpoint
Key: FLINK-20087
URL: https://issues.apache.org/jira/browse/FLINK-20087
[
https://issues.apache.org/jira/browse/FLINK-20044?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17228315#comment-17228315
]
Jiayi Liao commented on FLINK-20044:
[~sewen] I guess this is not a cancellation sit
Jiayi Liao created FLINK-20044:
--
Summary: Disposal of RocksDB could last forever
Key: FLINK-20044
URL: https://issues.apache.org/jira/browse/FLINK-20044
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-19778?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17219520#comment-17219520
]
Jiayi Liao commented on FLINK-19778:
In the JM log, the point is why zk store cannot
[
https://issues.apache.org/jira/browse/FLINK-19596?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jiayi Liao closed FLINK-19596.
--
Resolution: Fixed
Fixed in https://issues.apache.org/jira/browse/FLINK-19401
> Do not recover Complet
[
https://issues.apache.org/jira/browse/FLINK-19594?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17217372#comment-17217372
]
Jiayi Liao commented on FLINK-19594:
Link an duplicated issue reported earlier.
htt
[
https://issues.apache.org/jira/browse/FLINK-16051?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17217369#comment-17217369
]
Jiayi Liao commented on FLINK-16051:
[~zjwang] This is reported by a user recently,
[
https://issues.apache.org/jira/browse/FLINK-10284?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jiayi Liao closed FLINK-10284.
--
Resolution: Fixed
Close this since this is already fixed in another JIRA issue.
> TumblingEventTimeWi
[
https://issues.apache.org/jira/browse/FLINK-19596?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17216590#comment-17216590
]
Jiayi Liao commented on FLINK-19596:
[~roman_khachatryan] In the losing-regaining le
[
https://issues.apache.org/jira/browse/FLINK-19596?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17216541#comment-17216541
]
Jiayi Liao commented on FLINK-19596:
[~yunta] I didn't know there's already a JIRA b
[
https://issues.apache.org/jira/browse/FLINK-5463?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17214604#comment-17214604
]
Jiayi Liao edited comment on FLINK-5463 at 10/15/20, 10:51 AM:
[
https://issues.apache.org/jira/browse/FLINK-5463?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jiayi Liao updated FLINK-5463:
--
Affects Version/s: 1.9.0
> RocksDB.disposeInternal does not react to interrupts, blocks task cancellati
1 - 100 of 473 matches
Mail list logo