[jira] [Commented] (FLINK-32695) Migrate SourceFunction in Tests to Source V2 API

[ https://issues.apache.org/jira/browse/FLINK-32695?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18010542#comment-18010542 ] Poorvank Bhatia commented on FLINK-32695: - Hey [~afedulov] , The first set of pu

[jira] [Commented] (FLINK-38034) raise back the visibility of org.apache.flink.streaming.runtime.operators.GenericWriteAheadSinkTest to public

[ https://issues.apache.org/jira/browse/FLINK-38034?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17987229#comment-17987229 ] Poorvank Bhatia commented on FLINK-38034: - Makes a lot of sense [~echauchot] .  

[jira] [Commented] (FLINK-25425) Make Cassandra Sink available for Flink SQL users

[ https://issues.apache.org/jira/browse/FLINK-25425?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17985781#comment-17985781 ] Poorvank Bhatia commented on FLINK-25425: - Hey [~echauchot] Can u assign this to

[jira] [Commented] (FLINK-37984) Move Cassandra Sink to Sink V2

[ https://issues.apache.org/jira/browse/FLINK-37984?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17985780#comment-17985780 ] Poorvank Bhatia commented on FLINK-37984: - Hey [~echauchot] Can u assign this to

[jira] [Commented] (FLINK-37987) Implement JdbcDynamicTableSinkV2 (JDBC Sink) to use new Sink API v2

[ https://issues.apache.org/jira/browse/FLINK-37987?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17985858#comment-17985858 ] Poorvank Bhatia commented on FLINK-37987: - Hey [~Leonard] , Can u have a look an

[jira] [Updated] (FLINK-37987) Implement JdbcDynamicTableSinkV2 (JDBC Sink) to use new Sink API v2

[ https://issues.apache.org/jira/browse/FLINK-37987?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Poorvank Bhatia updated FLINK-37987: Summary: Implement JdbcDynamicTableSinkV2 (JDBC Sink) to use new Sink API v2 (was: Implem

[jira] [Created] (FLINK-37987) Implement JdbcDynamicTableSinkV2 to use new Sink API v2

Poorvank Bhatia created FLINK-37987: --- Summary: Implement JdbcDynamicTableSinkV2 to use new Sink API v2 Key: FLINK-37987 URL: https://issues.apache.org/jira/browse/FLINK-37987 Project: Flink

[jira] [Commented] (FLINK-26823) Make Cassandra Source available for Flink SQL users

[ https://issues.apache.org/jira/browse/FLINK-26823?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17985782#comment-17985782 ] Poorvank Bhatia commented on FLINK-26823: - Hey [~martijnvisser] [~echauchot] if

[jira] [Created] (FLINK-37984) Move Cassandra Sink to Sink V2

Poorvank Bhatia created FLINK-37984: --- Summary: Move Cassandra Sink to Sink V2 Key: FLINK-37984 URL: https://issues.apache.org/jira/browse/FLINK-37984 Project: Flink Issue Type: Sub-task

[jira] [Comment Edited] (FLINK-26821) Refactor Cassandra Sink implementation to the ASync Sink

[ https://issues.apache.org/jira/browse/FLINK-26821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17954268#comment-17954268 ] Poorvank Bhatia edited comment on FLINK-26821 at 5/27/25 9:54 AM:

[jira] [Commented] (FLINK-26821) Refactor Cassandra Sink implementation to the ASync Sink

[ https://issues.apache.org/jira/browse/FLINK-26821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17954268#comment-17954268 ] Poorvank Bhatia commented on FLINK-26821: - Hey [~rmetzger] [~martijnvisser]  I h

[jira] [Commented] (FLINK-28516) UI is misleading when source doesn't emit watermark due to misconfigured idleness

[ https://issues.apache.org/jira/browse/FLINK-28516?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17937537#comment-17937537 ] Poorvank Bhatia commented on FLINK-28516: - Hey [~chesnay] is this being worked u

[jira] [Updated] (FLINK-37444) Migrate ArrowSourceFunction to SourceV2

[ https://issues.apache.org/jira/browse/FLINK-37444?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Poorvank Bhatia updated FLINK-37444: Description: [ArrowSourceFunction|https://github.com/apache/flink/blob/master/flink-python

[jira] [Created] (FLINK-37444) Migrate ArrowSourceFunction to SourceV2

Poorvank Bhatia created FLINK-37444: --- Summary: Migrate ArrowSourceFunction to SourceV2 Key: FLINK-37444 URL: https://issues.apache.org/jira/browse/FLINK-37444 Project: Flink Issue Type: Tec

[jira] [Updated] (FLINK-37445) Migrate InputFormatSourceFunction to the Source V2 API

[ https://issues.apache.org/jira/browse/FLINK-37445?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Poorvank Bhatia updated FLINK-37445: Parent: FLINK-28045 Issue Type: Sub-task (was: Technical Debt) > Migrate InputFor

[jira] [Updated] (FLINK-37444) Migrate ArrowSourceFunction to SourceV2

[ https://issues.apache.org/jira/browse/FLINK-37444?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Poorvank Bhatia updated FLINK-37444: Parent: FLINK-28045 Issue Type: Sub-task (was: Technical Debt) > Migrate ArrowSou

[jira] [Commented] (FLINK-37445) Migrate InputFormatSourceFunction to the Source V2 API

[ https://issues.apache.org/jira/browse/FLINK-37445?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17933883#comment-17933883 ] Poorvank Bhatia commented on FLINK-37445: - Yes yes. The handling of bounded sour

[jira] [Commented] (FLINK-37445) Migrate InputFormatSourceFunction to the Source V2 API

[ https://issues.apache.org/jira/browse/FLINK-37445?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17933835#comment-17933835 ] Poorvank Bhatia commented on FLINK-37445: - Hey [~gaborgsomogyi] , Was planning t

[jira] [Commented] (FLINK-37444) Migrate ArrowSourceFunction to SourceV2

[ https://issues.apache.org/jira/browse/FLINK-37444?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17933823#comment-17933823 ] Poorvank Bhatia commented on FLINK-37444: - Hey [~afedulov] can you assign this t

[jira] [Created] (FLINK-37445) Migrate InputFormatSourceFunction to the Source V2 API

Poorvank Bhatia created FLINK-37445: --- Summary: Migrate InputFormatSourceFunction to the Source V2 API Key: FLINK-37445 URL: https://issues.apache.org/jira/browse/FLINK-37445 Project: Flink

[jira] [Updated] (FLINK-37444) Migrate ArrowSourceFunction to SourceV2

[ https://issues.apache.org/jira/browse/FLINK-37444?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Poorvank Bhatia updated FLINK-37444: Description: [ArrowSourceFunction |https://github.com/apache/flink/blob/master/flink-pyth

[jira] [Updated] (FLINK-37444) Migrate ArrowSourceFunction to SourceV2

[ https://issues.apache.org/jira/browse/FLINK-37444?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Poorvank Bhatia updated FLINK-37444: Description: [ArrowSourceFunction|https://github.com/apache/flink/blob/master/flink-python

[jira] [Updated] (FLINK-37444) Migrate ArrowSourceFunction to SourceV2

[ https://issues.apache.org/jira/browse/FLINK-37444?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Poorvank Bhatia updated FLINK-37444: Description: [ArrowSourceFunction |https://github.com/apache/flink/blob/master/flink-pyth

[jira] [Updated] (FLINK-37444) Migrate ArrowSourceFunction to SourceV2

[ https://issues.apache.org/jira/browse/FLINK-37444?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Poorvank Bhatia updated FLINK-37444: Description: [ArrowSourceFunction |https://github.com/apache/flink/blob/master/flink-pyth

[jira] [Updated] (FLINK-37298) Custom Batch Handling in AsyncSink

[ https://issues.apache.org/jira/browse/FLINK-37298?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Poorvank Bhatia updated FLINK-37298: Fix Version/s: 2.1.0 (was: 1.18.0) > Custom Batch Handling in Async

[jira] [Commented] (FLINK-37298) Custom Batch Handling in AsyncSink

[ https://issues.apache.org/jira/browse/FLINK-37298?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17926015#comment-17926015 ] Poorvank Bhatia commented on FLINK-37298: - Thanks [~chalixar] . I have modified

[jira] [Commented] (FLINK-37298) Custom Batch Handling in AsyncSink

[ https://issues.apache.org/jira/browse/FLINK-37298?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17925943#comment-17925943 ] Poorvank Bhatia commented on FLINK-37298: - Thanks [~chalixar] , have already men

[jira] [Created] (FLINK-37298) Custom Batch Handling in AsyncSink

Poorvank Bhatia created FLINK-37298: --- Summary: Custom Batch Handling in AsyncSink Key: FLINK-37298 URL: https://issues.apache.org/jira/browse/FLINK-37298 Project: Flink Issue Type: Improvem

[jira] [Updated] (FLINK-37298) Custom Batch Handling in AsyncSink

[ https://issues.apache.org/jira/browse/FLINK-37298?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Poorvank Bhatia updated FLINK-37298: Priority: Not a Priority (was: Major) > Custom Batch Handling in AsyncSink >

[jira] [Commented] (FLINK-16851) Add common metrics to the SourceReader base implementation.

[ https://issues.apache.org/jira/browse/FLINK-16851?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17893806#comment-17893806 ] Poorvank Bhatia commented on FLINK-16851: - Hey [~becket_qin] , Is this still bei

[jira] [Commented] (FLINK-25921) Support different input parallelism for preCommit topology

[ https://issues.apache.org/jira/browse/FLINK-25921?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17893796#comment-17893796 ] Poorvank Bhatia commented on FLINK-25921: - Hey [~fpaul] , If this is still unass

[jira] [Commented] (FLINK-21909) Unify API and implementation for Hive and Filesystem source connector

[ https://issues.apache.org/jira/browse/FLINK-21909?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17893792#comment-17893792 ] Poorvank Bhatia commented on FLINK-21909: - Hey [~jark] , If this is still unassi

[jira] [Commented] (FLINK-25822) Migrate away from using Source- and SinkFunctions for internal tests

[ https://issues.apache.org/jira/browse/FLINK-25822?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17892052#comment-17892052 ] Poorvank Bhatia commented on FLINK-25822: - Hey, [~afedulov] , Is anyone working

[jira] [Commented] (FLINK-26821) Refactor Cassandra Sink implementation to the ASync Sink

[ https://issues.apache.org/jira/browse/FLINK-26821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17891794#comment-17891794 ] Poorvank Bhatia commented on FLINK-26821: - Hey [~rmetzger], If this is not alrea