[jira] [Updated] (FLINK-24846) AsyncWaitOperator fails during stop-with-savepoint

2021-12-15 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24846?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-24846: --- Fix Version/s: 1.15.0 1.14.3 > AsyncWaitOperator fails during

[jira] [Assigned] (FLINK-25199) fromValues does not emit final MAX watermark

2021-12-15 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25199?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski reassigned FLINK-25199: -- Assignee: (was: Dawid Wysakowicz) > fromValues does not emit final MAX watermark

[jira] [Assigned] (FLINK-18808) Task-level numRecordsOut metric may be underestimated

2021-12-15 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18808?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski reassigned FLINK-18808: -- Assignee: Lijie Wang > Task-level numRecordsOut metric may be underestimated >

[jira] [Commented] (FLINK-18808) Task-level numRecordsOut metric may be underestimated

2021-12-14 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18808?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17459274#comment-17459274 ] Piotr Nowojski commented on FLINK-18808: That would be great :) would you like me to assign the

[jira] [Commented] (FLINK-6755) Allow triggering Checkpoints through command line client

2021-12-13 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-6755?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17458438#comment-17458438 ] Piotr Nowojski commented on FLINK-6755: --- The motivation behind this feature request will be covered

[jira] [Closed] (FLINK-12619) Support TERMINATE/SUSPEND Job with Checkpoint

2021-12-13 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-12619?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-12619. -- Resolution: Won't Do FLINK-25276 should address the motivation behind this feature, while the

[jira] [Created] (FLINK-25276) Support native and incremental savepoints

2021-12-13 Thread Piotr Nowojski (Jira)
Piotr Nowojski created FLINK-25276: -- Summary: Support native and incremental savepoints Key: FLINK-25276 URL: https://issues.apache.org/jira/browse/FLINK-25276 Project: Flink Issue Type:

[jira] [Closed] (FLINK-11748) Optimize savepoint: Remove the task states and KeyedState into increments.

2021-12-13 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-11748?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-11748. -- Resolution: Abandoned The PR has been closed. It looks like this ticket should have been

[jira] [Created] (FLINK-25275) Weighted KeyGroup assignment

2021-12-13 Thread Piotr Nowojski (Jira)
Piotr Nowojski created FLINK-25275: -- Summary: Weighted KeyGroup assignment Key: FLINK-25275 URL: https://issues.apache.org/jira/browse/FLINK-25275 Project: Flink Issue Type: New Feature

[jira] [Commented] (FLINK-25256) Savepoints do not work with ExternallyInducedSources

2021-12-10 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25256?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17457073#comment-17457073 ] Piotr Nowojski commented on FLINK-25256: This is related to supporting/handling "force full

[jira] [Updated] (FLINK-25256) Savepoints do not work with ExternallyInducedSources

2021-12-10 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25256?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-25256: --- Description: It is not possible to take a proper savepoint with {{ExternallyInducedSource}}

[jira] [Commented] (FLINK-18808) Task-level numRecordsOut metric may be underestimated

2021-12-10 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18808?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17457071#comment-17457071 ] Piotr Nowojski commented on FLINK-18808: [~wanglijie95] as far as I remember, counting calls to

[jira] [Created] (FLINK-25255) Consider/design implementing State Processor API (FC)

2021-12-10 Thread Piotr Nowojski (Jira)
Piotr Nowojski created FLINK-25255: -- Summary: Consider/design implementing State Processor API (FC) Key: FLINK-25255 URL: https://issues.apache.org/jira/browse/FLINK-25255 Project: Flink

[jira] [Commented] (FLINK-18808) Task-level numRecordsOut metric may be underestimated

2021-12-09 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18808?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17456235#comment-17456235 ] Piotr Nowojski commented on FLINK-18808: I'm not sure. Maybe it would be actually better to pick

[jira] [Updated] (FLINK-18647) How to handle processing time timers with bounded input

2021-12-09 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18647?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-18647: --- Priority: Not a Priority (was: Minor) > How to handle processing time timers with bounded

[jira] [Commented] (FLINK-25167) Support user-defined `StreamOperatorFactory` in `ConnectedStreams`#transform

