[jira] [Commented] (FLINK-29245) [JUnit 5 Migration] Remove RetryRule

2022-10-03 Thread Nagaraj Tantri (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17612480#comment-17612480 ] Nagaraj Tantri commented on FLINK-29245: Hi [~mapohl], I would like to work on this. Can I raise

[jira] [Updated] (FLINK-29498) Flink Async I/O Retry Strategies Do Not Work for Scala AsyncDataStream API

2022-10-03 Thread Eric Xiao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29498?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Eric Xiao updated FLINK-29498: -- Description: We are using the async I/O to make HTTP calls and one of the features we wanted to

[jira] [Updated] (FLINK-29498) Flink Async I/O Retry Strategies Do Not Work for Scala AsyncDataStream API

2022-10-03 Thread Eric Xiao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29498?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Eric Xiao updated FLINK-29498: -- Description: When I try calling the function \{{AsyncDataStream.unorderedWaitWithRetry}} from the

[jira] [Created] (FLINK-29498) Flink Async I/O Retry Strategies Do Not Work for Scala AsyncDataStream API

2022-10-03 Thread Eric Xiao (Jira)
Eric Xiao created FLINK-29498: - Summary: Flink Async I/O Retry Strategies Do Not Work for Scala AsyncDataStream API Key: FLINK-29498 URL: https://issues.apache.org/jira/browse/FLINK-29498 Project: Flink

[jira] [Created] (FLINK-29497) Provide an option to publish the flink-dist jar file artifact

2022-10-03 Thread Thomas Weise (Jira)
Thomas Weise created FLINK-29497: Summary: Provide an option to publish the flink-dist jar file artifact Key: FLINK-29497 URL: https://issues.apache.org/jira/browse/FLINK-29497 Project: Flink

[jira] [Updated] (FLINK-29496) Unable to configure STS endpoint when using ASSUME_ROLE credential provider in Kinesis connector

2022-10-03 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29496?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer updated FLINK-29496: -- Affects Version/s: 1.15.2 1.16.0 > Unable to configure STS endpoint

[jira] [Assigned] (FLINK-29496) Unable to configure STS endpoint when using ASSUME_ROLE credential provider in Kinesis connector

2022-10-03 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29496?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer reassigned FLINK-29496: - Assignee: Aleksandr Pilipenko > Unable to configure STS endpoint when using

[jira] [Commented] (FLINK-29496) Unable to configure STS endpoint when using ASSUME_ROLE credential provider in Kinesis connector

2022-10-03 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29496?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17612334#comment-17612334 ] Danny Cranmer commented on FLINK-29496: --- Thanks [~a.pilipenko], please apply this to Amazon

[jira] [Updated] (FLINK-29496) Unable to configure STS endpoint when using ASSUME_ROLE credential provider in Kinesis connector

2022-10-03 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29496?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer updated FLINK-29496: -- Fix Version/s: 1.17.0 1.15.3 1.16.1 > Unable to

[jira] [Created] (FLINK-29496) Unable to configure STS endpoint when using ASSUME_ROLE credential provider in Kinesis connector

2022-10-03 Thread Aleksandr Pilipenko (Jira)
Aleksandr Pilipenko created FLINK-29496: --- Summary: Unable to configure STS endpoint when using ASSUME_ROLE credential provider in Kinesis connector Key: FLINK-29496 URL:

[jira] [Commented] (FLINK-29495) PulsarSinkE2ECase hang

2022-10-03 Thread Xingbo Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29495?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17612306#comment-17612306 ] Xingbo Huang commented on FLINK-29495: --

[jira] [Commented] (FLINK-29427) LookupJoinITCase failed with classloader problem

2022-10-03 Thread Xingbo Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29427?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17612304#comment-17612304 ] Xingbo Huang commented on FLINK-29427: --

[jira] [Commented] (FLINK-29495) PulsarSinkE2ECase hang

2022-10-03 Thread Xingbo Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29495?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17612302#comment-17612302 ] Xingbo Huang commented on FLINK-29495: --

[jira] [Commented] (FLINK-29495) PulsarSinkE2ECase hang

2022-10-03 Thread Xingbo Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29495?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17612301#comment-17612301 ] Xingbo Huang commented on FLINK-29495: -- cc [~syhily]  Could you help take a look? Thx. >

[jira] [Created] (FLINK-29495) PulsarSinkE2ECase hang

2022-10-03 Thread Xingbo Huang (Jira)
Xingbo Huang created FLINK-29495: Summary: PulsarSinkE2ECase hang Key: FLINK-29495 URL: https://issues.apache.org/jira/browse/FLINK-29495 Project: Flink Issue Type: Bug Components:

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

2022-10-03 Thread Xingbo Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29387?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17612298#comment-17612298 ] Xingbo Huang commented on FLINK-29387: --

[jira] [Commented] (FLINK-29419) HybridShuffle.testHybridFullExchangesRestart hangs

2022-10-03 Thread Xingbo Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17612296#comment-17612296 ] Xingbo Huang commented on FLINK-29419: --

[jira] [Resolved] (FLINK-29413) Make it possible to associate triggered and completed savepoints

2022-10-03 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29413?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora resolved FLINK-29413. Resolution: Fixed merged to main 1f6a75056acae90e9fab182fd076ee6755b35bbb > Make it possible to

[jira] [Commented] (FLINK-29494) ChangeLogNormalize operator causes unexpected firing of past windows after state restoration

2022-10-03 Thread David Anderson (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29494?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17612213#comment-17612213 ] David Anderson commented on FLINK-29494: [~twalthr] [~jingzhang] [~godfrey] This is an

[jira] [Commented] (FLINK-29402) Add USE_DIRECT_READ configuration parameter for RocksDB

2022-10-03 Thread Donatien (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29402?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17612208#comment-17612208 ] Donatien commented on FLINK-29402: -- Thanks for your comment! Considering that Facebook uses DirectIO

[jira] [Updated] (FLINK-29494) ChangeLogNormalize operator causes unexpected firing of past windows after state restoration

2022-10-03 Thread Rashmin Patel (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29494?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rashmin Patel updated FLINK-29494: -- Component/s: Runtime / Checkpointing > ChangeLogNormalize operator causes unexpected firing

[jira] [Updated] (FLINK-29494) ChangeLogNormalize operator causes unexpected firing of past windows after state restoration

2022-10-03 Thread Rashmin Patel (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29494?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rashmin Patel updated FLINK-29494: -- Component/s: (was: Runtime / Checkpointing) > ChangeLogNormalize operator causes

[jira] [Closed] (FLINK-29156) Support LISTAGG in the Table API

2022-10-03 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29156?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-29156. --- Fix Version/s: 1.17.0 Resolution: Fixed Merged to master via

[jira] [Updated] (FLINK-29494) ChangeLogNormalize operator causes unexpected firing of past windows after state restoration

2022-10-03 Thread Rashmin Patel (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29494?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rashmin Patel updated FLINK-29494: -- Description: *Issue Summary:* While doing GroupWindowAggregation on stream produced by

[jira] [Updated] (FLINK-29494) ChangeLogNormalize operator causes undesired firing of past windows after state restoration

2022-10-03 Thread Rashmin Patel (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29494?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rashmin Patel updated FLINK-29494: -- Description: *Issue Summary:* While doing GroupWindowAggregation on stream produced by

[jira] [Updated] (FLINK-29494) ChangeLogNormalize operator causes unexpected firing of past windows after state restoration

2022-10-03 Thread Rashmin Patel (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29494?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rashmin Patel updated FLINK-29494: -- Summary: ChangeLogNormalize operator causes unexpected firing of past windows after state

[jira] [Updated] (FLINK-29494) ChangeLogNormalize operator causes undesired firing of past windows after state restoration

2022-10-03 Thread Rashmin Patel (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29494?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rashmin Patel updated FLINK-29494: -- Description: *Issue Summary:* While doing GroupWindowAggregation on stream produced by

[jira] [Updated] (FLINK-29494) ChangeLogNormalize operator causes undesired firing of past windows after state restoration

2022-10-03 Thread Rashmin Patel (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29494?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rashmin Patel updated FLINK-29494: -- Summary: ChangeLogNormalize operator causes undesired firing of past windows after state

[jira] [Created] (FLINK-29494) ChangeLogNormalize operator causes undesired firing of past windows after restoration

2022-10-03 Thread Rashmin Patel (Jira)
Rashmin Patel created FLINK-29494: - Summary: ChangeLogNormalize operator causes undesired firing of past windows after restoration Key: FLINK-29494 URL: https://issues.apache.org/jira/browse/FLINK-29494