issues  

Messages by Thread

• [jira] [Updated] (FLINK-36452) Avoid EOFException when reading binlog after a large table has just completed snapshot reading Yanquan Lv (Jira)
• [jira] [Updated] (FLINK-37508) Postgres CDC Jdbc query should use debezium.snapshot.fetch.size rather than debezium.query.fetch.size. Yanquan Lv (Jira)
• [jira] [Assigned] (FLINK-37508) Postgres CDC Jdbc query should use debezium.snapshot.fetch.size rather than debezium.query.fetch.size. Yanquan Lv (Jira)
• [jira] [Updated] (FLINK-37346) [CI] Unit Tests (mysql) / compile_and_test (8, generic) (pull_request)Failing after 60m Yanquan Lv (Jira)
• [jira] [Assigned] (FLINK-37331) Add comprehensive data type coverage tests for new MysqlSource implementation Yanquan Lv (Jira)
• [jira] [Updated] (FLINK-35589) Support MemorySize type in FlinkCDC ConfigOptions Yanquan Lv (Jira)
• [jira] [Updated] (FLINK-37203) Support AltertableCommentEvent and AlterColumnCommentEvent. Yanquan Lv (Jira)
• [jira] [Updated] (FLINK-37200) Add e2e test for ElasticSearch Sink. Yanquan Lv (Jira)
• [jira] [Updated] (FLINK-37199) Update document in quickly start to guide user to add checkpoint configuration Yanquan Lv (Jira)
• [jira] [Assigned] (FLINK-37200) Add e2e test for ElasticSearch Sink. Yanquan Lv (Jira)
• [jira] [Updated] (FLINK-36813) MySQLCDC supports synchronization of specified fields Yanquan Lv (Jira)
• [jira] [Updated] (FLINK-36967) Bump dependency of Paimon Pipeline connector to 0.9.0 Yanquan Lv (Jira)
• [jira] [Updated] (FLINK-36798) Improve data processing speed during the phase from snapshot to incremental phase Yanquan Lv (Jira)
• [jira] [Updated] (FLINK-36581) Allow passing Flink configuration by yaml job file or command line parameters Yanquan Lv (Jira)
• [jira] [Updated] (FLINK-35664) Flink CDC pipeline transform supports mask function Yanquan Lv (Jira)
• [jira] [Updated] (FLINK-36546) Handle batch sources in DataSinkTranslator Yanquan Lv (Jira)
• [jira] [Updated] (FLINK-35718) Cherrypick DBZ-5333 to fix frequently failover by EOFException. Yanquan Lv (Jira)
• [jira] [Updated] (FLINK-35713) Add sink PARALLELISM for flink-cdc Yanquan Lv (Jira)
• [jira] [Updated] (FLINK-35684) Add missing option for DataSource and DataSink Yanquan Lv (Jira)
• [jira] [Assigned] (FLINK-35684) Add missing option for DataSource and DataSink Yanquan Lv (Jira)
• [jira] [Updated] (FLINK-36163) Kafka cdc pipeline source supports protobuf format. Yanquan Lv (Jira)
• [jira] [Updated] (FLINK-35693) Change variable specificOffsetFile, specificOffsetPos and startupTimestampMillis to Offset in StartupOptions Yanquan Lv (Jira)
• [jira] [Updated] (FLINK-35349) Use connection in openJdbcConnection of SqlServerDialect/Db2Dialect/OracleDialect Yanquan Lv (Jira)
• [jira] [Updated] (FLINK-37223) Add the missing content of MySQL CDC to the Chinese document. Yanquan Lv (Jira)
• [jira] [Updated] (FLINK-36263) Include only changed columns in old for canal format in Kakfa Sink Yanquan Lv (Jira)
• [jira] [Updated] (FLINK-34730) Translate pages of Flink CDC docs to Chinese Yanquan Lv (Jira)
• [jira] [Commented] (FLINK-33319) Add AverageTime metric to measure delta change in GC time ouyangwulin (Jira)
• [jira] [Updated] (FLINK-37118) Enhance flink cdc metrics Yanquan Lv (Jira)
• [jira] [Updated] (FLINK-36222) Support the use of LLM models for data processing in the transform module. Yanquan Lv (Jira)
• [jira] [Assigned] (FLINK-35450) Introduce Tikv pipeline DataSource Yanquan Lv (Jira)
• [jira] [Updated] (FLINK-34735) "Developer Guide - Understanding Flink CDC API" Page for Flink CDC Chinese Documentation Yanquan Lv (Jira)
• [jira] [Assigned] (FLINK-35459) Use Incremental Source Framework in Flink CDC TiKV Source Connector Yanquan Lv (Jira)
• [jira] [Updated] (FLINK-35459) Use Incremental Source Framework in Flink CDC TiKV Source Connector Yanquan Lv (Jira)
• [jira] [Assigned] (FLINK-36996) The schema and namespace of MySQL pipeline connector metadata are reversed Yanquan Lv (Jira)
• [jira] [Updated] (FLINK-34747) "legacy-flink-cdc-sources" Page of DB2 for Flink CDC Chinese Documentation. Yanquan Lv (Jira)
• [jira] [Updated] (FLINK-34736) "Deployment - Standalone" Page for Flink CDC Chinese Documentation Yanquan Lv (Jira)
• [jira] [Resolved] (FLINK-37709) Add file descriptor usage in default JVM metrics Leonard Xu (Jira)
• [jira] [Assigned] (FLINK-37731) Update dependency of Paimon to 1.1 and add support for Postpone Bucket Leonard Xu (Jira)
• [PR] [FLINK-37479][postgres] Add support for PARTITIONED TABLE [flink-cdc] via GitHub
  • Re: [PR] [FLINK-37479][postgres] Add support for PARTITIONED TABLE [flink-cdc] via GitHub
  • Re: [PR] [FLINK-37479][postgres] Add support for PARTITIONED TABLE [flink-cdc] via GitHub
  • Re: [PR] [FLINK-37479][postgres] Add support for PARTITIONED TABLE [flink-cdc] via GitHub
  • Re: [PR] [FLINK-37479][postgres] Add support for PARTITIONED TABLE [flink-cdc] via GitHub
  • Re: [PR] [FLINK-37479][postgres] Add support for PARTITIONED TABLE [flink-cdc] via GitHub
  • Re: [PR] [FLINK-37479][postgres] Add support for PARTITIONED TABLE [flink-cdc] via GitHub
  • Re: [PR] [FLINK-37479][postgres] Add support for PARTITIONED TABLE [flink-cdc] via GitHub
  • Re: [PR] [FLINK-37479][postgres] Add support for PARTITIONED TABLE [flink-cdc] via GitHub
  • Re: [PR] [FLINK-37479][postgres] Add support for PARTITIONED TABLE [flink-cdc] via GitHub
  • Re: [PR] [FLINK-37479][postgres] Add support for PARTITIONED TABLE [flink-cdc] via GitHub
  • Re: [PR] [FLINK-37479][postgres] Add support for PARTITIONED TABLE [flink-cdc] via GitHub
  • Re: [PR] [FLINK-37479][postgres] Add support for PARTITIONED TABLE [flink-cdc] via GitHub
  • Re: [PR] [FLINK-37479][postgres] Add support for PARTITIONED TABLE [flink-cdc] via GitHub
  • Re: [PR] [FLINK-37479][postgres] Add support for PARTITIONED TABLE [flink-cdc] via GitHub
  • Re: [PR] [FLINK-37479][postgres] Add support for PARTITIONED TABLE [flink-cdc] via GitHub
  • Re: [PR] [FLINK-37479][postgres] Add support for PARTITIONED TABLE [flink-cdc] via GitHub
  • Re: [PR] [FLINK-37479][postgres] Add support for PARTITIONED TABLE [flink-cdc] via GitHub
  • Re: [PR] [FLINK-37479][postgres] Add support for PARTITIONED TABLE [flink-cdc] via GitHub
  • Re: [PR] [FLINK-37479][postgres] Add support for PARTITIONED TABLE [flink-cdc] via GitHub
