[jira] [Comment Edited] (FLINK-26803) Merge small ChannelState file for Unaligned Checkpoint

[ https://issues.apache.org/jira/browse/FLINK-26803?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17679859#comment-17679859 ] Piotr Nowojski edited comment on FLINK-26803 at 1/25/23 12:11 PM: --

[jira] [Comment Edited] (FLINK-26803) Merge small ChannelState file for Unaligned Checkpoint

[ https://issues.apache.org/jira/browse/FLINK-26803?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17679859#comment-17679859 ] Piotr Nowojski edited comment on FLINK-26803 at 1/25/23 12:10 PM: --

[jira] [Closed] (FLINK-30278) Unexpected config mutation in SinkTransformationTranslator

[ https://issues.apache.org/jira/browse/FLINK-30278?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-30278. -- Fix Version/s: 1.17.0 Resolution: Fixed Merged to master as f38c2370e85 > Unexpected

[jira] [Updated] (FLINK-30278) Unexpected config mutation in SinkTransformationTranslator

[ https://issues.apache.org/jira/browse/FLINK-30278?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-30278: --- Affects Version/s: (was: 1.16.0) > Unexpected config mutation in

[jira] [Closed] (FLINK-26803) Merge small ChannelState file for Unaligned Checkpoint

[ https://issues.apache.org/jira/browse/FLINK-26803?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-26803. -- Resolution: Fixed merged as 8be94e6^^, 8be94e6^ and 8be94e6 into apache:master Big thanks

[jira] [Comment Edited] (FLINK-29825) Improve benchmark stability

[ https://issues.apache.org/jira/browse/FLINK-29825?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17679077#comment-17679077 ] Piotr Nowojski edited comment on FLINK-29825 at 1/20/23 9:17 AM: - Thanks

[jira] [Commented] (FLINK-29825) Improve benchmark stability

[ https://issues.apache.org/jira/browse/FLINK-29825?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17679077#comment-17679077 ] Piotr Nowojski commented on FLINK-29825: Thanks for picking this up [~Yanfei Lei]. Are you

[jira] [Commented] (FLINK-30709) NetworkInput#emitNext() should push records to DataOutput in a while loop

[ https://issues.apache.org/jira/browse/FLINK-30709?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17678190#comment-17678190 ] Piotr Nowojski commented on FLINK-30709: Thanks for following up on my comment! FYI, the

[jira] [Comment Edited] (FLINK-30623) Performance regression in checkpointSingleInput.UNALIGNED on 04.01.2023

[ https://issues.apache.org/jira/browse/FLINK-30623?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17676002#comment-17676002 ] Piotr Nowojski edited comment on FLINK-30623 at 1/13/23 1:51 PM: - I have

[jira] [Comment Edited] (FLINK-30533) SourceOperator#emitNext() should push records to DataOutput in a while loop

[ https://issues.apache.org/jira/browse/FLINK-30533?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17676585#comment-17676585 ] Piotr Nowojski edited comment on FLINK-30533 at 1/13/23 11:12 AM: -- It

[jira] [Comment Edited] (FLINK-30533) SourceOperator#emitNext() should push records to DataOutput in a while loop

[ https://issues.apache.org/jira/browse/FLINK-30533?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17676585#comment-17676585 ] Piotr Nowojski edited comment on FLINK-30533 at 1/13/23 11:12 AM: -- It

[jira] [Commented] (FLINK-30533) SourceOperator#emitNext() should push records to DataOutput in a while loop

[ https://issues.apache.org/jira/browse/FLINK-30533?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17676585#comment-17676585 ] Piotr Nowojski commented on FLINK-30533: It looks like a nice improvement:

[jira] [Commented] (FLINK-30623) Performance regression in checkpointSingleInput.UNALIGNED on 04.01.2023

[ https://issues.apache.org/jira/browse/FLINK-30623?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17676002#comment-17676002 ] Piotr Nowojski commented on FLINK-30623: I have some doubts about FLINK-30533 design. Maybe it

[jira] [Updated] (FLINK-30623) Performance regression in checkpointSingleInput.UNALIGNED on 04.01.2023

[ https://issues.apache.org/jira/browse/FLINK-30623?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-30623: --- Priority: Blocker (was: Critical) > Performance regression in

[jira] [Closed] (FLINK-28766) UnalignedCheckpointStressITCase.runStressTest failed with NoSuchFileException

[ https://issues.apache.org/jira/browse/FLINK-28766?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-28766. -- Resolution: Fixed Merged to master as 1ddaa2a460d and 9e1cefe2509 >

[jira] [Commented] (FLINK-27944) IO metrics collision happens if a task has union inputs

[ https://issues.apache.org/jira/browse/FLINK-27944?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17642032#comment-17642032 ] Piotr Nowojski commented on FLINK-27944: Thanks! Merged to release 1.15 as dd3c3473a85^ and

[jira] [Closed] (FLINK-27944) IO metrics collision happens if a task has union inputs

[ https://issues.apache.org/jira/browse/FLINK-27944?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-27944. -- Resolution: Fixed > IO metrics collision happens if a task has union inputs >

[jira] [Commented] (FLINK-27944) IO metrics collision happens if a task has union inputs

[ https://issues.apache.org/jira/browse/FLINK-27944?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17641916#comment-17641916 ] Piotr Nowojski commented on FLINK-27944: merged to master as 20808fd^ and 20808fd merged to

[jira] [Updated] (FLINK-27944) IO metrics collision happens if a task has union inputs

[ https://issues.apache.org/jira/browse/FLINK-27944?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-27944: --- Fix Version/s: 1.17.0 1.16.1 1.15.4 > IO metrics

[jira] (FLINK-27944) IO metrics collision happens if a task has union inputs

[ https://issues.apache.org/jira/browse/FLINK-27944 ] Piotr Nowojski deleted comment on FLINK-27944: was (Author: pnowojski): merged commit 20808fd into apache:master > IO metrics collision happens if a task has union inputs >

[jira] [Commented] (FLINK-27944) IO metrics collision happens if a task has union inputs

[ https://issues.apache.org/jira/browse/FLINK-27944?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17641908#comment-17641908 ] Piotr Nowojski commented on FLINK-27944: merged commit 20808fd into apache:master > IO metrics

[jira] [Commented] (FLINK-29634) Support periodic checkpoint triggering

[ https://issues.apache.org/jira/browse/FLINK-29634?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17641837#comment-17641837 ] Piotr Nowojski commented on FLINK-29634: Oh, thanks for correcting me [~thw]. Yes, I think this

[jira] [Commented] (FLINK-27944) IO metrics collision happens if a task has union inputs

[ https://issues.apache.org/jira/browse/FLINK-27944?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17641289#comment-17641289 ] Piotr Nowojski commented on FLINK-27944: I think this PR has been abandoned (I asked to rebase

[jira] [Assigned] (FLINK-27944) IO metrics collision happens if a task has union inputs

[ https://issues.apache.org/jira/browse/FLINK-27944?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski reassigned FLINK-27944: -- Assignee: Weijie Guo (was: xiaogang zhou) > IO metrics collision happens if a task

[jira] [Commented] (FLINK-29634) Support periodic checkpoint triggering

[ https://issues.apache.org/jira/browse/FLINK-29634?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17640466#comment-17640466 ] Piotr Nowojski commented on FLINK-29634: I'm not sure if Flink should try to satisfy more and

[jira] [Comment Edited] (FLINK-29856) Triggering savepoint does not trigger operator notifyCheckpointComplete

[ https://issues.apache.org/jira/browse/FLINK-29856?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17640461#comment-17640461 ] Piotr Nowojski edited comment on FLINK-29856 at 11/29/22 8:31 AM: -- Yes,

[jira] [Comment Edited] (FLINK-29856) Triggering savepoint does not trigger operator notifyCheckpointComplete

[ https://issues.apache.org/jira/browse/FLINK-29856?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17640461#comment-17640461 ] Piotr Nowojski edited comment on FLINK-29856 at 11/29/22 8:31 AM: -- Yes,

[jira] [Comment Edited] (FLINK-29856) Triggering savepoint does not trigger operator notifyCheckpointComplete

[ https://issues.apache.org/jira/browse/FLINK-29856?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17640461#comment-17640461 ] Piotr Nowojski edited comment on FLINK-29856 at 11/29/22 8:29 AM: -- Yes,

[jira] [Commented] (FLINK-29856) Triggering savepoint does not trigger operator notifyCheckpointComplete

[ https://issues.apache.org/jira/browse/FLINK-29856?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17640461#comment-17640461 ] Piotr Nowojski commented on FLINK-29856: Yes, this is the intended behavour. {quote} I think the

[jira] [Updated] (FLINK-30070) Create savepoints without side effects

[ https://issues.apache.org/jira/browse/FLINK-30070?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-30070: --- Description: Side effects are any external state - a state that is stored not in Flink, but

[jira] [Updated] (FLINK-28853) FLIP-217 Support watermark alignment of source splits

[ https://issues.apache.org/jira/browse/FLINK-28853?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-28853: --- Release Note: Added support for watermark alignment of source splits. Since Flink 1.17,

[jira] [Closed] (FLINK-30100) Remove the unused CheckpointFailureReason

[ https://issues.apache.org/jira/browse/FLINK-30100?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-30100. -- Assignee: Rui Fan Resolution: Fixed Merged to master as 5e0e0fde630..aa0cd873709 >

[jira] [Commented] (FLINK-28853) FLIP-217 Support watermark alignment of source splits

[ https://issues.apache.org/jira/browse/FLINK-28853?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17638655#comment-17638655 ] Piotr Nowojski commented on FLINK-28853: I think yes, but it looks like [the

[jira] [Updated] (FLINK-28853) FLIP-217 Support watermark alignment of source splits

[ https://issues.apache.org/jira/browse/FLINK-28853?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-28853: --- Release Note: Added support for watermark alignment of source splits. Since Flink 1.17,

[jira] [Closed] (FLINK-27117) FLIP-217: Support watermark alignment of source splits

[ https://issues.apache.org/jira/browse/FLINK-27117?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-27117. -- Resolution: Duplicate > FLIP-217: Support watermark alignment of source splits >

[jira] [Closed] (FLINK-30155) Pretty print MutatedConfigurationException

[ https://issues.apache.org/jira/browse/FLINK-30155?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-30155. -- Resolution: Fixed merged commit 011819c into apache:master > Pretty print

[jira] [Created] (FLINK-30155) Pretty print MutatedConfigurationException

Piotr Nowojski created FLINK-30155: -- Summary: Pretty print MutatedConfigurationException Key: FLINK-30155 URL: https://issues.apache.org/jira/browse/FLINK-30155 Project: Flink Issue Type:

[jira] [Commented] (FLINK-30103) Test InputFormatCacheLoaderTest.checkCounter failed due to unexpected value on azure

[ https://issues.apache.org/jira/browse/FLINK-30103?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17637101#comment-17637101 ] Piotr Nowojski commented on FLINK-30103: [~smiralex], are those two issues related? Error

[jira] [Updated] (FLINK-28695) Fail to send partition request to restarted taskmanager

[ https://issues.apache.org/jira/browse/FLINK-28695?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-28695: --- Description: After upgrade to *1.15.1* we started getting error while running JOB  

[jira] [Closed] (FLINK-28695) Fail to send partition request to restarted taskmanager

[ https://issues.apache.org/jira/browse/FLINK-28695?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-28695. -- Fix Version/s: 1.17.0 1.16.1 1.15.4 Resolution:

[jira] [Commented] (FLINK-28695) Fail to send partition request to restarted taskmanager

[ https://issues.apache.org/jira/browse/FLINK-28695?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17636590#comment-17636590 ] Piotr Nowojski commented on FLINK-28695: Thanks for the explanation! > Fail to send partition

[jira] [Comment Edited] (FLINK-28695) Fail to send partition request to restarted taskmanager

[ https://issues.apache.org/jira/browse/FLINK-28695?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17636563#comment-17636563 ] Piotr Nowojski edited comment on FLINK-28695 at 11/21/22 8:55 AM: --

[jira] [Commented] (FLINK-28695) Fail to send partition request to restarted taskmanager

[ https://issues.apache.org/jira/browse/FLINK-28695?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17636563#comment-17636563 ] Piotr Nowojski commented on FLINK-28695: [~fanrui] if the {{inputChannels}} is empty how would

[jira] [Commented] (FLINK-28695) Fail to send partition request to restarted taskmanager

[ https://issues.apache.org/jira/browse/FLINK-28695?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17635947#comment-17635947 ] Piotr Nowojski commented on FLINK-28695: I've assigned the ticket to you [~fanrui]. Please ping

[jira] [Updated] (FLINK-28695) Fail to send partition request to restarted taskmanager

[ https://issues.apache.org/jira/browse/FLINK-28695?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-28695: --- Priority: Critical (was: Major) > Fail to send partition request to restarted taskmanager

[jira] [Assigned] (FLINK-28695) Fail to send partition request to restarted taskmanager

[ https://issues.apache.org/jira/browse/FLINK-28695?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski reassigned FLINK-28695: -- Assignee: Rui Fan > Fail to send partition request to restarted taskmanager >

[jira] [Created] (FLINK-30070) Create savepoints without side effects

Piotr Nowojski created FLINK-30070: -- Summary: Create savepoints without side effects Key: FLINK-30070 URL: https://issues.apache.org/jira/browse/FLINK-30070 Project: Flink Issue Type: New

[jira] [Commented] (FLINK-30068) Allow users to configure what to do with errors while committing transactions during recovery in KafkaSink

[ https://issues.apache.org/jira/browse/FLINK-30068?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17635239#comment-17635239 ] Piotr Nowojski commented on FLINK-30068: A temporary workaround might be to drop old

[jira] [Created] (FLINK-30068) Allow users to configure what to do with errors while committing transactions during recovery in KafkaSink

Piotr Nowojski created FLINK-30068: -- Summary: Allow users to configure what to do with errors while committing transactions during recovery in KafkaSink Key: FLINK-30068 URL:

[jira] [Closed] (FLINK-29387) IntervalJoinITCase.testIntervalJoinSideOutputRightLateData failed with AssertionError

[ https://issues.apache.org/jira/browse/FLINK-29387?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-29387. -- Fix Version/s: 1.17.0 Resolution: Fixed merged commit 7e51db9 into apache:master >

[jira] [Commented] (FLINK-29387) IntervalJoinITCase.testIntervalJoinSideOutputRightLateData failed with AssertionError

[ https://issues.apache.org/jira/browse/FLINK-29387?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17634232#comment-17634232 ] Piotr Nowojski commented on FLINK-29387: Thanks for fixing the issue [~stupid_pig] >

[jira] [Commented] (FLINK-16419) Avoid to recommit transactions which are known committed successfully to Kafka upon recovery

[ https://issues.apache.org/jira/browse/FLINK-16419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17634229#comment-17634229 ] Piotr Nowojski commented on FLINK-16419: Hi [~YordanPavlov], as explained in this ticket, Flink

[jira] [Closed] (FLINK-30002) Change the alignmentTimeout to alignedCheckpointTimeout

[ https://issues.apache.org/jira/browse/FLINK-30002?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-30002. -- Assignee: Rui Fan Resolution: Fixed merged commit 0a3e711 into apache:master now >

[jira] [Commented] (FLINK-29387) IntervalJoinITCase.testIntervalJoinSideOutputRightLateData failed with AssertionError

[ https://issues.apache.org/jira/browse/FLINK-29387?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17633612#comment-17633612 ] Piotr Nowojski commented on FLINK-29387: I've assigned the ticket to you [~stupid_pig]. It

[jira] [Assigned] (FLINK-29387) IntervalJoinITCase.testIntervalJoinSideOutputRightLateData failed with AssertionError

[ https://issues.apache.org/jira/browse/FLINK-29387?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski reassigned FLINK-29387: -- Assignee: chenyuzhi (was: Piotr Nowojski) >

[jira] [Assigned] (FLINK-29387) IntervalJoinITCase.testIntervalJoinSideOutputRightLateData failed with AssertionError

[ https://issues.apache.org/jira/browse/FLINK-29387?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski reassigned FLINK-29387: -- Assignee: Piotr Nowojski >

[jira] [Closed] (FLINK-29888) Improve MutatedConfigurationException for disallowed changes in CheckpointConfig and ExecutionConfig

[ https://issues.apache.org/jira/browse/FLINK-29888?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-29888. -- Resolution: Fixed Merged to master as 69526c56a10..488db256914 > Improve

[jira] [Comment Edited] (FLINK-24119) KafkaITCase.testTimestamps fails due to "Topic xxx already exist"

[ https://issues.apache.org/jira/browse/FLINK-24119?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17630411#comment-17630411 ] Piotr Nowojski edited comment on FLINK-24119 at 11/8/22 1:19 PM: -

[jira] [Commented] (FLINK-24119) KafkaITCase.testTimestamps fails due to "Topic xxx already exist"

[ https://issues.apache.org/jira/browse/FLINK-24119?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17630411#comment-17630411 ] Piotr Nowojski commented on FLINK-24119:

[jira] [Comment Edited] (FLINK-29379) Back (most of the) ExecutionConfig and CheckpointConfig by Configuration

[ https://issues.apache.org/jira/browse/FLINK-29379?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17630409#comment-17630409 ] Piotr Nowojski edited comment on FLINK-29379 at 11/8/22 1:16 PM: - Most

[jira] [Closed] (FLINK-29379) Back (most of the) ExecutionConfig and CheckpointConfig by Configuration

[ https://issues.apache.org/jira/browse/FLINK-29379?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-29379. -- Resolution: Fixed Most of the {{CheckpointConfig}} migrated to {{Configuration}} in

[jira] [Updated] (FLINK-29379) Back (most of the) ExecutionConfig and CheckpointConfig by Configuration

[ https://issues.apache.org/jira/browse/FLINK-29379?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-29379: --- Summary: Back (most of the) ExecutionConfig and CheckpointConfig by Configuration (was:

[jira] [Updated] (FLINK-29379) Back ExecutionConfig and CheckpointConfig by Configuration

[ https://issues.apache.org/jira/browse/FLINK-29379?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-29379: --- Fix Version/s: 1.17.0 > Back ExecutionConfig and CheckpointConfig by Configuration >

[jira] [Commented] (FLINK-29379) Back ExecutionConfig and CheckpointConfig by Configuration

[ https://issues.apache.org/jira/browse/FLINK-29379?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17629539#comment-17629539 ] Piotr Nowojski commented on FLINK-29379: First part ({{ExecutionConfig}}) merged as

[jira] [Closed] (FLINK-29807) Drop TypeSerializerConfigSnapshot and savepoint support from Flink versions < 1.8.0

[ https://issues.apache.org/jira/browse/FLINK-29807?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-29807. -- Resolution: Fixed Merged to master as 1e131d2a777..32cc0143753 > Drop

[jira] [Created] (FLINK-29888) Improve MutatedConfigurationException for disallowed changes in CheckpointConfig and ExecutionConfig

Piotr Nowojski created FLINK-29888: -- Summary: Improve MutatedConfigurationException for disallowed changes in CheckpointConfig and ExecutionConfig Key: FLINK-29888 URL:

[jira] [Closed] (FLINK-29584) Upgrade java 11 version on the microbenchmark worker

[ https://issues.apache.org/jira/browse/FLINK-29584?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-29584. -- Resolution: Fixed I've upgraded the JDK version but it didn't change anything. > Upgrade

[jira] [Updated] (FLINK-29818) HsResultPartitionTest.testAvailability fails

[ https://issues.apache.org/jira/browse/FLINK-29818?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-29818: --- Priority: Blocker (was: Major) > HsResultPartitionTest.testAvailability fails >

[jira] [Commented] (FLINK-29818) HsResultPartitionTest.testAvailability fails

[ https://issues.apache.org/jira/browse/FLINK-29818?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17628856#comment-17628856 ] Piotr Nowojski commented on FLINK-29818:

[jira] [Commented] (FLINK-29886) networkThroughput 1000,100ms,OpenSSL Benchmark is failing

[ https://issues.apache.org/jira/browse/FLINK-29886?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17628818#comment-17628818 ] Piotr Nowojski commented on FLINK-29886: Last successful build is on {{1c4081fa77}} flink/master

[jira] [Created] (FLINK-29886) networkThroughput 1000,100ms,OpenSSL Benchmark is failing

Piotr Nowojski created FLINK-29886: -- Summary: networkThroughput 1000,100ms,OpenSSL Benchmark is failing Key: FLINK-29886 URL: https://issues.apache.org/jira/browse/FLINK-29886 Project: Flink

[jira] [Closed] (FLINK-29730) Do not support concurrent unaligned checkpoints in the ChannelStateWriteRequestDispatcherImpl

[ https://issues.apache.org/jira/browse/FLINK-29730?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-29730. -- Resolution: Fixed merged commit 00a2580 into apache:master now > Do not support concurrent

[jira] [Assigned] (FLINK-29730) Do not support concurrent unaligned checkpoints in the ChannelStateWriteRequestDispatcherImpl

[ https://issues.apache.org/jira/browse/FLINK-29730?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski reassigned FLINK-29730: -- Assignee: Rui Fan > Do not support concurrent unaligned checkpoints in the >

[jira] [Updated] (FLINK-29387) IntervalJoinITCase.testIntervalJoinSideOutputRightLateData failed with AssertionError

[ https://issues.apache.org/jira/browse/FLINK-29387?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-29387: --- Priority: Blocker (was: Critical) >

[jira] [Commented] (FLINK-29387) IntervalJoinITCase.testIntervalJoinSideOutputRightLateData failed with AssertionError

[ https://issues.apache.org/jira/browse/FLINK-29387?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17628348#comment-17628348 ] Piotr Nowojski commented on FLINK-29387:

[jira] [Comment Edited] (FLINK-29379) Back ExecutionConfig and CheckpointConfig by Configuration

[ https://issues.apache.org/jira/browse/FLINK-29379?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17628233#comment-17628233 ] Piotr Nowojski edited comment on FLINK-29379 at 11/3/22 10:19 AM: -- We

[jira] [Comment Edited] (FLINK-29379) Back ExecutionConfig and CheckpointConfig by Configuration

[ https://issues.apache.org/jira/browse/FLINK-29379?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17628233#comment-17628233 ] Piotr Nowojski edited comment on FLINK-29379 at 11/3/22 10:18 AM: -- We

[jira] [Commented] (FLINK-29379) Back ExecutionConfig and CheckpointConfig by Configuration

[ https://issues.apache.org/jira/browse/FLINK-29379?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17628233#comment-17628233 ] Piotr Nowojski commented on FLINK-29379: We can not refactor ExecutionConfig as long as we

[jira] [Commented] (FLINK-24119) KafkaITCase.testTimestamps fails due to "Topic xxx already exist"

[ https://issues.apache.org/jira/browse/FLINK-24119?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17627634#comment-17627634 ] Piotr Nowojski commented on FLINK-24119:

[jira] [Updated] (FLINK-29807) Drop TypeSerializerConfigSnapshot and savepoint support from Flink versions < 1.8.0

[ https://issues.apache.org/jira/browse/FLINK-29807?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-29807: --- Release Note: Savepoints using `TypeSerializerConfigSnapshot` are no longer supported. That

[jira] [Updated] (FLINK-29807) Drop TypeSerializerConfigSnapshot and savepoint support from Flink versions < 1.8.0

[ https://issues.apache.org/jira/browse/FLINK-29807?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-29807: --- Description: The motivation behind this move is two fold. One reason is that it complicates

[jira] [Created] (FLINK-29807) Drop TypeSerializerConfigSnapshot and savepoint support from Flink versions < 1.8.0

Piotr Nowojski created FLINK-29807: -- Summary: Drop TypeSerializerConfigSnapshot and savepoint support from Flink versions < 1.8.0 Key: FLINK-29807 URL: https://issues.apache.org/jira/browse/FLINK-29807

[jira] [Commented] (FLINK-29545) kafka consuming stop when trigger first checkpoint

[ https://issues.apache.org/jira/browse/FLINK-29545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17620377#comment-17620377 ] Piotr Nowojski commented on FLINK-29545: Huh. On the screenshots that you attached

[jira] [Closed] (FLINK-11323) Upgrade KryoSerializer snapshot to implement new TypeSerializerSnapshot interface

[ https://issues.apache.org/jira/browse/FLINK-11323?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-11323. -- Fix Version/s: 1.8.0 Resolution: Fixed Seems to be merged to master since 1.8.

[jira] [Created] (FLINK-29662) PojoSerializerSnapshot is using incorrect ExecutionConfig when restoring serializer

Piotr Nowojski created FLINK-29662: -- Summary: PojoSerializerSnapshot is using incorrect ExecutionConfig when restoring serializer Key: FLINK-29662 URL: https://issues.apache.org/jira/browse/FLINK-29662

[jira] [Updated] (FLINK-29645) BatchExecutionKeyedStateBackend is using incorrect ExecutionConfig when creating serializer

[ https://issues.apache.org/jira/browse/FLINK-29645?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-29645: --- Priority: Minor (was: Major) > BatchExecutionKeyedStateBackend is using incorrect

[jira] [Created] (FLINK-29645) BatchExecutionKeyedStateBackend is using incorrect ExecutionConfig when creating serializer

Piotr Nowojski created FLINK-29645: -- Summary: BatchExecutionKeyedStateBackend is using incorrect ExecutionConfig when creating serializer Key: FLINK-29645 URL: https://issues.apache.org/jira/browse/FLINK-29645

[jira] [Commented] (FLINK-13876) Remove ExecutionConfig field from PojoSerializer

[ https://issues.apache.org/jira/browse/FLINK-13876?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17617675#comment-17617675 ] Piotr Nowojski commented on FLINK-13876: I'm not sure, but if this is a really issue, that's not

[jira] [Comment Edited] (FLINK-29545) kafka consuming stop when trigger first checkpoint

[ https://issues.apache.org/jira/browse/FLINK-29545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17617613#comment-17617613 ] Piotr Nowojski edited comment on FLINK-29545 at 10/14/22 9:58 AM: -- It

[jira] [Comment Edited] (FLINK-29545) kafka consuming stop when trigger first checkpoint

[ https://issues.apache.org/jira/browse/FLINK-29545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17617613#comment-17617613 ] Piotr Nowojski edited comment on FLINK-29545 at 10/14/22 9:57 AM: -- It

[jira] [Comment Edited] (FLINK-29545) kafka consuming stop when trigger first checkpoint

[ https://issues.apache.org/jira/browse/FLINK-29545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17617613#comment-17617613 ] Piotr Nowojski edited comment on FLINK-29545 at 10/14/22 9:57 AM: -- It

[jira] [Comment Edited] (FLINK-29545) kafka consuming stop when trigger first checkpoint

[ https://issues.apache.org/jira/browse/FLINK-29545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17617613#comment-17617613 ] Piotr Nowojski edited comment on FLINK-29545 at 10/14/22 9:57 AM: -- It

[jira] [Comment Edited] (FLINK-29545) kafka consuming stop when trigger first checkpoint

[ https://issues.apache.org/jira/browse/FLINK-29545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17617613#comment-17617613 ] Piotr Nowojski edited comment on FLINK-29545 at 10/14/22 9:56 AM: -- It

[jira] [Comment Edited] (FLINK-29545) kafka consuming stop when trigger first checkpoint

[ https://issues.apache.org/jira/browse/FLINK-29545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17617613#comment-17617613 ] Piotr Nowojski edited comment on FLINK-29545 at 10/14/22 9:56 AM: -- It

[jira] [Comment Edited] (FLINK-29545) kafka consuming stop when trigger first checkpoint

[ https://issues.apache.org/jira/browse/FLINK-29545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17617613#comment-17617613 ] Piotr Nowojski edited comment on FLINK-29545 at 10/14/22 9:56 AM: -- It

[jira] [Comment Edited] (FLINK-29545) kafka consuming stop when trigger first checkpoint

[ https://issues.apache.org/jira/browse/FLINK-29545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17617613#comment-17617613 ] Piotr Nowojski edited comment on FLINK-29545 at 10/14/22 9:55 AM: -- It

[jira] [Comment Edited] (FLINK-29545) kafka consuming stop when trigger first checkpoint

[ https://issues.apache.org/jira/browse/FLINK-29545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17617613#comment-17617613 ] Piotr Nowojski edited comment on FLINK-29545 at 10/14/22 9:55 AM: -- It

[jira] [Commented] (FLINK-29545) kafka consuming stop when trigger first checkpoint

[ https://issues.apache.org/jira/browse/FLINK-29545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17617613#comment-17617613 ] Piotr Nowojski commented on FLINK-29545: It looks like the problem is with the upstream sources.

[jira] [Commented] (FLINK-29379) Back ExecutionConfig and CheckpointConfig by Configuration

[ https://issues.apache.org/jira/browse/FLINK-29379?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17617096#comment-17617096 ] Piotr Nowojski commented on FLINK-29379: I would propose to start with an intermediate step.

[jira] [Assigned] (FLINK-29379) Back ExecutionConfig and CheckpointConfig by Configuration

[ https://issues.apache.org/jira/browse/FLINK-29379?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski reassigned FLINK-29379: -- Assignee: Piotr Nowojski > Back ExecutionConfig and CheckpointConfig by

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