2021-12-09 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25167?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17456224#comment-17456224 ] Piotr Nowojski commented on FLINK-25167: Until we overhaul {{ProcessFunction}} I think exposing

[jira] [Commented] (FLINK-24149) Make checkpoint self-contained and relocatable

2021-12-08 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24149?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17455237#comment-17455237 ] Piotr Nowojski commented on FLINK-24149: [~Feifan Wang] I've noticed that you opened a PR for

[jira] [Assigned] (FLINK-24086) Do not re-register SharedStateRegistry to reduce the recovery time of the job

2021-12-08 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24086?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski reassigned FLINK-24086: -- Assignee: Roman Khachatryan (was: ming li) > Do not re-register SharedStateRegistry

[jira] [Updated] (FLINK-25026) UnalignedCheckpointRescaleITCase.shouldRescaleUnalignedCheckpoint fails on AZP

2021-12-08 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25026?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-25026: --- Priority: Major (was: Critical) >

[jira] [Closed] (FLINK-25081) When chaining an operator of a side output stream, the num records sent displayed on the dashboard is incorrect

2021-12-07 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25081?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-25081. -- Resolution: Duplicate [~reswqa], let me close this ticket so that we have all of the

[jira] [Updated] (FLINK-25081) When chaining an operator of a side output stream, the num records sent displayed on the dashboard is incorrect

2021-12-07 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25081?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-25081: --- Component/s: Runtime / Task (was: Runtime / Network) > When chaining

[jira] [Updated] (FLINK-25081) When chaining an operator of a side output stream, the num records sent displayed on the dashboard is incorrect

2021-12-07 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25081?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-25081: --- Component/s: Runtime / Network > When chaining an operator of a side output stream, the num

[jira] [Comment Edited] (FLINK-25081) When chaining an operator of a side output stream, the num records sent displayed on the dashboard is incorrect

2021-12-07 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25081?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17454624#comment-17454624 ] Piotr Nowojski edited comment on FLINK-25081 at 12/7/21, 12:41 PM: ---

[jira] [Commented] (FLINK-25081) When chaining an operator of a side output stream, the num records sent displayed on the dashboard is incorrect

2021-12-07 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25081?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17454624#comment-17454624 ] Piotr Nowojski commented on FLINK-25081: Isn't this a duplicate of FLINK-18808? > When chaining

[jira] [Updated] (FLINK-25191) Skip savepoints for recovery

2021-12-07 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25191?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-25191: --- Description: Intermediate savepoints should not be used for recovery. In order to achieve

[jira] [Updated] (FLINK-14884) User defined function for checkpoint trigger time and interval behavior

2021-12-06 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14884?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-14884: --- Priority: Not a Priority (was: Minor) > User defined function for checkpoint trigger time

[jira] [Updated] (FLINK-14011) Make some fields final and initialize them during construction in AsyncWaitOperator

2021-12-06 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14011?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-14011: --- Priority: Not a Priority (was: Minor) > Make some fields final and initialize them during

[jira] [Commented] (FLINK-25103) KeyedBroadcastProcessFunction run set 6, parallelism ValueState variables A

2021-12-06 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25103?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17453848#comment-17453848 ] Piotr Nowojski commented on FLINK-25103: Hey [~wangbaohua]. Note for the future, it's much

[jira] [Updated] (FLINK-25103) KeyedBroadcastProcessFunction run set 6, parallelism ValueState variables A

2021-12-06 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25103?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-25103: --- Priority: Major (was: Blocker) > KeyedBroadcastProcessFunction run set 6, parallelism

[jira] [Updated] (FLINK-25028) java.lang.OutOfMemoryError: Java heap space

2021-12-05 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25028?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-25028: --- Priority: Major (was: Critical) > java.lang.OutOfMemoryError: Java heap space >

[jira] [Commented] (FLINK-24696) Translate how to configure unaligned checkpoints into Chinese

2021-11-23 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24696?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17448094#comment-17448094 ] Piotr Nowojski commented on FLINK-24696: Sure, thanks! > Translate how to configure unaligned

[jira] [Assigned] (FLINK-24696) Translate how to configure unaligned checkpoints into Chinese

2021-11-23 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24696?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski reassigned FLINK-24696: -- Assignee: ZhuoYu Chen > Translate how to configure unaligned checkpoints into

