[
https://issues.apache.org/jira/browse/FLINK-18647?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17616283#comment-17616283
]
Piotr Nowojski commented on FLINK-18647:
+1 for moving the discussion to the dev mailing list.
[
https://issues.apache.org/jira/browse/FLINK-29584?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17615773#comment-17615773
]
Piotr Nowojski commented on FLINK-29584:
I think it might, but I think the issue we are seeing
Piotr Nowojski created FLINK-29584:
--
Summary: Upgrade java 11 version on the microbenchmark worker
Key: FLINK-29584
URL: https://issues.apache.org/jira/browse/FLINK-29584
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-28474?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski closed FLINK-28474.
--
Fix Version/s: (was: 1.15.3)
(was: 1.14.7)
[
https://issues.apache.org/jira/browse/FLINK-16908?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski updated FLINK-16908:
---
Fix Version/s: (was: 1.17.0)
> FlinkKafkaProducerITCase testScaleUpAfterScalingDown
[
https://issues.apache.org/jira/browse/FLINK-21307?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski updated FLINK-21307:
---
Fix Version/s: (was: 1.17.0)
> Revisit activation model of FlinkSecurityManager
>
[
https://issues.apache.org/jira/browse/FLINK-15550?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski updated FLINK-15550:
---
Fix Version/s: (was: 1.17.0)
> testCancelTaskExceptionAfterTaskMarkedFailed failed on
[
https://issues.apache.org/jira/browse/FLINK-26568?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski updated FLINK-26568:
---
Fix Version/s: (was: 1.17.0)
>
[
https://issues.apache.org/jira/browse/FLINK-23970?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski updated FLINK-23970:
---
Fix Version/s: (was: 1.17.0)
> Split off the behaviour for finished StreamTask(s)
>
[
https://issues.apache.org/jira/browse/FLINK-18647?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17611059#comment-17611059
]
Piotr Nowojski edited comment on FLINK-18647 at 9/29/22 2:20 PM:
-
[
https://issues.apache.org/jira/browse/FLINK-18647?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17611059#comment-17611059
]
Piotr Nowojski commented on FLINK-18647:
{quote}
I tend to we directly head to the final
[
https://issues.apache.org/jira/browse/FLINK-29406?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski reassigned FLINK-29406:
--
Assignee: lincoln lee
> Expose Finish Method For TableFunction
>
[
https://issues.apache.org/jira/browse/FLINK-18647?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17607948#comment-17607948
]
Piotr Nowojski commented on FLINK-18647:
[~dkapoor1], is there some other ticket for the
{quote}
[
https://issues.apache.org/jira/browse/FLINK-27101?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski updated FLINK-27101:
---
Component/s: Runtime / REST
> Periodically break the chain of incremental checkpoint
[
https://issues.apache.org/jira/browse/FLINK-27101?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski updated FLINK-27101:
---
Summary: Periodically break the chain of incremental checkpoint (trigger
checkpoints via
[
https://issues.apache.org/jira/browse/FLINK-6755?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17458438#comment-17458438
]
Piotr Nowojski edited comment on FLINK-6755 at 9/19/22 10:19 AM:
-
The
[
https://issues.apache.org/jira/browse/FLINK-27530?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17606522#comment-17606522
]
Piotr Nowojski commented on FLINK-27530:
[~godfreyhe] there were no braking changes that user
[
https://issues.apache.org/jira/browse/FLINK-18647?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17606503#comment-17606503
]
Piotr Nowojski edited comment on FLINK-18647 at 9/19/22 8:59 AM:
-
[
https://issues.apache.org/jira/browse/FLINK-18647?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17606503#comment-17606503
]
Piotr Nowojski commented on FLINK-18647:
{{quote}}
I would suggest going for an implementation
[
https://issues.apache.org/jira/browse/FLINK-23886?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski updated FLINK-23886:
---
Affects Version/s: 1.14.4
1.13.5
> An exception is thrown out when
[
https://issues.apache.org/jira/browse/FLINK-28975?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17598346#comment-17598346
]
Piotr Nowojski edited comment on FLINK-28975 at 8/31/22 12:05 PM:
--
[
https://issues.apache.org/jira/browse/FLINK-28975?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17598346#comment-17598346
]
Piotr Nowojski commented on FLINK-28975:
{quote}WatermarksWithIdleness (which is an impl of
[
https://issues.apache.org/jira/browse/FLINK-28975?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17597833#comment-17597833
]
Piotr Nowojski commented on FLINK-28975:
Why are we re-emitting idleness periodically?
>
[
https://issues.apache.org/jira/browse/FLINK-26326?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski updated FLINK-26326:
---
Fix Version/s: (was: 1.17.0)
> FLIP-203: Support native and incremental savepoints 1.1
[
https://issues.apache.org/jira/browse/FLINK-26683?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski updated FLINK-26683:
---
Fix Version/s: (was: 1.17.0)
> Commit side effects if stop-with-savepoint failed while
[
https://issues.apache.org/jira/browse/FLINK-22805?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski updated FLINK-22805:
---
Fix Version/s: (was: 1.17.0)
> Dynamic configuration of Flink checkpoint interval
>
[
https://issues.apache.org/jira/browse/FLINK-11499?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski updated FLINK-11499:
---
Priority: Not a Priority (was: Minor)
> Extend StreamingFileSink BulkFormats to support
[
https://issues.apache.org/jira/browse/FLINK-11499?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski updated FLINK-11499:
---
Fix Version/s: (was: 1.17.0)
> Extend StreamingFileSink BulkFormats to support
[
https://issues.apache.org/jira/browse/FLINK-15378?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski updated FLINK-15378:
---
Fix Version/s: (was: 1.17.0)
> StreamFileSystemSink supported mutil hdfs plugins.
>
[
https://issues.apache.org/jira/browse/FLINK-15012?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski updated FLINK-15012:
---
Fix Version/s: (was: 1.17.0)
> Checkpoint directory not cleaned up
>
[
https://issues.apache.org/jira/browse/FLINK-20103?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski updated FLINK-20103:
---
Fix Version/s: (was: 1.17.0)
> Improve test coverage with chaos testing & side-by-side
[
https://issues.apache.org/jira/browse/FLINK-18405?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski updated FLINK-18405:
---
Fix Version/s: (was: 1.17.0)
> Add watermark support for unaligned checkpoints
>
[
https://issues.apache.org/jira/browse/FLINK-28853?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski reassigned FLINK-28853:
--
Assignee: Sebastian Mattheis
> FLIP-217 Support watermark alignment of source splits
[
https://issues.apache.org/jira/browse/FLINK-28504?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17583571#comment-17583571
]
Piotr Nowojski commented on FLINK-28504:
{quote}
After giving this a second look I think the
[
https://issues.apache.org/jira/browse/FLINK-28835?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski closed FLINK-28835.
--
Resolution: Fixed
fixed on release-1.15 as 39a737f31be
merged commit b1c40bd into
[
https://issues.apache.org/jira/browse/FLINK-28835?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski reassigned FLINK-28835:
--
Assignee: Piotr Nowojski
> Savepoint and checkpoint capabilities and limitations
[
https://issues.apache.org/jira/browse/FLINK-28835?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski updated FLINK-28835:
---
Priority: Critical (was: Major)
> Savepoint and checkpoint capabilities and limitations
Piotr Nowojski created FLINK-28835:
--
Summary: Savepoint and checkpoint capabilities and limitations
table is incorrect
Key: FLINK-28835
URL: https://issues.apache.org/jira/browse/FLINK-28835
[
https://issues.apache.org/jira/browse/FLINK-25256?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski closed FLINK-25256.
--
Fix Version/s: 1.15.0
(was: 1.14.6)
Resolution: Fixed
>
[
https://issues.apache.org/jira/browse/FLINK-28474?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski updated FLINK-28474:
---
Description:
After Checkpoint abort, ChannelStateWriteResult should fail.
But if
[
https://issues.apache.org/jira/browse/FLINK-27165?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski updated FLINK-27165:
---
Priority: Not a Priority (was: Minor)
> Benchmark test
[
https://issues.apache.org/jira/browse/FLINK-22643?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17565043#comment-17565043
]
Piotr Nowojski edited comment on FLINK-22643 at 7/11/22 2:55 PM:
-
After
[
https://issues.apache.org/jira/browse/FLINK-22643?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski updated FLINK-22643:
---
Attachment: Screenshot 2022-07-11 at 16.55.02.png
> Too many TCP connections among
[
https://issues.apache.org/jira/browse/FLINK-22643?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17565043#comment-17565043
]
Piotr Nowojski edited comment on FLINK-22643 at 7/11/22 2:52 PM:
-
After
[
https://issues.apache.org/jira/browse/FLINK-22643?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17565043#comment-17565043
]
Piotr Nowojski edited comment on FLINK-22643 at 7/11/22 2:52 PM:
-
After
[
https://issues.apache.org/jira/browse/FLINK-22643?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17565043#comment-17565043
]
Piotr Nowojski commented on FLINK-22643:
After closing a ticket I forgot to mention that this
[
https://issues.apache.org/jira/browse/FLINK-22643?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski updated FLINK-22643:
---
Attachment: Screenshot 2022-07-11 at 16.49.42.png
> Too many TCP connections among
[
https://issues.apache.org/jira/browse/FLINK-28487?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski reassigned FLINK-28487:
--
Assignee: Hong Liang Teoh
> Introduce configurable RateLimitingStrategy for Async
[
https://issues.apache.org/jira/browse/FLINK-28357?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17564588#comment-17564588
]
Piotr Nowojski commented on FLINK-28357:
Hi [~Sandys-Lumsdaine]
{quote}
Maybe my example above
[
https://issues.apache.org/jira/browse/FLINK-28357?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17563760#comment-17563760
]
Piotr Nowojski edited comment on FLINK-28357 at 7/8/22 7:18 AM:
I've
[
https://issues.apache.org/jira/browse/FLINK-28357?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17563760#comment-17563760
]
Piotr Nowojski edited comment on FLINK-28357 at 7/7/22 7:18 PM:
I've
[
https://issues.apache.org/jira/browse/FLINK-28357?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski updated FLINK-28357:
---
Fix Version/s: 1.16.0
> Watermark issue when recovering Finished sources
>
[
https://issues.apache.org/jira/browse/FLINK-28357?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski closed FLINK-28357.
--
Fix Version/s: 1.15.2
1.14.6
Resolution: Fixed
I've fixed the
[
https://issues.apache.org/jira/browse/FLINK-28357?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17562485#comment-17562485
]
Piotr Nowojski commented on FLINK-28357:
{quote}
Also - you say "non-chained map" but I believe
[
https://issues.apache.org/jira/browse/FLINK-28357?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17562234#comment-17562234
]
Piotr Nowojski edited comment on FLINK-28357 at 7/4/22 7:38 PM:
Thanks
[
https://issues.apache.org/jira/browse/FLINK-28357?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17562234#comment-17562234
]
Piotr Nowojski commented on FLINK-28357:
Thanks for the bug report. Indeed there was a bug where
[
https://issues.apache.org/jira/browse/FLINK-28357?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski reassigned FLINK-28357:
--
Assignee: Piotr Nowojski
> Watermark issue when recovering Finished sources
>
Title: Message Title
Piotr Nowojski
Title: Message Title
Piotr Nowojski
[
https://issues.apache.org/jira/browse/FLINK-26803?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17559261#comment-17559261
]
Piotr Nowojski commented on FLINK-26803:
Hi [~fanrui] +1, from my side to the design doc.
>
[
https://issues.apache.org/jira/browse/FLINK-26803?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski reassigned FLINK-26803:
--
Assignee: fanrui
> Merge small ChannelState file for Unaligned Checkpoint
>
[
https://issues.apache.org/jira/browse/FLINK-26762?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski closed FLINK-26762.
--
Resolution: Fixed
Chinese documentation translation merged as commit e57f2cf into
[
https://issues.apache.org/jira/browse/FLINK-27921?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17558053#comment-17558053
]
Piotr Nowojski commented on FLINK-27921:
Benchmarks maybe could be rewritten in such way that
[
https://issues.apache.org/jira/browse/FLINK-25454?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17557971#comment-17557971
]
Piotr Nowojski commented on FLINK-25454:
merged commit 10e6341 into apache:release-1.14
This
[
https://issues.apache.org/jira/browse/FLINK-25454?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17557971#comment-17557971
]
Piotr Nowojski edited comment on FLINK-25454 at 6/23/22 9:33 AM:
-
merged
[
https://issues.apache.org/jira/browse/FLINK-25454?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski updated FLINK-25454:
---
Fix Version/s: 1.14.6
> Negative time in throughput calculator
>
[
https://issues.apache.org/jira/browse/FLINK-26762?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17556873#comment-17556873
]
Piotr Nowojski edited comment on FLINK-26762 at 6/21/22 3:48 PM:
-
[
https://issues.apache.org/jira/browse/FLINK-26762?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17556873#comment-17556873
]
Piotr Nowojski commented on FLINK-26762:
Feature merged commit 0b60ee8 into apache:master
> Add
[
https://issues.apache.org/jira/browse/FLINK-26762?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski updated FLINK-26762:
---
Release Note:
New concept of overdraft network buffers was introduced to mitigate effects
[
https://issues.apache.org/jira/browse/FLINK-27792?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17556311#comment-17556311
]
Piotr Nowojski commented on FLINK-27792:
Thanks for the analysis [~fanrui]. It makes sense to
[
https://issues.apache.org/jira/browse/FLINK-27792?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=1725#comment-1725
]
Piotr Nowojski commented on FLINK-27792:
Thanks for pointing this out. So what's happening in
[
https://issues.apache.org/jira/browse/FLINK-27792?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17555461#comment-17555461
]
Piotr Nowojski commented on FLINK-27792:
What is causing this `InterruptedException`? Where does
[
https://issues.apache.org/jira/browse/FLINK-26993?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17555078#comment-17555078
]
Piotr Nowojski commented on FLINK-26993:
merged commit 3e86cf2 into apache:release-1.15 now
>
[
https://issues.apache.org/jira/browse/FLINK-26993?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski updated FLINK-26993:
---
Fix Version/s: 1.15.2
> CheckpointCoordinatorTest#testMinCheckpointPause
>
[
https://issues.apache.org/jira/browse/FLINK-25454?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17555077#comment-17555077
]
Piotr Nowojski commented on FLINK-25454:
I've looked into backporting this fix, but it's not
[
https://issues.apache.org/jira/browse/FLINK-27114?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski updated FLINK-27114:
---
Fix Version/s: (was: 1.16.0)
(was: 1.15.1)
[
https://issues.apache.org/jira/browse/FLINK-24483?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski updated FLINK-24483:
---
Fix Version/s: (was: 1.16.0)
(was: 1.13.7)
[
https://issues.apache.org/jira/browse/FLINK-27522?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski closed FLINK-27522.
--
Resolution: Fixed
merged commit 9146220 into apache:master
> Ignore max buffers per channel
[
https://issues.apache.org/jira/browse/FLINK-27667?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17543996#comment-17543996
]
Piotr Nowojski commented on FLINK-27667:
[
https://issues.apache.org/jira/browse/FLINK-27667?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski updated FLINK-27667:
---
Priority: Critical (was: Major)
> YARNHighAvailabilityITCase fails with "Failed to delete
[
https://issues.apache.org/jira/browse/FLINK-27825?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski closed FLINK-27825.
--
Resolution: Fixed
Thanks for the update [~fanrui].
merged commit 317b230 into apache:master
[
https://issues.apache.org/jira/browse/FLINK-27825?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski reassigned FLINK-27825:
--
Assignee: fanrui (was: Piotr Nowojski)
> Update the doc of aligned checkpoint
[
https://issues.apache.org/jira/browse/FLINK-27825?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski reassigned FLINK-27825:
--
Assignee: Piotr Nowojski
> Update the doc of aligned checkpoint timeout
>
[
https://issues.apache.org/jira/browse/FLINK-27789?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski reassigned FLINK-27789:
--
Assignee: fanrui
> LegacySource compatible with overdraft buffer
>
[
https://issues.apache.org/jira/browse/FLINK-27530?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski reassigned FLINK-27530:
--
Assignee: fanrui
> FLIP-227: Support overdraft buffer
>
[
https://issues.apache.org/jira/browse/FLINK-27522?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski reassigned FLINK-27522:
--
Assignee: fanrui
> Ignore max buffers per channel when allocate buffer
>
[
https://issues.apache.org/jira/browse/FLINK-27251?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski closed FLINK-27251.
--
Resolution: Fixed
Merged to master as e68d679e8ac^^..e68d679e8ac.
Thank you [~fanrui] for a
[
https://issues.apache.org/jira/browse/FLINK-27724?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski closed FLINK-27724.
--
Resolution: Not A Problem
As [~fanrui] pointed out in an offline discussion,
[
https://issues.apache.org/jira/browse/FLINK-27724?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski reassigned FLINK-27724:
--
Assignee: fanrui
> The SubtaskCheckpointCoordinatorImpl#close() isn't called in
[
https://issues.apache.org/jira/browse/FLINK-27724?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17540947#comment-17540947
]
Piotr Nowojski commented on FLINK-27724:
{quote}
In StreamTask#cancel(),
[
https://issues.apache.org/jira/browse/FLINK-26803?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17538819#comment-17538819
]
Piotr Nowojski commented on FLINK-26803:
Sorry for late response [~fanrui]. Thanks for the
[
https://issues.apache.org/jira/browse/FLINK-27251?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17538730#comment-17538730
]
Piotr Nowojski edited comment on FLINK-27251 at 5/18/22 11:01 AM:
--
[
https://issues.apache.org/jira/browse/FLINK-27251?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17538730#comment-17538730
]
Piotr Nowojski commented on FLINK-27251:
Thanks [~fanrui] for the update. I will take a look :)
[
https://issues.apache.org/jira/browse/FLINK-27640?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski updated FLINK-27640:
---
Summary: Flink not compiling, flink-connector-hive_2.12 is missing jhyde
Piotr Nowojski created FLINK-27640:
--
Summary: Flink not compiling, flink-connector-hive_2.12 is missing
pentaho-aggdesigner-algorithm:jar:5.1.5-jhyde
Key: FLINK-27640
URL:
[
https://issues.apache.org/jira/browse/FLINK-27251?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17536089#comment-17536089
]
Piotr Nowojski edited comment on FLINK-27251 at 5/12/22 12:34 PM:
--
[
https://issues.apache.org/jira/browse/FLINK-27251?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski reassigned FLINK-27251:
--
Assignee: fanrui
> Timeout aligned to unaligned checkpoint barrier in the output
[
https://issues.apache.org/jira/browse/FLINK-27251?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17536089#comment-17536089
]
Piotr Nowojski commented on FLINK-27251:
Thanks for the answers. Re 3., thanks for the pointers,
[
https://issues.apache.org/jira/browse/FLINK-25872?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17534881#comment-17534881
]
Piotr Nowojski commented on FLINK-25872:
I would still wait and see how many people would be
[
https://issues.apache.org/jira/browse/FLINK-27251?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17534876#comment-17534876
]
Piotr Nowojski edited comment on FLINK-27251 at 5/11/22 12:53 PM:
--
I've
501 - 600 of 4477 matches
Mail list logo