[jira] [Created] (FLINK-35477) Pulsar connector resets existing subscription

2024-05-28 Thread Igor Basov (Jira)
Igor Basov created FLINK-35477: -- Summary: Pulsar connector resets existing subscription Key: FLINK-35477 URL: https://issues.apache.org/jira/browse/FLINK-35477 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-35476) The IF built-in function returns an exception when returning a string

2024-05-28 Thread jianhao.Li (Jira)
jianhao.Li created FLINK-35476: -- Summary: The IF built-in function returns an exception when returning a string Key: FLINK-35476 URL: https://issues.apache.org/jira/browse/FLINK-35476 Project: Flink

[jira] [Created] (FLINK-35475) Introduce isInternalSorterSupport to OperatorAttributes

2024-05-28 Thread Xuannan Su (Jira)
Xuannan Su created FLINK-35475: -- Summary: Introduce isInternalSorterSupport to OperatorAttributes Key: FLINK-35475 URL: https://issues.apache.org/jira/browse/FLINK-35475 Project: Flink Issue

[jira] [Created] (FLINK-35474) During the process of catching up after a restart, Flink CDC uses the latest table information to parse old binlogs.

2024-05-28 Thread stevedengzhi (Jira)
stevedengzhi created FLINK-35474: Summary: During the process of catching up after a restart, Flink CDC uses the latest table information to parse old binlogs. Key: FLINK-35474 URL: https://issues.apache.org/jira

[jira] [Created] (FLINK-35473) FLIP-457: Improve Table/SQL Configuration for Flink 2.0

2024-05-28 Thread Jane Chan (Jira)
Jane Chan created FLINK-35473: - Summary: FLIP-457: Improve Table/SQL Configuration for Flink 2.0 Key: FLINK-35473 URL: https://issues.apache.org/jira/browse/FLINK-35473 Project: Flink Issue Type

[jira] [Created] (FLINK-35472) Improve tests for Elasticsearch 8 connector

2024-05-28 Thread Mingliang Liu (Jira)
Mingliang Liu created FLINK-35472: - Summary: Improve tests for Elasticsearch 8 connector Key: FLINK-35472 URL: https://issues.apache.org/jira/browse/FLINK-35472 Project: Flink Issue Type

[jira] [Created] (FLINK-35471) Kubernetes operator bumps the flink version to 1.19

2024-05-28 Thread Rui Fan (Jira)
Rui Fan created FLINK-35471: --- Summary: Kubernetes operator bumps the flink version to 1.19 Key: FLINK-35471 URL: https://issues.apache.org/jira/browse/FLINK-35471 Project: Flink Issue Type

[jira] [Created] (FLINK-35470) Flink 1.18.1 and 1.19.0 having build jdk 1.8 and causing incompatibilities with Java 17

2024-05-28 Thread Rajat Pratap Singh (Jira)
Rajat Pratap Singh created FLINK-35470: -- Summary: Flink 1.18.1 and 1.19.0 having build jdk 1.8 and causing incompatibilities with Java 17 Key: FLINK-35470 URL: https://issues.apache.org/jira/browse/FLINK

[jira] [Created] (FLINK-35469) Unstable test case 'testProject' of JdbcDynamicTableSourceITCase

2024-05-27 Thread RocMarshal (Jira)
RocMarshal created FLINK-35469: -- Summary: Unstable test case 'testProject' of JdbcDynamicTableSourceITCase Key: FLINK-35469 URL: https://issues.apache.org/jira/browse/FLINK-35469 Project: Flink

[jira] [Created] (FLINK-35468) [Connectors/Pulsar] update isEnableAutoAcknowledgeMessage config comment

2024-05-27 Thread zhou zhuohan (Jira)
zhou zhuohan created FLINK-35468: Summary: [Connectors/Pulsar] update isEnableAutoAcknowledgeMessage config comment Key: FLINK-35468 URL: https://issues.apache.org/jira/browse/FLINK-35468 Project

[jira] [Created] (FLINK-35467) The flink-cdc.sh script of flink-cdc-3.1.0 cannot read the correct Flink configuration information specified by the flink-conf.yaml through the FLINK_CONF_DIR environmen

2024-05-27 Thread Justin.Liu (Jira)
: FLINK-35467 URL: https://issues.apache.org/jira/browse/FLINK-35467 Project: Flink Issue Type: Improvement Components: Flink CDC Affects Versions: cdc-3.1.0 Environment: Environment Information: flink-1.17.1 flink-cdc-3.1.0

