[jira] [Comment Edited] (FLINK-26708) TimestampsAndWatermarksOperator should not propagate WatermarkStatus

[ https://issues.apache.org/jira/browse/FLINK-26708?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17513232#comment-17513232 ] Dawid Wysakowicz edited comment on FLINK-26708 at 3/29/22, 11:30 AM: -

[jira] [Commented] (FLINK-26708) TimestampsAndWatermarksOperator should not propagate WatermarkStatus

[ https://issues.apache.org/jira/browse/FLINK-26708?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17514023#comment-17514023 ] Dawid Wysakowicz commented on FLINK-26708: -- Sorry, about that. I shouldn't have backported it

[jira] [Updated] (FLINK-26748) flink jobmanager metaspace oom

[ https://issues.apache.org/jira/browse/FLINK-26748?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-26748: - Component/s: Runtime / Configuration Runtime / Coordination

[jira] [Commented] (FLINK-26748) flink jobmanager metaspace oom

[ https://issues.apache.org/jira/browse/FLINK-26748?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17513975#comment-17513975 ] Dawid Wysakowicz commented on FLINK-26748: -- Could you please elaborate a bit more what are you

[jira] [Updated] (FLINK-26683) Commit side effects if stop-with-savepoint failed while finishing

[ https://issues.apache.org/jira/browse/FLINK-26683?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-26683: - Summary: Commit side effects if stop-with-savepoint failed while finishing (was:

[jira] [Closed] (FLINK-26629) Error in code comment for SubtaskStateMapper.RANGE

[ https://issues.apache.org/jira/browse/FLINK-26629?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz closed FLINK-26629. Fix Version/s: 1.15.0 1.14.5 Assignee: Shubin Ruan

[jira] [Closed] (FLINK-26599) CheckpointCoordinatorTest.testMinCheckpointPause failed on azure

[ https://issues.apache.org/jira/browse/FLINK-26599?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz closed FLINK-26599. Resolution: Cannot Reproduce > CheckpointCoordinatorTest.testMinCheckpointPause failed on

[jira] [Updated] (FLINK-26575) Improve the info message when restoring keyed state backend

[ https://issues.apache.org/jira/browse/FLINK-26575?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-26575: - Labels: pull-request-available starter (was: pull-request-available) > Improve the

[jira] [Updated] (FLINK-26548) the source parallelism is not set correctly with AdaptiveBatchScheduler

[ https://issues.apache.org/jira/browse/FLINK-26548?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-26548: - Component/s: Connectors / FileSystem Runtime / Coordination

[jira] [Closed] (FLINK-26783) Restore from a stop-with-savepoint if failed during committing

[ https://issues.apache.org/jira/browse/FLINK-26783?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz closed FLINK-26783. Resolution: Fixed Fixed in * master ** f21b551f4fc14900e473c88af662db25292e3b8c * 1.15.0

[jira] [Closed] (FLINK-26708) TimestampsAndWatermarksOperator should not propagate WatermarkStatus

[ https://issues.apache.org/jira/browse/FLINK-26708?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz closed FLINK-26708. Fix Version/s: 1.15.0 1.13.7 1.14.5

[jira] [Closed] (FLINK-26854) 重定向数据库无法写入

[ https://issues.apache.org/jira/browse/FLINK-26854?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz closed FLINK-26854. Resolution: Invalid Closing as we use English in JIRA. Feel free to reopen it once you

[jira] [Commented] (FLINK-26783) Restore from a stop-with-savepoint if failed during committing

[ https://issues.apache.org/jira/browse/FLINK-26783?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17511694#comment-17511694 ] Dawid Wysakowicz commented on FLINK-26783: -- After an offline discussion we said that simply

[jira] [Commented] (FLINK-26683) Terminate the job anyway if savepoint finished when stop-with-savepoint

[ https://issues.apache.org/jira/browse/FLINK-26683?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17510519#comment-17510519 ] Dawid Wysakowicz commented on FLINK-26683: -- {quote} In my case, the task doesn't need commit.

[jira] [Updated] (FLINK-26683) Terminate the job anyway if savepoint finished when stop-with-savepoint

[ https://issues.apache.org/jira/browse/FLINK-26683?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-26683: - Affects Version/s: 1.14.4 > Terminate the job anyway if savepoint finished when

[jira] [Updated] (FLINK-26683) Terminate the job anyway if savepoint finished when stop-with-savepoint

[ https://issues.apache.org/jira/browse/FLINK-26683?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-26683: - Fix Version/s: 1.16.0 > Terminate the job anyway if savepoint finished when

[jira] [Commented] (FLINK-26683) Terminate the job anyway if savepoint finished when stop-with-savepoint

[ https://issues.apache.org/jira/browse/FLINK-26683?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17509923#comment-17509923 ] Dawid Wysakowicz commented on FLINK-26683: -- I think we should still restart the job if it fails

[jira] [Created] (FLINK-26783) Restore from a stop-with-savepoint if failed during committing

Dawid Wysakowicz created FLINK-26783: Summary: Restore from a stop-with-savepoint if failed during committing Key: FLINK-26783 URL: https://issues.apache.org/jira/browse/FLINK-26783 Project:

[jira] [Created] (FLINK-26708) TimestampsAndWatermarksOperator should not propagate WatermarkStatus

Dawid Wysakowicz created FLINK-26708: Summary: TimestampsAndWatermarksOperator should not propagate WatermarkStatus Key: FLINK-26708 URL: https://issues.apache.org/jira/browse/FLINK-26708

[jira] [Assigned] (FLINK-26700) Update chinese documentation regarding restore modes

[ https://issues.apache.org/jira/browse/FLINK-26700?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz reassigned FLINK-26700: Assignee: Feifan Wang > Update chinese documentation regarding restore modes >

[jira] [Commented] (FLINK-26700) Update chinese documentation regarding restore modes

[ https://issues.apache.org/jira/browse/FLINK-26700?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17508081#comment-17508081 ] Dawid Wysakowicz commented on FLINK-26700: -- Sure, just be aware I won't be able to help you

[jira] [Created] (FLINK-26700) Update chinese documentation regarding restore modes

Dawid Wysakowicz created FLINK-26700: Summary: Update chinese documentation regarding restore modes Key: FLINK-26700 URL: https://issues.apache.org/jira/browse/FLINK-26700 Project: Flink

[jira] [Updated] (FLINK-26686) Use a junit temp folder for TestingTaskManagerRuntimeInfo tmpWorkingDirectory

[ https://issues.apache.org/jira/browse/FLINK-26686?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-26686: - Description: Following FLINK-26418, maybe it's a good idea to not expose a constructor

[jira] [Closed] (FLINK-26418) Tests on flink-table-planner produce tmp_XXX dirs which are not cleaned up

[ https://issues.apache.org/jira/browse/FLINK-26418?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz closed FLINK-26418. Fix Version/s: 1.15.0 Resolution: Fixed Fixed in: * master **

[jira] [Closed] (FLINK-24328) Long term fix for receiving new buffer size before network reader configured

[ https://issues.apache.org/jira/browse/FLINK-24328?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz closed FLINK-24328. Fix Version/s: (was: 1.15.0) Resolution: Won't Fix We decided the "temporary"

[jira] [Closed] (FLINK-26501) Quickstarts Scala nightly end-to-end test failed on azure due to checkponts failed and logs contains exceptions

[ https://issues.apache.org/jira/browse/FLINK-26501?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz closed FLINK-26501. Fix Version/s: 1.15.0 1.14.5 Resolution: Fixed Fixed in: *

[jira] [Commented] (FLINK-26388) Release Testing: Repeatable Cleanup (FLINK-25433)

[ https://issues.apache.org/jira/browse/FLINK-26388?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17504975#comment-17504975 ] Dawid Wysakowicz commented on FLINK-26388: -- It's fine. I wanted to close it once we decide if

[jira] [Commented] (FLINK-26274) Test local recovery works across TaskManager process restarts

[ https://issues.apache.org/jira/browse/FLINK-26274?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17504916#comment-17504916 ] Dawid Wysakowicz commented on FLINK-26274: -- I repeated the test on current master. It did work

[jira] [Closed] (FLINK-26274) Test local recovery works across TaskManager process restarts

[ https://issues.apache.org/jira/browse/FLINK-26274?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz closed FLINK-26274. Resolution: Done > Test local recovery works across TaskManager process restarts >

[jira] [Updated] (FLINK-26606) CompletedCheckpoints that failed to be discarded are not stored in the CompletedCheckpointStore

[ https://issues.apache.org/jira/browse/FLINK-26606?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-26606: - Component/s: Runtime / Checkpointing > CompletedCheckpoints that failed to be discarded

[jira] [Commented] (FLINK-26274) Test local recovery works across TaskManager process restarts

[ https://issues.apache.org/jira/browse/FLINK-26274?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17504857#comment-17504857 ] Dawid Wysakowicz commented on FLINK-26274: -- Sure! Thanks for taking care of the issue. > Test

[jira] [Commented] (FLINK-26388) Release Testing: Repeatable Cleanup (FLINK-25433)

[ https://issues.apache.org/jira/browse/FLINK-26388?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17504827#comment-17504827 ] Dawid Wysakowicz commented on FLINK-26388: -- No, I meant checkpoints that failed to be

[jira] [Updated] (FLINK-26568) BlockingShuffleITCase.testDeletePartitionFileOfBoundedBlockingShuffle timing out on Azure

[ https://issues.apache.org/jira/browse/FLINK-26568?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-26568: - Component/s: (was: Runtime / Coordination) (was: Tests) >

[jira] [Updated] (FLINK-26568) BlockingShuffleITCase.testDeletePartitionFileOfBoundedBlockingShuffle timing out on Azure

[ https://issues.apache.org/jira/browse/FLINK-26568?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-26568: - Component/s: Runtime / Network >

[jira] [Commented] (FLINK-26388) Release Testing: Repeatable Cleanup (FLINK-25433)

[ https://issues.apache.org/jira/browse/FLINK-26388?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17504243#comment-17504243 ] Dawid Wysakowicz commented on FLINK-26388: -- I checked it again and it seems to work fine. One

[jira] [Closed] (FLINK-26164) Document watermark alignment

[ https://issues.apache.org/jira/browse/FLINK-26164?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz closed FLINK-26164. Resolution: Implemented Implemented in 106280e10a96d729943985986198b942446197d9 >

[jira] [Commented] (FLINK-26274) Test local recovery works across TaskManager process restarts

[ https://issues.apache.org/jira/browse/FLINK-26274?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17503402#comment-17503402 ] Dawid Wysakowicz commented on FLINK-26274: -- [~chesnay] Do I understand correctly, you're

[jira] [Commented] (FLINK-25819) NetworkBufferPoolTest.testIsAvailableOrNotAfterRequestAndRecycleMultiSegments fails on AZP

[ https://issues.apache.org/jira/browse/FLINK-25819?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17503355#comment-17503355 ] Dawid Wysakowicz commented on FLINK-25819: -- Hey [~akalashnikov], do you mind creating a

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

[ https://issues.apache.org/jira/browse/FLINK-25256?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17503350#comment-17503350 ] Dawid Wysakowicz commented on FLINK-25256: -- All Flink versions are affected. It has never

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

[ https://issues.apache.org/jira/browse/FLINK-25256?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-25256: - Affects Version/s: 1.12.7 > Savepoints do not work with ExternallyInducedSources >

[jira] [Updated] (FLINK-26274) Test local recovery works across TaskManager process restarts

[ https://issues.apache.org/jira/browse/FLINK-26274?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-26274: - Attachment: taskmanager_flink-taskmanager-2_log > Test local recovery works across

[jira] [Commented] (FLINK-26274) Test local recovery works across TaskManager process restarts

[ https://issues.apache.org/jira/browse/FLINK-26274?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17502246#comment-17502246 ] Dawid Wysakowicz commented on FLINK-26274: -- {quote} In step 4: Did you happen to check the

[jira] [Commented] (FLINK-26274) Test local recovery works across TaskManager process restarts

[ https://issues.apache.org/jira/browse/FLINK-26274?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17502184#comment-17502184 ] Dawid Wysakowicz commented on FLINK-26274: -- Do you mind taking a look? [~trohrmann] [~dmvk] >

[jira] [Comment Edited] (FLINK-26274) Test local recovery works across TaskManager process restarts

[ https://issues.apache.org/jira/browse/FLINK-26274?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17502183#comment-17502183 ] Dawid Wysakowicz edited comment on FLINK-26274 at 3/7/22, 10:28 AM:

[jira] [Comment Edited] (FLINK-26274) Test local recovery works across TaskManager process restarts

[ https://issues.apache.org/jira/browse/FLINK-26274?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17502183#comment-17502183 ] Dawid Wysakowicz edited comment on FLINK-26274 at 3/7/22, 10:28 AM:

[jira] [Updated] (FLINK-26274) Test local recovery works across TaskManager process restarts

[ https://issues.apache.org/jira/browse/FLINK-26274?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-26274: - Attachment: jobmanager_local_restore_2.log > Test local recovery works across

[jira] [Commented] (FLINK-26274) Test local recovery works across TaskManager process restarts

[ https://issues.apache.org/jira/browse/FLINK-26274?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17502183#comment-17502183 ] Dawid Wysakowicz commented on FLINK-26274: -- I tried testing the feature in a following way: 1.

[jira] [Comment Edited] (FLINK-26491) In org/apache/flink/streaming/api/graph/StreamingJobGraphGenerator.java#L173 the annotation should be "if" instead of "iff"

[ https://issues.apache.org/jira/browse/FLINK-26491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17501273#comment-17501273 ] Dawid Wysakowicz edited comment on FLINK-26491 at 3/4/22, 11:08 AM:

[jira] [Commented] (FLINK-26491) In org/apache/flink/streaming/api/graph/StreamingJobGraphGenerator.java#L173 the annotation should be "if" instead of "iff"

[ https://issues.apache.org/jira/browse/FLINK-26491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17501273#comment-17501273 ] Dawid Wysakowicz commented on FLINK-26491: -- The usage of "iff" there is most probably correct:

[jira] [Assigned] (FLINK-26274) Test local recovery works across TaskManager process restarts

[ https://issues.apache.org/jira/browse/FLINK-26274?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz reassigned FLINK-26274: Assignee: Dawid Wysakowicz > Test local recovery works across TaskManager

[jira] [Assigned] (FLINK-26416) Release Testing: Sink V2 sanity checks

[ https://issues.apache.org/jira/browse/FLINK-26416?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz reassigned FLINK-26416: Assignee: Liu > Release Testing: Sink V2 sanity checks >

[jira] [Closed] (FLINK-25833) FlinkUserCodeClassLoader is not registered as parallel capable

[ https://issues.apache.org/jira/browse/FLINK-25833?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz closed FLINK-25833. Fix Version/s: 1.15.0 Resolution: Fixed Fixed in

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

[ https://issues.apache.org/jira/browse/FLINK-25256?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17500557#comment-17500557 ] Dawid Wysakowicz commented on FLINK-25256: -- I don't have an opinion on a more explicit control

[jira] [Closed] (FLINK-26338) Add documentation of savepoint type on Command-Line part

[ https://issues.apache.org/jira/browse/FLINK-26338?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz closed FLINK-26338. Resolution: Fixed Fixed in fa02a604457bec4ccc0ecc829c0e8e408a6823d8 > Add documentation

[jira] [Closed] (FLINK-26353) "flink stop --help" does not list "--type" option

[ https://issues.apache.org/jira/browse/FLINK-26353?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz closed FLINK-26353. Fix Version/s: 1.15.0 Resolution: Fixed Fixed in

[jira] [Closed] (FLINK-25988) UnalignedCheckpointRescaleITCase failed with exit code 137

[ https://issues.apache.org/jira/browse/FLINK-25988?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz closed FLINK-25988. Fix Version/s: 1.15.0 1.14.5 Resolution: Fixed >

[jira] [Commented] (FLINK-25988) UnalignedCheckpointRescaleITCase failed with exit code 137

[ https://issues.apache.org/jira/browse/FLINK-25988?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17499440#comment-17499440 ] Dawid Wysakowicz commented on FLINK-25988: -- Closing for now as we introduced an improvement in

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

[ https://issues.apache.org/jira/browse/FLINK-25026?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz closed FLINK-25026. Fix Version/s: 1.15.0 1.14.5 Resolution: Fixed >

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

[ https://issues.apache.org/jira/browse/FLINK-25026?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17498966#comment-17498966 ] Dawid Wysakowicz edited comment on FLINK-25026 at 3/1/22, 10:30 AM:

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

[ https://issues.apache.org/jira/browse/FLINK-25256?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz reassigned FLINK-25256: Assignee: (was: Dawid Wysakowicz) > Savepoints do not work with

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

[ https://issues.apache.org/jira/browse/FLINK-25256?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17499438#comment-17499438 ] Dawid Wysakowicz commented on FLINK-25256: -- Externally induced sources are quite limited atm.

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

[ https://issues.apache.org/jira/browse/FLINK-25256?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-25256: - Issue Type: Improvement (was: Bug) > Savepoints do not work with

[jira] [Assigned] (FLINK-26388) Release Testing: Repeatable Cleanup (FLINK-25433)

[ https://issues.apache.org/jira/browse/FLINK-26388?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz reassigned FLINK-26388: Assignee: Dawid Wysakowicz > Release Testing: Repeatable Cleanup (FLINK-25433) >

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

[ https://issues.apache.org/jira/browse/FLINK-25026?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17498966#comment-17498966 ] Dawid Wysakowicz commented on FLINK-25026: -- Introduced a solution to make the test more stable:

[jira] [Commented] (FLINK-26392) Support externally induced sources in MultipleInputStreamTask

[ https://issues.apache.org/jira/browse/FLINK-26392?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17498807#comment-17498807 ] Dawid Wysakowicz commented on FLINK-26392: -- I found a PoC from [~jqin] :

[jira] [Created] (FLINK-26392) Support externally induced sources in MultipleInputStreamTask

Dawid Wysakowicz created FLINK-26392: Summary: Support externally induced sources in MultipleInputStreamTask Key: FLINK-26392 URL: https://issues.apache.org/jira/browse/FLINK-26392 Project: Flink

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

[ https://issues.apache.org/jira/browse/FLINK-25256?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz reassigned FLINK-25256: Assignee: Dawid Wysakowicz > Savepoints do not work with

[jira] [Commented] (FLINK-26389) Many operators of ”flink-end-to-end-tests“ have been deprecated and need to be updated

[ https://issues.apache.org/jira/browse/FLINK-26389?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17498781#comment-17498781 ] Dawid Wysakowicz commented on FLINK-26389: -- Could you please list those in the description? So

[jira] [Commented] (FLINK-26389) Many operators of ”flink-end-to-end-tests“ have been deprecated and need to be updated

[ https://issues.apache.org/jira/browse/FLINK-26389?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17498770#comment-17498770 ] Dawid Wysakowicz commented on FLINK-26389: -- [~chengyunzhang] Could you elaborate which

[jira] [Closed] (FLINK-25819) NetworkBufferPoolTest.testIsAvailableOrNotAfterRequestAndRecycleMultiSegments fails on AZP

[ https://issues.apache.org/jira/browse/FLINK-25819?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz closed FLINK-25819. Fix Version/s: 1.15.0 1.14.5 Resolution: Fixed >

[jira] [Comment Edited] (FLINK-25819) NetworkBufferPoolTest.testIsAvailableOrNotAfterRequestAndRecycleMultiSegments fails on AZP

[ https://issues.apache.org/jira/browse/FLINK-25819?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17498153#comment-17498153 ] Dawid Wysakowicz edited comment on FLINK-25819 at 2/28/22, 8:04 AM:

[jira] [Comment Edited] (FLINK-25819) NetworkBufferPoolTest.testIsAvailableOrNotAfterRequestAndRecycleMultiSegments fails on AZP

[ https://issues.apache.org/jira/browse/FLINK-25819?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17498153#comment-17498153 ] Dawid Wysakowicz edited comment on FLINK-25819 at 2/28/22, 8:03 AM:

[jira] [Commented] (FLINK-26052) Update chinese documentation regarding FLIP-203

[ https://issues.apache.org/jira/browse/FLINK-26052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17498747#comment-17498747 ] Dawid Wysakowicz commented on FLINK-26052: -- Sure [~shenzhu0127] I can assign it to you. Just

[jira] [Assigned] (FLINK-26052) Update chinese documentation regarding FLIP-203

[ https://issues.apache.org/jira/browse/FLINK-26052?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz reassigned FLINK-26052: Assignee: Shen Zhu > Update chinese documentation regarding FLIP-203 >

[jira] [Commented] (FLINK-25819) NetworkBufferPoolTest.testIsAvailableOrNotAfterRequestAndRecycleMultiSegments fails on AZP

[ https://issues.apache.org/jira/browse/FLINK-25819?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17498153#comment-17498153 ] Dawid Wysakowicz commented on FLINK-25819: -- Fixed in: * master **

[jira] [Closed] (FLINK-26354) "-restoreMode" should be "--restoreMode" and should have a shorthand

[ https://issues.apache.org/jira/browse/FLINK-26354?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz closed FLINK-26354. Fix Version/s: 1.15.0 Resolution: Fixed Fixed in

[jira] [Commented] (FLINK-26349) AvroParquetReaders does not work with ReflectData

[ https://issues.apache.org/jira/browse/FLINK-26349?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17498082#comment-17498082 ] Dawid Wysakowicz commented on FLINK-26349: -- That is not true. The problem I pointed above is

[jira] [Commented] (FLINK-26301) Test AvroParquet format

[ https://issues.apache.org/jira/browse/FLINK-26301?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17498056#comment-17498056 ] Dawid Wysakowicz commented on FLINK-26301: -- A very basic job works fine. I created parquet

[jira] [Closed] (FLINK-26301) Test AvroParquet format

[ https://issues.apache.org/jira/browse/FLINK-26301?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz closed FLINK-26301. Resolution: Done > Test AvroParquet format > --- > >

[jira] [Commented] (FLINK-26273) Test checkpoints restore modes & formats

[ https://issues.apache.org/jira/browse/FLINK-26273?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17498012#comment-17498012 ] Dawid Wysakowicz commented on FLINK-26273: -- I think you covered it well. Thanks! > Test

[jira] [Comment Edited] (FLINK-26301) Test AvroParquet format

[ https://issues.apache.org/jira/browse/FLINK-26301?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17497996#comment-17497996 ] Dawid Wysakowicz edited comment on FLINK-26301 at 2/25/22, 9:06 AM:

[jira] [Commented] (FLINK-26301) Test AvroParquet format

[ https://issues.apache.org/jira/browse/FLINK-26301?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17497996#comment-17497996 ] Dawid Wysakowicz commented on FLINK-26301: -- > I didn't see any conflict. It seems user can

[jira] [Comment Edited] (FLINK-26349) AvroParquetReaders does not work with ReflectData

[ https://issues.apache.org/jira/browse/FLINK-26349?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17497992#comment-17497992 ] Dawid Wysakowicz edited comment on FLINK-26349 at 2/25/22, 9:00 AM:

[jira] [Commented] (FLINK-26349) AvroParquetReaders does not work with ReflectData

[ https://issues.apache.org/jira/browse/FLINK-26349?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17497992#comment-17497992 ] Dawid Wysakowicz commented on FLINK-26349: -- Yes, and why is that not supported? >

[jira] [Assigned] (FLINK-26354) "-restoreMode" should be "--restoreMode" and should have a shorthand

[ https://issues.apache.org/jira/browse/FLINK-26354?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz reassigned FLINK-26354: Assignee: Dawid Wysakowicz > "-restoreMode" should be "--restoreMode" and should

[jira] [Comment Edited] (FLINK-26354) "-restoreMode" should be "--restoreMode" and should have a shorthand

[ https://issues.apache.org/jira/browse/FLINK-26354?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17497544#comment-17497544 ] Dawid Wysakowicz edited comment on FLINK-26354 at 2/24/22, 4:56 PM:

[jira] [Commented] (FLINK-26354) "-restoreMode" should be "--restoreMode" and should have a shorthand

[ https://issues.apache.org/jira/browse/FLINK-26354?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17497544#comment-17497544 ] Dawid Wysakowicz commented on FLINK-26354: -- > How difficult would it be to make the short

[jira] [Comment Edited] (FLINK-26301) Test AvroParquet format

[ https://issues.apache.org/jira/browse/FLINK-26301?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17497540#comment-17497540 ] Dawid Wysakowicz edited comment on FLINK-26301 at 2/24/22, 4:53 PM:

[jira] [Commented] (FLINK-26301) Test AvroParquet format

[ https://issues.apache.org/jira/browse/FLINK-26301?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17497540#comment-17497540 ] Dawid Wysakowicz commented on FLINK-26301: -- > The standard parquet lib will take the

[jira] [Commented] (FLINK-26301) Test AvroParquet format

[ https://issues.apache.org/jira/browse/FLINK-26301?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17497538#comment-17497538 ] Dawid Wysakowicz commented on FLINK-26301: -- > The reason of choosing PublicEvolving is that the

[jira] [Commented] (FLINK-26353) "flink stop --help" does not list "--type" option

[ https://issues.apache.org/jira/browse/FLINK-26353?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17497535#comment-17497535 ] Dawid Wysakowicz commented on FLINK-26353: -- This will have the same problem [FLINK-26354]. Can

[jira] [Assigned] (FLINK-26353) "flink stop --help" does not list "--type" option

[ https://issues.apache.org/jira/browse/FLINK-26353?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz reassigned FLINK-26353: Assignee: Dawid Wysakowicz > "flink stop --help" does not list "--type" option

[jira] [Commented] (FLINK-26354) "-restoreMode" should be "--restoreMode" and should have a shorthand

[ https://issues.apache.org/jira/browse/FLINK-26354?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17497515#comment-17497515 ] Dawid Wysakowicz commented on FLINK-26354: -- Ah, forgot that has not been the only place. There

[jira] [Comment Edited] (FLINK-26354) "-restoreMode" should be "--restoreMode" and should have a shorthand

[ https://issues.apache.org/jira/browse/FLINK-26354?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17497505#comment-17497505 ] Dawid Wysakowicz edited comment on FLINK-26354 at 2/24/22, 4:09 PM:

[jira] [Comment Edited] (FLINK-26354) "-restoreMode" should be "--restoreMode" and should have a shorthand

[ https://issues.apache.org/jira/browse/FLINK-26354?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17497505#comment-17497505 ] Dawid Wysakowicz edited comment on FLINK-26354 at 2/24/22, 4:08 PM:

[jira] [Commented] (FLINK-26354) "-restoreMode" should be "--restoreMode" and should have a shorthand

[ https://issues.apache.org/jira/browse/FLINK-26354?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17497505#comment-17497505 ] Dawid Wysakowicz commented on FLINK-26354: -- Having the above in mind. I am afraid we can not

[jira] [Commented] (FLINK-26354) "-restoreMode" should be "--restoreMode" and should have a shorthand

[ https://issues.apache.org/jira/browse/FLINK-26354?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17497495#comment-17497495 ] Dawid Wysakowicz commented on FLINK-26354: -- The shorthand was explicitly voted against:

[jira] [Commented] (FLINK-26301) Test AvroParquet format

[ https://issues.apache.org/jira/browse/FLINK-26301?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17497488#comment-17497488 ] Dawid Wysakowicz commented on FLINK-26301: -- But this is 1. not documented 2. not possible in

[jira] [Comment Edited] (FLINK-26301) Test AvroParquet format

[ https://issues.apache.org/jira/browse/FLINK-26301?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17497370#comment-17497370 ] Dawid Wysakowicz edited comment on FLINK-26301 at 2/24/22, 12:48 PM: -

[jira] [Comment Edited] (FLINK-26301) Test AvroParquet format

[ https://issues.apache.org/jira/browse/FLINK-26301?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17497370#comment-17497370 ] Dawid Wysakowicz edited comment on FLINK-26301 at 2/24/22, 12:48 PM: -

<    1   2   3   4   5   6   7   8   9   10   >