[
https://issues.apache.org/jira/browse/FLINK-19688?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17218858#comment-17218858
]
Arvid Heise commented on FLINK-19688:
-
Merged into master as 840e8af879e69c1bf9ad121
[
https://issues.apache.org/jira/browse/FLINK-19688?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Arvid Heise resolved FLINK-19688.
-
Resolution: Fixed
> Flink batch job fails because of InterruptedExceptions from network stack
>
Arvid Heise created FLINK-19801:
---
Summary: Add support for virtual channels
Key: FLINK-19801
URL: https://issues.apache.org/jira/browse/FLINK-19801
Project: Flink
Issue Type: Sub-task
[
https://issues.apache.org/jira/browse/FLINK-19338?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Arvid Heise resolved FLINK-19338.
-
Fix Version/s: 1.12.0
Resolution: Fixed
> New source interface cannot unregister unregist
[
https://issues.apache.org/jira/browse/FLINK-19338?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17220369#comment-17220369
]
Arvid Heise commented on FLINK-19338:
-
I'm deeply sorry for the confusion. I already
[
https://issues.apache.org/jira/browse/FLINK-19338?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17220371#comment-17220371
]
Arvid Heise commented on FLINK-19338:
-
Merged into master as c34b5a2121deed7475f172d
[
https://issues.apache.org/jira/browse/FLINK-19791?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17220523#comment-17220523
]
Arvid Heise commented on FLINK-19791:
-
Merged a fix into master as 0184672733fb2417c
[
https://issues.apache.org/jira/browse/FLINK-19791?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Arvid Heise resolved FLINK-19791.
-
Resolution: Fixed
> PartitionRequestClientFactoryTest.testInterruptsNotCached fails with
> Null
[
https://issues.apache.org/jira/browse/FLINK-19801?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Arvid Heise updated FLINK-19801:
Description:
During rescaling of unaligned checkpoints, if state from multiple former
channels ar
[
https://issues.apache.org/jira/browse/FLINK-22830?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17358565#comment-17358565
]
Arvid Heise commented on FLINK-22830:
-
I'm responding on stackoverflow. Such questio
[
https://issues.apache.org/jira/browse/FLINK-22830?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Arvid Heise closed FLINK-22830.
---
Resolution: Not A Problem
> DataSet API to allow to collect and do the bulk upload in DB
> -
Arvid Heise created FLINK-22902:
---
Summary: Port KafkaSink to FLIP-143
Key: FLINK-22902
URL: https://issues.apache.org/jira/browse/FLINK-22902
Project: Flink
Issue Type: Improvement
Co
[
https://issues.apache.org/jira/browse/FLINK-22876?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17359288#comment-17359288
]
Arvid Heise commented on FLINK-22876:
-
Merged into master as
e36792d184ce0f60912b99
[
https://issues.apache.org/jira/browse/FLINK-22792?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Arvid Heise reassigned FLINK-22792:
---
Assignee: Tianxin Zhao
> Limit size of already processed files in File Source SplitEnumerat
[
https://issues.apache.org/jira/browse/FLINK-22608?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Arvid Heise closed FLINK-22608.
---
Resolution: Invalid
Hi [~Autumn],
Please check [Supported data types for schema
evolution|https://
Arvid Heise created FLINK-22964:
---
Summary: Connector-base exposes dependency to flink-core.
Key: FLINK-22964
URL: https://issues.apache.org/jira/browse/FLINK-22964
Project: Flink
Issue Type: Bu
[
https://issues.apache.org/jira/browse/FLINK-22964?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Arvid Heise updated FLINK-22964:
Description:
Connectors get shaded into the user jar and as such should contain no
unnecessary de
[
https://issues.apache.org/jira/browse/FLINK-22964?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Arvid Heise updated FLINK-22964:
Labels: classloading (was: )
> Connector-base exposes dependency to flink-core.
> ---
[
https://issues.apache.org/jira/browse/FLINK-22964?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Arvid Heise updated FLINK-22964:
Component/s: Connectors / Common
> Connector-base exposes dependency to flink-core.
>
[
https://issues.apache.org/jira/browse/FLINK-22876?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Arvid Heise closed FLINK-22876.
---
Resolution: Fixed
> Adding SharedObjects junit rule to ease test development
> -
[
https://issues.apache.org/jira/browse/FLINK-21389?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17363389#comment-17363389
]
Arvid Heise commented on FLINK-21389:
-
Merged into 1.13 as 4780b5d98e53c7a1cbabf2092
[
https://issues.apache.org/jira/browse/FLINK-21389?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Arvid Heise closed FLINK-21389.
---
Fix Version/s: 1.13.2
Resolution: Resolved
> ParquetInputFormat should not need parquet schem
Arvid Heise created FLINK-23024:
---
Summary: RPC result TaskManagerInfoWithSlots not serializable
Key: FLINK-23024
URL: https://issues.apache.org/jira/browse/FLINK-23024
Project: Flink
Issue Type
[
https://issues.apache.org/jira/browse/FLINK-23024?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17364965#comment-17364965
]
Arvid Heise commented on FLINK-23024:
-
CC [~karmagyz]
> RPC result TaskManagerInfoW
[
https://issues.apache.org/jira/browse/FLINK-22698?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Arvid Heise resolved FLINK-22698.
-
Fix Version/s: 1.13.2
1.12.5
1.14.0
Resolution: Fixe
[
https://issues.apache.org/jira/browse/FLINK-22698?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17367250#comment-17367250
]
Arvid Heise commented on FLINK-22698:
-
Merged into master as 9df4d26530c3dc12345d3c4
[
https://issues.apache.org/jira/browse/FLINK-20888?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Arvid Heise reassigned FLINK-20888:
---
Assignee: Arvid Heise
> ContinuousFileReaderOperator should not close the output on close()
[
https://issues.apache.org/jira/browse/FLINK-23011?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17368014#comment-17368014
]
Arvid Heise commented on FLINK-23011:
-
Thanks for sharing your thoughts.
I agree wi
[
https://issues.apache.org/jira/browse/FLINK-23011?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17368244#comment-17368244
]
Arvid Heise commented on FLINK-23011:
-
Re 1b) I agree that we already have it for st
[
https://issues.apache.org/jira/browse/FLINK-23022?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17368252#comment-17368252
]
Arvid Heise commented on FLINK-23022:
-
Imho is the ticket correct and we should fix
[
https://issues.apache.org/jira/browse/FLINK-23022?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17368252#comment-17368252
]
Arvid Heise edited comment on FLINK-23022 at 6/23/21, 2:51 PM:
---
[
https://issues.apache.org/jira/browse/FLINK-23022?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17368252#comment-17368252
]
Arvid Heise edited comment on FLINK-23022 at 6/23/21, 2:52 PM:
---
[
https://issues.apache.org/jira/browse/FLINK-23022?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17368278#comment-17368278
]
Arvid Heise commented on FLINK-23022:
-
Sorry you are right, it definitively loads fr
[
https://issues.apache.org/jira/browse/FLINK-22081?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Arvid Heise reassigned FLINK-22081:
---
Assignee: Chen Qin (was: Prem Santosh)
> Entropy key not resolved if flink-s3-fs-hadoop is
[
https://issues.apache.org/jira/browse/FLINK-22053?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17312892#comment-17312892
]
Arvid Heise commented on FLINK-22053:
-
Merged into master as a93251b4599e7c7d77ec6f0
[
https://issues.apache.org/jira/browse/FLINK-22053?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Arvid Heise resolved FLINK-22053.
-
Fix Version/s: 1.12.3
1.13.0
Resolution: Fixed
> NumberSequenceSource
[
https://issues.apache.org/jira/browse/FLINK-13550?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17313104#comment-17313104
]
Arvid Heise commented on FLINK-13550:
-
Merged into master for 1.13 as
e9385051cd2ac
[
https://issues.apache.org/jira/browse/FLINK-13550?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Arvid Heise resolved FLINK-13550.
-
Fix Version/s: 1.13.0
Release Note: Flink now offers Flamegraphs for each node in the job gr
[
https://issues.apache.org/jira/browse/FLINK-13552?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Arvid Heise closed FLINK-13552.
---
Release Note: Directly resolved in parent ticket.
Resolution: Done
> Render vertex FlameGraph
[
https://issues.apache.org/jira/browse/FLINK-13551?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Arvid Heise closed FLINK-13551.
---
Release Note: Directly resolved in parent ticket.
Resolution: Fixed
> Add vertex FlameGraph RE
[
https://issues.apache.org/jira/browse/FLINK-21880?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17316001#comment-17316001
]
Arvid Heise commented on FLINK-21880:
-
Merged fix into master as 2b1cf60219ba3ae88c3
[
https://issues.apache.org/jira/browse/FLINK-21880?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Arvid Heise resolved FLINK-21880.
-
Fix Version/s: 1.13.0
Resolution: Fixed
> UnalignedCheckpointRescaleITCase fails on azure
[
https://issues.apache.org/jira/browse/FLINK-22084?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17316018#comment-17316018
]
Arvid Heise commented on FLINK-22084:
-
We shouldn't support changes in maxParallelis
[
https://issues.apache.org/jira/browse/FLINK-22019?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17316029#comment-17316029
]
Arvid Heise commented on FLINK-22019:
-
For the time being, I'm assuming that this is
[
https://issues.apache.org/jira/browse/FLINK-20816?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Arvid Heise reassigned FLINK-20816:
---
Assignee: Arvid Heise
> NotifyCheckpointAbortedITCase failed due to timeout
> -
[
https://issues.apache.org/jira/browse/FLINK-21797?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Arvid Heise reassigned FLINK-21797:
---
Assignee: (was: Arvid Heise)
> Performance regression on 03/11/21
> ---
[
https://issues.apache.org/jira/browse/FLINK-21378?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Arvid Heise closed FLINK-21378.
---
Resolution: Incomplete
The idea is incomplete, see FLINK-21936.
> Rescale pointwise connection duri
[
https://issues.apache.org/jira/browse/FLINK-16504?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17316107#comment-17316107
]
Arvid Heise commented on FLINK-16504:
-
It seems as if I get proper priority for crea
[
https://issues.apache.org/jira/browse/FLINK-22132?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Arvid Heise updated FLINK-22132:
Description:
To test unaligned checkpoints, we should use a few different applications that
use d
[
https://issues.apache.org/jira/browse/FLINK-21873?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Arvid Heise reassigned FLINK-21873:
---
Assignee: Arvid Heise
> CoordinatedSourceRescaleITCase.testUpscaling fails on AZP
> ---
[
https://issues.apache.org/jira/browse/FLINK-22132?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17316161#comment-17316161
]
Arvid Heise commented on FLINK-22132:
-
Since the task is pretty huge. I'm splitting
Arvid Heise created FLINK-22136:
---
Summary: Device application for unaligned checkpoint test on
cluster
Key: FLINK-22136
URL: https://issues.apache.org/jira/browse/FLINK-22136
Project: Flink
Is
Arvid Heise created FLINK-22137:
---
Summary: Execute unaligned checkpoint test on a cluster
Key: FLINK-22137
URL: https://issues.apache.org/jira/browse/FLINK-22137
Project: Flink
Issue Type: Sub-
[
https://issues.apache.org/jira/browse/FLINK-22132?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Arvid Heise updated FLINK-22132:
Description:
To test unaligned checkpoints, we should use a few different applications that
use d
[
https://issues.apache.org/jira/browse/FLINK-21873?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17316183#comment-17316183
]
Arvid Heise commented on FLINK-21873:
-
The exception actually showed that everything
[
https://issues.apache.org/jira/browse/FLINK-20816?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17316515#comment-17316515
]
Arvid Heise commented on FLINK-20816:
-
[~yunta]'s analysis is spot on; there is not
[
https://issues.apache.org/jira/browse/FLINK-20816?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17316519#comment-17316519
]
Arvid Heise commented on FLINK-20816:
-
Indeed
https://dev.azure.com/apache-flink/ap
[
https://issues.apache.org/jira/browse/FLINK-21873?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17316684#comment-17316684
]
Arvid Heise commented on FLINK-21873:
-
Merged into master as 9953206599910983425dcee
[
https://issues.apache.org/jira/browse/FLINK-21873?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Arvid Heise resolved FLINK-21873.
-
Fix Version/s: (was: 1.14.0)
1.13.0
Resolution: Fixed
> Coordinate
[
https://issues.apache.org/jira/browse/FLINK-22081?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17316922#comment-17316922
]
Arvid Heise commented on FLINK-22081:
-
Merged into master as 2d3559e66db, into 1.12
[
https://issues.apache.org/jira/browse/FLINK-22081?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Arvid Heise updated FLINK-22081:
Fix Version/s: (was: 1.10.4)
(was: 1.12.2)
(was:
[
https://issues.apache.org/jira/browse/FLINK-22081?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Arvid Heise updated FLINK-22081:
Affects Version/s: 1.13.0
1.10.3
1.11.3
[
https://issues.apache.org/jira/browse/FLINK-22081?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Arvid Heise updated FLINK-22081:
Priority: Major (was: Minor)
> Entropy key not resolved if flink-s3-fs-hadoop is added as a plugi
[
https://issues.apache.org/jira/browse/FLINK-22081?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17316924#comment-17316924
]
Arvid Heise commented on FLINK-22081:
-
Merging into 1.10 is quite an effort and the
[
https://issues.apache.org/jira/browse/FLINK-22081?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Arvid Heise resolved FLINK-22081.
-
Resolution: Fixed
> Entropy key not resolved if flink-s3-fs-hadoop is added as a plugin
> --
[
https://issues.apache.org/jira/browse/FLINK-22136?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Arvid Heise updated FLINK-22136:
Description:
To test unaligned checkpoints, we should use a few different applications that
use d
[
https://issues.apache.org/jira/browse/FLINK-22173?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17317784#comment-17317784
]
Arvid Heise commented on FLINK-22173:
-
Browsing through the log, we first have some
[
https://issues.apache.org/jira/browse/FLINK-20816?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17317839#comment-17317839
]
Arvid Heise commented on FLINK-20816:
-
With some more echo debugging, it's most like
[
https://issues.apache.org/jira/browse/FLINK-20816?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17317839#comment-17317839
]
Arvid Heise edited comment on FLINK-20816 at 4/9/21, 10:00 AM:
---
[
https://issues.apache.org/jira/browse/FLINK-20816?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17317847#comment-17317847
]
Arvid Heise commented on FLINK-20816:
-
That is actually be design of the test
{nofor
[
https://issues.apache.org/jira/browse/FLINK-20816?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17318134#comment-17318134
]
Arvid Heise commented on FLINK-20816:
-
I found the root cause: the test assumes impl
[
https://issues.apache.org/jira/browse/FLINK-20816?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17318485#comment-17318485
]
Arvid Heise commented on FLINK-20816:
-
Downgraded to Major as it's a test-only issue
[
https://issues.apache.org/jira/browse/FLINK-20816?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Arvid Heise updated FLINK-20816:
Priority: Major (was: Critical)
> NotifyCheckpointAbortedITCase failed due to timeout
> -
[
https://issues.apache.org/jira/browse/FLINK-17979?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Arvid Heise resolved FLINK-17979.
-
Resolution: Fixed
Solved with FLINK-19533, FLINK-19801, and FLINK-21945.
> Support rescaling fo
[
https://issues.apache.org/jira/browse/FLINK-19801?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Arvid Heise updated FLINK-19801:
Release Note: (was: While recovering from unaligned checkpoints, users
can now change the parall
[
https://issues.apache.org/jira/browse/FLINK-17979?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Arvid Heise updated FLINK-17979:
Release Note: While recovering from unaligned checkpoints, users can now
change the parallelism of
[
https://issues.apache.org/jira/browse/FLINK-20816?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17319664#comment-17319664
]
Arvid Heise commented on FLINK-20816:
-
Merged into master as fad4874f9866de7d3c2f5fb
[
https://issues.apache.org/jira/browse/FLINK-20816?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Arvid Heise resolved FLINK-20816.
-
Resolution: Fixed
> NotifyCheckpointAbortedITCase failed due to timeout
> --
[
https://issues.apache.org/jira/browse/FLINK-22190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17319910#comment-17319910
]
Arvid Heise commented on FLINK-22190:
-
1. You get byZeroException because you are di
[
https://issues.apache.org/jira/browse/FLINK-21992?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17319986#comment-17319986
]
Arvid Heise commented on FLINK-21992:
-
It turns out that there is an issue with noti
[
https://issues.apache.org/jira/browse/FLINK-21992?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Arvid Heise updated FLINK-21992:
Summary: Fix availability notification in UnionInputGate (was: Investigate
potential buffer leak
[
https://issues.apache.org/jira/browse/FLINK-22173?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17319992#comment-17319992
]
Arvid Heise commented on FLINK-22173:
-
I'm expecting some connection to FLINK-21992.
[
https://issues.apache.org/jira/browse/FLINK-21992?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Arvid Heise reassigned FLINK-21992:
---
Assignee: Arvid Heise (was: Piotr Nowojski)
> Fix availability notification in UnionInputG
[
https://issues.apache.org/jira/browse/FLINK-22259?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17320466#comment-17320466
]
Arvid Heise commented on FLINK-22259:
-
Seems to be test-only:
{noformat}
07:36:19,5
[
https://issues.apache.org/jira/browse/FLINK-21992?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Arvid Heise updated FLINK-21992:
Fix Version/s: 1.12.3
> Fix availability notification in UnionInputGate
>
[
https://issues.apache.org/jira/browse/FLINK-21992?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17321096#comment-17321096
]
Arvid Heise commented on FLINK-21992:
-
Merged into master as 7c3abe11a28d54a585985ef
[
https://issues.apache.org/jira/browse/FLINK-22259?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Arvid Heise reassigned FLINK-22259:
---
Assignee: Arvid Heise
> UnalignedCheckpointITCase fails with "Value too large for header, t
[
https://issues.apache.org/jira/browse/FLINK-22259?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17321208#comment-17321208
]
Arvid Heise commented on FLINK-22259:
-
Source is not finishing as {{numRestarts}} is
[
https://issues.apache.org/jira/browse/FLINK-21992?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17321279#comment-17321279
]
Arvid Heise commented on FLINK-21992:
-
Merged into 1.12 as e2cbfad6a3cdafe3d568bb43a
[
https://issues.apache.org/jira/browse/FLINK-21992?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Arvid Heise resolved FLINK-21992.
-
Resolution: Fixed
> Fix availability notification in UnionInputGate
> --
[
https://issues.apache.org/jira/browse/FLINK-22259?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17321280#comment-17321280
]
Arvid Heise commented on FLINK-22259:
-
It seems as if the {{SyncEvent}} is not sent
[
https://issues.apache.org/jira/browse/FLINK-22259?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17321282#comment-17321282
]
Arvid Heise commented on FLINK-22259:
-
I guess the test assumes that the enumerator
[
https://issues.apache.org/jira/browse/FLINK-22259?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17321282#comment-17321282
]
Arvid Heise edited comment on FLINK-22259 at 4/15/21, 7:08 AM:
---
[
https://issues.apache.org/jira/browse/FLINK-22259?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17321282#comment-17321282
]
Arvid Heise edited comment on FLINK-22259 at 4/15/21, 7:25 AM:
---
[
https://issues.apache.org/jira/browse/FLINK-22019?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17331824#comment-17331824
]
Arvid Heise commented on FLINK-22019:
-
Probably a duplicate of FLINK-22368.
> Unali
[
https://issues.apache.org/jira/browse/FLINK-22019?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17331824#comment-17331824
]
Arvid Heise edited comment on FLINK-22019 at 4/26/21, 6:59 AM:
---
[
https://issues.apache.org/jira/browse/FLINK-22136?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17333024#comment-17333024
]
Arvid Heise commented on FLINK-22136:
-
Merged into master as
7973bbc6e748a0ca36741b
[
https://issues.apache.org/jira/browse/FLINK-22136?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Arvid Heise resolved FLINK-22136.
-
Fix Version/s: 1.14.0
Resolution: Fixed
> Device application for unaligned checkpoint tes
[
https://issues.apache.org/jira/browse/FLINK-17170?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17337132#comment-17337132
]
Arvid Heise commented on FLINK-17170:
-
Hi [~dannycranmer] , why do we need to have t
[
https://issues.apache.org/jira/browse/FLINK-17170?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Arvid Heise reassigned FLINK-17170:
---
Assignee: Arvid Heise
> Cannot stop streaming job with savepoint which uses kinesis consume
601 - 700 of 1523 matches
Mail list logo
