issues  

Messages by Date

• 2025/03/11 Re: [PR] [FLINK-37419] Align the map value serialization in ForSt sync and async states [flink] via GitHub
• 2025/03/11 [jira] [Updated] (FLINK-37444) Migrate ArrowSourceFunction to SourceV2 Poorvank Bhatia (Jira)
• 2025/03/11 Re: [PR] [FLINK-37440] Fix the bug that parallelism.default do not always adopts 1 as the default value. [flink] via GitHub
• 2025/03/11 Re: [PR] [FLINK-36684][cdc-connector][mysql] Support read changelog as append only mode [flink-cdc] via GitHub
• 2025/03/11 Re: [PR] [FLINK-36684][cdc-connector][mysql] Support read changelog as append only mode [flink-cdc] via GitHub
• 2025/03/11 [jira] [Commented] (FLINK-37424) Using JDK11 for the binary convenience release Weijie Guo (Jira)
• 2025/03/11 [jira] [Commented] (FLINK-37445) Migrate InputFormatSourceFunction to the Source V2 API Martijn Visser (Jira)
• 2025/03/11 Re: [PR] [FLINK-37431]We should use guava Lists instead of curator shade Lists… [flink] via GitHub
• 2025/03/11 Re: [PR] [FLINK-37440] Fix the bug that parallelism.default do not always adopts 1 as the default value. [flink] via GitHub
• 2025/03/11 Re: [PR] [FLINK-37440] Fix the bug that parallelism.default do not always adopts 1 as the default value. [flink] via GitHub
• 2025/03/11 Re: [PR] [FLINK-37440] Fix the bug that parallelism.default do not always adopts 1 as the default value. [flink] via GitHub
• 2025/03/11 Re: [PR] [FLINK-28897] [TABLE-SQL] Fail to use udf in added jar when enabling checkpoint [flink] via GitHub
• 2025/03/11 Re: [PR] [FLINK-37332] Support any column as chunk key column (postgres, orcale, db2, sqlserver) #3922 [flink-cdc] via GitHub
• 2025/03/11 [jira] [Commented] (FLINK-37425) Sanity check before ForSt cache created Zakelly Lan (Jira)
• 2025/03/11 Re: [PR] [FLINK-37429][transform] Map each column name to a new name in generated expression [flink-cdc] via GitHub
• 2025/03/11 Re: [PR] [FLINK-37460][state] Make state processor API checkpoint ID configurable [flink] via GitHub
• 2025/03/11 Re: [PR] [FLINK-37460][state] Make state processor API checkpoint ID configurable [flink] via GitHub
• 2025/03/11 Re: [PR] [FLINK-37460][state] Make state processor API checkpoint ID configurable [flink] via GitHub
• 2025/03/11 [jira] [Created] (FLINK-37448) status.taskManager.replicas to show actual TaskManager count Robert Metzger (Jira)
• 2025/03/11 Re: [PR] [FLINK-37381] [doc] Fix typo in Join document [flink] via GitHub
• 2025/03/11 Re: [PR] [FLINK-37383][flink-examples]Correct throttling logic on ThrottledIterator [flink] via GitHub
• 2025/03/11 [jira] [Created] (FLINK-37444) Migrate ArrowSourceFunction to SourceV2 Poorvank Bhatia (Jira)
• 2025/03/11 Re: [PR] [FLINK-37265][docs] Document of python elasticsearch connector exeample has a little mistake [flink-connector-elasticsearch] via GitHub
• 2025/03/11 [jira] [Assigned] (FLINK-25986) Add FLIP-190 new API methods to python Mika Naylor (Jira)
• 2025/03/11 Re: [PR] [FLINK-37460][state] Make state processor API checkpoint ID configurable [flink] via GitHub
• 2025/03/11 [jira] [Created] (FLINK-37453) Migration Tests / data_stream_migration_test (8, 1.20.1) failed Leonard Xu (Jira)
• 2025/03/11 [jira] [Commented] (FLINK-37443) Add returns() method to DataStream V2 API for specifying output types with lambda expressions Nil Madhab (Jira)
• 2025/03/11 Re: [PR] [FLINK-33525] Move ImpulseSource to new Source API [flink-kubernetes-operator] via GitHub
• 2025/03/11 [jira] [Updated] (FLINK-25986) Add FLIP-190 new API methods to python ASF GitHub Bot (Jira)
• 2025/03/11 [PR] [hotfix][state/forst] Make incremental checkpoint configurable [flink] via GitHub
• 2025/03/11 [jira] [Updated] (FLINK-37431) We should use guava Lists instead of curator shade Lists to avoid unnecessary error zlzhang0122 (Jira)
• 2025/03/11 [PR] [FLINK-36652] Upgrade Apache ORC Version to 1.9.4 [flink] via GitHub
• 2025/03/11 Re: [PR] [FLINK-37367][state/forst] Make ForSt inherit uploaded SST files after restorations. [flink] via GitHub
• 2025/03/11 Re: [PR] [FLINK-36488] [TABLE SQL/API] Remove deprecated methods StreamTableEnvironment.toAppendStream from flink-table-api-java-bridge module [flink] via GitHub
• 2025/03/11 Re: [PR] [FLINK-37429][transform] Map each column name to a new name in generated expression [flink-cdc] via GitHub
• 2025/03/11 Re: [PR] [FLINK-37298] Added Pluggable Components for BatchStrategy & BufferWrapper in AsyncSinkWriter. [flink] via GitHub
• 2025/03/11 [jira] [Assigned] (FLINK-37444) Migrate ArrowSourceFunction to SourceV2 Alexander Fedulov (Jira)
• 2025/03/11 [jira] [Comment Edited] (FLINK-28897) Fail to use udf in added jar when enabling checkpoint david radley (Jira)
• 2025/03/11 Re: [PR] [FLINK-36652] Upgrade Apache ORC Version to 1.9.4 [flink] via GitHub
• 2025/03/11 [jira] [Commented] (FLINK-37445) Migrate InputFormatSourceFunction to the Source V2 API Gabor Somogyi (Jira)
• 2025/03/11 Re: [PR] [FLINK-37419] Align the map value serialization in ForSt sync and async states [flink] via GitHub
• 2025/03/11 Re: [PR] [FLINK-37357][table-planner]Migrating SqlNode conversion logic from SqlNodeToOperationConversion to SqlNodeConverters [flink] via GitHub
• 2025/03/11 Re: [PR] [FLINK-37440] Fix the bug that parallelism.default do not always adopts 1 as the default value. [flink] via GitHub
• 2025/03/11 Re: [PR] [FLINK-37429][transform] Map each column name to a new name in generated expression [flink-cdc] via GitHub
• 2025/03/11 Re: [PR] [FLINK-37352] Write full changelog to PaimonSink. [flink-cdc] via GitHub
• 2025/03/11 Re: [PR] corrected released version in the release doc. [flink-web] via GitHub
• 2025/03/11 [jira] [Created] (FLINK-37443) Add returns() method to DataStream V2 API for specifying output types with lambda expressions Nil Madhab (Jira)
• 2025/03/11 [jira] [Closed] (FLINK-37439) Missing file creation with overwrite semantic in ForSt wrapped file system Zakelly Lan (Jira)
• 2025/03/11 Re: [PR] Draft PR for plugin based approach for evaluation hook for scaling metric evaluation [flink-kubernetes-operator] via GitHub
• 2025/03/11 Re: [PR] Add Flink 2.0.0 release [flink-web] via GitHub
• 2025/03/11 Re: [PR] [FLINK-33525] Move ImpulseSource to new Source API [flink-kubernetes-operator] via GitHub
• 2025/03/11 [PR] Draft PR for plugin based approach for custom evaluator for scaling metric evaluation [flink-kubernetes-operator] via GitHub
• 2025/03/11 Re: [PR] [FLINK-33525] Move ImpulseSource to new Source API [flink-kubernetes-operator] via GitHub
• 2025/03/11 [jira] [Updated] (FLINK-37443) Add returns() method to DataStream V2 API for specifying output types with lambda expressions Nil Madhab (Jira)
• 2025/03/11 [jira] [Commented] (FLINK-37443) Add returns() method to DataStream V2 API for specifying output types with lambda expressions Nil Madhab (Jira)
• 2025/03/11 Re: [PR] [FLINK-37446][table-api-java] Support named arguments in Table API [flink] via GitHub
• 2025/03/11 [jira] [Assigned] (FLINK-37460) Using State Processor API and Kafka Sink with Exactly once delivery leads to org.apache.kafka.common.errors.InvalidPidMappingException Gabor Somogyi (Jira)
• 2025/03/11 Re: [PR] [FLINK-37460][state] Make state processor API checkpoint ID configurable [flink] via GitHub
• 2025/03/11 Re: [PR] [FLINK-37298] Added Pluggable Components for BatchStrategy & BufferWrapper in AsyncSinkWriter. [flink] via GitHub
• 2025/03/11 Re: [PR] [FLINK-37460][state] Make state processor API checkpoint ID configurable [flink] via GitHub
• 2025/03/11 [jira] [Updated] (FLINK-37443) Add returns() method to DataStream V2 API for specifying output types with lambda expressions ASF GitHub Bot (Jira)
• 2025/03/11 [jira] [Commented] (FLINK-37460) Using State Processor API and Kafka Sink with Exactly once delivery leads to org.apache.kafka.common.errors.InvalidPidMappingException Gabor Somogyi (Jira)
• 2025/03/11 Re: [PR] FLINK-37443 Trying out using lambda function in dataStreamV2 tests [flink] via GitHub
• 2025/03/11 [jira] [Commented] (FLINK-37460) Using State Processor API and Kafka Sink with Exactly once delivery leads to org.apache.kafka.common.errors.InvalidPidMappingException Gabor Somogyi (Jira)
• 2025/03/11 Re: [PR] [FLINK-37446][table-api-java] Support named arguments in Table API [flink] via GitHub
• 2025/03/11 [jira] [Updated] (FLINK-37460) Using State Processor API and Kafka Sink with Exactly once delivery leads to org.apache.kafka.common.errors.InvalidPidMappingException ASF GitHub Bot (Jira)
• 2025/03/11 [PR] [FLINK-37460][state] Make state processor API checkpoint ID configurable [flink] via GitHub
• 2025/03/11 Re: [PR] [FLINK-37446][table-api-java] Support named arguments in Table API [flink] via GitHub
• 2025/03/11 Re: [PR] [FLINK-37446][table-api-java] Support named arguments in Table API [flink] via GitHub
• 2025/03/11 Re: [PR] Adding MongoDB Connector v2.0.0 [flink-web] via GitHub
• 2025/03/11 Re: [PR] [FLINK-37446][table-api-java] Support named arguments in Table API [flink] via GitHub
• 2025/03/11 [jira] [Commented] (FLINK-37460) Using State Processor API and Kafka Sink with Exactly once delivery leads to org.apache.kafka.common.errors.InvalidPidMappingException Grzegorz Liter (Jira)
• 2025/03/11 Re: [PR] [FLINK-37446][table-api-java] Support named arguments in Table API [flink] via GitHub
• 2025/03/11 [PR] Trying out using lambda function in dataStreamV2 tests [flink] via GitHub
• 2025/03/11 [jira] [Updated] (FLINK-37459) Document correction - 1.9.0 Shalini M (Jira)
• 2025/03/11 Re: [PR] [FLINK-37446][table-api-java] Support named arguments in Table API [flink] via GitHub
• 2025/03/11 [jira] [Commented] (FLINK-37460) Using State Processor API and Kafka Sink with Exactly once delivery leads to org.apache.kafka.common.errors.InvalidPidMappingException Gabor Somogyi (Jira)
• 2025/03/11 [jira] [Updated] (FLINK-37452) Add support for writing to Paimon Append Only table. ASF GitHub Bot (Jira)
• 2025/03/11 [PR] corrected released version in the release doc. [flink-web] via GitHub
• 2025/03/11 Re: [PR] [FLINK-33388][runtime] Support tasks balancing at TM level for Default Scheduler [flink] via GitHub
• 2025/03/11 Re: [PR] [FLINK-25986][python] Add remaining FLIP-190 API methods to Python Table API [flink] via GitHub
• 2025/03/11 Re: [PR] [FLINK-25986][python] Add remaining FLIP-190 API methods to Python Table API [flink] via GitHub
• 2025/03/11 [jira] [Comment Edited] (FLINK-37460) Using State Processor API and Kafka Sink with Exactly once delivery leads to org.apache.kafka.common.errors.InvalidPidMappingException Grzegorz Liter (Jira)
• 2025/03/11 [jira] [Commented] (FLINK-37460) Using State Processor API and Kafka Sink with Exactly once delivery leads to org.apache.kafka.common.errors.InvalidPidMappingException Grzegorz Liter (Jira)
• 2025/03/11 Re: [PR] corrected released version in the release doc. [flink-web] via GitHub
• 2025/03/11 [jira] [Commented] (FLINK-37460) Using State Processor API and Kafka Sink with Exactly once delivery leads to org.apache.kafka.common.errors.InvalidPidMappingException Gabor Somogyi (Jira)
• 2025/03/11 Re: [PR] [FLINK-37365][pyflink] Add API stability decorators for PyFlink APIs [flink] via GitHub
• 2025/03/11 [jira] [Updated] (FLINK-37451) Document correction - 1.10.0 and 1.9.0 Shalini M (Jira)
• 2025/03/11 [jira] [Comment Edited] (FLINK-37460) Using State Processor API and Kafka Sink with Exactly once delivery leads to org.apache.kafka.common.errors.InvalidPidMappingException Martijn Visser (Jira)
• 2025/03/11 [jira] [Commented] (FLINK-37460) Using State Processor API and Kafka Sink with Exactly once delivery leads to org.apache.kafka.common.errors.InvalidPidMappingException Martijn Visser (Jira)
• 2025/03/11 [jira] [Updated] (FLINK-37460) Using State Processor API and Kafka Sink with Exactly once delivery leads to org.apache.kafka.common.errors.InvalidPidMappingException Martijn Visser (Jira)
• 2025/03/11 [jira] [Updated] (FLINK-37460) Using State Processor API and Kafka Sink with Exactly once delivery leads to org.apache.kafka.common.errors.InvalidPidMappingException Grzegorz Liter (Jira)
• 2025/03/11 [jira] [Updated] (FLINK-37460) Using State Processor API and Kafka Sink with Exactly once delivery leads to org.apache.kafka.common.errors.InvalidPidMappingException Grzegorz Liter (Jira)
• 2025/03/11 [jira] [Created] (FLINK-37460) Using State Processor API and Kafka Sink with Exactly once delivery leads to org.apache.kafka.common.errors.InvalidPidMappingException Grzegorz Liter (Jira)
• 2025/03/11 [jira] [Updated] (FLINK-37459) Document correction - 1.9.0 Shalini M (Jira)
• 2025/03/11 Re: [PR] [FLINK-25986][python] Add remaining FLIP-190 API methods to Python Table API [flink] via GitHub
• 2025/03/11 [jira] [Updated] (FLINK-37451) Document correction - 1.10.0 Shalini M (Jira)
• 2025/03/11 Re: [PR] [FLINK-37458][datastream] Forbid enableAsyncState() for synchronous operators [flink] via GitHub
• 2025/03/11 [jira] [Updated] (FLINK-37445) Migrate InputFormatSourceFunction to the Source V2 API Poorvank Bhatia (Jira)
• 2025/03/11 Re: [PR] corrected released version in the release doc. [flink-web] via GitHub
• 2025/03/11 [jira] [Updated] (FLINK-37459) Document correction - 1.9.0 Shalini M (Jira)
• 2025/03/11 [jira] [Updated] (FLINK-37458) Forbid enableAsyncState() for synchronous operators ASF GitHub Bot (Jira)
• 2025/03/11 Re: [PR] [FLINK-37446][table-api-java] Support named arguments in Table API [flink] via GitHub
• 2025/03/11 [PR] [FLINK-37458][datastream] Forbid enableAsyncState() for synchronous operators [flink] via GitHub
• 2025/03/11 [jira] [Closed] (FLINK-37459) Document correction - 1.9.0 Shalini M (Jira)
• 2025/03/11 [jira] [Updated] (FLINK-37451) Document correction - 1.10.0 and 1.9.0 Shalini M (Jira)
• 2025/03/11 [jira] [Updated] (FLINK-37451) Document correction - 1.10.0 and 1.9.0 Shalini M (Jira)
• 2025/03/11 [jira] [Updated] (FLINK-37459) Document correction - 1.9.0 Shalini M (Jira)
• 2025/03/11 [jira] [Updated] (FLINK-37459) Document correction - 1.9.0 Shalini M (Jira)
• 2025/03/11 [jira] [Updated] (FLINK-37451) Document correction - 1.10.0 and 1.9.0 Shalini M (Jira)
• 2025/03/11 [jira] [Updated] (FLINK-37451) Document correction - 1.10.0 Shalini M (Jira)
• 2025/03/11 [jira] [Updated] (FLINK-37451) Document correction - 1.10.0 Shalini M (Jira)
• 2025/03/11 [jira] [Created] (FLINK-37459) Document correction - 1.9.0 Shalini M (Jira)
• 2025/03/11 [jira] [Updated] (FLINK-37459) Document correction - 1.9.0 Shalini M (Jira)
• 2025/03/11 [jira] [Created] (FLINK-37455) Create error Event when job goes into FAILED state Gyula Fora (Jira)
• 2025/03/11 [jira] [Updated] (FLINK-37459) Document correction - 1.9.0 Shalini M (Jira)
• 2025/03/11 [jira] [Updated] (FLINK-37459) Document correction - 1.9.0 Shalini M (Jira)
• 2025/03/11 [PR] corrected released version in the release doc. [flink-web] via GitHub
• 2025/03/11 [jira] [Created] (FLINK-37458) Forbid enableAsyncState() for synchronous operators Yanfei Lei (Jira)
• 2025/03/11 [jira] [Created] (FLINK-37457) Support asArgument in Python Table API Timo Walther (Jira)
• 2025/03/11 Re: [PR] [FLINK-37298] Added Pluggable Components for BatchStrategy & BufferWrapper in AsyncSinkWriter. [flink] via GitHub
• 2025/03/11 Re: [PR] [FLINK-36931][cdc] FlinkCDC YAML supports batch mode [flink-cdc] via GitHub
• 2025/03/11 Re: [PR] [hotfix] Support dameng database [flink-connector-jdbc] via GitHub
• 2025/03/11 [jira] [Updated] (FLINK-37444) Migrate ArrowSourceFunction to SourceV2 Poorvank Bhatia (Jira)
• 2025/03/11 Re: [PR] [FLINK-37440] Fix the bug that parallelism.default do not always adopts 1 as the default value. [flink] via GitHub
• 2025/03/11 Re: [PR] corrected released version in the release doc. [flink-web] via GitHub
• 2025/03/11 Re: [PR] corrected released version in the release doc. [flink-web] via GitHub
• 2025/03/11 [jira] [Created] (FLINK-37456) Stream data for SQL state connector in case of List and Map state Gabor Somogyi (Jira)
• 2025/03/11 [jira] [Updated] (FLINK-37453) Migration Tests / data_stream_migration_test (8, 1.20.1) failed Leonard Xu (Jira)
• 2025/03/11 [jira] [Assigned] (FLINK-37452) Add support for writing to Paimon Append Only table. Leonard Xu (Jira)
• 2025/03/11 [jira] [Created] (FLINK-37454) Unit Tests (mongodb6) / compile_and_test (8, generic) is not stable Leonard Xu (Jira)
• 2025/03/11 Re: [PR] [FLINK-37449][postgres] Fix postgres cdc don't commit lsn when taskManager failover [flink-cdc] via GitHub
• 2025/03/11 [PR] [FLINK-25986][python] Add remaining FLIP-190 API methods to Python Table API [flink] via GitHub
• 2025/03/11 [jira] [Updated] (FLINK-37450) Document correction - 1.11.0 Shalini M (Jira)
• 2025/03/11 [jira] [Updated] (FLINK-37446) Support asArgument in Table API ASF GitHub Bot (Jira)
• 2025/03/11 [jira] [Commented] (FLINK-37450) Document correction Shalini M (Jira)
• 2025/03/11 [jira] [Updated] (FLINK-37451) Document correction - 1.10.0 Shalini M (Jira)
• 2025/03/11 Re: [PR] [FLINK-37446][table-api-java] Support named arguments in Table API [flink] via GitHub
• 2025/03/11 [jira] [Updated] (FLINK-37452) Add support for writing to Paimon Append only table. Yanquan Lv (Jira)
• 2025/03/11 [jira] [Updated] (FLINK-37452) Add support for writing to Paimon Append Only table. Yanquan Lv (Jira)
• 2025/03/11 Re: [PR] [FLINK-37288] Add Google Cloud Spanner dialect and catalog [flink-connector-jdbc] via GitHub
• 2025/03/11 Re: [PR] [FLINK-28897] [TABLE-SQL] Backport fix for fail to use udf in added jar when enabling checkpoint to 1.19.2 [flink] via GitHub
• 2025/03/10 [jira] [Updated] (FLINK-37449) Postgres don't commit lsn when taskmanager failover ASF GitHub Bot (Jira)
• 2025/03/10 Re: [PR] [minor] Correct variables name according to option name. [flink-cdc] via GitHub
• 2025/03/10 Re: [PR] [FLINK-37408] Update all docker-compose references to docker compose [flink] via GitHub
• 2025/03/10 [jira] [Resolved] (FLINK-37326) The transform module reports an error when column is a Java keyword Leonard Xu (Jira)
• 2025/03/10 [jira] [Updated] (FLINK-37450) Document correction Shalini M (Jira)
• 2025/03/10 [jira] [Updated] (FLINK-37450) Document correction - 1.11.0 Shalini M (Jira)
• 2025/03/10 [jira] [Created] (FLINK-37452) Add support for writing to Paimon Append only table. Yanquan Lv (Jira)
• 2025/03/10 [jira] [Updated] (FLINK-37451) Document correction - 1.10.0 Shalini M (Jira)
• 2025/03/10 [jira] [Updated] (FLINK-37451) Document correction - 1.10.0 Shalini M (Jira)
• 2025/03/10 [jira] [Updated] (FLINK-37451) Document correction - 1.10.0 Shalini M (Jira)
• 2025/03/10 [jira] [Updated] (FLINK-37451) Document correction - 1.10.0 Shalini M (Jira)
• 2025/03/10 [PR] [FLINK-37446][table-api-java] Support named arguments in Table API [flink] via GitHub
• 2025/03/10 [jira] [Created] (FLINK-37451) Document correction - 1.10.0 Shalini M (Jira)
• 2025/03/10 [jira] [Updated] (FLINK-37451) Document correction - 1.10.0 Shalini M (Jira)
• 2025/03/10 [jira] [Updated] (FLINK-37451) Document correction - 1.10.0 Shalini M (Jira)
• 2025/03/10 [jira] [Updated] (FLINK-37450) Document correction Shalini M (Jira)
• 2025/03/10 [jira] [Updated] (FLINK-37450) Document correction Shalini M (Jira)
• 2025/03/10 [jira] [Updated] (FLINK-37450) Document correction Shalini M (Jira)
• 2025/03/10 [jira] [Created] (FLINK-37450) Document correction Shalini M (Jira)
• 2025/03/10 Re: [PR] [FLINK-37429][transform] Map each column name to a new name in generated expression [flink-cdc] via GitHub
• 2025/03/10 Re: [PR] corrected released version in the release doc. [flink-web] via GitHub
• 2025/03/10 [PR] corrected released version in the release doc. [flink-web] via GitHub
• 2025/03/10 [jira] [Assigned] (FLINK-37308) HybridSourceReader doesn't support pauseOrResumeSplits Xingcan Cui (Jira)
• 2025/03/10 [PR] [minor] Correct variables name according to option name. [flink-cdc] via GitHub
• 2025/03/10 [jira] [Commented] (FLINK-37429) Map each original column name to a new name in generated expression to support column name containing '-' Leonard Xu (Jira)
• 2025/03/10 [jira] [Commented] (FLINK-34962) flink-connector-pulsa starts failed due to incorrect use of Pulsar API: LookupService. getPartitionedTopicMetadata Yubiao Feng (Jira)
• 2025/03/10 Re: [PR] [FLINK-37429][transform] Map each column name to a new name in generated expression [flink-cdc] via GitHub
• 2025/03/10 [jira] [Resolved] (FLINK-37429) Map each original column name to a new name in generated expression to support column name containing '-' Leonard Xu (Jira)
• 2025/03/10 Re: [PR] [hotfix] Support dameng database [flink-connector-jdbc] via GitHub
• 2025/03/10 Re: [PR] [FLINK-37329][table-planner] Skip Source Stats Collection When table.optimizer.source.report-statistics-enabled is False [flink] via GitHub
• 2025/03/10 Re: [PR] [hotfix] Support dameng database [flink-connector-jdbc] via GitHub
• 2025/03/10 Re: [PR] [FLINK-37328][FileSystems] Upgrade GCS connector to 2.2.26. [flink] via GitHub
• 2025/03/10 [jira] [Commented] (FLINK-37443) Add returns() method to DataStream V2 API for specifying output types with lambda expressions Weijie Guo (Jira)
• 2025/03/10 [jira] [Assigned] (FLINK-37443) Add returns() method to DataStream V2 API for specifying output types with lambda expressions Weijie Guo (Jira)
• 2025/03/10 Re: [PR] [FLINK-37440] Fix the bug that parallelism.default do not always adopts 1 as the default value. [flink] via GitHub
• 2025/03/10 [jira] [Commented] (FLINK-37445) Migrate InputFormatSourceFunction to the Source V2 API Martijn Visser (Jira)
• 2025/03/10 Re: [PR] [FLINK-33525] Move ImpulseSource to new Source API [flink-kubernetes-operator] via GitHub
• 2025/03/10 [jira] [Commented] (FLINK-37445) Migrate InputFormatSourceFunction to the Source V2 API Alexander Fedulov (Jira)
• 2025/03/10 Re: [PR] Add Flink 2.0.0 release [flink-web] via GitHub
• 2025/03/10 Re: [PR] Add Flink 2.0.0 release [flink-web] via GitHub
• 2025/03/10 [jira] [Assigned] (FLINK-37445) Migrate InputFormatSourceFunction to the Source V2 API Alexander Fedulov (Jira)
• 2025/03/10 [jira] [Comment Edited] (FLINK-37445) Migrate InputFormatSourceFunction to the Source V2 API Alexander Fedulov (Jira)
• 2025/03/10 [jira] [Commented] (FLINK-37445) Migrate InputFormatSourceFunction to the Source V2 API Poorvank Bhatia (Jira)
• 2025/03/10 [jira] [Assigned] (FLINK-37430) Operator hides the actual error on deployment issues Gyula Fora (Jira)
• 2025/03/10 Re: [PR] [FLINK-37329][table-planner] Skip Source Stats Collection When table.optimizer.source.report-statistics-enabled is False [flink] via GitHub
• 2025/03/10 Re: [PR] [FLINK-37329][table-planner] Skip Source Stats Collection When table.optimizer.source.report-statistics-enabled is False [flink] via GitHub
• 2025/03/10 [jira] [Commented] (FLINK-37445) Migrate InputFormatSourceFunction to the Source V2 API Gabor Somogyi (Jira)
• 2025/03/10 Re: [PR] [FLINK-18590][json] Support json array explode to multi messages [flink] via GitHub
• 2025/03/10 Re: [PR] [FLINK-37440] Fix the bug that parallelism.default do not always adopts 1 as the default value. [flink] via GitHub
• 2025/03/10 [jira] [Commented] (FLINK-37445) Migrate InputFormatSourceFunction to the Source V2 API Poorvank Bhatia (Jira)
• 2025/03/10 [jira] [Commented] (FLINK-37445) Migrate InputFormatSourceFunction to the Source V2 API Gabor Somogyi (Jira)
• 2025/03/10 [jira] [Created] (FLINK-37447) [Flink CDC] Supports Variant type in YAML API Leonard Xu (Jira)
• 2025/03/10 [jira] [Created] (FLINK-37446) Support asArgument in Table API Timo Walther (Jira)
• 2025/03/10 [jira] [Commented] (FLINK-37444) Migrate ArrowSourceFunction to SourceV2 Poorvank Bhatia (Jira)
• 2025/03/10 [jira] [Created] (FLINK-37445) Migrate InputFormatSourceFunction to the Source V2 API Poorvank Bhatia (Jira)
• 2025/03/10 [jira] [Commented] (FLINK-28897) Fail to use udf in added jar when enabling checkpoint david radley (Jira)
• 2025/03/10 Re: [PR] [FLINK-36165][source-connector/mysql] Support capturing snapshot data with conditions [flink-cdc] via GitHub
• 2025/03/10 Re: [PR] [FLINK-37410][runtime/metrics] Split level Watermark metrics [flink] via GitHub

• Earlier messages