• [jira] [Updated] (FLINK-37479) postgres cdc connector support discover PARTITIONED TABLE ASF GitHub Bot (Jira)
• Re: [PR] [FLINK-35595][core] MailboxProcessor#processMailsWhenDefaultActionUnavailable avoids allocating Optional [flink] via GitHub
• [PR] Verify Flaky Behavior in Apache Flink CEP Operator Test Using GitHub ActionsVerify cep flaky test [flink] via GitHub
  • Re: [PR] Verify Flaky Behavior in Apache Flink CEP Operator Test Using GitHub ActionsVerify cep flaky test [flink] via GitHub
• [PR] [hotfix][python] Add pandas type annotations for TableEnvironment.from_pandas and Table.to_pandas [flink] via GitHub
  • Re: [PR] [hotfix][python] Add pandas type annotations for TableEnvironment.from_pandas and Table.to_pandas [flink] via GitHub
  • Re: [PR] [hotfix][python] Add pandas type annotations for TableEnvironment.from_pandas and Table.to_pandas [flink] via GitHub
  • Re: [PR] [hotfix][python] Add pandas type annotations for TableEnvironment.from_pandas and Table.to_pandas [flink] via GitHub
  • Re: [PR] [hotfix][python] Add pandas type annotations for TableEnvironment.from_pandas and Table.to_pandas [flink] via GitHub
