issues
Thread
Date
Earlier messages
Later messages
Messages by Date
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)
2024/05/23
[jira] [Updated] (FLINK-35429) We don't need introduce getFlinkConfigurationOptions for SqlGatewayRestEndpointFactory#Context
Weijie Guo (Jira)
2024/05/23
[jira] [Created] (FLINK-35429) We don't need introduce getFlinkConfigurationOptions for SqlGatewayRestEndpointFactory#Context
Weijie Guo (Jira)
2024/05/23
[jira] [Updated] (FLINK-35359) General Improvement to Configuration for Flink 2.0
Xuannan Su (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-35359) General Improvement to Configuration for Flink 2.0
Xuannan Su (Jira)
2024/05/23
[jira] [Updated] (FLINK-35359) General Improvement to Configuration for Flink 2.0
Xuannan Su (Jira)
2024/05/23
Re: [PR] [FLINK-35421]fixed schema operator blocking when restart [flink-cdc]
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-34108][table] Add built-in URL_ENCODE and URL_DECODE function. [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] [Commented] (FLINK-35428) WindowJoinITCase#testInnerJoin failed on AZP as NPE
Ryan Skraba (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-34108][table] Add built-in URL_ENCODE and URL_DECODE function. [flink]
via GitHub
2024/05/23
[jira] [Commented] (FLINK-35115) Kinesis connector writes wrong Kinesis sequence number at stop with savepoint
Vadim Vararu (Jira)
2024/05/23
[jira] [Comment Edited] (FLINK-31724) SqlClientITCase.testMatchRecognize fails with "bash -c rm -rf /opt/flink/checkpoint/*" returned non-zero exit code 1
Weijie Guo (Jira)
2024/05/23
[jira] [Updated] (FLINK-31724) SqlClientITCase.testMatchRecognize fails with "bash -c rm -rf /opt/flink/checkpoint/*" returned non-zero exit code 1
Weijie Guo (Jira)
2024/05/23
[jira] [Commented] (FLINK-35342) MaterializedTableStatementITCase test can check for wrong status
Weijie Guo (Jira)
2024/05/23
[jira] [Commented] (FLINK-34273) git fetch fails
Weijie Guo (Jira)
2024/05/23
[jira] [Updated] (FLINK-35428) WindowJoinITCase#testInnerJoin failed on AZP as NPE
Weijie Guo (Jira)
2024/05/23
[jira] [Created] (FLINK-35428) WindowJoinITCase#testInnerJoin failed on AZP as NPE
Weijie Guo (Jira)
2024/05/23
[jira] [Updated] (FLINK-35420) WordCountMapredITCase fails to compile in IntelliJ
Piotr Nowojski (Jira)
2024/05/23
[jira] [Assigned] (FLINK-35420) WordCountMapredITCase fails to compile in IntelliJ
Piotr Nowojski (Jira)
2024/05/23
[jira] [Closed] (FLINK-35420) WordCountMapredITCase fails to compile in IntelliJ
Piotr Nowojski (Jira)
2024/05/23
Re: [PR] [FLINK-35420][hadoop-compatibility][test] Workaround some strange scala issue [flink]
via GitHub
2024/05/23
[jira] [Resolved] (FLINK-35410) Avoid sync waiting in coordinator thread of ForSt executor
Zakelly Lan (Jira)
2024/05/23
[jira] [Commented] (FLINK-35410) Avoid sync waiting in coordinator thread of ForSt executor
Zakelly Lan (Jira)
2024/05/23
[jira] [Updated] (FLINK-35410) Avoid sync waiting in coordinator thread of ForSt executor
ASF GitHub Bot (Jira)
2024/05/23
Re: [PR] [FLINK-35410][state] Avoid sync waiting in coordinator thread of ForSt executor [flink]
via GitHub
2024/05/22
[jira] [Commented] (FLINK-35411) Optimize wait logic in draining of async state requests
liuzhuo (Jira)
2024/05/22
Re: [PR] [FLINK-35400][checkpoint] Release FileMergingSnapshotManager if all tasks finished [flink]
via GitHub
2024/05/22
[jira] [Assigned] (FLINK-35359) General Improvement to Configuration for Flink 2.0
Xintong Song (Jira)
2024/05/22
Re: [PR] [FLINK-35240][Connectors][format]Disable FLUSH_AFTER_WRITE_VALUE to avoid flush per record for csv format [flink]
via GitHub
2024/05/22
Re: [PR] [FLINK-35240][Connectors][format]Disable FLUSH_AFTER_WRITE_VALUE to avoid flush per record for csv format [flink]
via GitHub
2024/05/22
Re: [PR] [FLINK-33892][runtime] Support Job Recovery from JobMaster Failures for Batch Jobs. [flink]
via GitHub
2024/05/22
Re: [PR] [FLINK-33892][runtime] Support Job Recovery from JobMaster Failures for Batch Jobs. [flink]
via GitHub
2024/05/22
Re: [PR] [FLINK-35359][config] General Improvement to Configuration for Flink 2.0 [flink]
via GitHub
2024/05/22
Re: [PR] [FLINK-34123][core][type] Introduce built-in serialization support for map and lists [flink]
via GitHub
2024/05/22
Re: [PR] [FLINK-35049][state] Implement Map Async State API for ForStStateBackend [flink]
via GitHub
2024/05/22
Re: [PR] [FLINK-34123][core][type] Introduce built-in serialization support for map and lists [flink]
via GitHub
2024/05/22
Re: [PR] [FLINK-34123][core][type] Introduce built-in serialization support for map and lists [flink]
via GitHub
2024/05/22
Re: [PR] [FLINK-35240][Connectors][format]Disable FLUSH_AFTER_WRITE_VALUE to avoid flush per record for csv format [flink]
via GitHub
2024/05/22
Re: [PR] [FLINK-35305]Amazon SQS Sink Connector [flink-connector-aws]
via GitHub
2024/05/22
Re: [PR] [FLINK-35305]Amazon SQS Sink Connector [flink-connector-aws]
via GitHub
2024/05/22
Re: [PR] [FLINK-35305]Amazon SQS Sink Connector [flink-connector-aws]
via GitHub
2024/05/22
Re: [PR] [FLINK-35305]Amazon SQS Sink Connector [flink-connector-aws]
via GitHub
2024/05/22
[jira] [Assigned] (FLINK-35412) Batch execution of async state request callback
Zakelly Lan (Jira)
2024/05/22
[jira] [Assigned] (FLINK-35411) Optimize wait logic in draining of async state requests
Zakelly Lan (Jira)
2024/05/22
[jira] [Commented] (FLINK-35411) Optimize wait logic in draining of async state requests
Zakelly Lan (Jira)
2024/05/22
[jira] [Assigned] (FLINK-35411) Optimize wait logic in draining of async state requests
Zakelly Lan (Jira)
2024/05/22
Re: [PR] [FLINK-35355][State] Internal async aggregating state and corresponding state descriptor [flink]
via GitHub
2024/05/22
Re: [PR] [FLINK-34123][core][type] Introduce built-in serialization support for map and lists [flink]
via GitHub
2024/05/22
[jira] [Assigned] (FLINK-34914) FLIP-436: Introduce Catalog-related Syntax
Weijie Guo (Jira)
2024/05/22
Re: [PR] [FLINK-35047][state] Shutdown StateExecutors when ForStKeyedStateBackend is closed [flink]
via GitHub
2024/05/22
Re: [PR] [FLINK-35305]Amazon SQS Sink Connector [flink-connector-aws]
via GitHub
2024/05/22
Re: [PR] [FLINK-35305]Amazon SQS Sink Connector [flink-connector-aws]
via GitHub
2024/05/22
[jira] [Assigned] (FLINK-34123) Introduce built-in serialization support for Map and List
Weijie Guo (Jira)
2024/05/22
Re: [PR] [FLINK-35305]Amazon SQS Sink Connector [flink-connector-aws]
via GitHub
2024/05/22
Re: [PR] [FLINK-35305]Amazon SQS Sink Connector [flink-connector-aws]
via GitHub
2024/05/22
Re: [PR] [FLINK-34123][core][type] Introduce built-in serialization support for map and lists [flink]
via GitHub
2024/05/22
Re: [PR] [FLINK-35305]Amazon SQS Sink Connector [flink-connector-aws]
via GitHub
2024/05/22
[jira] [Created] (FLINK-35427) Support fail-on-unknown-field config in json format
huhuan (Jira)
2024/05/22
Re: [PR] [FLINK-35240][Connectors][format]Disable FLUSH_AFTER_WRITE_VALUE to avoid flush per record for csv format [flink]
via GitHub
2024/05/22
Re: [PR] [FLINK-35426][table-planner] Change the distribution of DynamicFilteringDataCollector to Broadcast [flink]
via GitHub
2024/05/22
[jira] [Updated] (FLINK-35426) Change the distribution of DynamicFilteringDataCollector to Broadcast
ASF GitHub Bot (Jira)
2024/05/22
[PR] [FLINK-35426][table-planner] Change the distribution of DynamicFilteringDataCollector to Broadcast [flink]
via GitHub
2024/05/22
Re: [PR] [FLINK-35305]Amazon SQS Sink Connector [flink-connector-aws]
via GitHub
2024/05/22
[jira] [Updated] (FLINK-35421) Schema Operator blocking forever when Akka Rpc timeout
hk__lrzy (Jira)
2024/05/22
[jira] [Commented] (FLINK-35426) Change the distribution of DynamicFilteringDataCollector to Broadcast
Zhu Zhu (Jira)
2024/05/22
[jira] [Assigned] (FLINK-35426) Change the distribution of DynamicFilteringDataCollector to Broadcast
Zhu Zhu (Jira)
2024/05/22
Re: [PR] [FLINK-31664] Implement ARRAY_INTERSECT function [flink]
via GitHub
2024/05/22
Re: [PR] [FLINK-31664] Implement ARRAY_INTERSECT function [flink]
via GitHub
2024/05/22
[jira] [Commented] (FLINK-35426) Change the distribution of DynamicFilteringDataCollector to Broadcast
xingbe (Jira)
2024/05/22
[jira] [Created] (FLINK-35426) Change the distribution of DynamicFilteringDataCollector to Broadcast
xingbe (Jira)
2024/05/22
Re: [PR] [FLINK-35351][checkpoint] Fix fail during restore from unaligned chec… [flink]
via GitHub
2024/05/22
Re: [PR] [FLINK-35305]Amazon SQS Sink Connector [flink-connector-aws]
via GitHub
2024/05/22
Re: [PR] [FLINK-35355][State] Internal async aggregating state and corresponding state descriptor [flink]
via GitHub
2024/05/22
[jira] [Created] (FLINK-35425) Support convert Freshness to cron expression for full refresh mode
dalongliu (Jira)
2024/05/22
[jira] [Commented] (FLINK-35421) Schema Operator blocking forever when Akka Rpc timeout
hk__lrzy (Jira)
2024/05/22
[jira] [Updated] (FLINK-35421) Schema Operator blocking forever when Akka Rpc timeout
ASF GitHub Bot (Jira)
2024/05/22
[PR] [FLINK-35421]fixed schema operator blocking when restart [flink-cdc]
via GitHub
2024/05/22
Re: [PR] [FLINK-34108][table] Add built-in URL_ENCODE and URL_DECODE function. [flink]
via GitHub
2024/05/22
[jira] [Comment Edited] (FLINK-31223) sql-client.sh fails to start with ssl enabled
Weijie Guo (Jira)
2024/05/22
[jira] [Updated] (FLINK-31223) sql-client.sh fails to start with ssl enabled
Weijie Guo (Jira)
2024/05/22
Re: [PR] [FLINK-31223][sqlgateway] Introduce getFlinkConfigurationOptions to g… [flink]
via GitHub
2024/05/22
Re: [PR] [FLINK-31223][sqlgateway] Introduce getFlinkConfigurationOptions to g… [flink]
via GitHub
2024/05/22
Re: [PR] [FLINK-31223][sqlgateway] Introduce getFlinkConfigurationOptions to [flink]
via GitHub
2024/05/22
Re: [PR] [FLINK-35129][cdc][postgres] Add checkpoint cycle option for commit offsets [flink-cdc]
via GitHub
2024/05/22
Re: [PR] [hotfix][rest] Add getter methods for SubtasksTimesInfo to get all values easily [flink]
via GitHub
2024/05/22
Re: [PR] [hotfix][rest] Add getter methods for SubtasksTimesInfo to get all values easily [flink]
via GitHub
2024/05/22
Re: [PR] [hotfix][rest] Add getter methods for SubtasksTimesInfo to get all values easily [flink]
via GitHub
2024/05/22
[jira] [Commented] (FLINK-35421) Schema Operator blocking forever when Akka Rpc timeout
LvYanquan (Jira)
2024/05/22
[jira] [Updated] (FLINK-35417) JobManager and TaskManager support merging and run in a single process
Xintong Song (Jira)
2024/05/22
[jira] [Updated] (FLINK-35129) Postgres source commits the offset after every multiple checkpoint cycles.
ASF GitHub Bot (Jira)
2024/05/22
[PR] [FLINK-35129][cdc][postgres] Add checkpoint cycle option for commit offsets [flink-cdc]
via GitHub
2024/05/22
[jira] [Updated] (FLINK-35424) Elasticsearch connector 8 supports SSL context
Mingliang Liu (Jira)
2024/05/22
[jira] [Updated] (FLINK-35424) Elasticsearch connector 8 supports SSL context
Mingliang Liu (Jira)
2024/05/22
[jira] [Updated] (FLINK-35424) Elasticsearch connector 8 supports SSL context
Mingliang Liu (Jira)
2024/05/22
[jira] [Created] (FLINK-35424) Elasticsearch connector 8 supports SSL context
Mingliang Liu (Jira)
2024/05/22
Re: [PR] [FLINK-34108][table] Add built-in URL_ENCODE and URL_DECODE function. [flink]
via GitHub
2024/05/22
Re: [PR] remove duplicated word [flink]
via GitHub
2024/05/22
[PR] remove duplicated word [flink]
via GitHub
2024/05/22
Re: [PR] [FLINK-35423][table] ARRAY_EXCEPT should follow set semantics [flink]
via GitHub
2024/05/22
[jira] [Assigned] (FLINK-35423) ARRAY_EXCEPT should support set semantics
Sergey Nuyanzin (Jira)
2024/05/22
[jira] [Updated] (FLINK-35423) ARRAY_EXCEPT should support set semantics
ASF GitHub Bot (Jira)
2024/05/22
[PR] [FLINK-35423][table] ARRAY_EXCEPT should follow set semantics [flink]
via GitHub
2024/05/22
Re: [PR] [FLINK-33759] [flink-parquet] Add support for nested array with row/map/array type [flink]
via GitHub
2024/05/22
Re: [PR] [FLINK-33759] [flink-parquet] Add support for nested array with row/map/array type [flink]
via GitHub
2024/05/22
Re: [PR] [FLINK-33759] [flink-parquet] Add support for nested array with row/map/array type [flink]
via GitHub
2024/05/22
Re: [PR] [FLINK-33759] [flink-parquet] Add support for nested array with row/map/array type [flink]
via GitHub
2024/05/22
Re: [PR] [FLINK-33759] [flink-parquet] Add support for nested array with row/map/array type [flink]
via GitHub
2024/05/22
Re: [PR] [FLINK-33759] [flink-parquet] Add support for nested array with row/map/array type [flink]
via GitHub
2024/05/22
Re: [PR] chore: Update pekko version [flink]
via GitHub
2024/05/22
Re: [PR] [FLINK-35240][Connectors][format]Disable FLUSH_AFTER_WRITE_VALUE to avoid flush per record for csv format [flink]
via GitHub
2024/05/22
Re: [PR] [FLINK-20400][e2e] Migrate test_streaming_sql.sh [flink]
via GitHub
2024/05/22
[jira] [Commented] (FLINK-35417) JobManager and TaskManager support merging and run in a single process
Jing Ge (Jira)
2024/05/22
Re: [PR] [FLINK-35216] Support for RETURNING clause of JSON_QUERY [flink]
via GitHub
2024/05/22
[jira] [Assigned] (FLINK-35417) JobManager and TaskManager support merging and run in a single process
Jing Ge (Jira)
2024/05/22
Re: [PR] [FLINK-35216] Support for RETURNING clause of JSON_QUERY [flink]
via GitHub
2024/05/22
Re: [PR] [FLINK-33212][runtime] add job status changed listener for lineage [flink]
via GitHub
2024/05/22
Re: [PR] [FLINK-31223][sqlgateway] Introduce getFlinkConfigurationOptions to [flink]
via GitHub
2024/05/22
Re: [PR] [FLINK-35216] Support for RETURNING clause of JSON_QUERY [flink]
via GitHub
2024/05/22
[jira] [Commented] (FLINK-35417) JobManager and TaskManager support merging and run in a single process
melin (Jira)
2024/05/22
[jira] [Commented] (FLINK-34935) TIMESTAMP_LTZ type Unsupported when using JdbcCatalog to read from Postgres
Pietro (Jira)
Earlier messages
Later messages