[jira] [Created] (FLINK-36683) Support metadata 'row_kind' virtual column for Mongo CDC Connector

Runkang He created FLINK-36683: -- Summary: Support metadata 'row_kind' virtual column for Mongo CDC Connector Key: FLINK-36683 URL: https://issues.apache.org/jira/browse/FLINK-36683 Proj

[jira] [Created] (FLINK-36682) Add split assign strategy to avoid OOM error in TaskManager

Yanquan Lv created FLINK-36682: -- Summary: Add split assign strategy to avoid OOM error in TaskManager Key: FLINK-36682 URL: https://issues.apache.org/jira/browse/FLINK-36682 Project: Flink

[jira] [Created] (FLINK-36681) Wrong chunks splitting query in incremental snapshot reading section in mysql cdc doc

Runkang He created FLINK-36681: -- Summary: Wrong chunks splitting query in incremental snapshot reading section in mysql cdc doc Key: FLINK-36681 URL: https://issues.apache.org/jira/browse/FLINK-36681

[jira] [Created] (FLINK-36680) Flink K8S operator image 1.20.0 is still using Flink 1.19.1

Maxime created FLINK-36680: -- Summary: Flink K8S operator image 1.20.0 is still using Flink 1.19.1 Key: FLINK-36680 URL: https://issues.apache.org/jira/browse/FLINK-36680 Project: Flink Issue Type

[jira] [Created] (FLINK-36679) Add a metric to track checkpoint _metadata size

Mingliang Liu created FLINK-36679: - Summary: Add a metric to track checkpoint _metadata size Key: FLINK-36679 URL: https://issues.apache.org/jira/browse/FLINK-36679 Project: Flink Issue Type

[jira] [Created] (FLINK-36678) The Flink CDC Yarn deployment mode document description is incorrect

xuweiwei created FLINK-36678: Summary: The Flink CDC Yarn deployment mode document description is incorrect Key: FLINK-36678 URL: https://issues.apache.org/jira/browse/FLINK-36678 Project: Flink

[jira] [Created] (FLINK-36677) Instruct users to change log level dynamically in operator

Luke Chen created FLINK-36677: - Summary: Instruct users to change log level dynamically in operator Key: FLINK-36677 URL: https://issues.apache.org/jira/browse/FLINK-36677 Project: Flink Issue

[jira] [Created] (FLINK-36676) Flink CDC SQL Server Connector Missing Data

Chance created FLINK-36676: -- Summary: Flink CDC SQL Server Connector Missing Data Key: FLINK-36676 URL: https://issues.apache.org/jira/browse/FLINK-36676 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-36675) Dynamic option hints will not take effect when restoring exec plan from json plan without setting 'table.plan.compile.catalog-objects' to 'all'

URL: https://issues.apache.org/jira/browse/FLINK-36675 Project: Flink Issue Type: Bug Components: Table SQL / Planner Affects Versions: 2.0-preview, 1.19.1, 1.20.0 Reporter: xuyang -- This message was sent by Atlassian Jira (v8.20.10#820010)

[jira] [Created] (FLINK-36674) Flink will not commit if checkpointing is not enabled

slankka created FLINK-36674: --- Summary: Flink will not commit if checkpointing is not enabled Key: FLINK-36674 URL: https://issues.apache.org/jira/browse/FLINK-36674 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-36673) Operator is not properly handling failed deployments without savepoints

Yaroslav Tkachenko created FLINK-36673: -- Summary: Operator is not properly handling failed deployments without savepoints Key: FLINK-36673 URL: https://issues.apache.org/jira/browse/FLINK-36673

[jira] [Created] (FLINK-36672) Kinesis Table API for new KDS source should infer region from streamARN

Hong Liang Teoh created FLINK-36672: --- Summary: Kinesis Table API for new KDS source should infer region from streamARN Key: FLINK-36672 URL: https://issues.apache.org/jira/browse/FLINK-36672

[jira] [Created] (FLINK-36671) Kinesis Table API for new KDS source does not support metadata.