• [jira] [Updated] (FLINK-37523) e2e: Test stream python udf sql job fails ASF GitHub Bot (Jira)
• [PR] [FLINK-37523][CI] Fix Python test/e2e tests missing libpython/python headers [flink] via GitHub
  • Re: [PR] [FLINK-37523][CI] Fix Python test/e2e tests missing libpython/python headers [flink] via GitHub
  • Re: [PR] [FLINK-37523][CI] Fix Python test/e2e tests missing libpython/python headers [flink] via GitHub
  • Re: [PR] [FLINK-37523][CI] Fix Python test/e2e tests missing libpython/python headers [flink] via GitHub
  • Re: [PR] [FLINK-37523][CI] Fix Python test/e2e tests missing libpython/python headers [flink] via GitHub
• [jira] [Commented] (FLINK-37733) Externalise DynamoDB connector IT Test to E2E test package Daren Wong (Jira)
• [jira] [Updated] (FLINK-37733) Externalise DynamoDB IT Test to E2E test package Daren Wong (Jira)
• [PR] [FLINK-37733] Externalise DynamoDB connector IT Test to E2E test package [flink-connector-aws] via GitHub
  • Re: [PR] [FLINK-37733] Externalise DynamoDB connector IT Test to E2E test package [flink-connector-aws] via GitHub
  • Re: [PR] [FLINK-37733] Externalise DynamoDB connector IT Test to E2E test package [flink-connector-aws] via GitHub
  • Re: [PR] [FLINK-37733] Externalise DynamoDB connector IT Test to E2E test package [flink-connector-aws] via GitHub
  • Re: [PR] [FLINK-37733] Externalise DynamoDB connector IT Test to E2E test package [flink-connector-aws] via GitHub
• [jira] [Updated] (FLINK-37733) Externalise DynamoDB connector IT Test to E2E test package Daren Wong (Jira)
  • [jira] [Updated] (FLINK-37733) Externalise DynamoDB connector IT Test to E2E test package ASF GitHub Bot (Jira)
• [jira] [Created] (FLINK-37733) Externalise DynamoDB IT Test to E2E test package Daren Wong (Jira)
• [jira] [Assigned] (FLINK-37523) e2e: Test stream python udf sql job fails Mika Naylor (Jira)
• [jira] [Updated] (FLINK-37732) FLIP-527: State Schema Evolution for RowData Weiqing Yang (Jira)
  • [jira] [Updated] (FLINK-37732) FLIP-527: State Schema Evolution for RowData Weiqing Yang (Jira)
• [jira] [Created] (FLINK-37732) FLIP-527: State Schema Evolution for RowData Weiqing Yang (Jira)
• [PR] Add FlinkCDC v3.4.0 [flink-web] via GitHub
  • Re: [PR] Add Flink CDC v3.4.0 [flink-web] via GitHub
  • Re: [PR] Add Flink CDC v3.4.0 [flink-web] via GitHub
  • Re: [PR] Add Flink CDC v3.4.0 [flink-web] via GitHub
  • Re: [PR] Add Flink CDC v3.4.0 [flink-web] via GitHub
• [jira] [Updated] (FLINK-26425) Support rolling log aggregation on YARN Ferenc Csaky (Jira)
• [PR] [FLINK-26425][yarn] Support YARN rolling log aggregation [flink] via GitHub
  • Re: [PR] [FLINK-26425][yarn] Support rolling log aggregation [flink] via GitHub
  • Re: [PR] [FLINK-26425][yarn] Support rolling log aggregation [flink] via GitHub
  • Re: [PR] [FLINK-26425][yarn] Support rolling log aggregation [flink] via GitHub
  • Re: [PR] [FLINK-26425][yarn] Support rolling log aggregation [flink] via GitHub
  • Re: [PR] [FLINK-26425][yarn] Support rolling log aggregation [flink] via GitHub
