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

[DISCUSS] FLIP-264 Extract BaseCoordinatorContext

2022-10-03 Thread gang ye
Hi, We submit the Flip proposal at Confluent to extract BaseCoordinatorContext from SourceCoordinatorContext to reuse it for other coordinators E.g. in the shuffling support of Flink Iceberg sink

Re: [DISCUSS] FLIP-246: Multi Cluster Kafka Source

2022-10-03 Thread Mason Chen
Hi Ryan, Just copying your message over to the email chain. Hi Mason, > First off, thanks for putting this FLIP together! Sorry for the delay. > Full disclosure Mason and I chatted a little bit at Flink Forward 2022 but > I have tried to capture the questions I had for him then. > I'll start the

[DISCUSS] FLIP-265 Deprecate and remove Scala API support

2022-10-03 Thread Martijn Visser
Hi everyone, I would like to open a discussion thread on FLIP-265 Deprecate and remove Scala API support. Please take a look at https://cwiki.apache.org/confluence/display/FLINK/FLIP-265+Deprecate+and+remove+Scala+API+support and provide your feedback. Best regards, Martijn https://twitter.com/M

Re: [DISCUSS] FLIP-265 Deprecate and remove Scala API support

2022-10-03 Thread Márton Balassi
Hi Martjin, Thanks for compiling the FLIP. I agree with the sentiment that Scala poses considerable maintenance overhead and key improvements (like 2.13 or 2.12.8 supports) are hanging stale. With that said before we make this move we should attempt to understand the userbase affected. A quick Sla