Hong Liang Teoh created FLINK-36671: --- Summary: Kinesis Table API for new KDS source does not support metadata. Key: FLINK-36671 URL: https://issues.apache.org/jira/browse/FLINK-36671 Project: Flink

[jira] [Created] (FLINK-36670) Optimize port range out-of-bounds exception log

Gianzie created FLINK-36670: --- Summary: Optimize port range out-of-bounds exception log Key: FLINK-36670 URL: https://issues.apache.org/jira/browse/FLINK-36670 Project: Flink Issue Type

[jira] [Created] (FLINK-36669) The flink version of ES should use parent's pom

Gianzie created FLINK-36669: --- Summary: The flink version of ES should use parent's pom Key: FLINK-36669 URL: https://issues.apache.org/jira/browse/FLINK-36669 Project: Flink Issue

[jira] [Created] (FLINK-36668) Release flink-connector-aws v5.0.0

Hong Liang Teoh created FLINK-36668: --- Summary: Release flink-connector-aws v5.0.0 Key: FLINK-36668 URL: https://issues.apache.org/jira/browse/FLINK-36668 Project: Flink Issue Type

[jira] [Created] (FLINK-36667) Remove `proto` schema definitions from source

Lorenzo Nicora created FLINK-36667: -- Summary: Remove `proto` schema definitions from source Key: FLINK-36667 URL: https://issues.apache.org/jira/browse/FLINK-36667 Project: Flink Issue Type

[jira] [Created] (FLINK-36663) [Window]The first processWatermark() after Sliding Window restore may have extra expired data.

kaitian created FLINK-36663: --- Summary: [Window]The first processWatermark() after Sliding Window restore may have extra expired data. Key: FLINK-36663 URL: https://issues.apache.org/jira/browse/FLINK-36663

[jira] [Created] (FLINK-36666) CI/CD should check NOTICE files for discrepancies.

Hong Liang Teoh created FLINK-3: --- Summary: CI/CD should check NOTICE files for discrepancies. Key: FLINK-3 URL: https://issues.apache.org/jira/browse/FLINK-3 Project: Flink

[jira] [Created] (FLINK-36665) WINDOW_START, WINDOW_END always return TIMESTAMP(3)

Dawid Wysakowicz created FLINK-36665: Summary: WINDOW_START, WINDOW_END always return TIMESTAMP(3) Key: FLINK-36665 URL: https://issues.apache.org/jira/browse/FLINK-36665 Project: Flink

[jira] [Created] (FLINK-36664) [Window]The window with window_offset will lose data.

kaitian created FLINK-36664: --- Summary: [Window]The window with window_offset will lose data. Key: FLINK-36664 URL: https://issues.apache.org/jira/browse/FLINK-36664 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-36662) Incorrect constant pull up when group keys in aggregate are NULL

lincoln lee created FLINK-36662: --- Summary: Incorrect constant pull up when group keys in aggregate are NULL Key: FLINK-36662 URL: https://issues.apache.org/jira/browse/FLINK-36662 Project: Flink

[jira] [Created] (FLINK-36661) the managed memory setting is relatively small, resulting in duplicate processing results for batch tasks

陈磊 created FLINK-36661: -- Summary: the managed memory setting is relatively small, resulting in duplicate processing results for batch tasks Key: FLINK-36661 URL: https://issues.apache.org/jira/browse/FLINK-36661

[jira] [Created] (FLINK-36660) Release flink-connector-elasticsearch vx.x.x for Flink 2.0

LvYanquan created FLINK-36660: - Summary: Release flink-connector-elasticsearch vx.x.x for Flink 2.0 Key: FLINK-36660 URL: https://issues.apache.org/jira/browse/FLINK-36660 Project: Flink Issue

[jira] [Created] (FLINK-36659) Release flink-connector-jdbc vx.x.x for Flink 2.0

LvYanquan created FLINK-36659: - Summary: Release flink-connector-jdbc vx.x.x for Flink 2.0 Key: FLINK-36659 URL: https://issues.apache.org/jira/browse/FLINK-36659 Project: Flink Issue Type: Sub