• [jira] [Created] (FLINK-37731) Update dependency of Paimon to 1.1 and add support for Postpone Bucket Yanquan Lv (Jira)
• [jira] [Assigned] (FLINK-26425) Yarn aggregate log files in a rolling fashion for flink Ferenc Csaky (Jira)
• [jira] [Updated] (FLINK-26425) Yarn aggregate log files in a rolling fashion for flink Ferenc Csaky (Jira)
  • [jira] [Updated] (FLINK-26425) Yarn aggregate log files in a rolling fashion for flink Ferenc Csaky (Jira)
  • [jira] [Updated] (FLINK-26425) Yarn aggregate log files in a rolling fashion for flink ASF GitHub Bot (Jira)
• [jira] [Updated] (FLINK-37729) Implement ResultTypeQueryable for Avro serialization schema ASF GitHub Bot (Jira)
• [PR] [FLINK-37729][flink-formats] ResultTypeQueryable for Avro serialization schema [flink] via GitHub
  • Re: [PR] [FLINK-37729][flink-formats] ResultTypeQueryable for Avro serialization schema [flink] via GitHub
  • Re: [PR] [FLINK-37729][flink-formats] ResultTypeQueryable for Avro serialization schema [flink] via GitHub
  • Re: [PR] [FLINK-37729][flink-formats] ResultTypeQueryable for Avro serialization schema [flink] via GitHub
  • Re: [PR] [FLINK-37729][flink-formats] ResultTypeQueryable for Avro serialization schema [flink] via GitHub
  • Re: [PR] [FLINK-37729][flink-formats] ResultTypeQueryable for Avro serialization schema [flink] via GitHub
  • Re: [PR] [FLINK-37729][flink-formats] ResultTypeQueryable for Avro serialization schema [flink] via GitHub
  • Re: [PR] [FLINK-37729][flink-formats] ResultTypeQueryable for Avro serialization schema [flink] via GitHub
• [jira] [Resolved] (FLINK-37509) Increment scan source no need to buffer data when enable skipping backfill. Ruan Hang (Jira)
• [jira] [Assigned] (FLINK-37453) Migration Tests / data_stream_migration_test (8, 1.20.1) failed Leonard Xu (Jira)
• [jira] [Resolved] (FLINK-37453) Migration Tests / data_stream_migration_test (8, 1.20.1) failed Leonard Xu (Jira)
• Re: [PR] [FLINK-37453][tests] Add state restoration Pipeline E2e cases [flink-cdc] via GitHub
• [jira] [Resolved] (FLINK-35093) Postgres source connector support SPECIFIC_OFFSETS start up mode from an existed replication slot. Leonard Xu (Jira)
• [jira] [Updated] (FLINK-37541) Deprecate getTargetColumns in DynamicTableSink.Context xiangyu feng (Jira)
• [jira] [Created] (FLINK-37730) Collect job exceptions as kubernetes events Robert Metzger (Jira)
• [jira] [Created] (FLINK-37729) Implement ResultTypeQueryable for Avro serialization schema Pawel Leszczynski (Jira)
• [PR] [FLINK-37728][python] fix incorrect import org.apache.flink.table.runtime.operators.window.Window [flink] via GitHub
  • Re: [PR] [FLINK-37728][python] fix incorrect import org.apache.flink.table.runtime.operators.window.Window [flink] via GitHub
  • Re: [PR] [FLINK-37728][python] add support org.apache.flink.table.runtime.operators.window.GlobalWindow [flink] via GitHub
• [jira] [Assigned] (FLINK-36973) udf dateformat support LocalZonedTimestampData datatype Leonard Xu (Jira)
• [jira] [Updated] (FLINK-37728) Incorrect import in EmbeddedPythonWindowOperator.java ASF GitHub Bot (Jira)
• [jira] [Updated] (FLINK-36973) udf dateformat support LocalZonedTimestampData datatype Leonard Xu (Jira)
• [jira] [Resolved] (FLINK-36973) udf dateformat support LocalZonedTimestampData datatype Leonard Xu (Jira)
• Re: [PR] [FLINK-36973] DateFormat function supports LocalZonedTimestampData type [flink-cdc] via GitHub
• [jira] [Assigned] (FLINK-37728) Incorrect import in EmbeddedPythonWindowOperator.java Shuyi Chen (Jira)
• [jira] [Created] (FLINK-37728) Incorrect import in EmbeddedPythonWindowOperator.java Shuyi Chen (Jira)
• [jira] [Created] (FLINK-37727) java.lang.UnsatisfiedLinkError error on pemja.core.PythonInterpreter$MainInterpreter.initialize() Shuyi Chen (Jira)
• [jira] [Updated] (FLINK-37720) Enable sink reuse table optimizer by default and apply plan changes to existing test cases xiangyu feng (Jira)
• Re: [PR] [FLINK-36876] Support external eventLoopGroup for RestClient [flink] via GitHub
  • Re: [PR] [FLINK-36876] Support external eventLoopGroup for RestClient [flink] via GitHub
