[jira] [Updated] (FLINK-35165) AdaptiveBatch Scheduler should not restrict the default source parallelism to the max parallelism set

[ https://issues.apache.org/jira/browse/FLINK-35165?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35165: --- Labels: pull-request-available (was: ) > AdaptiveBatch Scheduler should not restrict the

[jira] [Updated] (FLINK-35259) FlinkCDC Pipeline transform can't deal timestamp field

[ https://issues.apache.org/jira/browse/FLINK-35259?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35259: --- Labels: pull-request-available (was: ) > FlinkCDC Pipeline transform can't deal timestamp

[jira] [Updated] (FLINK-34916) Support `ALTER CATALOG SET` syntax

[ https://issues.apache.org/jira/browse/FLINK-34916?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-34916: --- Labels: pull-request-available (was: ) > Support `ALTER CATALOG SET` syntax >

[jira] [Updated] (FLINK-35258) Broken links to Doris in Flink CDC Documentation

[ https://issues.apache.org/jira/browse/FLINK-35258?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35258: --- Labels: pull-request-available (was: ) > Broken links to Doris in Flink CDC Documentation

[jira] [Updated] (FLINK-35256) Pipeline transform ignores column type nullability

[ https://issues.apache.org/jira/browse/FLINK-35256?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35256: --- Labels: pull-request-available (was: ) > Pipeline transform ignores column type

[jira] [Updated] (FLINK-35255) DataSinkWriterOperator should override snapshotState and processWatermark method

[ https://issues.apache.org/jira/browse/FLINK-35255?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35255: --- Labels: pull-request-available (was: ) > DataSinkWriterOperator should override

[jira] [Updated] (FLINK-35251) SchemaDerivation serializes mapping incorrectly on checkpoint

[ https://issues.apache.org/jira/browse/FLINK-35251?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35251: --- Labels: pull-request-available (was: ) > SchemaDerivation serializes mapping incorrectly

[jira] [Updated] (FLINK-29797) can't run a job on yarn, if set fs.default-scheme

[ https://issues.apache.org/jira/browse/FLINK-29797?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-29797: --- Labels: pull-request-available (was: ) > can't run a job on yarn, if set fs.default-scheme

[jira] [Updated] (FLINK-35240) Disable FLUSH_AFTER_WRITE_VALUE to avoid flush per record

[ https://issues.apache.org/jira/browse/FLINK-35240?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35240: --- Labels: pull-request-available (was: ) > Disable FLUSH_AFTER_WRITE_VALUE to avoid flush

[jira] [Updated] (FLINK-35194) Support describe job syntax and execution

[ https://issues.apache.org/jira/browse/FLINK-35194?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35194: --- Labels: pull-request-available (was: ) > Support describe job syntax and execution >

[jira] [Updated] (FLINK-35246) SqlClientSSLTest.testGatewayMode failed in AZP

[ https://issues.apache.org/jira/browse/FLINK-35246?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35246: --- Labels: pull-request-available (was: ) > SqlClientSSLTest.testGatewayMode failed in AZP >

[jira] [Updated] (FLINK-35245) Add metrics for flink-connector-tidb-cdc

[ https://issues.apache.org/jira/browse/FLINK-35245?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35245: --- Labels: pull-request-available (was: ) > Add metrics for flink-connector-tidb-cdc >

[jira] [Updated] (FLINK-35244) Move package for flink-connector-tidb-cdc test

[ https://issues.apache.org/jira/browse/FLINK-35244?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35244: --- Labels: pull-request-available (was: ) > Move package for flink-connector-tidb-cdc test >

[jira] [Updated] (FLINK-34127) Kafka connector repo runs a duplicate of `IntegrationTests` framework tests

[ https://issues.apache.org/jira/browse/FLINK-34127?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-34127: --- Labels: pull-request-available (was: ) > Kafka connector repo runs a duplicate of

[jira] [Updated] (FLINK-34977) FLIP-433: State Access on DataStream API V2

[ https://issues.apache.org/jira/browse/FLINK-34977?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-34977: --- Labels: pull-request-available (was: ) > FLIP-433: State Access on DataStream API V2 >

[jira] [Updated] (FLINK-32843) [JUnit5 Migration] The jobmaster package of flink-runtime module

[ https://issues.apache.org/jira/browse/FLINK-32843?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-32843: --- Labels: pull-request-available (was: ) > [JUnit5 Migration] The jobmaster package of

[jira] [Updated] (FLINK-35217) Missing fsync in FileSystemCheckpointStorage

[ https://issues.apache.org/jira/browse/FLINK-35217?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35217: --- Labels: pull-request-available (was: ) > Missing fsync in FileSystemCheckpointStorage >

[jira] [Updated] (FLINK-35239) 1.19 docs show outdated warning

[ https://issues.apache.org/jira/browse/FLINK-35239?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35239: --- Labels: pull-request-available (was: ) > 1.19 docs show outdated warning >

[jira] [Updated] (FLINK-35236) Flink 1.19 Translation error on the execution_mode/order-of-processing

[ https://issues.apache.org/jira/browse/FLINK-35236?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35236: --- Labels: pull-request-available (was: ) > Flink 1.19 Translation error on the

[jira] [Updated] (FLINK-35235) Fix missing dependencies in the uber jar

[ https://issues.apache.org/jira/browse/FLINK-35235?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35235: --- Labels: pull-request-available (was: ) > Fix missing dependencies in the uber jar >

[jira] [Updated] (FLINK-35223) Add jobType in JobDetailsInfo related rest api

[ https://issues.apache.org/jira/browse/FLINK-35223?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35223: --- Labels: pull-request-available (was: ) > Add jobType in JobDetailsInfo related rest api >

[jira] [Updated] (FLINK-35234) Fix NullPointerException of org.apache.flink.cdc.common.configuration.ConfigurationUtils#convertToString

[ https://issues.apache.org/jira/browse/FLINK-35234?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35234: --- Labels: pull-request-available (was: ) > Fix NullPointerException of >

[jira] [Updated] (FLINK-35215) The performance of serializerKryo and serializerKryoWithoutRegistration are regressed

[ https://issues.apache.org/jira/browse/FLINK-35215?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35215: --- Labels: pull-request-available (was: ) > The performance of serializerKryo and

[jira] [Updated] (FLINK-35233) HBase lookup result is wrong when lookup cache is enabled

[ https://issues.apache.org/jira/browse/FLINK-35233?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35233: --- Labels: pull-request-available (was: ) > HBase lookup result is wrong when lookup cache is

[jira] [Updated] (FLINK-35208) Respect pipeline.cached-files during processing Python dependencies

[ https://issues.apache.org/jira/browse/FLINK-35208?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35208: --- Labels: pull-request-available (was: ) > Respect pipeline.cached-files during processing

[jira] [Updated] (FLINK-35189) Introduce test-filesystem Catalog based on FileSystem Connector to support materialized table

[ https://issues.apache.org/jira/browse/FLINK-35189?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35189: --- Labels: pull-request-available (was: ) > Introduce test-filesystem Catalog based on

[jira] [Updated] (FLINK-35221) Support SQL 2011 reserved keywords as identifiers in Flink HiveParser

[ https://issues.apache.org/jira/browse/FLINK-35221?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35221: --- Labels: pull-request-available (was: ) > Support SQL 2011 reserved keywords as identifiers

[jira] [Updated] (FLINK-35222) Adding getJobType for AccessExecutionGraph

[ https://issues.apache.org/jira/browse/FLINK-35222?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35222: --- Labels: pull-request-available (was: ) > Adding getJobType for AccessExecutionGraph >

[jira] [Updated] (FLINK-35228) DynamicKafkaSource does not read re-added topic for the same cluster

[ https://issues.apache.org/jira/browse/FLINK-35228?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35228: --- Labels: pull-request-available (was: ) > DynamicKafkaSource does not read re-added topic

[jira] [Updated] (FLINK-35190) Support create materialized table syntax

[ https://issues.apache.org/jira/browse/FLINK-35190?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35190: --- Labels: pull-request-available (was: ) > Support create materialized table syntax >

[jira] [Updated] (FLINK-35141) Release flink-connector-pulsar v4.2.0 for Flink 1.19

[ https://issues.apache.org/jira/browse/FLINK-35141?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35141: --- Labels: pull-request-available (was: ) > Release flink-connector-pulsar v4.2.0 for Flink

[jira] [Updated] (FLINK-35176) Support property authentication connection for JDBC catalog & dynamic table

[ https://issues.apache.org/jira/browse/FLINK-35176?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35176: --- Labels: pull-request-available (was: ) > Support property authentication connection for

[jira] [Updated] (FLINK-35088) watermark alignment maxAllowedWatermarkDrift and updateInterval param need check

[ https://issues.apache.org/jira/browse/FLINK-35088?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35088: --- Labels: pull-request-available (was: ) > watermark alignment maxAllowedWatermarkDrift and

[jira] [Updated] (FLINK-35216) Support for RETURNING clause of JSON_QUERY

[ https://issues.apache.org/jira/browse/FLINK-35216?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35216: --- Labels: pull-request-available (was: ) > Support for RETURNING clause of JSON_QUERY >

[jira] [Updated] (FLINK-35167) Introduce MaxCompute pipeline DataSink

[ https://issues.apache.org/jira/browse/FLINK-35167?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35167: --- Labels: pull-request-available (was: ) > Introduce MaxCompute pipeline DataSink >

[jira] [Updated] (FLINK-35184) Hash collision inside MiniBatchStreamingJoin operator

[ https://issues.apache.org/jira/browse/FLINK-35184?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35184: --- Labels: pull-request-available (was: ) > Hash collision inside MiniBatchStreamingJoin

[jira] [Updated] (FLINK-35214) Update result partition id for remote input channel when unknown input channel is updated

[ https://issues.apache.org/jira/browse/FLINK-35214?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35214: --- Labels: pull-request-available (was: ) > Update result partition id for remote input

[jira] [Updated] (FLINK-35172) DDL statement is added to the Schema Change Event

[ https://issues.apache.org/jira/browse/FLINK-35172?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35172: --- Labels: pull-request-available (was: ) > DDL statement is added to the Schema Change Event

[jira] [Updated] (FLINK-35188) Introduce CatalogMaterializedTable and related interface to support materialized table

[ https://issues.apache.org/jira/browse/FLINK-35188?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35188: --- Labels: pull-request-available (was: ) > Introduce CatalogMaterializedTable and related

[jira] [Updated] (FLINK-33722) MATCH_RECOGNIZE in batch mode ignores events order

[ https://issues.apache.org/jira/browse/FLINK-33722?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-33722: --- Labels: pull-request-available (was: ) > MATCH_RECOGNIZE in batch mode ignores events

[jira] [Updated] (FLINK-35158) Error handling in StateFuture's callback

[ https://issues.apache.org/jira/browse/FLINK-35158?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35158: --- Labels: pull-request-available (was: ) > Error handling in StateFuture's callback >

[jira] [Updated] (FLINK-35138) Release flink-connector-kafka v3.2.0 for Flink 1.19

[ https://issues.apache.org/jira/browse/FLINK-35138?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35138: --- Labels: pull-request-available (was: ) > Release flink-connector-kafka v3.2.0 for Flink

[jira] [Updated] (FLINK-35183) Expose FlinkMinorVersion as metric for applications in operator

[ https://issues.apache.org/jira/browse/FLINK-35183?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35183: --- Labels: pull-request-available (was: ) > Expose FlinkMinorVersion as metric for

[jira] [Updated] (FLINK-35196) bouncycastle class not found for flink pulsar connector

[ https://issues.apache.org/jira/browse/FLINK-35196?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35196: --- Labels: pull-request-available (was: ) > bouncycastle class not found for flink pulsar

[jira] [Updated] (FLINK-35134) Release flink-connector-elasticsearch vX.X.X for Flink 1.19

[ https://issues.apache.org/jira/browse/FLINK-35134?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35134: --- Labels: pull-request-available (was: ) > Release flink-connector-elasticsearch vX.X.X for

[jira] [Updated] (FLINK-35186) Create State V2 from new StateDescriptor

[ https://issues.apache.org/jira/browse/FLINK-35186?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35186: --- Labels: pull-request-available (was: ) > Create State V2 from new StateDescriptor >

[jira] [Updated] (FLINK-35182) Bump org.apache.commons:commons-compress from 1.24.0 to 1.26.1 for Flink Pulsar connector

[ https://issues.apache.org/jira/browse/FLINK-35182?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35182: --- Labels: pull-request-available (was: ) > Bump org.apache.commons:commons-compress from

[jira] [Updated] (FLINK-35173) Debezium for Mysql connector Custom Time Serializer

[ https://issues.apache.org/jira/browse/FLINK-35173?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35173: --- Labels: CDC pull-request-available (was: CDC) > Debezium for Mysql connector Custom Time

[jira] [Updated] (FLINK-33463) Support the implementation of dynamic source tables based on the new source

[ https://issues.apache.org/jira/browse/FLINK-33463?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-33463: --- Labels: pull-request-available (was: ) > Support the implementation of dynamic source

[jira] [Updated] (FLINK-35177) Datagen examples in documentation do not compile

[ https://issues.apache.org/jira/browse/FLINK-35177?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35177: --- Labels: pull-request-available (was: ) > Datagen examples in documentation do not compile

[jira] [Updated] (FLINK-35175) HadoopDataInputStream can't compile with Hadoop 3.2.3

[ https://issues.apache.org/jira/browse/FLINK-35175?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35175: --- Labels: pull-request-available (was: ) > HadoopDataInputStream can't compile with Hadoop

[jira] [Updated] (FLINK-35133) Release flink-connector-cassandra v3.2.0 for Flink 1.19

[ https://issues.apache.org/jira/browse/FLINK-35133?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35133: --- Labels: pull-request-available (was: ) > Release flink-connector-cassandra v3.2.0 for

[jira] [Updated] (FLINK-35168) Basic State Iterator for async processing

[ https://issues.apache.org/jira/browse/FLINK-35168?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35168: --- Labels: pull-request-available (was: ) > Basic State Iterator for async processing >

[jira] [Updated] (FLINK-35142) Release flink-connector-rabbitmq vX.X.X for Flink 1.19

[ https://issues.apache.org/jira/browse/FLINK-35142?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35142: --- Labels: pull-request-available (was: ) > Release flink-connector-rabbitmq vX.X.X for Flink

[jira] [Updated] (FLINK-35039) Create Profiling JobManager/TaskManager Instance failed

[ https://issues.apache.org/jira/browse/FLINK-35039?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35039: --- Labels: pull-request-available (was: ) > Create Profiling JobManager/TaskManager Instance

[jira] [Updated] (FLINK-35169) Recycle buffers to freeSegments before releasing data buffer for sort accumulator

[ https://issues.apache.org/jira/browse/FLINK-35169?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35169: --- Labels: pull-request-available (was: ) > Recycle buffers to freeSegments before releasing

[jira] [Updated] (FLINK-35154) Javadoc aggregate fails

[ https://issues.apache.org/jira/browse/FLINK-35154?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35154: --- Labels: pull-request-available (was: ) > Javadoc aggregate fails > ---

[jira] [Updated] (FLINK-35166) Improve the performance of Hybrid Shuffle when enable memory decoupling

[ https://issues.apache.org/jira/browse/FLINK-35166?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35166: --- Labels: pull-request-available (was: ) > Improve the performance of Hybrid Shuffle when

[jira] [Updated] (FLINK-35047) Introduce ForStStateBackend to manage ForSt

[ https://issues.apache.org/jira/browse/FLINK-35047?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35047: --- Labels: pull-request-available (was: ) > Introduce ForStStateBackend to manage ForSt >

[jira] [Updated] (FLINK-35162) Support grouping state get and put access

[ https://issues.apache.org/jira/browse/FLINK-35162?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35162: --- Labels: pull-request-available (was: ) > Support grouping state get and put access >

[jira] [Updated] (FLINK-35159) CreatingExecutionGraph can leak CheckpointCoordinator and cause JM crash

[ https://issues.apache.org/jira/browse/FLINK-35159?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35159: --- Labels: pull-request-available (was: ) > CreatingExecutionGraph can leak

[jira] [Updated] (FLINK-35155) Introduce TableRuntimeException

[ https://issues.apache.org/jira/browse/FLINK-35155?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35155: --- Labels: pull-request-available (was: ) > Introduce TableRuntimeException >

[jira] [Updated] (FLINK-35156) Wire new operators for async state with DataStream V2

[ https://issues.apache.org/jira/browse/FLINK-35156?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35156: --- Labels: pull-request-available (was: ) > Wire new operators for async state with

[jira] [Updated] (FLINK-35127) CDC ValuesDataSourceITCase crashed due to OutOfMemoryError

[ https://issues.apache.org/jira/browse/FLINK-35127?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35127: --- Labels: pull-request-available test-stability (was: test-stability) > CDC

[jira] [Updated] (FLINK-35124) Connector Release Fails to run Checkstyle

[ https://issues.apache.org/jira/browse/FLINK-35124?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35124: --- Labels: pull-request-available (was: ) > Connector Release Fails to run Checkstyle >

[jira] [Updated] (FLINK-35027) Implement checkpoint drain in AsyncExecutionController

[ https://issues.apache.org/jira/browse/FLINK-35027?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35027: --- Labels: pull-request-available (was: ) > Implement checkpoint drain in

[jira] [Updated] (FLINK-33460) Support property authentication connection.

[ https://issues.apache.org/jira/browse/FLINK-33460?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-33460: --- Labels: pull-request-available (was: ) > Support property authentication connection. >

[jira] [Updated] (FLINK-35149) Fix DataSinkTranslator#sinkTo ignoring pre-write topology if not TwoPhaseCommittingSink

[ https://issues.apache.org/jira/browse/FLINK-35149?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35149: --- Labels: pull-request-available (was: ) > Fix DataSinkTranslator#sinkTo ignoring pre-write

[jira] [Updated] (FLINK-35148) Improve InstantiationUtil for checking nullary public constructor

[ https://issues.apache.org/jira/browse/FLINK-35148?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35148: --- Labels: pull-request-available (was: ) > Improve InstantiationUtil for checking nullary

[jira] [Updated] (FLINK-35115) Kinesis connector writes wrong Kinesis sequence number at stop with savepoint

[ https://issues.apache.org/jira/browse/FLINK-35115?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35115: --- Labels: kinesis pull-request-available (was: kinesis) > Kinesis connector writes wrong

[jira] [Updated] (FLINK-35136) Release flink-connector-hbase v4.0.0 for Flink 1.19

[ https://issues.apache.org/jira/browse/FLINK-35136?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35136: --- Labels: pull-request-available (was: ) > Release flink-connector-hbase v4.0.0 for Flink

[jira] [Updated] (FLINK-35135) Release flink-connector-gcp-pubsub v3.1.0 for Flink 1.19

[ https://issues.apache.org/jira/browse/FLINK-35135?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35135: --- Labels: pull-request-available (was: ) > Release flink-connector-gcp-pubsub v3.1.0 for

[jira] [Updated] (FLINK-35130) Simplify AvailabilityNotifierImpl to support speculative scheduler and improve performance

[ https://issues.apache.org/jira/browse/FLINK-35130?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35130: --- Labels: pull-request-available (was: ) > Simplify AvailabilityNotifierImpl to support

[jira] [Updated] (FLINK-35139) Release flink-connector-mongodb vX.X.X for Flink 1.19

[ https://issues.apache.org/jira/browse/FLINK-35139?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35139: --- Labels: pull-request-available (was: ) > Release flink-connector-mongodb vX.X.X for Flink

[jira] [Updated] (FLINK-35092) Add integrated test for Doris / Starrocks sink pipeline connector

[ https://issues.apache.org/jira/browse/FLINK-35092?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35092: --- Labels: pull-request-available (was: ) > Add integrated test for Doris / Starrocks sink

[jira] [Updated] (FLINK-35071) Remove dependency on flink-shaded from cdc source connector

[ https://issues.apache.org/jira/browse/FLINK-35071?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35071: --- Labels: pull-request-available (was: ) > Remove dependency on flink-shaded from cdc source

[jira] [Updated] (FLINK-35128) Re-calculate the starting change log offset after the new table added

[ https://issues.apache.org/jira/browse/FLINK-35128?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35128: --- Labels: pull-request-available (was: ) > Re-calculate the starting change log offset after

[jira] [Updated] (FLINK-34878) [Feature][Pipeline] Flink CDC pipeline transform supports CASE WHEN

[ https://issues.apache.org/jira/browse/FLINK-34878?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-34878: --- Labels: github-import pull-request-available (was: github-import) > [Feature][Pipeline]

[jira] [Updated] (FLINK-35028) Timer firing under async execution model

[ https://issues.apache.org/jira/browse/FLINK-35028?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35028: --- Labels: pull-request-available (was: ) > Timer firing under async execution model >

[jira] [Updated] (FLINK-35125) Implement ValueState for ForStStateBackend

[ https://issues.apache.org/jira/browse/FLINK-35125?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35125: --- Labels: pull-request-available (was: ) > Implement ValueState for ForStStateBackend >

[jira] [Updated] (FLINK-35116) Upgrade JOSDK dependency to 4.8.3

[ https://issues.apache.org/jira/browse/FLINK-35116?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35116: --- Labels: pull-request-available (was: ) > Upgrade JOSDK dependency to 4.8.3 >

[jira] [Updated] (FLINK-35120) Add Doris Pipeline connector integration test cases

[ https://issues.apache.org/jira/browse/FLINK-35120?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35120: --- Labels: pull-request-available (was: ) > Add Doris Pipeline connector integration test

[jira] [Updated] (FLINK-35119) UPDATE DataChangeEvent deserialized data is incorrect

[ https://issues.apache.org/jira/browse/FLINK-35119?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35119: --- Labels: pull-request-available (was: ) > UPDATE DataChangeEvent deserialized data is

[jira] [Updated] (FLINK-35113) Bump org.apache.commons:commons-compress from 1.25.0 to 1.26.1 for Flink AWS connectors

[ https://issues.apache.org/jira/browse/FLINK-35113?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35113: --- Labels: pull-request-available (was: ) > Bump org.apache.commons:commons-compress from

[jira] [Updated] (FLINK-35108) Deployment recovery is triggered on terminal jobs after jm shutdown ttl

[ https://issues.apache.org/jira/browse/FLINK-35108?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35108: --- Labels: pull-request-available (was: ) > Deployment recovery is triggered on terminal jobs

[jira] [Updated] (FLINK-30388) Add support for ElementConverted open() method for KDS/KDF/DDB

[ https://issues.apache.org/jira/browse/FLINK-30388?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-30388: --- Labels: pull-request-available (was: ) > Add support for ElementConverted open() method

[jira] [Updated] (FLINK-35026) Introduce async execution configurations

[ https://issues.apache.org/jira/browse/FLINK-35026?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35026: --- Labels: pull-request-available (was: ) > Introduce async execution configurations >

[jira] [Updated] (FLINK-35107) rename flink-connector-datagen-test module folder to flink-connector-datagen-tests

[ https://issues.apache.org/jira/browse/FLINK-35107?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35107: --- Labels: pull-request-available (was: ) > rename flink-connector-datagen-test module folder

[jira] [Updated] (FLINK-35105) Support setting default Autoscaler options at autoscaler standalone level

[ https://issues.apache.org/jira/browse/FLINK-35105?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35105: --- Labels: pull-request-available (was: ) > Support setting default Autoscaler options at

[jira] [Updated] (FLINK-34987) Introduce Internal State Interface for Async State API

[ https://issues.apache.org/jira/browse/FLINK-34987?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-34987: --- Labels: pull-request-available (was: ) > Introduce Internal State Interface for Async

[jira] [Updated] (FLINK-35102) Incorret Type mapping for Flink CDC Doris connector

[ https://issues.apache.org/jira/browse/FLINK-35102?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35102: --- Labels: pull-request-available (was: ) > Incorret Type mapping for Flink CDC Doris

[jira] [Updated] (FLINK-35046) Introduce New KeyedStateBackend related Async interfaces

[ https://issues.apache.org/jira/browse/FLINK-35046?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35046: --- Labels: pull-request-available (was: ) > Introduce New KeyedStateBackend related Async

[jira] [Updated] (FLINK-35101) Missing method parameter annotation for ResourceManagerGateway.sendSlotReport

[ https://issues.apache.org/jira/browse/FLINK-35101?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35101: --- Labels: pull-request-available (was: ) > Missing method parameter annotation for

[jira] [Updated] (FLINK-35097) Table API Filesystem connector with 'raw' format repeats last line

[ https://issues.apache.org/jira/browse/FLINK-35097?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35097: --- Labels: pull-request-available (was: ) > Table API Filesystem connector with 'raw' format

[jira] [Updated] (FLINK-30687) FILTER not effect in count(*)

[ https://issues.apache.org/jira/browse/FLINK-30687?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-30687: --- Labels: pull-request-available (was: ) > FILTER not effect in count(*) >

[jira] [Updated] (FLINK-35098) Incorrect results for queries like "10 >= y" on tables using Filesystem connector and Orc format

[ https://issues.apache.org/jira/browse/FLINK-35098?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35098: --- Labels: pull-request-available (was: ) > Incorrect results for queries like "10 >= y" on

[jira] [Updated] (FLINK-35094) SinkTestSuiteBase.testScaleDown is hanging for 1.20-SNAPSHOT

[ https://issues.apache.org/jira/browse/FLINK-35094?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35094: --- Labels: pull-request-available test-stability (was: test-stability) >

[jira] [Updated] (FLINK-35025) Wire AsyncExecutionController to AbstractStreamOperator

[ https://issues.apache.org/jira/browse/FLINK-35025?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35025: --- Labels: pull-request-available (was: ) > Wire AsyncExecutionController to

[jira] [Updated] (FLINK-35089) Two input AbstractStreamOperator may throw NPE when receiving RecordAttributes

[ https://issues.apache.org/jira/browse/FLINK-35089?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35089: --- Labels: pull-request-available (was: ) > Two input AbstractStreamOperator may throw NPE

[jira] [Updated] (FLINK-35090) Doris sink fails to create table when database does not exist

[ https://issues.apache.org/jira/browse/FLINK-35090?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35090: --- Labels: pull-request-available (was: ) > Doris sink fails to create table when database

  1   2   3   4   5   6   7   8   9   10   >