[jira] [Created] (FLINK-36658) Support and Release Connectors for Flink 2.0

LvYanquan created FLINK-36658: - Summary: Support and Release Connectors for Flink 2.0 Key: FLINK-36658 URL: https://issues.apache.org/jira/browse/FLINK-36658 Project: Flink Issue Type

[jira] [Created] (FLINK-36657) Release Flink 1.20

Matyas Orhidi created FLINK-36657: - Summary: Release Flink 1.20 Key: FLINK-36657 URL: https://issues.apache.org/jira/browse/FLINK-36657 Project: Flink Issue Type: Bug Reporter

[jira] [Created] (FLINK-36656) Flink CDC treats MySQL Sharding table with boolean type conversion error

Leonard Xu created FLINK-36656: -- Summary: Flink CDC treats MySQL Sharding table with boolean type conversion error Key: FLINK-36656 URL: https://issues.apache.org/jira/browse/FLINK-36656 Project: Flink

[jira] [Created] (FLINK-36655) using flink state processor api to process big state in rocksdb is very slow

guanghua pi created FLINK-36655: --- Summary: using flink state processor api to process big state in rocksdb is very slow Key: FLINK-36655 URL: https://issues.apache.org/jira/browse/FLINK-36655 Project

[jira] [Created] (FLINK-36654) Decimal divide Integer reports Null pointer exception

Shuai Xu created FLINK-36654: Summary: Decimal divide Integer reports Null pointer exception Key: FLINK-36654 URL: https://issues.apache.org/jira/browse/FLINK-36654 Project: Flink Issue Type

[jira] [Created] (FLINK-36653) OnlineLogisticRegressionModel not updating servable and prediction result

Yunfeng Zhou created FLINK-36653: Summary: OnlineLogisticRegressionModel not updating servable and prediction result Key: FLINK-36653 URL: https://issues.apache.org/jira/browse/FLINK-36653 Project

[jira] [Created] (FLINK-36652) Upgrade Apache ORC to 1.9.4

Yuchi Duan created FLINK-36652: -- Summary: Upgrade Apache ORC to 1.9.4 Key: FLINK-36652 URL: https://issues.apache.org/jira/browse/FLINK-36652 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-36651) Fix CI tests for ElasticSearch Connector

Ahmed Hamdy created FLINK-36651: --- Summary: Fix CI tests for ElasticSearch Connector Key: FLINK-36651 URL: https://issues.apache.org/jira/browse/FLINK-36651 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-36650) ConfluentRegistryAvroSerializationSchema always tries to register the schema on serialize even if it already exists

/jira/browse/FLINK-36650 Project: Flink Issue Type: Bug Components: Formats (JSON, Avro, Parquet, ORC, SequenceFile) Affects Versions: 1.19.1 Reporter: Jerome Gagnon When using the `ConfluentRegistryAvroSerializationSchema{*}`{*} as the serialization

[jira] [Created] (FLINK-36649) Oracle When reading via OracleIncrementalSource, the connection is occasionally closed

Di Wu created FLINK-36649: - Summary: Oracle When reading via OracleIncrementalSource, the connection is occasionally closed Key: FLINK-36649 URL: https://issues.apache.org/jira/browse/FLINK-36649 Project

[jira] [Created] (FLINK-36648) bump flink version to 2.0-preview1 for Kafka connector

LvYanquan created FLINK-36648: - Summary: bump flink version to 2.0-preview1 for Kafka connector Key: FLINK-36648 URL: https://issues.apache.org/jira/browse/FLINK-36648 Project: Flink Issue Type

[jira] [Created] (FLINK-36647) Support TimestampDiff function in cdc pipeline transform

Wenkai Qi created FLINK-36647: - Summary: Support TimestampDiff function in cdc pipeline transform Key: FLINK-36647 URL: https://issues.apache.org/jira/browse/FLINK-36647 Project: Flink Issue

[jira] [Created] (FLINK-36646) Support Java 17+ job images more conveniently in the operator

Rob Young created FLINK-36646: - Summary: Support Java 17+ job images more conveniently in the operator Key: FLINK-36646 URL: https://issues.apache.org/jira/browse/FLINK-36646 Project: Flink