• Re: [PR] Bump com.nimbusds:nimbus-jose-jwt from 4.41.1 to 9.37.2 in /flink-end-to-end-tests/flink-end-to-end-tests-sql [flink] via GitHub
• Re: [PR] [FLINK-37153] Monitor late event count in temporal join [flink] via GitHub
• Re: [PR] [FLINK-37207][runtime] Don't clear distributed cache in StreamExecutionEnvironment.configure [flink] via GitHub
• Re: [PR] [FLINK-37103] The parameters passed when calling method FactoryUtil.createDynamicTableSource are inconsistent [flink] via GitHub
• Re: [PR] [FLINK-37088][k8s]support flink applicaton taskmanager log mounting [flink] via GitHub
  • Re: [PR] [FLINK-37088][k8s]support flink applicaton taskmanager log mounting [flink] via GitHub
• Re: [PR] [hotfix] Fixed a typo in state_backends.md [flink] via GitHub
• [jira] [Commented] (FLINK-37542) Support sink reuse in streaming mode Xuyang Zhong (Jira)
• [jira] [Closed] (FLINK-37542) Support sink reuse in streaming mode Xuyang Zhong (Jira)
• [jira] (FLINK-37677) [cdc-connector] Sink support skip create table event JunboWang (Jira)
• [jira] [Assigned] (FLINK-37479) postgres cdc connector support discover PARTITIONED TABLE Leonard Xu (Jira)
• [jira] [Commented] (FLINK-37726) Read incremental data for existing tables tianzhu.wen (Jira)
  • [jira] [Commented] (FLINK-37726) Read incremental data for existing tables Yanquan Lv (Jira)
• [jira] [Commented] (FLINK-37717) Stuck occurred during the full synchronization phase, resulting in incomplete synchronization of all data Leonard Xu (Jira)
  • [jira] [Commented] (FLINK-37717) Stuck occurred during the full synchronization phase, resulting in incomplete synchronization of all data vertern (Jira)
  • [jira] [Commented] (FLINK-37717) Stuck occurred during the full synchronization phase, resulting in incomplete synchronization of all data vertern (Jira)
  • [jira] [Commented] (FLINK-37717) Stuck occurred during the full synchronization phase, resulting in incomplete synchronization of all data vertern (Jira)
  • [jira] [Commented] (FLINK-37717) Stuck occurred during the full synchronization phase, resulting in incomplete synchronization of all data vertern (Jira)
  • [jira] [Commented] (FLINK-37717) Stuck occurred during the full synchronization phase, resulting in incomplete synchronization of all data vertern (Jira)
  • [jira] [Commented] (FLINK-37717) Stuck occurred during the full synchronization phase, resulting in incomplete synchronization of all data ouyangwulin (Jira)
• [jira] [Updated] (FLINK-37717) Stuck occurred during the full synchronization phase, resulting in incomplete synchronization of all data Leonard Xu (Jira)
  • [jira] [Updated] (FLINK-37717) Stuck occurred during the full synchronization phase, resulting in incomplete synchronization of all data vertern (Jira)
  • [jira] [Updated] (FLINK-37717) Stuck occurred during the full synchronization phase, resulting in incomplete synchronization of all data vertern (Jira)
  • [jira] [Updated] (FLINK-37717) Stuck occurred during the full synchronization phase, resulting in incomplete synchronization of all data vertern (Jira)
  • [jira] [Updated] (FLINK-37717) Stuck occurred during the full synchronization phase, resulting in incomplete synchronization of all data vertern (Jira)
  • [jira] [Updated] (FLINK-37717) Stuck occurred during the full synchronization phase, resulting in incomplete synchronization of all data vertern (Jira)
• [jira] [Assigned] (FLINK-37726) Read incremental data for existing tables Leonard Xu (Jira)
  • [jira] [Assigned] (FLINK-37726) Read incremental data for existing tables Yanquan Lv (Jira)
• [jira] [Updated] (FLINK-37726) Read incremental data for existing tables Yanquan Lv (Jira)
  • [jira] [Updated] (FLINK-37726) Read incremental data for existing tables Yanquan Lv (Jira)
