[jira] [Assigned] (FLINK-26469) Adaptive job shows error in WebUI when not enough resource are available

2022-10-03 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26469?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz reassigned FLINK-26469: Assignee: Dawid Wysakowicz > Adaptive job shows error in WebUI when not enough re

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

2022-10-03 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29498?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17612486#comment-17612486 ] lincoln lee commented on FLINK-29498: - [~eric.xiao] There's a separate `org.apache.

[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&focusedCommentId=17612480#comment-17612480 ] Nagaraj Tantri commented on FLINK-29245: Hi [~mapohl], I would like to work on t

[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 lever

[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 sca

[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 whe

[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 ASSUME_ROLE

[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&focusedCommentId=17612334#comment-17612334 ] Danny Cranmer commented on FLINK-29496: --- Thanks [~a.pilipenko], please apply this

[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 configur

[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: https://issues.apache.org/jira/browse

[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&focusedCommentId=17612306#comment-17612306 ] Xingbo Huang commented on FLINK-29495: -- https://dev.azure.com/apache-flink/apache-f

[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&focusedCommentId=17612304#comment-17612304 ] Xingbo Huang commented on FLINK-29427: -- https://dev.azure.com/apache-flink/apache-f

[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&focusedCommentId=17612302#comment-17612302 ] Xingbo Huang commented on FLINK-29495: -- https://dev.azure.com/apache-flink/apache-f

[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&focusedCommentId=17612301#comment-17612301 ] Xingbo Huang commented on FLINK-29495: -- cc [~syhily]  Could you help take a look? T

[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&focusedCommentId=17612298#comment-17612298 ] Xingbo Huang commented on FLINK-29387: -- https://dev.azure.com/apache-flink/apache-f

[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&focusedCommentId=17612296#comment-17612296 ] Xingbo Huang commented on FLINK-29419: -- https://dev.azure.com/apache-flink/apache-f

[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 a

[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&focusedCommentId=17612213#comment-17612213 ] David Anderson commented on FLINK-29494: [~twalthr] [~jingzhang] [~godfrey] This

[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&focusedCommentId=17612208#comment-17612208 ] Donatien commented on FLINK-29402: -- Thanks for your comment! Considering that Facebook

[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 of

[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 unexpecte

[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 397141ed7c00586e5b5449177840243babe2a776