[jira] [Created] (FLINK-36645) Gracefully handle null execution plan from autoscaler

Sai Sharath Dandi created FLINK-36645: - Summary: Gracefully handle null execution plan from autoscaler Key: FLINK-36645 URL: https://issues.apache.org/jira/browse/FLINK-36645 Project: Flink

[jira] [Created] (FLINK-36643) Upgrade aws-java-sdk-core to 1.12.773+ to fix vulnerability

Thomas Cooper created FLINK-36643: - Summary: Upgrade aws-java-sdk-core to 1.12.773+ to fix vulnerability Key: FLINK-36643 URL: https://issues.apache.org/jira/browse/FLINK-36643 Project: Flink

[jira] [Created] (FLINK-36644) TIMESTAMPDIFF can not be string serialized

Dawid Wysakowicz created FLINK-36644: Summary: TIMESTAMPDIFF can not be string serialized Key: FLINK-36644 URL: https://issues.apache.org/jira/browse/FLINK-36644 Project: Flink Issue

[jira] [Created] (FLINK-36642) Table API expressions with several built-in functions are not correctly serialized to SQL

Fabian Hueske created FLINK-36642: - Summary: Table API expressions with several built-in functions are not correctly serialized to SQL Key: FLINK-36642 URL: https://issues.apache.org/jira/browse/FLINK-36642

[jira] [Created] (FLINK-36641) Support and Release Connectors for Flink 1.20

LvYanquan created FLINK-36641: - Summary: Support and Release Connectors for Flink 1.20 Key: FLINK-36641 URL: https://issues.apache.org/jira/browse/FLINK-36641 Project: Flink Issue Type

[jira] [Created] (FLINK-36640) Provide an easy way to reset autoscaling

Matyas Orhidi created FLINK-36640: - Summary: Provide an easy way to reset autoscaling Key: FLINK-36640 URL: https://issues.apache.org/jira/browse/FLINK-36640 Project: Flink Issue Type

[jira] [Created] (FLINK-36639) Use table aliases in Table API asSerializableString

Dawid Wysakowicz created FLINK-36639: Summary: Use table aliases in Table API asSerializableString Key: FLINK-36639 URL: https://issues.apache.org/jira/browse/FLINK-36639 Project: Flink

[jira] [Created] (FLINK-36638) Remove legacy bounded blocking shuffle

Weijie Guo created FLINK-36638: -- Summary: Remove legacy bounded blocking shuffle Key: FLINK-36638 URL: https://issues.apache.org/jira/browse/FLINK-36638 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-36637) Fix ListShards for Kinesis streams with large number of shards

Elphas Toringepi created FLINK-36637: Summary: Fix ListShards for Kinesis streams with large number of shards Key: FLINK-36637 URL: https://issues.apache.org/jira/browse/FLINK-36637 Project

[jira] [Created] (FLINK-36636) Timestamp data can not be compared in cdc pipeline transform

Wenkai Qi created FLINK-36636: - Summary: Timestamp data can not be compared in cdc pipeline transform Key: FLINK-36636 URL: https://issues.apache.org/jira/browse/FLINK-36636 Project: Flink

[jira] [Created] (FLINK-36635) PhysicalSlotRequestBulkImpl is not used and can be removed

Yi Zhang created FLINK-36635: Summary: PhysicalSlotRequestBulkImpl is not used and can be removed Key: FLINK-36635 URL: https://issues.apache.org/jira/browse/FLINK-36635 Project: Flink Issue

[jira] [Created] (FLINK-36634) Introduce AdaptiveBatchSchedulerFactory to support dynamic generate join operator at runtime

xingbe created FLINK-36634: -- Summary: Introduce AdaptiveBatchSchedulerFactory to support dynamic generate join operator at runtime Key: FLINK-36634 URL: https://issues.apache.org/jira/browse/FLINK-36634

[jira] [Created] (FLINK-36633) Add support for Flink 1.20 in Flink OpenSearch connector