[jira] [Created] (FLINK-35466) Cannot pass all columns to SQL UDFs using `*`

2024-05-27 Thread Gyula Fora (Jira)
Gyula Fora created FLINK-35466: -- Summary: Cannot pass all columns to SQL UDFs using `*` Key: FLINK-35466 URL: https://issues.apache.org/jira/browse/FLINK-35466 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-35465) Introduce BatchJobRecoveryHandler for recovery of batch jobs from JobMaster failures.

2024-05-27 Thread Junrui Li (Jira)
Junrui Li created FLINK-35465: - Summary: Introduce BatchJobRecoveryHandler for recovery of batch jobs from JobMaster failures. Key: FLINK-35465 URL: https://issues.apache.org/jira/browse/FLINK-35465

[jira] [Created] (FLINK-35464) Flink CDC 3.1 breaks operator state compatiblity

2024-05-27 Thread yux (Jira)
yux created FLINK-35464: --- Summary: Flink CDC 3.1 breaks operator state compatiblity Key: FLINK-35464 URL: https://issues.apache.org/jira/browse/FLINK-35464 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-35463) CDC job failed when restored from checkpoint when route rule changed.

2024-05-27 Thread hk__lrzy (Jira)
hk__lrzy created FLINK-35463: Summary: CDC job failed when restored from checkpoint when route rule changed. Key: FLINK-35463 URL: https://issues.apache.org/jira/browse/FLINK-35463 Project: Flink

[jira] [Created] (FLINK-35462) Introduce a parameter to control the chaining mode between a Flink SQL connector sink or source and its adjacent operator.

2024-05-27 Thread yuanfenghu (Jira)
/jira/browse/FLINK-35462 Project: Flink Issue Type: Improvement Components: Table SQL / Planner Reporter: yuanfenghu When using the flinksql connector, we can set the parallelism of the sink. However, when we modify the parallelism of the sink

[jira] [Created] (FLINK-35461) Improve Runtime Configuration for Flink 2.0

2024-05-26 Thread Xuannan Su (Jira)
Xuannan Su created FLINK-35461: -- Summary: Improve Runtime Configuration for Flink 2.0 Key: FLINK-35461 URL: https://issues.apache.org/jira/browse/FLINK-35461 Project: Flink Issue Type

[jira] [Created] (FLINK-35460) Check file size when position read for ForSt

2024-05-26 Thread Hangxiang Yu (Jira)
Hangxiang Yu created FLINK-35460: Summary: Check file size when position read for ForSt Key: FLINK-35460 URL: https://issues.apache.org/jira/browse/FLINK-35460 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-35459) Use Incremental Source Framework in Flink CDC TiKV Source Connector

2024-05-26 Thread ouyangwulin (Jira)
ouyangwulin created FLINK-35459: --- Summary: Use Incremental Source Framework in Flink CDC TiKV Source Connector Key: FLINK-35459 URL: https://issues.apache.org/jira/browse/FLINK-35459 Project: Flink

[jira] [Created] (FLINK-35458) Add serializer upgrade test for set serializer

2024-05-26 Thread Zhanghao Chen (Jira)
Zhanghao Chen created FLINK-35458: - Summary: Add serializer upgrade test for set serializer Key: FLINK-35458 URL: https://issues.apache.org/jira/browse/FLINK-35458 Project: Flink Issue Type

[jira] [Created] (FLINK-35457) EventTimeWindowCheckpointingITCase fails on AZP as NPE

2024-05-26 Thread Weijie Guo (Jira)
Weijie Guo created FLINK-35457: -- Summary: EventTimeWindowCheckpointingITCase fails on AZP as NPE Key: FLINK-35457 URL: https://issues.apache.org/jira/browse/FLINK-35457 Project: Flink Issue

[jira] [Created] (FLINK-35456) WindowAggregateITCase.testEventTimeHopWindow fails on AZP as NPE

2024-05-26 Thread Weijie Guo (Jira)
Weijie Guo created FLINK-35456: -- Summary: WindowAggregateITCase.testEventTimeHopWindow fails on AZP as NPE Key: FLINK-35456 URL: https://issues.apache.org/jira/browse/FLINK-35456 Project: Flink

[jira] [Created] (FLINK-35455) Non-idempotent unit tests