[jira] [Updated] (FLINK-16931) Large _metadata file lead to JobManager not responding when restart

2021-11-23 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16931?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-16931: --- Priority: Not a Priority (was: Minor) > Large _metadata file lead to JobManager not

[jira] [Updated] (FLINK-11038) Rewrite Kafka at-least-once it cases

2021-11-22 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-11038?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-11038: --- Priority: Not a Priority (was: Minor) > Rewrite Kafka at-least-once it cases >

[jira] [Commented] (FLINK-24967) Make the IO pattern configureable in state benchmarks

2021-11-22 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24967?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17447515#comment-17447515 ] Piotr Nowojski commented on FLINK-24967: [~aitozi], about this TODO that I've left, I didn't

[jira] [Commented] (FLINK-24693) Update Chinese version of "Checkpoints" and "Checkpointing" page

2021-11-22 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24693?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17447507#comment-17447507 ] Piotr Nowojski commented on FLINK-24693: Sure! Thanks for taking care of this. > Update Chinese

[jira] [Assigned] (FLINK-24693) Update Chinese version of "Checkpoints" and "Checkpointing" page

2021-11-22 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24693?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski reassigned FLINK-24693: -- Assignee: wulei0302 > Update Chinese version of "Checkpoints" and "Checkpointing"

[jira] [Updated] (FLINK-20724) Create a http handler for aggregating metrics from whole job

2021-11-22 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20724?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-20724: --- Priority: Not a Priority (was: Minor) > Create a http handler for aggregating metrics from

[jira] [Closed] (FLINK-20724) Create a http handler for aggregating metrics from whole job

2021-11-22 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20724?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-20724. -- Resolution: Abandoned > Create a http handler for aggregating metrics from whole job >

[jira] [Updated] (FLINK-20743) Print ContainerId For RemoteTransportException

2021-11-22 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20743?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-20743: --- Priority: Not a Priority (was: Minor) > Print ContainerId For RemoteTransportException >

[jira] [Updated] (FLINK-21467) Document possible recommended usage of Bounded{One/Multi}Input.endInput and emphasize that they could be called multiple times

2021-11-22 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21467?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-21467: --- Priority: Not a Priority (was: Minor) > Document possible recommended usage of

[jira] [Comment Edited] (FLINK-24815) Reduce the cpu cost of calculating stateSize during state allocation

2021-11-22 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24815?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17447466#comment-17447466 ] Piotr Nowojski edited comment on FLINK-24815 at 11/22/21, 3:13 PM: --- I

[jira] [Comment Edited] (FLINK-24815) Reduce the cpu cost of calculating stateSize during state allocation

2021-11-22 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24815?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17447466#comment-17447466 ] Piotr Nowojski edited comment on FLINK-24815 at 11/22/21, 3:13 PM: --- I

[jira] [Updated] (FLINK-24815) Reduce the cpu cost of calculating stateSize during state allocation

2021-11-22 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24815?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-24815: --- Component/s: Runtime / State Backends > Reduce the cpu cost of calculating stateSize during

[jira] [Commented] (FLINK-24815) Reduce the cpu cost of calculating stateSize during state allocation

2021-11-22 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24815?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17447466#comment-17447466 ] Piotr Nowojski commented on FLINK-24815: I think you are right. It looks like the

[jira] [Updated] (FLINK-12674) BoundedBlockingSubpartition#unsynchronizedGetNumberOfQueuedBuffers is not implemented

2021-11-16 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-12674?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-12674: --- Priority: Not a Priority (was: Minor) >

[jira] [Updated] (FLINK-12872) WindowOperator may fail with UnsupportedOperationException when merging windows

2021-11-16 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-12872?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-12872: --- Priority: Not a Priority (was: Minor) > WindowOperator may fail with

[jira] [Commented] (FLINK-24815) Reduce the cpu cost of calculating stateSize during state allocation

2021-11-16 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24815?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17444375#comment-17444375 ] Piotr Nowojski commented on FLINK-24815: I don't know much about this part of the code so sorry

[jira] [Closed] (FLINK-23466) UnalignedCheckpointITCase hangs on Azure

2021-11-16 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23466?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-23466. -- Resolution: Fixed I've extracted the newly reported issue to FLINK-24919 >