Andriy Redko created FLINK-36633: Summary: Add support for Flink 1.20 in Flink OpenSearch connector Key: FLINK-36633 URL: https://issues.apache.org/jira/browse/FLINK-36633 Project: Flink

[jira] [Created] (FLINK-36632) When scan.startup.mode is not initial and restart with savepoint, newly add-table will not synchronize snapshot data

MOBIN created FLINK-36632: - Summary: When scan.startup.mode is not initial and restart with savepoint, newly add-table will not synchronize snapshot data Key: FLINK-36632 URL: https://issues.apache.org/jira/browse/FLINK

[jira] [Created] (FLINK-36631) Supports reading incremental data from Oracle from a specified SCN

Di Wu created FLINK-36631: - Summary: Supports reading incremental data from Oracle from a specified SCN Key: FLINK-36631 URL: https://issues.apache.org/jira/browse/FLINK-36631 Project: Flink Issue

[jira] [Created] (FLINK-36630) kafka-connector random WakeupException after enabling watermark alignment

Alberto Lago created FLINK-36630: Summary: kafka-connector random WakeupException after enabling watermark alignment Key: FLINK-36630 URL: https://issues.apache.org/jira/browse/FLINK-36630 Project

[jira] [Created] (FLINK-36629) Introducing the AdaptiveSkewedJoinOptimizationStrategy

Lei Yang created FLINK-36629: Summary: Introducing the AdaptiveSkewedJoinOptimizationStrategy Key: FLINK-36629 URL: https://issues.apache.org/jira/browse/FLINK-36629 Project: Flink Issue Type

[jira] [Created] (FLINK-36628) OpenTelemetryTestBase.eventuallyConsumeJson failed on AZP

Weijie Guo created FLINK-36628: -- Summary: OpenTelemetryTestBase.eventuallyConsumeJson failed on AZP Key: FLINK-36628 URL: https://issues.apache.org/jira/browse/FLINK-36628 Project: Flink Issue

[jira] [Created] (FLINK-36627) Failure to process a CSV file in Flink due to a character encoding mismatch: the file is in ISO-8859 and the application expects UTF-8.

-36627 URL: https://issues.apache.org/jira/browse/FLINK-36627 Project: Flink Issue Type: Bug Reporter: Hector Miuler Malpica Gallegos I have error in read csv with charset ISO-8859, my error is the following: {{{color:#de350b}_Caused by

[jira] [Created] (FLINK-36626) Flink SQL JOINs behavior change from Flink 1.15 to Flink 1.18+

Eduardo Breijo created FLINK-36626: -- Summary: Flink SQL JOINs behavior change from Flink 1.15 to Flink 1.18+ Key: FLINK-36626 URL: https://issues.apache.org/jira/browse/FLINK-36626 Project: Flink

[jira] [Created] (FLINK-36625) Add helper classes for Lineage integration in connectors

Zhenqiu Huang created FLINK-36625: - Summary: Add helper classes for Lineage integration in connectors Key: FLINK-36625 URL: https://issues.apache.org/jira/browse/FLINK-36625 Project: Flink

[jira] [Created] (FLINK-36624) Log JobID in SourceCoordinator

Piotr Nowojski created FLINK-36624: -- Summary: Log JobID in SourceCoordinator Key: FLINK-36624 URL: https://issues.apache.org/jira/browse/FLINK-36624 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-36623) Improve logging in DefaultStateTransitionManager

Roman Khachatryan created FLINK-36623: - Summary: Improve logging in DefaultStateTransitionManager Key: FLINK-36623 URL: https://issues.apache.org/jira/browse/FLINK-36623 Project: Flink

[jira] [Created] (FLINK-36622) Remove the dependency of StateBenchmark on RocksDBKeyedStateBackend APIs.

Han Yin created FLINK-36622: --- Summary: Remove the dependency of StateBenchmark on RocksDBKeyedStateBackend APIs. Key: FLINK-36622 URL: https://issues.apache.org/jira/browse/FLINK-36622 Project: Flink

[jira] [Created] (FLINK-36621) Build failure: StatefulSink not found