2024-05-26 Thread Kaiyao Ke (Jira)
Kaiyao Ke created FLINK-35455: - Summary: Non-idempotent unit tests Key: FLINK-35455 URL: https://issues.apache.org/jira/browse/FLINK-35455 Project: Flink Issue Type: Bug Reporter

[jira] [Created] (FLINK-35454) Connector ArchTests fails due to dependency on fink.util.Preconditions

2024-05-26 Thread Ahmed Hamdy (Jira)
Ahmed Hamdy created FLINK-35454: --- Summary: Connector ArchTests fails due to dependency on fink.util.Preconditions Key: FLINK-35454 URL: https://issues.apache.org/jira/browse/FLINK-35454 Project: Flink

[jira] [Created] (FLINK-35453) StreamReader Charset fix with UTF8 in core files

2024-05-25 Thread xy (Jira)
xy created FLINK-35453: -- Summary: StreamReader Charset fix with UTF8 in core files Key: FLINK-35453 URL: https://issues.apache.org/jira/browse/FLINK-35453 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-35452) MySQL CDC not tracking newly added tables after snapshot

2024-05-25 Thread Sharon Xie (Jira)
Sharon Xie created FLINK-35452: -- Summary: MySQL CDC not tracking newly added tables after snapshot Key: FLINK-35452 URL: https://issues.apache.org/jira/browse/FLINK-35452 Project: Flink Issue

[jira] [Created] (FLINK-35451) Support `ALTER CATALOG COMMENT` syntax

2024-05-25 Thread Yubin Li (Jira)
Yubin Li created FLINK-35451: Summary: Support `ALTER CATALOG COMMENT` syntax Key: FLINK-35451 URL: https://issues.apache.org/jira/browse/FLINK-35451 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-35450) Introduce Tikv pipeline DataSource

2024-05-25 Thread ouyangwulin (Jira)
ouyangwulin created FLINK-35450: --- Summary: Introduce Tikv pipeline DataSource Key: FLINK-35450 URL: https://issues.apache.org/jira/browse/FLINK-35450 Project: Flink Issue Type: New Feature

[jira] [Created] (FLINK-35449) MySQL CDC Flink SQL column names are case-sensitive

2024-05-24 Thread linweijiang (Jira)
linweijiang created FLINK-35449: --- Summary: MySQL CDC Flink SQL column names are case-sensitive Key: FLINK-35449 URL: https://issues.apache.org/jira/browse/FLINK-35449 Project: Flink Issue Type

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

2024-05-24 Thread Caican Cai (Jira)
Caican Cai created FLINK-35448: -- Summary: Translate pod templates documentation into Chinese Key: FLINK-35448 URL: https://issues.apache.org/jira/browse/FLINK-35448 Project: Flink Issue Type

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

2024-05-24 Thread Zhongqiang Gong (Jira)
Zhongqiang Gong created FLINK-35447: --- Summary: Flink CDC Document document file had removed but website can access Key: FLINK-35447 URL: https://issues.apache.org/jira/browse/FLINK-35447 Project

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

2024-05-24 Thread Ryan Skraba (Jira)
Ryan Skraba created FLINK-35446: --- Summary: FileMergingSnapshotManagerBase throws a NullPointerException Key: FLINK-35446 URL: https://issues.apache.org/jira/browse/FLINK-35446 Project: Flink

[jira] [Created] (FLINK-35445) Update Async Sink documentation for Timeout configuration

2024-05-24 Thread Ahmed Hamdy (Jira)
Ahmed Hamdy created FLINK-35445: --- Summary: Update Async Sink documentation for Timeout configuration Key: FLINK-35445 URL: https://issues.apache.org/jira/browse/FLINK-35445 Project: Flink

[jira] [Created] (FLINK-35444) Paimon Pipeline Connector support changing column names to lowercase for Hive metastore

2024-05-24 Thread LvYanquan (Jira)
LvYanquan created FLINK-35444: - Summary: Paimon Pipeline Connector support changing column names to lowercase for Hive metastore Key: FLINK-35444 URL: https://issues.apache.org/jira/browse/FLINK-35444

[jira] [Created] (FLINK-35443) ChangelogLocalRecoveryITCase failed fatally with 239 exit code

2024-05-23 Thread Weijie Guo (Jira)
Weijie Guo created FLINK-35443: -- Summary: ChangelogLocalRecoveryITCase failed fatally with 239 exit code Key: FLINK-35443 URL: https://issues.apache.org/jira/browse/FLINK-35443 Project: Flink

