[jira] [Updated] (FLINK-35446) FileMergingSnapshotManagerBase throws a NullPointerException

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

[jira] [Updated] (FLINK-35052) Webhook validator should reject unsupported Flink versions

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

[jira] [Updated] (FLINK-35448) Translate pod templates documentation into Chinese

[ https://issues.apache.org/jira/browse/FLINK-35448?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35448: --- Labels: pull-request-available (was: ) > Translate pod templates documentation into

[jira] [Updated] (FLINK-35447) Flink CDC Document document file had removed but website can access

[ https://issues.apache.org/jira/browse/FLINK-35447?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35447: --- Labels: pull-request-available (was: ) > Flink CDC Document document file had removed but

[jira] [Updated] (FLINK-35435) [FLIP-451] Introduce timeout configuration to AsyncSink

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

[jira] [Updated] (FLINK-34545) Add OceanBase pipeline connector to Flink CDC

[ https://issues.apache.org/jira/browse/FLINK-34545?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-34545: --- Labels: pull-request-available (was: ) > Add OceanBase pipeline connector to Flink CDC >

[jira] [Updated] (FLINK-35430) ZoneId is not passed to DebeziumJsonSerializationSchema

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

[jira] [Updated] (FLINK-35440) unable to connect tableau to jdbc flink url using flink sql driver

[ https://issues.apache.org/jira/browse/FLINK-35440?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35440: --- Labels: pull-request-available (was: ) > unable to connect tableau to jdbc flink url using

[jira] [Updated] (FLINK-35326) Implement lineage interface for hive connector

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

[jira] [Updated] (FLINK-34877) [Feature][Pipeline] Flink CDC pipeline transform supports type conversion

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

[jira] [Updated] (FLINK-35437) BlockStatementGrouper uses lots of memory

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

[jira] [Updated] (FLINK-35436) Job can't launch when setting the option schema.change.behavior to IGNORE

[ https://issues.apache.org/jira/browse/FLINK-35436?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35436: --- Labels: pull-request-available (was: ) > Job can't launch when setting the option

[jira] [Updated] (FLINK-35429) We don't need introduce getFlinkConfigurationOptions for SqlGatewayRestEndpointFactory#Context

[ https://issues.apache.org/jira/browse/FLINK-35429?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35429: --- Labels: pull-request-available (was: ) > We don't need introduce

[jira] [Updated] (FLINK-35434) Support pass exception in StateExecutor to runtime

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

[jira] [Updated] (FLINK-35412) Batch execution of async state request callback

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

[jira] [Updated] (FLINK-35432) Support catch modify-event for mysql-cdc

[ https://issues.apache.org/jira/browse/FLINK-35432?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35432: --- Labels: pull-request-available (was: ) > Support catch modify-event for mysql-cdc >

[jira] [Updated] (FLINK-35431) Migrate references in Flink CDC documentation from Debezium 1.9 to 2.0

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

[jira] [Updated] (FLINK-35410) Avoid sync waiting in coordinator thread of ForSt executor

[ https://issues.apache.org/jira/browse/FLINK-35410?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35410: --- Labels: pull-request-available (was: ) > Avoid sync waiting in coordinator thread of ForSt

[jira] [Updated] (FLINK-35426) Change the distribution of DynamicFilteringDataCollector to Broadcast

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

[jira] [Updated] (FLINK-35421) Schema Operator blocking forever when Akka Rpc timeout

[ https://issues.apache.org/jira/browse/FLINK-35421?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35421: --- Labels: pull-request-available (was: ) > Schema Operator blocking forever when Akka Rpc

[jira] [Updated] (FLINK-35129) Postgres source commits the offset after every multiple checkpoint cycles.

[ https://issues.apache.org/jira/browse/FLINK-35129?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35129: --- Labels: pull-request-available (was: ) > Postgres source commits the offset after every

[jira] [Updated] (FLINK-35423) ARRAY_EXCEPT should support set semantics

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

[jira] [Updated] (FLINK-35420) WordCountMapredITCase fails to compile in IntelliJ

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

[jira] [Updated] (FLINK-35415) CDC Fails to create sink with Flink 1.19

[ https://issues.apache.org/jira/browse/FLINK-35415?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35415: --- Labels: pull-request-available (was: ) > CDC Fails to create sink with Flink 1.19 >

[jira] [Updated] (FLINK-34673) SessionRelatedITCase#testTouchSession failure on GitHub Actions

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

[jira] [Updated] (FLINK-35143) Expose newly added tables capture in mysql pipeline connector

[ https://issues.apache.org/jira/browse/FLINK-35143?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35143: --- Labels: pull-request-available (was: ) > Expose newly added tables capture in mysql

[jira] [Updated] (FLINK-35416) Weekly CI for ElasticSearch connector failed to compile

[ https://issues.apache.org/jira/browse/FLINK-35416?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35416: --- Labels: pull-request-available (was: ) > Weekly CI for ElasticSearch connector failed to

[jira] [Updated] (FLINK-33461) Support streaming related semantics for the new JDBC source

[ https://issues.apache.org/jira/browse/FLINK-33461?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-33461: --- Labels: pull-request-available (was: ) > Support streaming related semantics for the new

[jira] [Updated] (FLINK-35347) Implement InMemory workflow scheduler service and plugin to support materialized table

[ https://issues.apache.org/jira/browse/FLINK-35347?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35347: --- Labels: pull-request-available (was: ) > Implement InMemory workflow scheduler service and

[jira] [Updated] (FLINK-20402) Migrate test_tpch.sh

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

[jira] [Updated] (FLINK-35409) Request more splits if all splits are filtered from addSplits method

[ https://issues.apache.org/jira/browse/FLINK-35409?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35409: --- Labels: pull-request-available (was: ) > Request more splits if all splits are filtered

[jira] [Updated] (FLINK-35408) Add 30 min tolerance value when validating the time-zone setting

[ https://issues.apache.org/jira/browse/FLINK-35408?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35408: --- Labels: pull-request-available (was: ) > Add 30 min tolerance value when validating the

[jira] [Updated] (FLINK-35242) Add fine-grained schema evolution strategy

[ https://issues.apache.org/jira/browse/FLINK-35242?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35242: --- Labels: pull-request-available (was: ) > Add fine-grained schema evolution strategy >

[jira] [Updated] (FLINK-35406) Use inner serializer when casting RAW type to BINARY or STRING in cast rules

[ https://issues.apache.org/jira/browse/FLINK-35406?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35406: --- Labels: pull-request-available (was: ) > Use inner serializer when casting RAW type to

[jira] [Updated] (FLINK-35400) Rebuild FileMergingSnapshotManager in failover

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

[jira] [Updated] (FLINK-35354) Support host mapping in Flink tikv cdc

[ https://issues.apache.org/jira/browse/FLINK-35354?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35354: --- Labels: pull-request-available (was: ) > Support host mapping in Flink tikv cdc >

[jira] [Updated] (FLINK-35359) General Improvement to Configuration for Flink 2.0

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

[jira] [Updated] (FLINK-35403) FLIP-452: Allow Skipping Invocation of Function Calls While Constant-folding

[ https://issues.apache.org/jira/browse/FLINK-35403?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35403: --- Labels: pull-request-available (was: ) > FLIP-452: Allow Skipping Invocation of Function

[jira] [Updated] (FLINK-35402) [flink-operator][Deployment] add labels to metadata

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

[jira] [Updated] (FLINK-35382) ChangelogCompatibilityITCase.testRestore fails with an NPE

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

[jira] [Updated] (FLINK-35391) Bump dependency of Paimon Pipeline connector to 0.8.0

[ https://issues.apache.org/jira/browse/FLINK-35391?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35391: --- Labels: pull-request-available (was: ) > Bump dependency of Paimon Pipeline connector to

[jira] [Updated] (FLINK-35049) Implement Map Async State API for ForStStateBackend

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

[jira] [Updated] (FLINK-35355) Async aggregating state

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

[jira] [Updated] (FLINK-35395) Fix KeyedStateStore class annotation error

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

[jira] [Updated] (FLINK-32088) Re-uploading in state file-merging for space amplification control

[ https://issues.apache.org/jira/browse/FLINK-32088?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-32088: --- Labels: pull-request-available (was: ) > Re-uploading in state file-merging for space

[jira] [Updated] (FLINK-35379) File merging manager is not properly notified about checkpoint

[ https://issues.apache.org/jira/browse/FLINK-35379?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35379: --- Labels: pull-request-available (was: ) > File merging manager is not properly notified

[jira] [Updated] (FLINK-35386) Build Flink CDC 3.1 Documentation and mark it as stable

[ https://issues.apache.org/jira/browse/FLINK-35386?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35386: --- Labels: pull-request-available (was: ) > Build Flink CDC 3.1 Documentation and mark it as

[jira] [Updated] (FLINK-35378) [FLIP-453] Promote Unified Sink API V2 to Public and Deprecate SinkFunc

[ https://issues.apache.org/jira/browse/FLINK-35378?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35378: --- Labels: pull-request-available (was: ) > [FLIP-453] Promote Unified Sink API V2 to Public

[jira] [Updated] (FLINK-35383) Update compatibility matrix to include 1.19 release

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

[jira] [Updated] (FLINK-35331) Download links for binary releases are displayed as source releases on website

[ https://issues.apache.org/jira/browse/FLINK-35331?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35331: --- Labels: pull-request-available (was: ) > Download links for binary releases are displayed

[jira] [Updated] (FLINK-35289) Incorrect timestamp of stream elements collected from onTimer in batch mode

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

[jira] [Updated] (FLINK-35342) MaterializedTableStatementITCase test can check for wrong status

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

[jira] [Updated] (FLINK-35373) Simplify Flink CDC Paimon Sink web ui

[ https://issues.apache.org/jira/browse/FLINK-35373?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35373: --- Labels: pull-request-available (was: ) > Simplify Flink CDC Paimon Sink web ui >

[jira] [Updated] (FLINK-35356) Async reducing state

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

[jira] [Updated] (FLINK-35325) Paimon connector miss the position of AddColumnEvent

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

[jira] [Updated] (FLINK-35226) Deprecate execution-mode in ExecutionConfigInfo related rest api

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

[jira] [Updated] (FLINK-35225) Remove Execution mode in Flink WebUI

[ https://issues.apache.org/jira/browse/FLINK-35225?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35225: --- Labels: pull-request-available (was: ) > Remove Execution mode in Flink WebUI >

[jira] [Updated] (FLINK-32828) Partition aware watermark not handled correctly shortly after job start up from checkpoint or savepoint

[ https://issues.apache.org/jira/browse/FLINK-32828?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-32828: --- Labels: pull-request-available (was: ) > Partition aware watermark not handled correctly

[jira] [Updated] (FLINK-35353) Translate "Profiler" page into Chinese

[ https://issues.apache.org/jira/browse/FLINK-35353?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35353: --- Labels: pull-request-available (was: ) > Translate "Profiler" page into Chinese >

[jira] [Updated] (FLINK-35358) Breaking change when loading artifacts

[ https://issues.apache.org/jira/browse/FLINK-35358?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35358: --- Labels: pull-request-available (was: ) > Breaking change when loading artifacts >

[jira] [Updated] (FLINK-35361) Delete Flinkhistory files that failed to write to the local directory

[ https://issues.apache.org/jira/browse/FLINK-35361?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35361: --- Labels: pull-request-available (was: ) > Delete Flinkhistory files that failed to write to

[jira] [Updated] (FLINK-32092) Integrate snapshot file-merging with existing IT cases

[ https://issues.apache.org/jira/browse/FLINK-32092?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-32092: --- Labels: pull-request-available (was: ) > Integrate snapshot file-merging with existing IT

[jira] [Updated] (FLINK-35346) Introduce pluggable workflow scheduler interface for materialized table

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

[jira] [Updated] (FLINK-35318) incorrect timezone handling for TIMESTAMP_WITH_LOCAL_TIME_ZONE type during predicate pushdown

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

[jira] [Updated] (FLINK-35333) JdbcXaSinkTestBase fails in weekly Flink JDBC Connector tests

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

[jira] [Updated] (FLINK-24298) Refactor Google PubSub sink to use Unified Sink API

[ https://issues.apache.org/jira/browse/FLINK-24298?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-24298: --- Labels: pull-request-available (was: ) > Refactor Google PubSub sink to use Unified Sink

[jira] [Updated] (FLINK-34931) Update Kudu connector DataStream Sink implementation

[ https://issues.apache.org/jira/browse/FLINK-34931?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-34931: --- Labels: pull-request-available (was: ) > Update Kudu connector DataStream Sink

[jira] [Updated] (FLINK-35109) Add support for Flink 1.20-SNAPSHOT in Flink Kafka connector and drop support for 1.17 and 1.18

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

[jira] [Updated] (FLINK-35351) Restore from unaligned checkpoints with a custom partitioner fails.

[ https://issues.apache.org/jira/browse/FLINK-35351?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35351: --- Labels: pull-request-available (was: ) > Restore from unaligned checkpoints with a custom

[jira] [Updated] (FLINK-33983) Introduce JobEvent and JobEventStore for Batch Job Recovery

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

[jira] [Updated] (FLINK-35153) Internal Async State Implementation and StateDescriptor for Map/List State

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

[jira] [Updated] (FLINK-35344) Move same code from multiple subclasses to JdbcSourceChunkSplitter

[ https://issues.apache.org/jira/browse/FLINK-35344?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35344: --- Labels: pull-request-available (was: ) > Move same code from multiple subclasses to

[jira] [Updated] (FLINK-35253) Translate "State Processor API "page into Chinese

[ https://issues.apache.org/jira/browse/FLINK-35253?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35253: --- Labels: pull-request-available (was: ) > Translate "State Processor API "page into Chinese

[jira] [Updated] (FLINK-5193) Recovering all jobs fails completely if a single recovery fails

[ https://issues.apache.org/jira/browse/FLINK-5193?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-5193: -- Labels: pull-request-available (was: ) > Recovering all jobs fails completely if a single

[jira] [Updated] (FLINK-35337) Keep up with the latest version of tikv client

[ https://issues.apache.org/jira/browse/FLINK-35337?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35337: --- Labels: pull-request-available (was: ) > Keep up with the latest version of tikv client >

[jira] [Updated] (FLINK-20400) Migrate test_streaming_sql.sh

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

[jira] [Updated] (FLINK-35332) Manually setting rest.bind-address does not work for Flink running on Hadoop Yarn dual network environment

[ https://issues.apache.org/jira/browse/FLINK-35332?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35332: --- Labels: pull-request-available (was: ) > Manually setting rest.bind-address does not work

[jira] [Updated] (FLINK-33986) Extend shuffleMaster to support batch snapshot.

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

[jira] [Updated] (FLINK-34108) Add URL_ENCODE and URL_DECODE function

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

[jira] [Updated] (FLINK-33892) FLIP-383: Support Job Recovery from JobMaster Failures for Batch Jobs

[ https://issues.apache.org/jira/browse/FLINK-33892?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-33892: --- Labels: pull-request-available (was: ) > FLIP-383: Support Job Recovery from JobMaster

[jira] [Updated] (FLINK-35305) FLIP-438: Amazon SQS Sink Connector

[ https://issues.apache.org/jira/browse/FLINK-35305?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35305: --- Labels: pull-request-available (was: ) > FLIP-438: Amazon SQS Sink Connector >

[jira] [Updated] (FLINK-35323) Only the schema of the first hit table is recorded when the source-table of the transformer hits multiple tables

[ https://issues.apache.org/jira/browse/FLINK-35323?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35323: --- Labels: pull-request-available (was: ) > Only the schema of the first hit table is

[jira] [Updated] (FLINK-35041) IncrementalRemoteKeyedStateHandleTest.testSharedStateReRegistration failed

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

[jira] [Updated] (FLINK-35322) PubSub Connector Weekly build fails

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

[jira] [Updated] (FLINK-34993) Support Model CRUD in parser

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

[jira] [Updated] (FLINK-35328) AutoScale supports setting the maximum floating parallelism by the number of Pulsar partitions

[ https://issues.apache.org/jira/browse/FLINK-35328?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35328: --- Labels: pull-request-available (was: ) > AutoScale supports setting the maximum floating

[jira] [Updated] (FLINK-32082) Documentation of checkpoint file-merging

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

[jira] [Updated] (FLINK-35314) Add Flink CDC pipeline transform user document

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

[jira] [Updated] (FLINK-35317) Flink CDC CLI Supports submitting multiple YAML job at once

[ https://issues.apache.org/jira/browse/FLINK-35317?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35317: --- Labels: pull-request-available (was: ) > Flink CDC CLI Supports submitting multiple YAML

[jira] [Updated] (FLINK-35316) Add CDC e2e test case for on Flink 1.19

[ https://issues.apache.org/jira/browse/FLINK-35316?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35316: --- Labels: pull-request-available (was: ) > Add CDC e2e test case for on Flink 1.19 >

[jira] [Updated] (FLINK-35197) Support the execution of suspend, resume materialized table in continuous refresh mode

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

[jira] [Updated] (FLINK-35313) Add upsert changelog mode to avoid UPDATE_BEFORE records push down

[ https://issues.apache.org/jira/browse/FLINK-35313?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35313: --- Labels: pull-request-available (was: ) > Add upsert changelog mode to avoid UPDATE_BEFORE

[jira] [Updated] (FLINK-35293) FLIP-445: Support dynamic parallelism inference for HiveSource

[ https://issues.apache.org/jira/browse/FLINK-35293?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35293: --- Labels: pull-request-available (was: ) > FLIP-445: Support dynamic parallelism inference

[jira] [Updated] (FLINK-35164) Support `ALTER CATALOG RESET` syntax

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

[jira] [Updated] (FLINK-35310) Replace RBAC verb wildcards with actual verbs

[ https://issues.apache.org/jira/browse/FLINK-35310?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35310: --- Labels: pull-request-available (was: ) > Replace RBAC verb wildcards with actual verbs >

[jira] [Updated] (FLINK-35198) Support the execution of refresh materialized table

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

[jira] [Updated] (FLINK-35309) Enable Notice file ci check and fix Notice

[ https://issues.apache.org/jira/browse/FLINK-35309?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35309: --- Labels: pull-request-available (was: ) > Enable Notice file ci check and fix Notice >

[jira] [Updated] (FLINK-32087) Space amplification statistics of file merging

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

[jira] [Updated] (FLINK-35306) Flink cannot compile with jdk17

[ https://issues.apache.org/jira/browse/FLINK-35306?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35306: --- Labels: pull-request-available (was: ) > Flink cannot compile with jdk17 >

[jira] [Updated] (FLINK-35281) FlinkEnvironmentUtils#addJar add each jar only once

[ https://issues.apache.org/jira/browse/FLINK-35281?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35281: --- Labels: pull-request-available (was: ) > FlinkEnvironmentUtils#addJar add each jar only

  1   2   3   4   5   6   7   8   9   10   >