Piotr Nowojski created FLINK-36621: -- Summary: Build failure: StatefulSink not found Key: FLINK-36621 URL: https://issues.apache.org/jira/browse/FLINK-36621 Project: Flink Issue Type

[jira] [Created] (FLINK-36620) Add support for the flink-home parameter to be set in both “--flink-home $FLINK_HOME” and “--flink-home=$FLINK_HOME” formats

zjjiang created FLINK-36620: --- Summary: Add support for the flink-home parameter to be set in both “--flink-home $FLINK_HOME” and “--flink-home=$FLINK_HOME” formats Key: FLINK-36620 URL: https://issues.apache.org/jira

[jira] [Created] (FLINK-36619) Downstream lost the CreateTableEvent when tables were removed and then re-added

linqigeng created FLINK-36619: - Summary: Downstream lost the CreateTableEvent when tables were removed and then re-added Key: FLINK-36619 URL: https://issues.apache.org/jira/browse/FLINK-36619 Project

[jira] [Created] (FLINK-36618) Improve PostgresDialect.discoverDataCollections to reduce the start time of Postgres CDC

Hongshun Wang created FLINK-36618: - Summary: Improve PostgresDialect.discoverDataCollections to reduce the start time of Postgres CDC Key: FLINK-36618 URL: https://issues.apache.org/jira/browse/FLINK-36618

[jira] [Created] (FLINK-36617) Migrate kryo package

Siddharth R created FLINK-36617: --- Summary: Migrate kryo package Key: FLINK-36617 URL: https://issues.apache.org/jira/browse/FLINK-36617 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-36616) Null pointer in PubSub's GcpPublisherConfig

Radosław Stankiewicz created FLINK-36616: Summary: Null pointer in PubSub's GcpPublisherConfig Key: FLINK-36616 URL: https://issues.apache.org/jira/browse/FLINK-36616 Project:

[jira] [Created] (FLINK-36615) Support LEAD/LAG functions in Table API

Dawid Wysakowicz created FLINK-36615: Summary: Support LEAD/LAG functions in Table API Key: FLINK-36615 URL: https://issues.apache.org/jira/browse/FLINK-36615 Project: Flink Issue Type

[jira] [Created] (FLINK-36614) mysql cdc will be stuck when the ChangeEventQueue is full at snapshot consume phase

Youle created FLINK-36614: - Summary: mysql cdc will be stuck when the ChangeEventQueue is full at snapshot consume phase Key: FLINK-36614 URL: https://issues.apache.org/jira/browse/FLINK-36614 Project: Flink

[jira] [Created] (FLINK-36613) RescaleCheckpointManuallyITCase.testCheckpointRescalingInKeyedState fails on AZP

Sergey Nuyanzin created FLINK-36613: --- Summary: RescaleCheckpointManuallyITCase.testCheckpointRescalingInKeyedState fails on AZP Key: FLINK-36613 URL: https://issues.apache.org/jira/browse/FLINK-36613

[jira] [Created] (FLINK-36612) Flink TypeSerializer doesn't recognize valid POJO getters/setters generated by Lombok

Hong Liang Teoh created FLINK-36612: --- Summary: Flink TypeSerializer doesn't recognize valid POJO getters/setters generated by Lombok Key: FLINK-36612 URL: https://issues.apache.org/jira/browse/FLINK-

[jira] [Created] (FLINK-36611) Add schema info to output of Kafka sink

LvYanquan created FLINK-36611: - Summary: Add schema info to output of Kafka sink Key: FLINK-36611 URL: https://issues.apache.org/jira/browse/FLINK-36611 Project: Flink Issue Type: New Feature

[jira] [Created] (FLINK-36610) MySQL CDC supports parsing gh-ost generated schema changes

yux created FLINK-36610: --- Summary: MySQL CDC supports parsing gh-ost generated schema changes Key: FLINK-36610 URL: https://issues.apache.org/jira/browse/FLINK-36610 Project: Flink Issue Type

[jira] [Created] (FLINK-36609) Protobuf Format not support proto3