[jira] [Created] (FLINK-35442) Kafka Pipeline Sink may distribute the same key to different partitions after modify parallelism

2024-05-23 Thread LvYanquan (Jira)
LvYanquan created FLINK-35442: - Summary: Kafka Pipeline Sink may distribute the same key to different partitions after modify parallelism Key: FLINK-35442 URL: https://issues.apache.org/jira/browse/FLINK-35442

[jira] [Created] (FLINK-35441) Add CDC upgrade compatibility tests

2024-05-23 Thread yux (Jira)
yux created FLINK-35441: --- Summary: Add CDC upgrade compatibility tests Key: FLINK-35441 URL: https://issues.apache.org/jira/browse/FLINK-35441 Project: Flink Issue Type: Bug Components

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

2024-05-23 Thread Zach (Jira)
Zach created FLINK-35440: Summary: unable to connect tableau to jdbc flink url using flink sql driver Key: FLINK-35440 URL: https://issues.apache.org/jira/browse/FLINK-35440 Project: Flink Issue

[jira] [Created] (FLINK-35439) Python Support for AvroSchemaConverter

2024-05-23 Thread Greg Wills (Jira)
Greg Wills created FLINK-35439: -- Summary: Python Support for AvroSchemaConverter Key: FLINK-35439 URL: https://issues.apache.org/jira/browse/FLINK-35439 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-35438) SourceCoordinatorTest.testErrorThrownFromSplitEnumerator fails on wrong error

2024-05-23 Thread Ryan Skraba (Jira)
Ryan Skraba created FLINK-35438: --- Summary: SourceCoordinatorTest.testErrorThrownFromSplitEnumerator fails on wrong error Key: FLINK-35438 URL: https://issues.apache.org/jira/browse/FLINK-35438 Project

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

2024-05-23 Thread Dawid Wysakowicz (Jira)
Dawid Wysakowicz created FLINK-35437: Summary: BlockStatementGrouper uses lots of memory Key: FLINK-35437 URL: https://issues.apache.org/jira/browse/FLINK-35437 Project: Flink Issue Type

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

2024-05-23 Thread hk__lrzy (Jira)
hk__lrzy created FLINK-35436: Summary: Job can't launch when setting the option schema.change.behavior to IGNORE Key: FLINK-35436 URL: https://issues.apache.org/jira/browse/FLINK-35436 Project: Flink

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

2024-05-23 Thread Ahmed Hamdy (Jira)
Ahmed Hamdy created FLINK-35435: --- Summary: [FLIP-451] Introduce timeout configuration to AsyncSink Key: FLINK-35435 URL: https://issues.apache.org/jira/browse/FLINK-35435 Project: Flink Issue

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

2024-05-23 Thread Feifan Wang (Jira)
Feifan Wang created FLINK-35434: --- Summary: Support pass exception in StateExecutor to runtime Key: FLINK-35434 URL: https://issues.apache.org/jira/browse/FLINK-35434 Project: Flink Issue Type

[jira] [Created] (FLINK-35433) Provide a config parameter to set {{publishNotReadyAddresses}} option for the jobmanager's RPC Kubernetes service

2024-05-23 Thread Pavel (Jira)
Pavel created FLINK-35433: - Summary: Provide a config parameter to set {{publishNotReadyAddresses}} option for the jobmanager's RPC Kubernetes service Key: FLINK-35433 URL: https://issues.apache.org/jira/browse/FLINK

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

2024-05-23 Thread hk__lrzy (Jira)
hk__lrzy created FLINK-35432: Summary: Support catch modify-event for mysql-cdc Key: FLINK-35432 URL: https://issues.apache.org/jira/browse/FLINK-35432 Project: Flink Issue Type: Improvement

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

2024-05-23 Thread Zhongqiang Gong (Jira)
Zhongqiang Gong created FLINK-35431: --- Summary: Migrate references in Flink CDC documentation from Debezium 1.9 to 2.0 Key: FLINK-35431 URL: https://issues.apache.org/jira/browse/FLINK-35431 Project

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

2024-05-23 Thread LvYanquan (Jira)
LvYanquan created FLINK-35430: - Summary: ZoneId is not passed to DebeziumJsonSerializationSchema Key: FLINK-35430 URL: https://issues.apache.org/jira/browse/FLINK-35430 Project: Flink Issue Type

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