[jira] [Created] (FLINK-24919) UnalignedCheckpointITCase hangs on Azure

2021-11-16 Thread Piotr Nowojski (Jira)
Piotr Nowojski created FLINK-24919: -- Summary: UnalignedCheckpointITCase hangs on Azure Key: FLINK-24919 URL: https://issues.apache.org/jira/browse/FLINK-24919 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-24800) BufferTimeoutITCase.testDisablingBufferTimeout failed on Azure

2021-11-11 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24800?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17442272#comment-17442272 ] Piotr Nowojski commented on FLINK-24800: I agree with your assessment [~akalashnikov]. Let's

[jira] [Updated] (FLINK-24846) AsyncWaitOperator fails during stop-with-savepoint

2021-11-09 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24846?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-24846: --- Priority: Critical (was: Major) > AsyncWaitOperator fails during stop-with-savepoint >

[jira] [Updated] (FLINK-24846) AsyncWaitOperator fails during stop-with-savepoint

2021-11-09 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24846?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-24846: --- Affects Version/s: 1.14.0 > AsyncWaitOperator fails during stop-with-savepoint >

[jira] [Created] (FLINK-24846) AsyncWaitOperator fails during stop-with-savepoint

2021-11-09 Thread Piotr Nowojski (Jira)
Piotr Nowojski created FLINK-24846: -- Summary: AsyncWaitOperator fails during stop-with-savepoint Key: FLINK-24846 URL: https://issues.apache.org/jira/browse/FLINK-24846 Project: Flink Issue

[jira] [Closed] (FLINK-23665) Flaky test: BlockingShuffleITCase.testBoundedBlockingShuffle

2021-11-09 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23665?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-23665. -- Resolution: Duplicate > Flaky test: BlockingShuffleITCase.testBoundedBlockingShuffle >

[jira] [Updated] (FLINK-23665) Flaky test: BlockingShuffleITCase.testBoundedBlockingShuffle

2021-11-09 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23665?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-23665: --- Component/s: Runtime / Task > Flaky test: BlockingShuffleITCase.testBoundedBlockingShuffle

[jira] [Updated] (FLINK-24800) BufferTimeoutITCase.testDisablingBufferTimeout failed on Azure

2021-11-09 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24800?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-24800: --- Priority: Blocker (was: Critical) > BufferTimeoutITCase.testDisablingBufferTimeout failed

[jira] [Comment Edited] (FLINK-24690) Clarification of buffer size threshold calculation in BufferDebloater

2021-11-09 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24690?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17440943#comment-17440943 ] Piotr Nowojski edited comment on FLINK-24690 at 11/9/21, 9:14 AM: -- I

[jira] [Commented] (FLINK-24815) Reduce the cpu cost of calculating stateSize during state allocation

2021-11-09 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24815?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17440963#comment-17440963 ] Piotr Nowojski commented on FLINK-24815: {quote} I think we can try to provide a construction

[jira] [Updated] (FLINK-24815) Reduce the cpu cost of calculating stateSize during state allocation

2021-11-09 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24815?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-24815: --- Affects Version/s: 1.14.0 > Reduce the cpu cost of calculating stateSize during state

[jira] [Closed] (FLINK-24659) Two active miniCluster in RemoteBenchmarkBase

2021-11-08 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24659?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-24659. -- Fix Version/s: 1.15.0 Resolution: Fixed merged commit 0f8d2e3 into

[jira] [Assigned] (FLINK-24481) Translate buffer debloat documenation to chinese

2021-11-08 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24481?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski reassigned FLINK-24481: -- Assignee: Liu (was: Jichun Liu) > Translate buffer debloat documenation to chinese

[jira] [Assigned] (FLINK-24481) Translate buffer debloat documenation to chinese

2021-11-08 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24481?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski reassigned FLINK-24481: -- Assignee: Jichun Liu > Translate buffer debloat documenation to chinese >

[jira] [Commented] (FLINK-24481) Translate buffer debloat documenation to chinese

2021-11-08 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24481?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17440950#comment-17440950 ] Piotr Nowojski commented on FLINK-24481: Sure [~Jiangang], done. > Translate buffer debloat

