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

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

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

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-264 Extract BaseCoordinatorContext

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

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

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

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-29496) Unable to configure STS endpoint when using ASSUME_ROLE credential provider in Kinesis connector

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] [Created] (FLINK-29495) PulsarSinkE2ECase hang

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-29494) ChangeLogNormalize operator causes undesired firing of past windows after restoration

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