Arvid Heise created FLINK-13956:
---
Summary: Add sequence file format with repeated sync blocks
Key: FLINK-13956
URL: https://issues.apache.org/jira/browse/FLINK-13956
Project: Flink
Issue Type:
Arvid Heise created FLINK-13995:
---
Summary: Fix shading of the licence information of netty
Key: FLINK-13995
URL: https://issues.apache.org/jira/browse/FLINK-13995
Project: Flink
Issue Type: Bug
Arvid Heise created FLINK-14044:
---
Summary: Reducing synchronization in AsyncWaitOperator
Key: FLINK-14044
URL: https://issues.apache.org/jira/browse/FLINK-14044
Project: Flink
Issue Type: Impro
[
https://issues.apache.org/jira/browse/FLINK-14044?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Arvid Heise updated FLINK-14044:
Component/s: Runtime / Task
> Reducing synchronization in AsyncWaitOperator
>
Arvid Heise created FLINK-14199:
---
Summary: Only use dedicated/named classes for mailbox letters.
Key: FLINK-14199
URL: https://issues.apache.org/jira/browse/FLINK-14199
Project: Flink
Issue Typ
Arvid Heise created FLINK-14304:
---
Summary: Avoid task starvation with mailbox
Key: FLINK-14304
URL: https://issues.apache.org/jira/browse/FLINK-14304
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-35749?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17863034#comment-17863034
]
Arvid Heise commented on FLINK-35749:
-
Hi [~zjmean], I can take this topic over if y
[
https://issues.apache.org/jira/browse/FLINK-31762?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17863157#comment-17863157
]
Arvid Heise commented on FLINK-31762:
-
[~lorenzo.affetti] if you need help, feel fre
[
https://issues.apache.org/jira/browse/FLINK-35749?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17863214#comment-17863214
]
Arvid Heise commented on FLINK-35749:
-
Responded
https://github.com/apache/flink-co
[
https://issues.apache.org/jira/browse/FLINK-33545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17863737#comment-17863737
]
Arvid Heise commented on FLINK-33545:
-
Sorry for being late to this party. But I won
[
https://issues.apache.org/jira/browse/FLINK-33545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17863737#comment-17863737
]
Arvid Heise edited comment on FLINK-33545 at 7/8/24 9:58 AM:
-
[
https://issues.apache.org/jira/browse/FLINK-33545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17863737#comment-17863737
]
Arvid Heise edited comment on FLINK-33545 at 7/8/24 9:59 AM:
-
[
https://issues.apache.org/jira/browse/FLINK-34127?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17863740#comment-17863740
]
Arvid Heise commented on FLINK-34127:
-
[~masc] I can take over if you don't have tim
[
https://issues.apache.org/jira/browse/FLINK-35419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17863748#comment-17863748
]
Arvid Heise commented on FLINK-35419:
-
Looks like this could already be solved with
[
https://issues.apache.org/jira/browse/FLINK-35419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17863749#comment-17863749
]
Arvid Heise commented on FLINK-35419:
-
I wonder if this is a duplicate of
https://i
[
https://issues.apache.org/jira/browse/FLINK-34470?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Arvid Heise reassigned FLINK-34470:
---
Assignee: dongwoo.kim
> Transactional message + Table api kafka source with 'latest-offset'
[
https://issues.apache.org/jira/browse/FLINK-33545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17864053#comment-17864053
]
Arvid Heise commented on FLINK-33545:
-
Okay thanks for being open. I also think that
[
https://issues.apache.org/jira/browse/FLINK-25920?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17864069#comment-17864069
]
Arvid Heise commented on FLINK-25920:
-
Hi folks, I tried to repro the issue to no av
[
https://issues.apache.org/jira/browse/FLINK-25920?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17864155#comment-17864155
]
Arvid Heise commented on FLINK-25920:
-
Please trace {{org.apache.flink.connector.kaf
[
https://issues.apache.org/jira/browse/FLINK-35419?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Arvid Heise resolved FLINK-35419.
-
Resolution: Duplicate
> scan.bounded.latest-offset makes queries never finish if the latest mess
[
https://issues.apache.org/jira/browse/FLINK-35109?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17864198#comment-17864198
]
Arvid Heise commented on FLINK-35109:
-
[~ruanhang1993] are you still working on it?
Arvid Heise created FLINK-35796:
---
Summary: Ensure that MailboxExecutor.submit is used correctly
Key: FLINK-35796
URL: https://issues.apache.org/jira/browse/FLINK-35796
Project: Flink
Issue Type
[
https://issues.apache.org/jira/browse/FLINK-35796?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17864521#comment-17864521
]
Arvid Heise commented on FLINK-35796:
-
Merged into master as 0bf2aaac0e38e7f32296809
[
https://issues.apache.org/jira/browse/FLINK-35796?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Arvid Heise resolved FLINK-35796.
-
Resolution: Fixed
> Ensure that MailboxExecutor.submit is used correctly
> -
[
https://issues.apache.org/jira/browse/FLINK-25920?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17864641#comment-17864641
]
Arvid Heise commented on FLINK-25920:
-
Wow that log was insightful. We see that for
[
https://issues.apache.org/jira/browse/FLINK-25920?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17864666#comment-17864666
]
Arvid Heise commented on FLINK-25920:
-
Could you please verify that your transaction
[
https://issues.apache.org/jira/browse/FLINK-25920?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17864666#comment-17864666
]
Arvid Heise edited comment on FLINK-25920 at 7/10/24 1:46 PM:
[
https://issues.apache.org/jira/browse/FLINK-35749?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17865023#comment-17865023
]
Arvid Heise commented on FLINK-35749:
-
Merged into main as 4429b78.
> Kafka sink co
[
https://issues.apache.org/jira/browse/FLINK-35749?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Arvid Heise resolved FLINK-35749.
-
Fix Version/s: kafka-3.3.0
Resolution: Fixed
> Kafka sink component will lose data when k
[
https://issues.apache.org/jira/browse/FLINK-33497?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17865083#comment-17865083
]
Arvid Heise commented on FLINK-33497:
-
Blocked by FLINK-35109, so I will do it first
[
https://issues.apache.org/jira/browse/FLINK-35109?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Arvid Heise reassigned FLINK-35109:
---
Assignee: Arvid Heise (was: Ruan Hang)
> Add support for Flink 1.20-SNAPSHOT in Flink Kafk
[
https://issues.apache.org/jira/browse/FLINK-25920?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17866657#comment-17866657
]
Arvid Heise commented on FLINK-25920:
-
Sorry for the delay. I looked through the log
[
https://issues.apache.org/jira/browse/FLINK-25920?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17866657#comment-17866657
]
Arvid Heise edited comment on FLINK-25920 at 7/17/24 9:28 AM:
[
https://issues.apache.org/jira/browse/FLINK-1228?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14270772#comment-14270772
]
Arvid Heise commented on FLINK-1228:
My original intent with this ticket was indeed si
[
https://issues.apache.org/jira/browse/FLINK-25920?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17871304#comment-17871304
]
Arvid Heise commented on FLINK-25920:
-
I'm still unable to make any sense of the pro
Arvid Heise created FLINK-36176:
---
Summary: Remove support for ancient Kafka versions
Key: FLINK-36176
URL: https://issues.apache.org/jira/browse/FLINK-36176
Project: Flink
Issue Type: Technical
Arvid Heise created FLINK-36177:
---
Summary: Deprecating KafkaShuffle
Key: FLINK-36177
URL: https://issues.apache.org/jira/browse/FLINK-36177
Project: Flink
Issue Type: Technical Debt
C
[
https://issues.apache.org/jira/browse/FLINK-36176?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17878037#comment-17878037
]
Arvid Heise commented on FLINK-36176:
-
Merged into main as 268f6b5.
> Remove suppor
[
https://issues.apache.org/jira/browse/FLINK-22748?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Arvid Heise reassigned FLINK-22748:
---
Assignee: Kevin Lam (was: Nicholas Jiang)
> Allow dynamic target topic selection in SQL Ka
[
https://issues.apache.org/jira/browse/FLINK-36210?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Arvid Heise resolved FLINK-36210.
-
Fix Version/s: kafka-3.3.0
Resolution: Fixed
Merged into main as
https://github.com/apac
[
https://issues.apache.org/jira/browse/FLINK-36210?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Arvid Heise reassigned FLINK-36210:
---
Assignee: xiaochen.zhou
> Optimize the logic for fetching topic metadata in the TopicPatter
[
https://issues.apache.org/jira/browse/FLINK-34470?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17881536#comment-17881536
]
Arvid Heise commented on FLINK-34470:
-
[~dongwoo.kim] I have added a
[review|https:
Arvid Heise created FLINK-36278:
---
Summary: Fix Kafka connector logs getting too big
Key: FLINK-36278
URL: https://issues.apache.org/jira/browse/FLINK-36278
Project: Flink
Issue Type: Technical
Arvid Heise created FLINK-36287:
---
Summary: Sink with topologies should not participate in UC
Key: FLINK-36287
URL: https://issues.apache.org/jira/browse/FLINK-36287
Project: Flink
Issue Type: B
[
https://issues.apache.org/jira/browse/FLINK-34470?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Arvid Heise resolved FLINK-34470.
-
Fix Version/s: kafka-3.3.0
Release Note: Merged as 122a743
Resolution: Fixed
> Trans
Arvid Heise created FLINK-20444:
---
Summary: Chain AsyncWaitOperator to new sources
Key: FLINK-20444
URL: https://issues.apache.org/jira/browse/FLINK-20444
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-20444?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Arvid Heise reassigned FLINK-20444:
---
Assignee: Arvid Heise
> Chain AsyncWaitOperator to new sources
> --
[
https://issues.apache.org/jira/browse/FLINK-20444?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Arvid Heise resolved FLINK-20444.
-
Fix Version/s: 1.13.0
1.12.0
Resolution: Fixed
> Chain AsyncWaitOperat
[
https://issues.apache.org/jira/browse/FLINK-20444?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17241772#comment-17241772
]
Arvid Heise commented on FLINK-20444:
-
Merged into master as f79a09b8488190b549f4b71
[
https://issues.apache.org/jira/browse/FLINK-20418?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17241820#comment-17241820
]
Arvid Heise commented on FLINK-20418:
-
Merged into master as d019ce782164ddf317dd497
[
https://issues.apache.org/jira/browse/FLINK-20418?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Arvid Heise resolved FLINK-20418.
-
Resolution: Fixed
> NPE in IteratorSourceReader
> ---
>
>
[
https://issues.apache.org/jira/browse/FLINK-16443?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17242987#comment-17242987
]
Arvid Heise commented on FLINK-16443:
-
Merged into master as 208126aa242c4e217be4931
[
https://issues.apache.org/jira/browse/FLINK-16443?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Arvid Heise resolved FLINK-16443.
-
Fix Version/s: (was: 1.12.0)
1.13.0
Resolution: Fixed
> Fix wrong
[
https://issues.apache.org/jira/browse/FLINK-16443?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Arvid Heise reassigned FLINK-16443:
---
Assignee: Arvid Heise
> Fix wrong fix for user-code CheckpointExceptions
>
[
https://issues.apache.org/jira/browse/FLINK-16582?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17245074#comment-17245074
]
Arvid Heise commented on FLINK-16582:
-
[~gaoyunhaii] is there still some progress on
[
https://issues.apache.org/jira/browse/FLINK-16931?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Arvid Heise updated FLINK-16931:
Affects Version/s: 1.12.0
> Large _metadata file lead to JobManager not responding when restart
>
[
https://issues.apache.org/jira/browse/FLINK-16945?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Arvid Heise updated FLINK-16945:
Affects Version/s: 1.12.0
1.11.2
> Execute CheckpointFailureManager.FailJob
[
https://issues.apache.org/jira/browse/FLINK-17043?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Arvid Heise updated FLINK-17043:
Affects Version/s: 1.13.0
> Putting more information into accounting when failing a job in Failure
[
https://issues.apache.org/jira/browse/FLINK-17192?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Arvid Heise updated FLINK-17192:
Affects Version/s: 1.12.0
> java.lang.RuntimeException: Error obtaining the sorted input: Thread
[
https://issues.apache.org/jira/browse/FLINK-17208?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17245081#comment-17245081
]
Arvid Heise commented on FLINK-17208:
-
What's the status on this ticket? Aren't the
[
https://issues.apache.org/jira/browse/FLINK-19988?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Arvid Heise updated FLINK-19988:
Fix Version/s: 1.13.0
> Make Approximate Local Recovery Compatible With Unaligned Checkpoint
> ---
[
https://issues.apache.org/jira/browse/FLINK-19988?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Arvid Heise updated FLINK-19988:
Affects Version/s: 1.12.0
> Make Approximate Local Recovery Compatible With Unaligned Checkpoint
>
[
https://issues.apache.org/jira/browse/FLINK-19938?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Arvid Heise updated FLINK-19938:
Fix Version/s: 1.13.0
> Implement shuffle data read scheduling for sort-merge blocking shuffle
> -
[
https://issues.apache.org/jira/browse/FLINK-19925?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Arvid Heise updated FLINK-19925:
Fix Version/s: (was: 1.12.0)
1.12.1
1.13.0
> Errors$Nati
[
https://issues.apache.org/jira/browse/FLINK-19774?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Arvid Heise updated FLINK-19774:
Fix Version/s: 1.13.0
> Introduce Sub Partition View Version for Approximate Local Recovery
>
[
https://issues.apache.org/jira/browse/FLINK-19801?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Arvid Heise updated FLINK-19801:
Fix Version/s: 1.13.0
> Add support for virtual channels
>
>
>
[
https://issues.apache.org/jira/browse/FLINK-19895?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Arvid Heise updated FLINK-19895:
Fix Version/s: 1.13.0
> Unify Life Cycle Management of ResultPartitionType Pipelined Family
>
[
https://issues.apache.org/jira/browse/FLINK-19682?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Arvid Heise updated FLINK-19682:
Fix Version/s: 1.13.0
> Actively timeout checkpoint barriers on the inputs
> -
[
https://issues.apache.org/jira/browse/FLINK-19683?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Arvid Heise updated FLINK-19683:
Fix Version/s: 1.13.0
> Actively timeout aligned checkpoints on the output
> -
[
https://issues.apache.org/jira/browse/FLINK-19537?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Arvid Heise updated FLINK-19537:
Fix Version/s: 1.13.0
> Processed in-flight bytes metric is not accurate
> ---
[
https://issues.apache.org/jira/browse/FLINK-19016?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Arvid Heise updated FLINK-19016:
Component/s: (was: Runtime / Checkpointing)
Runtime / State Backends
> Checks
[
https://issues.apache.org/jira/browse/FLINK-18983?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Arvid Heise updated FLINK-18983:
Affects Version/s: 1.12.0
> Job doesn't changed to failed if close function has blocked
>
[
https://issues.apache.org/jira/browse/FLINK-18753?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Arvid Heise updated FLINK-18753:
Fix Version/s: (was: 1.12.0)
1.13.0
> Support local recovery for Unaligned
[
https://issues.apache.org/jira/browse/FLINK-18578?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Arvid Heise updated FLINK-18578:
Component/s: Connectors / Common
> Add rejecting checkpoint logic in source
>
[
https://issues.apache.org/jira/browse/FLINK-18578?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17245105#comment-17245105
]
Arvid Heise commented on FLINK-18578:
-
This sounds to me as if this should be implem
[
https://issues.apache.org/jira/browse/FLINK-18577?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17245108#comment-17245108
]
Arvid Heise commented on FLINK-18577:
-
Sorry for the late reply. Jira is not the bes
[
https://issues.apache.org/jira/browse/FLINK-18577?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Arvid Heise resolved FLINK-18577.
-
Resolution: Not A Problem
> Mail.run Blocked By the Legacy Source Thread
> -
[
https://issues.apache.org/jira/browse/FLINK-18572?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17245109#comment-17245109
]
Arvid Heise commented on FLINK-18572:
-
Unaligned checkpoint config is shown in 1.12+
[
https://issues.apache.org/jira/browse/FLINK-18572?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Arvid Heise updated FLINK-18572:
Component/s: (was: Runtime / Checkpointing)
Runtime / Web Frontend
[
https://issues.apache.org/jira/browse/FLINK-18424?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Arvid Heise resolved FLINK-18424.
-
Resolution: Incomplete
> How does standalone mode not rely on distributed state storage
> --
[
https://issues.apache.org/jira/browse/FLINK-18424?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17245194#comment-17245194
]
Arvid Heise commented on FLINK-18424:
-
Such questions are usually better asked on
[
[
https://issues.apache.org/jira/browse/FLINK-18405?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Arvid Heise updated FLINK-18405:
Fix Version/s: 1.13.0
> Add watermark support for unaligned checkpoints
>
[
https://issues.apache.org/jira/browse/FLINK-18139?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Arvid Heise resolved FLINK-18139.
-
Fix Version/s: 1.11.3
1.12.0
Resolution: Fixed
> Unaligned checkpoints
[
https://issues.apache.org/jira/browse/FLINK-17979?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Arvid Heise updated FLINK-17979:
Fix Version/s: (was: 1.12.0)
1.13.0
> Support rescaling for Unaligned Check
[
https://issues.apache.org/jira/browse/FLINK-17972?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Arvid Heise updated FLINK-17972:
Fix Version/s: 1.13.0
> Consider restructuring channel state
> ---
[
https://issues.apache.org/jira/browse/FLINK-17921?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Arvid Heise updated FLINK-17921:
Component/s: Runtime / Coordination
> RpcGlobalAggregateManager#updateGlobalAggregate would cause
[
https://issues.apache.org/jira/browse/FLINK-17808?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Arvid Heise updated FLINK-17808:
Fix Version/s: (was: 1.12.0)
1.13.0
> Rename checkpoint meta file to "_meta
[
https://issues.apache.org/jira/browse/FLINK-17732?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Arvid Heise resolved FLINK-17732.
-
Resolution: Cannot Reproduce
> RescalingITCase.testSavepointRescalingOutPartitionedOperatorState
[
https://issues.apache.org/jira/browse/FLINK-17732?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17245202#comment-17245202
]
Arvid Heise commented on FLINK-17732:
-
Ran test 1000x and couldn't reproduce. Both f
[
https://issues.apache.org/jira/browse/FLINK-17921?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17245224#comment-17245224
]
Arvid Heise commented on FLINK-17921:
-
[~mingleizhang], your proposal is definitivel
[
https://issues.apache.org/jira/browse/FLINK-17921?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Arvid Heise resolved FLINK-17921.
-
Resolution: Won't Fix
> RpcGlobalAggregateManager#updateGlobalAggregate would cause unexpected
[
https://issues.apache.org/jira/browse/FLINK-20376?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17245465#comment-17245465
]
Arvid Heise commented on FLINK-20376:
-
Could you make a screenshot of the topology o
[
https://issues.apache.org/jira/browse/FLINK-20489?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17245468#comment-17245468
]
Arvid Heise commented on FLINK-20489:
-
Let's first collect general information in
h
[
https://issues.apache.org/jira/browse/FLINK-20489?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17245468#comment-17245468
]
Arvid Heise edited comment on FLINK-20489 at 12/7/20, 7:35 PM:
---
[
https://issues.apache.org/jira/browse/FLINK-20433?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Arvid Heise reassigned FLINK-20433:
---
Assignee: Arvid Heise
> UnalignedCheckpointTestBase.execute failed with "TestTimedOutExcept
[
https://issues.apache.org/jira/browse/FLINK-20433?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17245537#comment-17245537
]
Arvid Heise commented on FLINK-20433:
-
Here is what I found so far
{noformat}
2352
[
https://issues.apache.org/jira/browse/FLINK-20433?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17245767#comment-17245767
]
Arvid Heise commented on FLINK-20433:
-
This ^ is actually a very rare issue that may
Arvid Heise created FLINK-20654:
---
Summary: Unaligned checkpoint recovery may lead to corrupted data
stream
Key: FLINK-20654
URL: https://issues.apache.org/jira/browse/FLINK-20654
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-20389?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17251651#comment-17251651
]
Arvid Heise commented on FLINK-20389:
-
The last couple of reported issues are caused
[
https://issues.apache.org/jira/browse/FLINK-20389?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17251651#comment-17251651
]
Arvid Heise edited comment on FLINK-20389 at 12/18/20, 10:12 AM:
-
1 - 100 of 1402 matches
Mail list logo