2024-05-23 Thread Weijie Guo (Jira)
Weijie Guo created FLINK-35429: -- Summary: We don't need introduce getFlinkConfigurationOptions for SqlGatewayRestEndpointFactory#Context Key: FLINK-35429 URL: https://issues.apache.org/jira/browse/FLINK-35429

[jira] [Created] (FLINK-35428) WindowJoinITCase#testInnerJoin failed on AZP as NPE

2024-05-23 Thread Weijie Guo (Jira)
Weijie Guo created FLINK-35428: -- Summary: WindowJoinITCase#testInnerJoin failed on AZP as NPE Key: FLINK-35428 URL: https://issues.apache.org/jira/browse/FLINK-35428 Project: Flink Issue Type

[jira] [Created] (FLINK-35427) Support fail-on-unknown-field config in json format

2024-05-22 Thread huhuan (Jira)
huhuan created FLINK-35427: -- Summary: Support fail-on-unknown-field config in json format Key: FLINK-35427 URL: https://issues.apache.org/jira/browse/FLINK-35427 Project: Flink Issue Type

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

2024-05-22 Thread xingbe (Jira)
xingbe created FLINK-35426: -- Summary: Change the distribution of DynamicFilteringDataCollector to Broadcast Key: FLINK-35426 URL: https://issues.apache.org/jira/browse/FLINK-35426 Project: Flink

[jira] [Created] (FLINK-35425) Support convert Freshness to cron expression for full refresh mode

2024-05-22 Thread dalongliu (Jira)
dalongliu created FLINK-35425: - Summary: Support convert Freshness to cron expression for full refresh mode Key: FLINK-35425 URL: https://issues.apache.org/jira/browse/FLINK-35425 Project: Flink

[jira] [Created] (FLINK-35424) Elasticsearch connector 8 supports SSL context

2024-05-22 Thread Mingliang Liu (Jira)
Mingliang Liu created FLINK-35424: - Summary: Elasticsearch connector 8 supports SSL context Key: FLINK-35424 URL: https://issues.apache.org/jira/browse/FLINK-35424 Project: Flink Issue Type

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

2024-05-22 Thread Sergey Nuyanzin (Jira)
Sergey Nuyanzin created FLINK-35423: --- Summary: ARRAY_EXCEPT should support set semantics Key: FLINK-35423 URL: https://issues.apache.org/jira/browse/FLINK-35423 Project: Flink Issue Type

[jira] [Created] (FLINK-35422) Flink dynamically adjusts operator-level resource usage without stopping the job

2024-05-22 Thread Jira
尹博星 created FLINK-35422: --- Summary: Flink dynamically adjusts operator-level resource usage without stopping the job Key: FLINK-35422 URL: https://issues.apache.org/jira/browse/FLINK-35422 Project: Flink

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

2024-05-22 Thread hk__lrzy (Jira)
hk__lrzy created FLINK-35421: Summary: Schema Operator blocking forever when Akka Rpc timeout Key: FLINK-35421 URL: https://issues.apache.org/jira/browse/FLINK-35421 Project: Flink Issue Type

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

2024-05-22 Thread Piotr Nowojski (Jira)
Piotr Nowojski created FLINK-35420: -- Summary: WordCountMapredITCase fails to compile in IntelliJ Key: FLINK-35420 URL: https://issues.apache.org/jira/browse/FLINK-35420 Project: Flink Issue

[jira] [Created] (FLINK-35419) scan.bounded.latest-offset makes queries never finish if the latest message is a EndTxn Kafka marker

2024-05-22 Thread Fabian Paul (Jira)
Fabian Paul created FLINK-35419: --- Summary: scan.bounded.latest-offset makes queries never finish if the latest message is a EndTxn Kafka marker Key: FLINK-35419 URL: https://issues.apache.org/jira/browse/FLINK

[jira] [Created] (FLINK-35418) EventTimeWindowCheckpointingITCase fails with an NPE

2024-05-22 Thread Ryan Skraba (Jira)
Ryan Skraba created FLINK-35418: --- Summary: EventTimeWindowCheckpointingITCase fails with an NPE Key: FLINK-35418 URL: https://issues.apache.org/jira/browse/FLINK-35418 Project: Flink Issue

[jira] [Created] (FLINK-35417) JobManager and TaskManager support merging and run in a single process

2024-05-21 Thread melin (Jira)
melin created FLINK-35417: - Summary: JobManager and TaskManager support merging and run in a single process Key: FLINK-35417 URL: https://issues.apache.org/jira/browse/FLINK-35417 Project: Flink

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

