issues
Thread
Date
Earlier messages
Later messages
Messages by Date
2024/05/23
[jira] [Assigned] (FLINK-35431) Migrate references in Flink CDC documentation from Debezium 1.9 to 2.0
Leonard Xu (Jira)
2024/05/23
Re: [PR] [BP-3.1][FLINK-35431][doc] Migrate references in Flink CDC documentation from Debezium 1.9 to 2.0 [flink-cdc]
via GitHub
2024/05/23
[jira] [Assigned] (FLINK-35434) Support pass exception in StateExecutor to runtime
Hangxiang Yu (Jira)
2024/05/23
[jira] [Commented] (FLINK-35067) Support metadata 'op_type' virtual column for Postgres CDC Connector.
Hongshun Wang (Jira)
2024/05/23
[jira] [Commented] (FLINK-35342) MaterializedTableStatementITCase test can check for wrong status
Weijie Guo (Jira)
2024/05/23
[jira] [Updated] (FLINK-35443) ChangelogLocalRecoveryITCase failed fatally with 239 exit code
Weijie Guo (Jira)
2024/05/23
[jira] [Created] (FLINK-35443) ChangelogLocalRecoveryITCase failed fatally with 239 exit code
Weijie Guo (Jira)
2024/05/23
[jira] [Updated] (FLINK-35443) ChangelogLocalRecoveryITCase failed fatally with 239 exit code
Weijie Guo (Jira)
2024/05/23
Re: [PR] [FLINK-35434] Support pass exception in StateExecutor to runtime [flink]
via GitHub
2024/05/23
Re: [PR] [FLINK-35400][checkpoint] Release FileMergingSnapshotManager if all tasks finished [flink]
via GitHub
2024/05/23
Re: [PR] [FLINK-35305]Amazon SQS Sink Connector [flink-connector-aws]
via GitHub
2024/05/23
[jira] [Comment Edited] (FLINK-34380) Strange RowKind and records about intermediate output when using minibatch join
Roman Boyko (Jira)
2024/05/23
[jira] [Comment Edited] (FLINK-34380) Strange RowKind and records about intermediate output when using minibatch join
Roman Boyko (Jira)
2024/05/23
[jira] [Commented] (FLINK-34380) Strange RowKind and records about intermediate output when using minibatch join
Roman Boyko (Jira)
2024/05/23
[jira] [Created] (FLINK-35442) Kafka Pipeline Sink may distribute the same key to different partitions after modify parallelism
LvYanquan (Jira)
2024/05/23
Re: [PR] [BP-3.0][FLINK-35431][doc] Migrate references in Flink CDC documentation from Debezium 1.9 to 2.0 [flink-cdc]
via GitHub
2024/05/23
[jira] [Commented] (FLINK-35347) Implement InMemory workflow scheduler service and plugin to support materialized table
dalongliu (Jira)
2024/05/23
[jira] [Resolved] (FLINK-35347) Implement InMemory workflow scheduler service and plugin to support materialized table
dalongliu (Jira)
2024/05/23
Re: [PR] [FLINK-35347][table] Introduce embedded scheduler and EmbeddedWorkflowScheduler plugin to support full refresh mode for materialized table [flink]
via GitHub
2024/05/23
Re: [PR] [BP-3.0][FLINK-35431][doc] Migrate references in Flink CDC documentation from Debezium 1.9 to 2.0 [flink-cdc]
via GitHub
2024/05/23
Re: [PR] [FLINK-35157][runtime] Sources with watermark alignment get stuck once some subtasks finish [flink]
via GitHub
2024/05/23
Re: [PR] [FLINK-35157][runtime] Sources with watermark alignment get stuck once some subtasks finish [flink]
via GitHub
2024/05/23
Re: [PR] [FLINK-35432]Support catch modify event for the mysql. [flink-cdc]
via GitHub
2024/05/23
Re: [PR] [FLINK-35143][cdc-connector][mysql] Expose newly added tables capture in mysql pipeline connector. [flink-cdc]
via GitHub
2024/05/23
Re: [PR] [FLINK-35215][core] Fix the bug when Kryo serialize length is 0 [flink]
via GitHub
2024/05/23
[jira] [Assigned] (FLINK-35441) Add CDC upgrade compatibility tests
Leonard Xu (Jira)
2024/05/23
Re: [PR] [FLINK-35355][State] Internal async aggregating state and corresponding state descriptor [flink]
via GitHub
2024/05/23
[jira] [Updated] (FLINK-35441) Add CDC upgrade compatibility tests
yux (Jira)
2024/05/23
Re: [PR] [FLINK-35215][core] Add a test for deserializing an object whose serialization result is an empty byte array [flink]
via GitHub
2024/05/23
[jira] [Commented] (FLINK-35441) Add CDC upgrade compatibility tests
yux (Jira)
2024/05/23
[jira] [Created] (FLINK-35441) Add CDC upgrade compatibility tests
yux (Jira)
2024/05/23
[PR] [FLINK-35215][core] Add a test for deserializing an object whose serialization result is an empty byte array [flink]
via GitHub
2024/05/23
Re: [PR] [FLINK-35143][cdc-connector][mysql] Expose newly added tables capture in mysql pipeline connector. [flink-cdc]
via GitHub
2024/05/23
Re: [PR] [FLINK-31664] Implement ARRAY_INTERSECT function [flink]
via GitHub
2024/05/23
Re: [PR] [FLINK-31664] Implement ARRAY_INTERSECT function [flink]
via GitHub
2024/05/23
Re: [PR] [FLINK-31664] Implement ARRAY_INTERSECT function [flink]
via GitHub
2024/05/23
Re: [PR] [FLINK-31664] Implement ARRAY_INTERSECT function [flink]
via GitHub
2024/05/23
Re: [PR] [FLINK-31664] Implement ARRAY_INTERSECT function [flink]
via GitHub
2024/05/23
[jira] [Closed] (FLINK-35221) Support SQL 2011 reserved keywords as identifiers in Flink HiveParser
luoyuxia (Jira)
2024/05/23
[jira] [Commented] (FLINK-35221) Support SQL 2011 reserved keywords as identifiers in Flink HiveParser
luoyuxia (Jira)
2024/05/23
Re: [PR] [FLINK-35221][hive] Support SQL 2011 reserved keywords as identifiers in HiveParser [flink-connector-hive]
via GitHub
2024/05/23
Re: [PR] [FLINK-35221][hive] Support SQL 2011 reserved keywords as identifiers in HiveParser [flink-connector-hive]
via GitHub
2024/05/23
[jira] [Updated] (FLINK-35417) JobManager and TaskManager support merging and run in a single process
melin (Jira)
2024/05/23
[jira] [Updated] (FLINK-35417) JobManager and TaskManager support merging and run in a single process
melin (Jira)
2024/05/23
Re: [PR] [FLINK-34877][cdc] Flink CDC pipeline transform supports type conversion [flink-cdc]
via GitHub
2024/05/23
Re: [PR] [FLINK-34877][cdc] Flink CDC pipeline transform supports type conversion [flink-cdc]
via GitHub
2024/05/23
Re: [PR] [FLINK-35347][table] Introduce embedded scheduler and EmbeddedWorkflowScheduler plugin to support full refresh mode for materialized table [flink]
via GitHub
2024/05/23
[jira] [Commented] (FLINK-35440) unable to connect tableau to jdbc flink url using flink sql driver
Zach (Jira)
2024/05/23
Re: [PR] [FLINK-35347][table] Introduce embedded scheduler and EmbeddedWorkflowScheduler plugin to support full refresh mode for materialized table [flink]
via GitHub
2024/05/23
Re: [PR] [FLINK-35440][Table SQL / JDBC] feat(flink-connection): support isValid for tableau [flink]
via GitHub
2024/05/23
[jira] [Updated] (FLINK-35440) unable to connect tableau to jdbc flink url using flink sql driver
ASF GitHub Bot (Jira)
2024/05/23
[PR] [FLINK-35440][Table SQL / JDBC] feat(flink-connection): support isValid for tableau [flink]
via GitHub
2024/05/23
[jira] [Created] (FLINK-35440) unable to connect tableau to jdbc flink url using flink sql driver
Zach (Jira)
2024/05/23
Re: [PR] [FLINK-35424][connectors/elasticsearch] Elasticsearch connector 8 supports SSL context [flink-connector-elasticsearch]
via GitHub
2024/05/23
Re: [PR] [FLINK-35424][connectors/elasticsearch] Elasticsearch connector 8 supports SSL context [flink-connector-elasticsearch]
via GitHub
2024/05/23
[jira] [Updated] (FLINK-35424) Elasticsearch connector 8 supports SSL context
Mingliang Liu (Jira)
2024/05/23
Re: [PR] [FLINK-35424][connectors/elasticsearch] Elasticsearch connector 8 supports SSL context [flink-connector-elasticsearch]
via GitHub
2024/05/23
Re: [PR] [FLINK-34993] parser changes to support model CRUD sql [flink]
via GitHub
2024/05/23
Re: [PR] [FLINK-34993] parser changes to support model CRUD sql [flink]
via GitHub
2024/05/23
Re: [PR] [FLINK-34993] parser changes to support model CRUD sql [flink]
via GitHub
2024/05/23
Re: [PR] [FLINK-35326][hive] add lineage integration for Hive connector [flink]
via GitHub
2024/05/23
Re: [PR] [FLINK-35129][cdc][postgres] Add checkpoint cycle option for commit offsets [flink-cdc]
via GitHub
2024/05/23
Re: [PR] [FLINK-35129][cdc][postgres] Add checkpoint cycle option for commit offsets [flink-cdc]
via GitHub
2024/05/23
[jira] [Updated] (FLINK-35326) Implement lineage interface for hive connector
ASF GitHub Bot (Jira)
2024/05/23
[PR] [FLINK-35326][hive] add lineage integration for Hive connector [flink]
via GitHub
2024/05/23
Re: [PR] [FLINK-35424][connectors/elasticsearch] Elasticsearch connector 8 supports SSL context [flink-connector-elasticsearch]
via GitHub
2024/05/23
[jira] [Updated] (FLINK-34877) [Feature][Pipeline] Flink CDC pipeline transform supports type conversion
ASF GitHub Bot (Jira)
2024/05/23
Re: [PR] [FLINK-34108][table] Add built-in URL_ENCODE and URL_DECODE function. [flink]
via GitHub
2024/05/23
Re: [PR] [FLINK-31664] Implement ARRAY_INTERSECT function [flink]
via GitHub
2024/05/23
Re: [PR] [FLINK-31664] Implement ARRAY_INTERSECT function [flink]
via GitHub
2024/05/23
Re: [PR] [FLINK-34108][table] Add built-in URL_ENCODE and URL_DECODE function. [flink]
via GitHub
2024/05/23
Re: [PR] [FLINK-31664] Implement ARRAY_INTERSECT function [flink]
via GitHub
2024/05/23
Re: [PR] [FLINK-34108][table] Add built-in URL_ENCODE and URL_DECODE function. [flink]
via GitHub
2024/05/23
Re: [PR] [FLINK-34108][table] Add built-in URL_ENCODE and URL_DECODE function. [flink]
via GitHub
2024/05/23
Re: [PR] [FLINK-34108][table] Add built-in URL_ENCODE and URL_DECODE function. [flink]
via GitHub
2024/05/23
Re: [PR] [FLINK-34487][ci] Adds Python Wheels nightly GHA workflow [flink]
via GitHub
2024/05/23
[jira] [Commented] (FLINK-34582) release build tools lost the newly added py3.11 packages for mac
Muhammet Orazov (Jira)
2024/05/23
[jira] [Created] (FLINK-35439) Python Support for AvroSchemaConverter
Greg Wills (Jira)
2024/05/23
[jira] [Created] (FLINK-35438) SourceCoordinatorTest.testErrorThrownFromSplitEnumerator fails on wrong error
Ryan Skraba (Jira)
2024/05/23
Re: [PR] [FLINK-34487][ci] Adds Python Wheels nightly GHA workflow [flink]
via GitHub
2024/05/23
Re: [PR] [BP-3.1][FLINK-35431][doc] Migrate references in Flink CDC documentation from Debezium 1.9 to 2.0 [flink-cdc]
via GitHub
2024/05/23
Re: [PR] [FLINK-34487][ci] Adds Python Wheels nightly GHA workflow [flink]
via GitHub
2024/05/23
Re: [PR] [FLINK-34487][ci] Adds Python Wheels nightly GHA workflow [flink]
via GitHub
2024/05/23
[jira] [Closed] (FLINK-35216) Support for RETURNING clause of JSON_QUERY
Dawid Wysakowicz (Jira)
2024/05/23
Re: [PR] [FLINK-35216] Support for RETURNING clause of JSON_QUERY [flink]
via GitHub
2024/05/23
Re: [PR] [FLINK-34108][table] Add built-in URL_ENCODE and URL_DECODE function. [flink]
via GitHub
2024/05/23
[jira] [Updated] (FLINK-34901) Update clause must EXCLUDED unique index
ouyangwulin (Jira)
2024/05/23
[jira] [Updated] (FLINK-34901) Update clause must EXCLUDED unique index
ouyangwulin (Jira)
2024/05/23
Re: [PR] [FLINK-34901][connectors/jdbc]Improve the performance of the update Postgres database [flink-connector-jdbc]
via GitHub
2024/05/23
Re: [PR] [FLINK-34108][table] Add built-in URL_ENCODE and URL_DECODE function. [flink]
via GitHub
2024/05/23
Re: [PR] chore: Update pekko version [flink]
via GitHub
2024/05/23
Re: [PR] chore: Update pekko version [flink]
via GitHub
2024/05/23
Re: [PR] chore: Update pekko version [flink]
via GitHub
2024/05/23
Re: [PR] [FLINK-34108][table] Add built-in URL_ENCODE and URL_DECODE function. [flink]
via GitHub
2024/05/23
Re: [PR] [FLINK-20398][e2e] Migrate test_batch_sql.sh to Java e2e tests framework [flink]
via GitHub
2024/05/23
Re: [PR] [FLINK-35432]Support catch modify event for the mysql. [flink-cdc]
via GitHub
2024/05/23
[jira] [Commented] (FLINK-34582) release build tools lost the newly added py3.11 packages for mac
Muhammet Orazov (Jira)
2024/05/23
Re: [PR] [FLINK-34487][ci] Adds Python Wheels nightly GHA workflow [flink]
via GitHub
2024/05/23
Re: [PR] [FLINK-35415][base] Fix compatibility with Flink 1.19 [flink-cdc]
via GitHub
2024/05/23
Re: [PR] [FLINK-35415][base] Fix compatibility with Flink 1.19 [flink-cdc]
via GitHub
2024/05/23
Re: [PR] [FLINK-33859] Support OpenSearch v2 [flink-connector-opensearch]
via GitHub
2024/05/23
Re: [PR] [FLINK-33681] Reuse input/output metrics of SourceOperator/SinkWriterOperator for task [flink]
via GitHub
2024/05/23
Re: [PR] [FLINK-35090][cdc][doris] Add database auto-creating support for Doris sink pipeline connector [flink-cdc]
via GitHub
2024/05/23
Re: [PR] [FLINK-33859] Support OpenSearch v2 [flink-connector-opensearch]
via GitHub
2024/05/23
Re: [PR] [FLINK-34487][ci] Adds Python Wheels nightly GHA workflow [flink]
via GitHub
2024/05/23
Re: [PR] [FLINK-35437] Rewrite BlockStatementGrouper so that it uses less memory [flink]
via GitHub
2024/05/23
Re: [PR] [FLINK-35415][base] Fix compatibility with Flink 1.19 [flink-cdc]
via GitHub
2024/05/23
[jira] [Updated] (FLINK-35437) BlockStatementGrouper uses lots of memory
ASF GitHub Bot (Jira)
2024/05/23
[PR] [FLINK-35437] Rewrite BlockStatementGrouper so that it uses less memory [flink]
via GitHub
2024/05/23
Re: [PR] [FLINK-35434] Support pass exception in StateExecutor to runtime [flink]
via GitHub
2024/05/23
[jira] [Commented] (FLINK-35380) ResumeCheckpointManuallyITCase hanging on tests
Ryan Skraba (Jira)
2024/05/23
[jira] [Commented] (FLINK-35342) MaterializedTableStatementITCase test can check for wrong status
Ryan Skraba (Jira)
2024/05/23
[jira] [Commented] (FLINK-33186) CheckpointAfterAllTasksFinishedITCase.testRestoreAfterSomeTasksFinished fails on AZP
Ryan Skraba (Jira)
2024/05/23
[jira] [Commented] (FLINK-28440) EventTimeWindowCheckpointingITCase failed with restore
Ryan Skraba (Jira)
2024/05/23
[jira] [Updated] (FLINK-35437) BlockStatementGrouper uses lots of memory
Dawid Wysakowicz (Jira)
2024/05/23
[jira] [Created] (FLINK-35437) BlockStatementGrouper uses lots of memory
Dawid Wysakowicz (Jira)
2024/05/23
Re: [PR] [FLINK-35049][state] Implement Map Async State API for ForStStateBackend [flink]
via GitHub
2024/05/23
Re: [PR] [FLINK-35355][State] Internal async aggregating state and corresponding state descriptor [flink]
via GitHub
2024/05/23
[jira] [Updated] (FLINK-35421) Schema Operator blocking forever when Akka Rpc timeout
hk__lrzy (Jira)
2024/05/23
[jira] [Updated] (FLINK-35432) Support catch modify-event for mysql-cdc
hk__lrzy (Jira)
2024/05/23
[jira] [Updated] (FLINK-35432) Support catch modify-event for mysql-cdc
hk__lrzy (Jira)
2024/05/23
[jira] [Updated] (FLINK-35436) Job can't launch when setting the option schema.change.behavior to IGNORE
hk__lrzy (Jira)
2024/05/23
Re: [PR] [FLINK-35347][table] Introduce embedded scheduler and EmbeddedWorkflowScheduler plugin to support full refresh mode for materialized table [flink]
via GitHub
2024/05/23
Re: [PR] [FLINK-33759] [flink-parquet] Add support for nested array with row/map/array type [flink]
via GitHub
2024/05/23
Re: [PR] [FLINK-35434] Support pass exception in StateExecutor to runtime [flink]
via GitHub
2024/05/23
Re: [PR] [FLINK-35167][cdc-connector] Introduce MaxCompute pipeline DataSink [flink-cdc]
via GitHub
2024/05/23
[jira] [Updated] (FLINK-35436) Job can't launch when setting the option schema.change.behavior to IGNORE
ASF GitHub Bot (Jira)
2024/05/23
Re: [PR] [FLINK-33759] [flink-parquet] Add support for nested array with row/map/array type [flink]
via GitHub
2024/05/23
Re: [PR] [FLINK-33759] [flink-parquet] Add support for nested array with row/map/array type [flink]
via GitHub
2024/05/23
Re: [PR] [FLINK-33759] [flink-parquet] Add support for nested array with row/map/array type [flink]
via GitHub
2024/05/23
[jira] [Closed] (FLINK-35429) We don't need introduce getFlinkConfigurationOptions for SqlGatewayRestEndpointFactory#Context
Weijie Guo (Jira)
2024/05/23
Re: [PR] [FLINK-34487][ci] Adds Python Wheels nightly GHA workflow [flink]
via GitHub
2024/05/23
Re: [PR] [FLINK-34456][configuration]Move all checkpoint-related options into CheckpointingOptions [flink]
via GitHub
2024/05/23
Re: [PR] [FLINK-35429][sqlgateway] Do not introduce new method in SqlGatewayEndpointFactory#Context [flink]
via GitHub
2024/05/23
[jira] [Updated] (FLINK-35429) We don't need introduce getFlinkConfigurationOptions for SqlGatewayRestEndpointFactory#Context
ASF GitHub Bot (Jira)
2024/05/23
Re: [PR] [FLINK-35429][sqlgateway] Do not introduce new method in SqlGatewayEndpointFactory#Context [flink]
via GitHub
2024/05/23
Re: [PR] [FLINK-34487][ci] Adds Python Wheels nightly GHA workflow [flink]
via GitHub
2024/05/23
Re: [PR] [FLINK-35221][hive] Support SQL 2011 reserved keywords as identifiers in HiveParser [flink-connector-hive]
via GitHub
2024/05/23
Re: [PR] [FLINK-33892][runtime] Support Job Recovery from JobMaster Failures for Batch Jobs. [flink]
via GitHub
2024/05/23
Re: [PR] [FLINK-34487][ci] Adds Python Wheels nightly GHA workflow [flink]
via GitHub
2024/05/23
Re: [PR] [FLINK-34487][ci] Adds Python Wheels nightly GHA workflow [flink]
via GitHub
2024/05/23
Re: [PR] [FLINK-35221][hive] Support SQL 2011 reserved keywords as identifiers in HiveParser [flink-connector-hive]
via GitHub
2024/05/23
Re: [PR] [FLINK-35221][hive] Support SQL 2011 reserved keywords as identifiers in HiveParser [flink-connector-hive]
via GitHub
2024/05/23
Re: [PR] [FLINK-35090][cdc][doris] Add database auto-creating support for Doris sink pipeline connector [flink-cdc]
via GitHub
2024/05/23
Re: [PR] [FLINK-34487][ci] Adds Python Wheels nightly GHA workflow [flink]
via GitHub
2024/05/23
Re: [PR] [FLINK-35415][base] Fix compatibility with Flink 1.19 [flink-cdc]
via GitHub
2024/05/23
Re: [PR] [FLINK-34487][ci] Adds Python Wheels nightly GHA workflow [flink]
via GitHub
2024/05/23
[jira] [Created] (FLINK-35436) Job can't launch when setting the option schema.change.behavior to IGNORE
hk__lrzy (Jira)
2024/05/23
Re: [PR] [FLINK-35347][table] Introduce embedded scheduler and EmbeddedWorkflowScheduler plugin to support full refresh mode for materialized table [flink]
via GitHub
2024/05/23
[jira] [Commented] (FLINK-34333) Fix FLINK-34007 LeaderElector bug in 1.18
Jira
2024/05/23
Re: [PR] [FLINK-35215][core] Fix the bug when Kryo serialize length is 0 [flink]
via GitHub
2024/05/23
Re: [PR] [FLINK-34487][ci] Adds Python Wheels nightly GHA workflow [flink]
via GitHub
2024/05/23
Re: [PR] [FLINK-35434] Support pass exception in StateExecutor to runtime [flink]
via GitHub
2024/05/23
Re: [PR] [FLINK-34487][ci] Adds Python Wheels nightly GHA workflow [flink]
via GitHub
2024/05/23
Re: [PR] [FLINK-34487][ci] Adds Python Wheels nightly GHA workflow [flink]
via GitHub
2024/05/23
Re: [PR] [FLINK-34487][ci] Adds Python Wheels nightly GHA workflow [flink]
via GitHub
2024/05/23
Re: [PR] [FLINK-20400][e2e] Migrate test_streaming_sql.sh [flink]
via GitHub
2024/05/23
Re: [PR] [FLINK-34108][table] Add built-in URL_ENCODE and URL_DECODE function. [flink]
via GitHub
2024/05/23
[jira] [Updated] (FLINK-35434) Support pass exception in StateExecutor to runtime
ASF GitHub Bot (Jira)
2024/05/23
Re: [PR] [FLINK-35434] Support pass exception in StateExecutor to runtime [flink]
via GitHub
2024/05/23
Re: [PR] [FLINK-33892][runtime] Support Job Recovery from JobMaster Failures for Batch Jobs. [flink]
via GitHub
2024/05/23
[PR] [Flink-35434] Support pass exception in StateExecutor to runtime [flink]
via GitHub
2024/05/23
Re: [PR] [FLINK-35412][State/Runtime] Batch execution of async state request callback [flink]
via GitHub
2024/05/23
[jira] [Updated] (FLINK-35412) Batch execution of async state request callback
ASF GitHub Bot (Jira)
2024/05/23
[jira] [Created] (FLINK-35435) [FLIP-451] Introduce timeout configuration to AsyncSink
Ahmed Hamdy (Jira)
2024/05/23
[PR] [FLINK-35412][State/Runtime] Batch execution of async state request callback [flink]
via GitHub
2024/05/23
[jira] [Created] (FLINK-35434) Support pass exception in StateExecutor to runtime
Feifan Wang (Jira)
2024/05/23
Re: [PR] [FLINK-34108][table] Add built-in URL_ENCODE and URL_DECODE function. [flink]
via GitHub
2024/05/23
Re: [PR] [FLINK-34108][table] Add built-in URL_ENCODE and URL_DECODE function. [flink]
via GitHub
2024/05/23
Re: [PR] [hotfix] [base] Fix the serialization error occurring with table names containing dot [flink-cdc]
via GitHub
2024/05/23
[jira] [Created] (FLINK-35433) Provide a config parameter to set {{publishNotReadyAddresses}} option for the jobmanager's RPC Kubernetes service
Pavel (Jira)
2024/05/23
[PR] [hotfix] [base] Fix the serialization error occurring with table names containing dot [flink-cdc]
via GitHub
2024/05/23
Re: [PR] [FLINK-35431][doc] Migrate references in Flink CDC documentation from Debezium 1.9 to 2.0 [flink-cdc]
via GitHub
2024/05/23
Re: [PR] [FLINK-35431][doc] Migrate references in Flink CDC documentation from Debezium 1.9 to 2.0 [flink-cdc]
via GitHub
2024/05/23
Re: [PR] [FLINK-35431][doc] Migrate references in Flink CDC documentation from Debezium 1.9 to 2.0 [flink-cdc]
via GitHub
2024/05/23
Re: [PR] [FLINK-35400][checkpoint] Release FileMergingSnapshotManager if all tasks finished [flink]
via GitHub
2024/05/23
Re: [PR] [FLINK-34108][table] Add built-in URL_ENCODE and URL_DECODE function. [flink]
via GitHub
2024/05/23
Re: [PR] [FLINK-35400][checkpoint] Release FileMergingSnapshotManager if all tasks finished [flink]
via GitHub
2024/05/23
[jira] [Updated] (FLINK-35432) Support catch modify-event for mysql-cdc
ASF GitHub Bot (Jira)
2024/05/23
[jira] [Updated] (FLINK-35431) Migrate references in Flink CDC documentation from Debezium 1.9 to 2.0
ASF GitHub Bot (Jira)
2024/05/23
[jira] [Created] (FLINK-35432) Support catch modify-event for mysql-cdc
hk__lrzy (Jira)
2024/05/23
Re: [PR] [hotfix] [base] Fix the serialization error occurring with table names containing dot [flink-cdc]
via GitHub
2024/05/23
[jira] [Commented] (FLINK-34945) Support recover shuffle descriptor and partition metrics from tiered storage
Junrui Li (Jira)
2024/05/23
[jira] [Created] (FLINK-35431) Migrate references in Flink CDC documentation from Debezium 1.9 to 2.0
Zhongqiang Gong (Jira)
2024/05/23
[jira] [Commented] (FLINK-35353) Translate "Profiler" page into Chinese
Juan Zifeng (Jira)
2024/05/23
Re: [PR] [FLINK-33892][runtime] Support Job Recovery from JobMaster Failures for Batch Jobs. [flink]
via GitHub
2024/05/23
Re: [PR] [FLINK-34108][table] Add built-in URL_ENCODE and URL_DECODE function. [flink]
via GitHub
2024/05/23
Re: [PR] [FLINK-33892][runtime] Support Job Recovery from JobMaster Failures for Batch Jobs. [flink]
via GitHub
2024/05/23
[jira] [Closed] (FLINK-35359) General Improvement to Configuration for Flink 2.0
Xintong Song (Jira)
2024/05/23
Re: [PR] [FLINK-34108][table] Add built-in URL_ENCODE and URL_DECODE function. [flink]
via GitHub
2024/05/23
Re: [PR] [FLINK-35359][config] General Improvement to Configuration for Flink 2.0 [flink]
via GitHub
2024/05/23
[jira] [Updated] (FLINK-35359) General Improvement to Configuration for Flink 2.0
Xintong Song (Jira)
2024/05/23
[jira] [Created] (FLINK-35430) ZoneId is not passed to DebeziumJsonSerializationSchema
LvYanquan (Jira)
2024/05/23
Re: [PR] [FLINK-31223][sqlgateway] Introduce getFlinkConfigurationOptions to g… [flink]
via GitHub
2024/05/23
[jira] [Updated] (FLINK-35429) We don't need introduce getFlinkConfigurationOptions for SqlGatewayRestEndpointFactory#Context
Weijie Guo (Jira)
2024/05/23
[jira] [Assigned] (FLINK-35429) We don't need introduce getFlinkConfigurationOptions for SqlGatewayRestEndpointFactory#Context
Weijie Guo (Jira)
2024/05/23
Re: [PR] [hotfix][sqlgateway] Do not introduce new method in SqlGatewayEndpointFactory#Context [flink]
via GitHub
2024/05/23
[jira] [Updated] (FLINK-35429) We don't need introduce getFlinkConfigurationOptions for SqlGatewayRestEndpointFactory#Context
Weijie Guo (Jira)
2024/05/23
Re: [PR] [FLINK-35216] Support for RETURNING clause of JSON_QUERY [flink]
via GitHub
2024/05/23
[jira] [Updated] (FLINK-35429) We don't need introduce getFlinkConfigurationOptions for SqlGatewayRestEndpointFactory#Context
Weijie Guo (Jira)
Earlier messages
Later messages