[jira] [Assigned] (FLINK-24376) Operator name in OperatorCoordinator should not use chained name

2021-11-08 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24376?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski reassigned FLINK-24376: -- Assignee: Qingsheng Ren > Operator name in OperatorCoordinator should not use

[jira] [Commented] (FLINK-24690) Clarification of buffer size threshold calculation in BufferDebloater

2021-11-08 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24690?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17440943#comment-17440943 ] Piotr Nowojski commented on FLINK-24690: I would be in favour of simplifying this so that

[jira] [Updated] (FLINK-24738) Fail during announcing buffer size to released local channel

2021-11-08 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24738?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-24738: --- Fix Version/s: 1.14.1 > Fail during announcing buffer size to released local channel >

[jira] [Comment Edited] (FLINK-24401) TM cannot exit after Metaspace OOM

2021-11-07 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24401?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17440253#comment-17440253 ] Piotr Nowojski edited comment on FLINK-24401 at 11/8/21, 7:52 AM: --

[jira] [Closed] (FLINK-24401) TM cannot exit after Metaspace OOM

2021-11-07 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24401?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-24401. -- Fix Version/s: 1.15.0 Resolution: Fixed Merged to master/release-1.14/release-1.13 as

[jira] [Updated] (FLINK-18808) Task-level numRecordsOut metric may be underestimated