2024-05-21 Thread Weijie Guo (Jira)
Weijie Guo created FLINK-35416: -- Summary: Weekly CI for ElasticSearch connector failed to compile Key: FLINK-35416 URL: https://issues.apache.org/jira/browse/FLINK-35416 Project: Flink Issue

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

2024-05-21 Thread yux (Jira)
yux created FLINK-35415: --- Summary: CDC Fails to create sink with Flink 1.19 Key: FLINK-35415 URL: https://issues.apache.org/jira/browse/FLINK-35415 Project: Flink Issue Type: Bug Components

[jira] [Created] (FLINK-35414) Cancel jobs through rest api for last-state upgrades

2024-05-21 Thread Gyula Fora (Jira)
Gyula Fora created FLINK-35414: -- Summary: Cancel jobs through rest api for last-state upgrades Key: FLINK-35414 URL: https://issues.apache.org/jira/browse/FLINK-35414 Project: Flink Issue Type

[jira] [Created] (FLINK-35413) VertexFinishedStateCheckerTest causes exit 239

2024-05-21 Thread Ryan Skraba (Jira)
Ryan Skraba created FLINK-35413: --- Summary: VertexFinishedStateCheckerTest causes exit 239 Key: FLINK-35413 URL: https://issues.apache.org/jira/browse/FLINK-35413 Project: Flink Issue Type: Bug

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

2024-05-21 Thread Zakelly Lan (Jira)
Zakelly Lan created FLINK-35412: --- Summary: Batch execution of async state request callback Key: FLINK-35412 URL: https://issues.apache.org/jira/browse/FLINK-35412 Project: Flink Issue Type

[jira] [Created] (FLINK-35411) Optimize wait logic in draining of async state requests

2024-05-21 Thread Zakelly Lan (Jira)
Zakelly Lan created FLINK-35411: --- Summary: Optimize wait logic in draining of async state requests Key: FLINK-35411 URL: https://issues.apache.org/jira/browse/FLINK-35411 Project: Flink Issue

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

2024-05-21 Thread Zakelly Lan (Jira)
Zakelly Lan created FLINK-35410: --- Summary: Avoid sync waiting in coordinator thread of ForSt executor Key: FLINK-35410 URL: https://issues.apache.org/jira/browse/FLINK-35410 Project: Flink

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

2024-05-21 Thread Xiao Huang (Jira)
Xiao Huang created FLINK-35409: -- Summary: Request more splits if all splits are filtered from addSplits method Key: FLINK-35409 URL: https://issues.apache.org/jira/browse/FLINK-35409 Project: Flink

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

2024-05-21 Thread Xiao Huang (Jira)
Xiao Huang created FLINK-35408: -- Summary: Add 30 min tolerance value when validating the time-zone setting Key: FLINK-35408 URL: https://issues.apache.org/jira/browse/FLINK-35408 Project: Flink

[jira] [Created] (FLINK-35407) ensure orderly transactions during the full consumption stage of MySQL CDC

2024-05-21 Thread xiaotouming (Jira)
xiaotouming created FLINK-35407: --- Summary: ensure orderly transactions during the full consumption stage of MySQL CDC Key: FLINK-35407 URL: https://issues.apache.org/jira/browse/FLINK-35407 Project

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

2024-05-21 Thread Zhenghua Gao (Jira)
Zhenghua Gao created FLINK-35406: Summary: Use inner serializer when casting RAW type to BINARY or STRING in cast rules Key: FLINK-35406 URL: https://issues.apache.org/jira/browse/FLINK-35406 Project

[jira] [Created] (FLINK-35405) Add buffer size/in-flight records metrics for AsyncExecutionController

2024-05-20 Thread Yanfei Lei (Jira)
Yanfei Lei created FLINK-35405: -- Summary: Add buffer size/in-flight records metrics for AsyncExecutionController Key: FLINK-35405 URL: https://issues.apache.org/jira/browse/FLINK-35405 Project: Flink

[jira] [Created] (FLINK-35404) Report metrics of KafkaConsumer in new Kafka source

2024-05-20 Thread Harshit Mittal (Jira)
Harshit Mittal created FLINK-35404: -- Summary: Report metrics of KafkaConsumer in new Kafka source Key: FLINK-35404 URL: https://issues.apache.org/jira/browse/FLINK-35404 Project: Flink

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