• [jira] [Created] (FLINK-37726) Read incremental data for existing tables Yanquan Lv (Jira)
• Re: [PR] [FLINK-36794] [cdc-composer/cli] pipeline cdc connector support multiple data sources [flink-cdc] via GitHub
• Re: [PR] [FLINK-36580][pipeline-connector-mysql] Fix column.[in|ex]clude.list parameter causing schema inconsistency [flink-cdc] via GitHub
• [PR] Makes Async calcs share correlate split rule with Python [flink] via GitHub
  • Re: [PR] Makes Async calcs share correlate split rule with Python [flink] via GitHub
• [PR] Fixes janino bug returning incorrect results [flink] via GitHub
  • Re: [PR] Fixes janino bug returning incorrect results [flink] via GitHub
  • Re: [PR] Fixes janino bug returning incorrect results [flink] via GitHub
  • Re: [PR] Fixes janino bug returning incorrect results [flink] via GitHub
• [jira] [Created] (FLINK-37720) Enable table.optimizer.reuse-sink by default xiangyu feng (Jira)
• [jira] [Updated] (FLINK-37725) Share PythonCorrelateSplitRule with Async Scalar Alan Sheinberg (Jira)
  • [jira] [Updated] (FLINK-37725) Share PythonCorrelateSplitRule with Async Scalar Alan Sheinberg (Jira)
• [jira] [Created] (FLINK-37725) Share PythonCorrelateSplitRule with Async Scalar Alan Sheinberg (Jira)
• [jira] [Created] (FLINK-37724) Add AsyncTableFunction as new UDF type Alan Sheinberg (Jira)
• [jira] [Created] (FLINK-37723) FLIP-498: AsyncTableFunction for async table function support Alan Sheinberg (Jira)
• [jira] [Created] (FLINK-37721) Fix Janino Bug which resulted in Alan Sheinberg (Jira)
• [PR] [FLINK-37720][table-planner] Set the default value of table.optimizer.reuse-sink-enabled as true [flink] via GitHub
  • Re: [PR] [FLINK-37720][table-planner] Set the default value of table.optimizer.reuse-sink-enabled as true [flink] via GitHub
  • Re: [PR] [FLINK-37720][table-planner] Set the default value of table.optimizer.reuse-sink-enabled as true [flink] via GitHub
  • Re: [PR] [FLINK-37720][table-planner] Set the default value of table.optimizer.reuse-sink-enabled as true [flink] via GitHub
  • Re: [PR] [FLINK-37720][table-planner] Enable sink reuse table optimizer by default and apply plan changes to existing test cases [flink] via GitHub
  • Re: [PR] [FLINK-37720][table-planner] Enable sink reuse table optimizer by default and apply plan changes to existing test cases [flink] via GitHub
• [jira] [Created] (FLINK-37722) Eliminate redundant field initialization when deserializing POJOs Zhanghao Chen (Jira)
• [jira] [Updated] (FLINK-37721) Fix janino bug returning incorrect results Alan Sheinberg (Jira)
• [jira] [Closed] (FLINK-37243) Ensure that async callback processing happen on known thread Alan Sheinberg (Jira)
• Re: [PR] [FLINK-36973]udf dateformat support LocalZonedTimestampData datatype [flink-cdc] via GitHub
  • Re: [PR] [FLINK-36973]udf dateformat support LocalZonedTimestampData datatype [flink-cdc] via GitHub
  • Re: [PR] [FLINK-36973]udf dateformat support LocalZonedTimestampData datatype [flink-cdc] via GitHub
  • Re: [PR] [FLINK-36973]udf dateformat support LocalZonedTimestampData datatype [flink-cdc] via GitHub
• [jira] [Assigned] (FLINK-37243) Ensure that async callback processing happen on known thread Alan Sheinberg (Jira)
• [jira] [Updated] (FLINK-37720) Enable table.optimizer.reuse-sink by default ASF GitHub Bot (Jira)
  • [jira] [Updated] (FLINK-37720) Enable table.optimizer.reuse-sink by default xiangyu feng (Jira)
• [jira] [Created] (FLINK-37719) Support Java 25 (LTS) Liam Miller-Cushon (Jira)
• [jira] [Updated] (FLINK-36902) Security Manager removal Liam Miller-Cushon (Jira)
  • [jira] [Updated] (FLINK-36902) Security Manager removal Liam Miller-Cushon (Jira)

• Earlier messages
• Later messages