Hongshun Wang created FLINK-36609: - Summary: Protobuf Format not support proto3 Key: FLINK-36609 URL: https://issues.apache.org/jira/browse/FLINK-36609 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-36608) Support dynamic StreamGraph optimization for AdaptiveBroadcastJoinOperator

xingbe created FLINK-36608: -- Summary: Support dynamic StreamGraph optimization for AdaptiveBroadcastJoinOperator Key: FLINK-36608 URL: https://issues.apache.org/jira/browse/FLINK-36608 Project: Flink

[jira] [Created] (FLINK-36607) Introduce AdaptiveBroadcastJoinProcessor to inject adaptive broadcast join

xingbe created FLINK-36607: -- Summary: Introduce AdaptiveBroadcastJoinProcessor to inject adaptive broadcast join Key: FLINK-36607 URL: https://issues.apache.org/jira/browse/FLINK-36607 Project: Flink

[jira] [Created] (FLINK-36606) TimestampITCase generates test artifacts outside of tmp folder

Sergey Nuyanzin created FLINK-36606: --- Summary: TimestampITCase generates test artifacts outside of tmp folder Key: FLINK-36606 URL: https://issues.apache.org/jira/browse/FLINK-36606 Project: Flink

[jira] [Created] (FLINK-36605) Upgrade Debezium version to 2.7.x

Anil Dasari created FLINK-36605: --- Summary: Upgrade Debezium version to 2.7.x Key: FLINK-36605 URL: https://issues.apache.org/jira/browse/FLINK-36605 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-36604) StreamingJobGraphGenerator::setOperatorConfig checks input serializer lengh

Mingliang Liu created FLINK-36604: - Summary: StreamingJobGraphGenerator::setOperatorConfig checks input serializer lengh Key: FLINK-36604 URL: https://issues.apache.org/jira/browse/FLINK-36604

[jira] [Created] (FLINK-36603) Inconsistent spelling of "behavior" across the API

Lorenzo Nicora created FLINK-36603: -- Summary: Inconsistent spelling of "behavior" across the API Key: FLINK-36603 URL: https://issues.apache.org/jira/browse/FLINK-36603 Project: Flink

[jira] [Created] (FLINK-36602) Upgrade Calcite version to 1.38.0

Thomas Cooper created FLINK-36602: - Summary: Upgrade Calcite version to 1.38.0 Key: FLINK-36602 URL: https://issues.apache.org/jira/browse/FLINK-36602 Project: Flink Issue Type: Technical

[jira] [Created] (FLINK-36601) Add JobID property to FlinkResultSet

Yi Cai created FLINK-36601: -- Summary: Add JobID property to FlinkResultSet Key: FLINK-36601 URL: https://issues.apache.org/jira/browse/FLINK-36601 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-36600) Implement java.sql.Wrapper interface.

Yi Cai created FLINK-36600: -- Summary: Implement java.sql.Wrapper interface. Key: FLINK-36600 URL: https://issues.apache.org/jira/browse/FLINK-36600 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-36599) Correct the name of the config which enables response codes group

Alan Zhang created FLINK-36599: -- Summary: Correct the name of the config which enables response codes group Key: FLINK-36599 URL: https://issues.apache.org/jira/browse/FLINK-36599 Project: Flink

[jira] [Created] (FLINK-36598) [state/forst] Refactor initialization of ForSt db core

Zakelly Lan created FLINK-36598: --- Summary: [state/forst] Refactor initialization of ForSt db core Key: FLINK-36598 URL: https://issues.apache.org/jira/browse/FLINK-36598 Project: Flink Issue

[jira] [Created] (FLINK-36597) Optimize SnapshotSplitAssigner error log output

MOBIN created FLINK-36597: - Summary: Optimize SnapshotSplitAssigner error log output Key: FLINK-36597 URL: https://issues.apache.org/jira/browse/FLINK-36597 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-36596) YAML Pipeline fails to schema change with no projection fields specified

yux created FLINK-36596: --- Summary: YAML Pipeline fails to schema change with no projection fields specified Key: FLINK-36596 URL: https://issues.apache.org/jira/browse/FLINK-36596 Project: Flink