2024-05-20 Thread Alan Sheinberg (Jira)
Alan Sheinberg created FLINK-35403: -- Summary: FLIP-452: Allow Skipping Invocation of Function Calls While Constant-folding Key: FLINK-35403 URL: https://issues.apache.org/jira/browse/FLINK-35403

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

2024-05-20 Thread Jira
Luís Costa created FLINK-35402: -- Summary: [flink-operator][Deployment] add labels to metadata Key: FLINK-35402 URL: https://issues.apache.org/jira/browse/FLINK-35402 Project: Flink Issue Type

[jira] [Created] (FLINK-35401) Add SQS Table API support

2024-05-20 Thread Ahmed Hamdy (Jira)
Ahmed Hamdy created FLINK-35401: --- Summary: Add SQS Table API support Key: FLINK-35401 URL: https://issues.apache.org/jira/browse/FLINK-35401 Project: Flink Issue Type: New Feature

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

2024-05-20 Thread Zakelly Lan (Jira)
Zakelly Lan created FLINK-35400: --- Summary: Rebuild FileMergingSnapshotManager in failover Key: FLINK-35400 URL: https://issues.apache.org/jira/browse/FLINK-35400 Project: Flink Issue Type: Sub

[jira] [Created] (FLINK-35399) Add documents for batch job master failure recovery

2024-05-19 Thread Zhu Zhu (Jira)
Zhu Zhu created FLINK-35399: --- Summary: Add documents for batch job master failure recovery Key: FLINK-35399 URL: https://issues.apache.org/jira/browse/FLINK-35399 Project: Flink Issue Type: Sub

[jira] [Created] (FLINK-35398) SqlGatewayE2ECase failed to pull image

2024-05-19 Thread Weijie Guo (Jira)
Weijie Guo created FLINK-35398: -- Summary: SqlGatewayE2ECase failed to pull image Key: FLINK-35398 URL: https://issues.apache.org/jira/browse/FLINK-35398 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-35397) Translate Controller Flow documentation into Chinese

2024-05-19 Thread Caican Cai (Jira)
Caican Cai created FLINK-35397: -- Summary: Translate Controller Flow documentation into Chinese Key: FLINK-35397 URL: https://issues.apache.org/jira/browse/FLINK-35397 Project: Flink Issue Type

[jira] [Created] (FLINK-35396) DynamoDB Streams Consumer consumption data is out of order

2024-05-18 Thread Suxing Lee (Jira)
Suxing Lee created FLINK-35396: -- Summary: DynamoDB Streams Consumer consumption data is out of order Key: FLINK-35396 URL: https://issues.apache.org/jira/browse/FLINK-35396 Project: Flink Issue

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

2024-05-18 Thread bradley (Jira)
bradley created FLINK-35395: --- Summary: Fix KeyedStateStore class annotation error Key: FLINK-35395 URL: https://issues.apache.org/jira/browse/FLINK-35395 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-35394) paimon pipeline support dynamic bucket

2024-05-18 Thread melin (Jira)
melin created FLINK-35394: - Summary: paimon pipeline support dynamic bucket Key: FLINK-35394 URL: https://issues.apache.org/jira/browse/FLINK-35394 Project: Flink Issue Type: New Feature

[jira] [Created] (FLINK-35393) Support flink kafka catalog

2024-05-18 Thread melin (Jira)
melin created FLINK-35393: - Summary: Support flink kafka catalog Key: FLINK-35393 URL: https://issues.apache.org/jira/browse/FLINK-35393 Project: Flink Issue Type: New Feature Components

[jira] [Created] (FLINK-35392) SQL Lookup Join on external database failing when using 'FOR SYSTEM_TIME AS OF' statement

2024-05-17 Thread Glauber M Dantas (Jira)
Glauber M Dantas created FLINK-35392: Summary: SQL Lookup Join on external database failing when using 'FOR SYSTEM_TIME AS OF' statement Key: FLINK-35392 URL: https://issues.apache.org/jira/browse/FLINK-35392

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

2024-05-17 Thread LvYanquan (Jira)
LvYanquan created FLINK-35391: - Summary: Bump dependency of Paimon Pipeline connector to 0.8.0 Key: FLINK-35391 URL: https://issues.apache.org/jira/browse/FLINK-35391 Project: Flink Issue Type

[jira] [Created] (FLINK-35390) Error reporting in SQL Server connection table structure table in Flink CDC-3.0 version