2021-11-07 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18808?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-18808: --- Labels: pull-request-available usability (was: auto-deprioritized-major

[jira] [Updated] (FLINK-18808) Task-level numRecordsOut metric may be underestimated

2021-11-07 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18808?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-18808: --- Priority: Not a Priority (was: Minor) > Task-level numRecordsOut metric may be

[jira] [Updated] (FLINK-19052) Performance issue with PojoSerializer

2021-11-07 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19052?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-19052: --- Priority: Not a Priority (was: Minor) > Performance issue with PojoSerializer >

[jira] [Comment Edited] (FLINK-24401) TM cannot exit after Metaspace OOM

2021-11-03 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24401?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17437798#comment-17437798 ] Piotr Nowojski edited comment on FLINK-24401 at 11/3/21, 8:02 AM: --

[jira] [Updated] (FLINK-19113) Add support for checkpointing with selectable inputs

2021-11-03 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19113?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-19113: --- Priority: Not a Priority (was: Minor) > Add support for checkpointing with selectable

[jira] [Commented] (FLINK-24401) TM cannot exit after Metaspace OOM

2021-11-03 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24401?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17437801#comment-17437801 ] Piotr Nowojski commented on FLINK-24401: [~fanrui], is this something that you would like to

[jira] [Commented] (FLINK-24401) TM cannot exit after Metaspace OOM

2021-11-03 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24401?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17437798#comment-17437798 ] Piotr Nowojski commented on FLINK-24401: At this moment I do not see a good justification for

[jira] [Closed] (FLINK-15550) testCancelTaskExceptionAfterTaskMarkedFailed failed on azure

2021-11-02 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15550?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-15550. -- Fix Version/s: 1.13.4 1.14.1 1.15.0 Resolution:

[jira] [Assigned] (FLINK-24659) Two active miniCluster in RemoteBenchmarkBase

2021-11-01 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24659?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski reassigned FLINK-24659: -- Assignee: Piotr Nowojski > Two active miniCluster in RemoteBenchmarkBase >

[jira] [Closed] (FLINK-24553) Change buffer debloating default configuration values

2021-11-01 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24553?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-24553. -- Release Note: The default configuration for buffer debloating mechanism has changed.

[jira] [Reopened] (FLINK-24553) Change buffer debloating default configuration values

2021-11-01 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24553?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski reopened FLINK-24553: > Change buffer debloating default configuration values >

[jira] [Closed] (FLINK-24553) Change buffer debloating default configuration values

2021-11-01 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24553?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-24553. -- Fix Version/s: 1.15.0 Resolution: Fixed merged commit 4377612 into apache:master >

[jira] [Updated] (FLINK-20548) Provide an option to disable propagation of timed out barriers

2021-11-01 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20548?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-20548: --- Priority: Not a Priority (was: Minor) > Provide an option to disable propagation of timed

[jira] [Closed] (FLINK-20489) Error in restoring checkpoint/savepoint when Flink is upgraded from 1.9 to 1.10.2

2021-11-01 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20489?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-20489. -- Resolution: Duplicate > Error in restoring checkpoint/savepoint when Flink is upgraded from

[jira] [Assigned] (FLINK-22088) CheckpointCoordinator might not be able to abort triggering checkpoint if failover happens during triggering

2021-11-01 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22088?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski reassigned FLINK-22088: -- Assignee: (was: Yun Gao) > CheckpointCoordinator might not be able to abort

[jira] [Updated] (FLINK-22088) CheckpointCoordinator might not be able to abort triggering checkpoint if failover happens during triggering

2021-11-01 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22088?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-22088: --- Priority: Not a Priority (was: Minor) > CheckpointCoordinator might not be able to abort

[jira] [Commented] (FLINK-24611) Prevent JM from discarding state on checkpoint abortion

2021-11-01 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24611?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17436699#comment-17436699 ] Piotr Nowojski commented on FLINK-24611: {quote} As for the removal of unused state after JM

[jira] [Commented] (FLINK-24553) Change buffer debloating default configuration values

2021-10-29 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24553?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17435946#comment-17435946 ] Piotr Nowojski commented on FLINK-24553: +1 for your proposals. > Change buffer debloating

[jira] [Updated] (FLINK-21201) Creating BoundedBlockingSubpartition blocks TaskManager’s main thread

2021-10-29 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21201?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-21201: --- Priority: Not a Priority (was: Minor) > Creating BoundedBlockingSubpartition blocks

[jira] [Commented] (FLINK-24694) Translate "Checkpointing under backpressure" page into Chinese

2021-10-29 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24694?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17435938#comment-17435938 ] Piotr Nowojski commented on FLINK-24694: Sure, thanks! > Translate "Checkpointing under

[jira] [Assigned] (FLINK-24694) Translate "Checkpointing under backpressure" page into Chinese

2021-10-29 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24694?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski reassigned FLINK-24694: -- Assignee: zlzhang0122 > Translate "Checkpointing under backpressure" page into

[jira] [Closed] (FLINK-24190) Handling large record with buffer debloat

2021-10-29 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24190?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-24190. -- Resolution: Fixed Merged to master as a3378133471^..a3378133471 > Handling large record with

[jira] [Closed] (FLINK-21263) Job hangs under backpressure

2021-10-29 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21263?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-21263. -- Resolution: Abandoned > Job hangs under backpressure > > >

[jira] [Closed] (FLINK-24670) Restructure unaligned checkpoints documentation page to "Checkpointing under back pressure"

2021-10-29 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24670?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-24670. -- Resolution: Fixed Merged to master as e6ef94814e4^ Merged to release-1.14 as ba0a7f725b4^ >

[jira] [Closed] (FLINK-24695) Update how to configure unaligned checkpoints in the documentation

2021-10-29 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24695?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-24695. -- Fix Version/s: 1.14.1 1.15.0 Resolution: Fixed Merged to master as

[jira] [Updated] (FLINK-24695) Update how to configure unaligned checkpoints in the documentation

2021-10-29 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24695?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-24695: --- Affects Version/s: (was: 1.14.1) 1.14.0 > Update how to

[jira] [Updated] (FLINK-24670) Restructure unaligned checkpoints documentation page to "Checkpointing under back pressure"

2021-10-29 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24670?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-24670: --- Description:

[jira] [Updated] (FLINK-24670) Restructure unaligned checkpoints documentation page to "Checkpointing under back pressure"

2021-10-29 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24670?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-24670: --- Description:

[jira] [Updated] (FLINK-24696) Translate how to configure unaligned checkpoints into Chinese

2021-10-29 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24696?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-24696: --- Description: As part of FLINK-24695

[jira] [Updated] (FLINK-24696) Translate how to configure unaligned checkpoints into Chinese

2021-10-29 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24696?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-24696: --- Description: As part of FLINK-24696

[jira] [Updated] (FLINK-24695) Update how to configure unaligned checkpoints in the documentation

2021-10-29 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24695?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-24695: --- Component/s: (was: chinese-translation) > Update how to configure unaligned checkpoints

<    5   6   7   8   9   10   11   12   13   14   >