[jira] [Created] (FLINK-36595) Supported Flink version for connector documentation does not get matched for 1.20

Aleksandr Pilipenko created FLINK-36595: --- Summary: Supported Flink version for connector documentation does not get matched for 1.20 Key: FLINK-36595 URL: https://issues.apache.org/jira/browse/FLINK-36595

[jira] [Created] (FLINK-36594) HiveCatalog should set HiveConf.hiveSiteLocation back

slankka created FLINK-36594: --- Summary: HiveCatalog should set HiveConf.hiveSiteLocation back Key: FLINK-36594 URL: https://issues.apache.org/jira/browse/FLINK-36594 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-36593) Upgrade io.airlift:aircompressor to mitigate CVE

Thomas Cooper created FLINK-36593: - Summary: Upgrade io.airlift:aircompressor to mitigate CVE Key: FLINK-36593 URL: https://issues.apache.org/jira/browse/FLINK-36593 Project: Flink Issue

[jira] [Created] (FLINK-36592) Support file cache for ForStStateBackend

Yanfei Lei created FLINK-36592: -- Summary: Support file cache for ForStStateBackend Key: FLINK-36592 URL: https://issues.apache.org/jira/browse/FLINK-36592 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-36591) WikipediaEditsSourceTest fails in all cases

Martijn Visser created FLINK-36591: -- Summary: WikipediaEditsSourceTest fails in all cases Key: FLINK-36591 URL: https://issues.apache.org/jira/browse/FLINK-36591 Project: Flink Issue Type

[jira] [Created] (FLINK-36590) Flink CDC does not Support MySQL > 8.0.x

yux created FLINK-36590: --- Summary: Flink CDC does not Support MySQL > 8.0.x Key: FLINK-36590 URL: https://issues.apache.org/jira/browse/FLINK-36590 Project: Flink Issue Type: Improvem

[jira] [Created] (FLINK-36589) Decouple the initialization of sync and async keyed statebackend

Zakelly Lan created FLINK-36589: --- Summary: Decouple the initialization of sync and async keyed statebackend Key: FLINK-36589 URL: https://issues.apache.org/jira/browse/FLINK-36589 Project: Flink

[jira] [Created] (FLINK-36588) flink catalog is supported in cdc yaml

ouyangwulin created FLINK-36588: --- Summary: flink catalog is supported in cdc yaml Key: FLINK-36588 URL: https://issues.apache.org/jira/browse/FLINK-36588 Project: Flink Issue Type: New Feature

[jira] [Created] (FLINK-36587) Postgres-cdc: Add support to override connector.class

Anil Dasari created FLINK-36587: --- Summary: Postgres-cdc: Add support to override connector.class Key: FLINK-36587 URL: https://issues.apache.org/jira/browse/FLINK-36587 Project: Flink Issue

[jira] [Created] (FLINK-36586) Upgrade Flink CDC dependency to Flink 1.19+

ZhengYu Chen created FLINK-36586: Summary: Upgrade Flink CDC dependency to Flink 1.19+ Key: FLINK-36586 URL: https://issues.apache.org/jira/browse/FLINK-36586 Project: Flink Issue Type: New

[jira] [Created] (FLINK-36585) The SplitFetcherManager.close() can chain the futures in a tight loop.

Jiangjie Qin created FLINK-36585: Summary: The SplitFetcherManager.close() can chain the futures in a tight loop. Key: FLINK-36585 URL: https://issues.apache.org/jira/browse/FLINK-36585 Project

[jira] [Created] (FLINK-36584) PostgresIncrementalSource is not exiting the flink execution when StartupOptions is snapshot and create multiple replication slots

://issues.apache.org/jira/browse/FLINK-36584 Project: Flink Issue Type: Bug Components: Flink CDC Affects Versions: 3.0.0 Reporter: Anil Dasari Issue-1. PostgresIncrementalSource is not exiting the Flink execution when StartupOptions is snapshot.   Postgres cdc

  1   2   3   4   5   6   7   8   9   10   >