2024-05-17 Thread Jira
段志民 created FLINK-35390: --- Summary: Error reporting in SQL Server connection table structure table in Flink CDC-3.0 version Key: FLINK-35390 URL: https://issues.apache.org/jira/browse/FLINK-35390 Project: Flink

[jira] [Created] (FLINK-35389) Implement List Async State API for ForStStateBackend

2024-05-17 Thread Hangxiang Yu (Jira)
Hangxiang Yu created FLINK-35389: Summary: Implement List Async State API for ForStStateBackend Key: FLINK-35389 URL: https://issues.apache.org/jira/browse/FLINK-35389 Project: Flink Issue

[jira] [Created] (FLINK-35388) Flink 1.18.1 get stuck after creating highly available job result storage directory

2024-05-17 Thread Jira
Pedro Mázala created FLINK-35388: Summary: Flink 1.18.1 get stuck after creating highly available job result storage directory Key: FLINK-35388 URL: https://issues.apache.org/jira/browse/FLINK-35388

[jira] [Created] (FLINK-35387) PG CDC source support heart beat

2024-05-16 Thread Hongshun Wang (Jira)
Hongshun Wang created FLINK-35387: - Summary: PG CDC source support heart beat Key: FLINK-35387 URL: https://issues.apache.org/jira/browse/FLINK-35387 Project: Flink Issue Type: Bug

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

2024-05-16 Thread Qingsheng Ren (Jira)
Qingsheng Ren created FLINK-35386: - Summary: Build Flink CDC 3.1 Documentation and mark it as stable Key: FLINK-35386 URL: https://issues.apache.org/jira/browse/FLINK-35386 Project: Flink

[jira] [Created] (FLINK-35385) upgrader flink dependency version to 1.19

2024-05-16 Thread Hongshun Wang (Jira)
Hongshun Wang created FLINK-35385: - Summary: upgrader flink dependency version to 1.19 Key: FLINK-35385 URL: https://issues.apache.org/jira/browse/FLINK-35385 Project: Flink Issue Type

[jira] [Created] (FLINK-35384) Expose metrics group to custom Partitioner

2024-05-16 Thread Steven Zhen Wu (Jira)
Steven Zhen Wu created FLINK-35384: -- Summary: Expose metrics group to custom Partitioner Key: FLINK-35384 URL: https://issues.apache.org/jira/browse/FLINK-35384 Project: Flink Issue Type

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

2024-05-16 Thread Aleksandr Pilipenko (Jira)
Aleksandr Pilipenko created FLINK-35383: --- Summary: Update compatibility matrix to include 1.19 release Key: FLINK-35383 URL: https://issues.apache.org/jira/browse/FLINK-35383 Project: Flink

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

2024-05-16 Thread Ryan Skraba (Jira)
Ryan Skraba created FLINK-35382: --- Summary: ChangelogCompatibilityITCase.testRestore fails with an NPE Key: FLINK-35382 URL: https://issues.apache.org/jira/browse/FLINK-35382 Project: Flink

[jira] [Created] (FLINK-35381) LocalRecoveryITCase failure on deleting directory

2024-05-16 Thread Ryan Skraba (Jira)
Ryan Skraba created FLINK-35381: --- Summary: LocalRecoveryITCase failure on deleting directory Key: FLINK-35381 URL: https://issues.apache.org/jira/browse/FLINK-35381 Project: Flink Issue Type

[jira] [Created] (FLINK-35380) ResumeCheckpointManuallyITCase hanging on tests

2024-05-16 Thread Ryan Skraba (Jira)
Ryan Skraba created FLINK-35380: --- Summary: ResumeCheckpointManuallyITCase hanging on tests Key: FLINK-35380 URL: https://issues.apache.org/jira/browse/FLINK-35380 Project: Flink Issue Type

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

2024-05-16 Thread Zakelly Lan (Jira)
Zakelly Lan created FLINK-35379: --- Summary: File merging manager is not properly notified about checkpoint Key: FLINK-35379 URL: https://issues.apache.org/jira/browse/FLINK-35379 Project: Flink

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

2024-05-16 Thread Martijn Visser (Jira)
Martijn Visser created FLINK-35378: -- Summary: [FLIP-453] Promote Unified Sink API V2 to Public and Deprecate SinkFunc Key: FLINK-35378 URL: https://issues.apache.org/jira/browse/FLINK-35378 Project

<    1   2   3   4   5   6   7   8   9   10   >