issues
Thread
Date
Earlier messages
Later messages
Messages by Thread
[PR] [FLINK-35239] [docs] Unset outdated warning [flink]
via GitHub
Re: [PR] [FLINK-35239] [docs] Unset outdated warning [flink]
via GitHub
Re: [PR] [FLINK-35239] [docs] Unset outdated warning [flink]
via GitHub
[jira] [Created] (FLINK-35239) 1.19 docs show outdated warning
Ufuk Celebi (Jira)
Re: [PR] [FLINK-34379][table] Fix OutOfMemoryError with large queries [flink]
via GitHub
Re: [PR] [FLINK-34379][table] Fix OutOfMemoryError with large queries [flink]
via GitHub
[PR] [FLINK-35236] [chinese-translation] Modify Translation error on the execution_mode/order-of-processing [flink]
via GitHub
Re: [PR] [FLINK-35236] [chinese-translation] Modify Translation error on the execution_mode/order-of-processing [flink]
via GitHub
Re: [PR] [FLINK-35236] [chinese-translation] Modify Translation error on the execution_mode/order-of-processing [flink]
via GitHub
Re: [PR] [FLINK-35236] [chinese-translation] Modify Translation error on the execution_mode/order-of-processing [flink]
via GitHub
Re: [PR] [FLINK-35236] [chinese-translation] Modify Translation error on the execution_mode/order-of-processing [flink]
via GitHub
Re: [PR] [FLINK-35236] [chinese-translation] Modify Translation error on the execution_mode/order-of-processing [flink]
via GitHub
Re: [PR] [FLINK-35236] [chinese-translation] Modify Translation error on the execution_mode/order-of-processing [flink]
via GitHub
[jira] [Comment Edited] (FLINK-35236) Flink 1.19 Translation error on the execution_mode/order-of-processing
Weijie Guo (Jira)
[jira] [Commented] (FLINK-35236) Flink 1.19 Translation error on the execution_mode/order-of-processing
Weijie Guo (Jira)
[jira] [Commented] (FLINK-35236) Flink 1.19 Translation error on the execution_mode/order-of-processing
hongxu han (Jira)
[jira] [Commented] (FLINK-35236) Flink 1.19 Translation error on the execution_mode/order-of-processing
hongxu han (Jira)
[PR] [DRAFT] Declare async state processing [flink]
via GitHub
Re: [PR] [DRAFT] Declare async state processing [flink]
via GitHub
[jira] [Updated] (FLINK-35238) AZP is not working since some ci agent unhealthy
Weijie Guo (Jira)
[jira] [Updated] (FLINK-35238) AZP is not working since some ci agent unhealthy
Weijie Guo (Jira)
[jira] [Commented] (FLINK-35238) AZP is not working since some ci agent unhealthy
Weijie Guo (Jira)
[jira] [Commented] (FLINK-35238) AZP is not working since some ci agent unhealthy
Weijie Guo (Jira)
[jira] [Created] (FLINK-35238) AZP is not working since some ci agent unhealthy
Weijie Guo (Jira)
[jira] [Updated] (FLINK-28568) Implements a new lookup join operator (sync mode only) with state to eliminate the non determinism
Weijie Guo (Jira)
[jira] [Updated] (FLINK-28568) Implements a new lookup join operator (sync mode only) with state to eliminate the non determinism
Weijie Guo (Jira)
[jira] [Updated] (FLINK-35236) Flink 1.19 Translation error on the execution_mode/order-of-processing
hongxu han (Jira)
[jira] [Updated] (FLINK-35236) Flink 1.19 Translation error on the execution_mode/order-of-processing
ASF GitHub Bot (Jira)
[jira] [Created] (FLINK-35237) Allow Custom HashFunction in PrePartitionOperator for Flink Sink Customization
zhangdingxin (Jira)
[jira] [Resolved] (FLINK-33506) Make AWS connectors compilable with jdk17
Danny Cranmer (Jira)
Re: [PR] [oracle]Error when TIMESTAMP_LTZ type is encoded in string type [flink-cdc]
via GitHub
[jira] [Updated] (FLINK-33506) Make AWS connectors compilable with jdk17
Danny Cranmer (Jira)
[jira] [Commented] (FLINK-33506) Make AWS connectors compilable with jdk17
Danny Cranmer (Jira)
Re: [PR] [oracle] The STRUCT type processing exception [flink-cdc]
via GitHub
[jira] [Updated] (FLINK-35236) Flink 1.19 Translation error on the Chinese official website
hongxu han (Jira)
[jira] [Updated] (FLINK-35236) Flink 1.19 Translation error on the Chinese official website
hongxu han (Jira)
[jira] [Created] (FLINK-35236) Flink 1.19 Translation error on the Chinese official website
hongxu han (Jira)
Re: [PR] [#1770] fix NumberFormatException when mysql server_id is larger than INT_MAX [flink-cdc]
via GitHub
Re: [PR] [tidb-cdc]When the task runs for a period of time, there are only Resolved Events [flink-cdc]
via GitHub
[jira] [Commented] (FLINK-35134) Release flink-connector-elasticsearch vX.X.X for Flink 1.19
Weijie Guo (Jira)
Re: [PR] Switch to a MySQL image with arm64 support [flink-cdc]
via GitHub
Re: [PR] [mysql][oracle] Quote primary key when split snapshot [flink-cdc]
via GitHub
Re: [PR] 升级Jackson版本 [flink-cdc]
via GitHub
[jira] [Updated] (FLINK-35235) Fix missing dependencies in the uber jar
ASF GitHub Bot (Jira)
[jira] [Comment Edited] (FLINK-35215) The performance of serializerKryo and serializerKryoWithoutRegistration are regressed
Rui Fan (Jira)
Re: [PR] support table splitting process control when read table snapshot [flink-cdc]
via GitHub
Re: [PR] [mysql] Support the rate limit when Mysql parallel read data output [flink-cdc]
via GitHub
Re: [PR] [e2e] optimization for arm64 [flink-cdc]
via GitHub
[PR] [release] Update version to 3.2-SNAPSHOT [flink-cdc]
via GitHub
Re: [PR] [release] Update version to 3.2-SNAPSHOT [flink-cdc]
via GitHub
Re: [PR] [release] Update version to 3.2-SNAPSHOT [flink-cdc]
via GitHub
Re: [PR] [release] Update version to 3.2-SNAPSHOT [flink-cdc]
via GitHub
Re: [PR] [mysql] Populate table schemas when scanNewlyAddedTables is enabled in binlog phase [flink-cdc]
via GitHub
Re: [PR] [metric] fix flink cdc metric conflict with flink built in metric [flink-cdc]
via GitHub
[PR] [docs][pipeline-connector][paimon] fix example bug for `Paimon 'wareh… [flink-cdc]
via GitHub
Re: [PR] [docs][pipeline-connector][paimon] fix example bug for `Paimon 'wareh… [flink-cdc]
via GitHub
Re: [PR] [Debezium] Fix the server timeZone bug of debeziumDeserialization when using dataSream API(#317) [flink-cdc]
via GitHub
[jira] [Assigned] (FLINK-34639) Flink CDC: Support DebeziumDeserializationSchema in OceanBase source connector
Qingsheng Ren (Jira)
[jira] [Created] (FLINK-35235) Fix missing dependencies in the uber jar
LvYanquan (Jira)
[jira] [Commented] (FLINK-34639) Flink CDC: Support DebeziumDeserializationSchema in OceanBase source connector
Qingsheng Ren (Jira)
Re: [PR] [tdsql] The first draft of TDSQL-CDC [flink-cdc]
via GitHub
Re: [PR] [tdsql] The first draft of TDSQL-CDC [flink-cdc]
via GitHub
Re: [PR] [tdsql] The first draft of TDSQL-CDC [flink-cdc]
via GitHub
Re: [PR] [mysql] Fix the binlogSplit state incompatibility when upgrading from 2.2.0 [flink-cdc]
via GitHub
Re: [PR] [mysql] Fix use latest-offset mode during caused add newly table not … [flink-cdc]
via GitHub
Re: [PR] [PostgreSQL] Add DeserializationConverterFactory for PostGIS schemas [flink-cdc]
via GitHub
Re: [PR] [mysql] expose meta_ts field in the metadata through flink sql [flink-cdc]
via GitHub
Re: [PR] [mysql] expose update_before field in the metadata through flink sql [flink-cdc]
via GitHub
Re: [PR] [mysql] expose op type in the metadata through flink sql [flink-cdc]
via GitHub
Re: [PR] [mysql] keep order of each split by replacing HashMap with LinkedHashMap [flink-cdc]
via GitHub
Re: [PR] [FLINK-35223][rest] Add jobType in JobDetailsInfo related rest api [flink]
via GitHub
Re: [PR] support op_type metadata columns [flink-cdc]
via GitHub
Re: [PR] support op_type metadata columns [flink-cdc]
via GitHub
Re: [PR] [mysql] support for transaction metadata events [flink-cdc]
via GitHub
Re: [PR] Added option for MysqlSource to dispatch watermark event at the begin… [flink-cdc]
via GitHub
Re: [PR] [BP-3.1][FLINK-35128][cdc-connector][cdc-base] Re-calculate the starting changelog offset after the new table added (#3230) [flink-cdc]
via GitHub
Re: [PR] [mysql] expose Enumerator metrics via Source Event [flink-cdc]
via GitHub
Re: [PR] [mysql] expose Enumerator metrics via Source Event [flink-cdc]
via GitHub
Re: [PR] [mysql] expose Enumerator metrics via Source Event [flink-cdc]
via GitHub
Re: [PR] [mysql] expose Enumerator metrics via Source Event [flink-cdc]
via GitHub
[jira] [Commented] (FLINK-35128) Re-calculate the starting change log offset after the new table added
Qingsheng Ren (Jira)
[jira] [Updated] (FLINK-35234) Fix NullPointerException of org.apache.flink.cdc.common.configuration.ConfigurationUtils#convertToString
ASF GitHub Bot (Jira)
[PR] [FLINK-35234][hotfix][cdc-common] Fix NullPointerException of org.apache.flink.cdc.common.configuration.ConfigurationUtils#convertToString [flink-cdc]
via GitHub
Re: [PR] [FLINK-35234][hotfix][cdc-common] Fix NullPointerException of org.apache.flink.cdc.common.configuration.ConfigurationUtils#convertToString [flink-cdc]
via GitHub
Re: [PR] [FLINK-35234][hotfix][cdc-common] Fix NullPointerException of org.apache.flink.cdc.common.configuration.ConfigurationUtils#convertToString [flink-cdc]
via GitHub
Re: [PR] fix: fix mysql-cdc case sensitive [flink-cdc]
via GitHub
[jira] [Created] (FLINK-35234) Fix NullPointerException of org.apache.flink.cdc.common.configuration.ConfigurationUtils#convertToString
Hongshun Wang (Jira)
[jira] [Commented] (FLINK-35220) the error of mysql cdc
Hongshun Wang (Jira)
Re: [PR] [mysql] Add schema validation for table schema #493 [flink-cdc]
via GitHub
Re: [PR] optimize the update operation in binlog events [flink-cdc]
via GitHub
[jira] [Closed] (FLINK-35097) Table API Filesystem connector with 'raw' format repeats last line
Timo Walther (Jira)
[jira] [Reopened] (FLINK-34902) INSERT INTO column mismatch leads to IndexOutOfBoundsException
Timo Walther (Jira)
[jira] [Commented] (FLINK-34902) INSERT INTO column mismatch leads to IndexOutOfBoundsException
Timo Walther (Jira)
[jira] [Commented] (FLINK-34902) INSERT INTO column mismatch leads to IndexOutOfBoundsException
Jeyhun Karimov (Jira)
Re: [PR] [mysql] Support docker image of ARM chip [flink-cdc]
via GitHub
Re: [PR] [FLINK-35215][core] Fix the bug when Kryo serialize length is 0 [flink]
via GitHub
Re: [PR] [FLINK-35215][core] Fix the bug when Kryo serialize length is 0 [flink]
via GitHub
Re: [PR] [FLINK-35215][core] Fix the bug when Kryo serialize length is 0 [flink]
via GitHub
Re: [PR] [FLINK-35215][core] Fix the bug when Kryo serialize length is 0 [flink]
via GitHub
Re: [PR] [FLINK-35215][core] Fix the bug when Kryo serialize length is 0 [flink]
via GitHub
[jira] [Updated] (FLINK-35215) The performance of serializerKryo and serializerKryoWithoutRegistration are regressed
ASF GitHub Bot (Jira)
[jira] [Updated] (FLINK-35215) The performance of serializerKryo and serializerKryoWithoutRegistration are regressed
Rui Fan (Jira)
[jira] [Updated] (FLINK-35215) The performance of serializerKryo and serializerKryoWithoutRegistration are regressed
Rui Fan (Jira)
[jira] [Updated] (FLINK-35233) HBase lookup result is wrong when lookup cache is enabled
ASF GitHub Bot (Jira)
[PR] [FLINK-35233] Fix lookup cache reuse RowData object problem [flink-connector-hbase]
via GitHub
Re: [PR] [FLINK-35233] Fix lookup cache reuse RowData object problem [flink-connector-hbase]
via GitHub
Re: [PR] [FLINK-35233] Fix lookup cache reuse RowData object problem [flink-connector-hbase]
via GitHub
Re: [PR] [FLINK-33358][sql] Fix Flink SQL Client fail to start in Flink on YARN [flink]
via GitHub
[jira] [Created] (FLINK-35233) HBase lookup result is wrong when lookup cache is enabled
tanjialiang (Jira)
[PR] [FLINK-35208][python] Respect pipeline.cached-files during handling Python dependencies [flink]
via GitHub
Re: [PR] [FLINK-35208][python] Respect pipeline.cached-files during handling Python dependencies [flink]
via GitHub
[jira] [Assigned] (FLINK-33463) Support the implementation of dynamic source tables based on the new source
Rui Fan (Jira)
[jira] [Assigned] (FLINK-33462) Sort out the document page about the new Jdbc source.
Rui Fan (Jira)
[jira] [Assigned] (FLINK-33461) Support streaming related semantics for the new jdbc source
Rui Fan (Jira)
[jira] [Assigned] (FLINK-35176) Support property authentication connection for JDBC catalog & dynamic table
Rui Fan (Jira)
[jira] [Resolved] (FLINK-33460) Support property authentication connection.
Rui Fan (Jira)
[jira] [Commented] (FLINK-35230) Split FlinkSqlParserImplTest to reduce the code lines.
dalongliu (Jira)
[jira] [Commented] (FLINK-35230) Split FlinkSqlParserImplTest to reduce the code lines.
Shuai Xu (Jira)
[jira] [Resolved] (FLINK-29050) [JUnit5 Migration] Module: flink-hadoop-compatibility
Rui Fan (Jira)
[jira] [Commented] (FLINK-29050) [JUnit5 Migration] Module: flink-hadoop-compatibility
Rui Fan (Jira)
[jira] [Commented] (FLINK-33460) Support property authentication connection.
Rui Fan (Jira)
[jira] [Assigned] (FLINK-33460) Support property authentication connection.
Rui Fan (Jira)
[jira] [Commented] (FLINK-35188) Introduce CatalogMaterializedTable and related interface to support materialized table
dalongliu (Jira)
[jira] [Resolved] (FLINK-35188) Introduce CatalogMaterializedTable and related interface to support materialized table
dalongliu (Jira)
[jira] [Resolved] (FLINK-35088) watermark alignment maxAllowedWatermarkDrift and updateInterval param need check
Rui Fan (Jira)
Re: [PR] [hotfix] Use jdk 1.8 for profile activation [flink-connector-opensearch]
via GitHub
Re: [PR] Bump org.opensearch:opensearch from 1.3.0 to 2.11.1 in /flink-connector-opensearch [flink-connector-opensearch]
via GitHub
Re: [PR] Bump org.opensearch:opensearch from 1.3.0 to 2.11.1 in /flink-connector-opensearch [flink-connector-opensearch]
via GitHub
Re: [PR] Bump org.opensearch:opensearch from 1.3.0 to 2.11.1 in /flink-connector-opensearch [flink-connector-opensearch]
via GitHub
[jira] [Assigned] (FLINK-35228) DynamicKafkaSource does not read re-added topic for the same cluster
Mason Chen (Jira)
[jira] [Updated] (FLINK-35232) Support for retry settings on GCS connector
Vikas M (Jira)
[jira] [Updated] (FLINK-35232) Support for retry settings on GCS connector
Vikas M (Jira)
[jira] [Updated] (FLINK-35232) Support for retry settings on GCS connector
Vikas M (Jira)
[jira] [Updated] (FLINK-35232) Support for retry settings on GCS connector
Vikas M (Jira)
[jira] [Updated] (FLINK-35232) Support for retry settings on GCS connector
Vikas M (Jira)
[jira] [Updated] (FLINK-35232) Support for retry settings on GCS connector
Oleksandr Nitavskyi (Jira)
[jira] [Updated] (FLINK-35232) Support for retry settings on GCS connector
Oleksandr Nitavskyi (Jira)
[jira] [Updated] (FLINK-35232) Support for retry settings on GCS connector
Oleksandr Nitavskyi (Jira)
[jira] [Created] (FLINK-35232) Support for retry settings on GCS connector
Vikas M (Jira)
[jira] [Updated] (FLINK-35231) Tests rely on listJobsFunction in TestingClusterClient are broken
Artem Plyusnin (Jira)
[jira] [Created] (FLINK-35231) Test relies on listJobsFunction in TestingClusterClient are broken
Artem Plyusnin (Jira)
Re: [PR] Draft pr for initial review of apicurio [flink]
via GitHub
Re: [PR] [cdc-connector][db2] Db2 support incremental source [flink-cdc]
via GitHub
Re: [PR] [cdc-connector][db2] Db2 support incremental source [flink-cdc]
via GitHub
[PR] Fix type annotation in `MapState.put_all()` [flink]
via GitHub
Re: [PR] Fix type annotation in `MapState.put_all()` [flink]
via GitHub
[jira] [Created] (FLINK-35230) Split FlinkSqlParserImplTest to reduce the code lines.
Feng Jin (Jira)
[jira] [Updated] (FLINK-35230) Split FlinkSqlParserImplTest to reduce the code lines.
Feng Jin (Jira)
[jira] [Updated] (FLINK-35230) Split FlinkSqlParserImplTest to reduce the code lines.
Feng Jin (Jira)
[jira] [Updated] (FLINK-35230) Split FlinkSqlParserImplTest to reduce the code lines.
dalongliu (Jira)
[jira] [Assigned] (FLINK-35157) Sources with watermark alignment get stuck once some subtasks finish
Gyula Fora (Jira)
[jira] [Commented] (FLINK-35157) Sources with watermark alignment get stuck once some subtasks finish
elon_X (Jira)
[jira] [Updated] (FLINK-35157) Sources with watermark alignment get stuck once some subtasks finish
elon_X (Jira)
[jira] [Commented] (FLINK-31223) sql-client.sh fails to start with ssl enabled
david radley (Jira)
[jira] [Commented] (FLINK-31223) sql-client.sh fails to start with ssl enabled
Weijie Guo (Jira)
[jira] [Commented] (FLINK-31223) sql-client.sh fails to start with ssl enabled
david radley (Jira)
Re: [PR] [FLINK-31223] sql-client.sh fails to start with ssl enabled [flink]
via GitHub
Re: [PR] [FLINK-31223] sql-client.sh fails to start with ssl enabled [flink]
via GitHub
Re: [PR] [FLINK-31223] sql-client.sh fails to start with ssl enabled [flink]
via GitHub
Re: [PR] [FLINK-31223] sql-client.sh fails to start with ssl enabled [flink]
via GitHub
Re: [PR] [FLINK-31223] sql-client.sh fails to start with ssl enabled [flink]
via GitHub
Re: [PR] [FLINK-31223] sql-client.sh fails to start with ssl enabled [flink]
via GitHub
Re: [PR] [FLINK-31223] sql-client.sh fails to start with ssl enabled [flink]
via GitHub
Re: [PR] [FLINK-31223] sql-client.sh fails to start with ssl enabled [flink]
via GitHub
Re: [PR] [FLINK-31223] sql-client.sh fails to start with ssl enabled [flink]
via GitHub
Re: [PR] [FLINK-31223] sql-client.sh fails to start with ssl enabled [flink]
via GitHub
Re: [PR] [FLINK-31223] sql-client.sh fails to start with ssl enabled [flink]
via GitHub
Re: [PR] [FLINK-31223] sql-client.sh fails to start with ssl enabled [flink]
via GitHub
Re: [PR] [FLINK-31223] sql-client.sh fails to start with ssl enabled [flink]
via GitHub
Re: [PR] [FLINK-31223] sql-client.sh fails to start with ssl enabled [flink]
via GitHub
Re: [PR] [FLINK-31223] sql-client.sh fails to start with ssl enabled [flink]
via GitHub
[PR] [hotfix][docs] Fix the invalid link to FLINK-32468 [flink]
via GitHub
Re: [PR] [hotfix][docs] Fix the invalid link to FLINK-32468 [flink]
via GitHub
Re: [PR] [hotfix][docs] Fix the invalid link to FLINK-32468 [flink]
via GitHub
Re: [PR] [hotfix][docs] Fix the invalid link in 1.18 release note [flink]
via GitHub
Re: [PR] [hotfix][docs] Fix the invalid link in 1.18 release note [flink]
via GitHub
Re: [PR] [hotfix][docs] Fix the invalid link in 1.18 release note [flink]
via GitHub
Re: [PR] [hotfix][docs] Fix the invalid link in 1.18 release note [flink]
via GitHub
Re: [PR] [hotfix][docs] Fix the invalid link in 1.18 release note [flink]
via GitHub
[jira] [Updated] (FLINK-35189) Introduce test-filesystem Catalog based on FileSystem Connector to support materialized table
ASF GitHub Bot (Jira)
[jira] [Updated] (FLINK-35189) Introduce test-filesystem Catalog based on FileSystem Connector to support materialized table
dalongliu (Jira)
[jira] [Updated] (FLINK-35189) Introduce test-filesystem Catalog based on FileSystem Connector to support materialized table
dalongliu (Jira)
[PR] [FLINK-35189][testing/test-filesystem]Introduce test-filesystem Catalog based on FileSystem Connector to support materialized table [flink]
via GitHub
Re: [PR] [FLINK-35189][testing/test-filesystem]Introduce test-filesystem Catalog based on FileSystem Connector to support materialized table [flink]
via GitHub
Re: [PR] [FLINK-35189][testing/test-filesystem]Introduce test-filesystem Catalog based on FileSystem Connector to support materialized table [flink]
via GitHub
Re: [PR] [FLINK-35189][testing/test-filesystem]Introduce test-filesystem Catalog based on FileSystem Connector to support materialized table [flink]
via GitHub
Re: [PR] [FLINK-35189][test-utils]Introduce test-filesystem Catalog based on FileSystem Connector to support materialized table [flink]
via GitHub
[jira] [Created] (FLINK-35229) join An error occurred when the table was empty
lixu (Jira)
[jira] [Closed] (FLINK-35148) Improve InstantiationUtil for checking nullary public constructor
Xintong Song (Jira)
[jira] [Assigned] (FLINK-35148) Improve InstantiationUtil for checking nullary public constructor
Xintong Song (Jira)
[PR] Update parallel.md [flink]
via GitHub
Re: [PR] Update parallel.md [flink]
via GitHub
[PR] [FLINK-35221][hive] Support SQL 2011 reserved keywords as identifiers in HiveParser [flink]
via GitHub
Re: [PR] [FLINK-35221][hive] Support SQL 2011 reserved keywords as identifiers in HiveParser [flink]
via GitHub
[jira] [Updated] (FLINK-35222) Adding getJobType for AccessExecutionGraph
ASF GitHub Bot (Jira)
[PR] [FLINK-35222][rest] Adding getJobType for AccessExecutionGraph [flink]
via GitHub
Re: [PR] [FLINK-35222][rest] Adding getJobType for AccessExecutionGraph [flink]
via GitHub
Re: [PR] [FLINK-35222][rest] Adding getJobType for AccessExecutionGraph [flink]
via GitHub
[jira] [Updated] (FLINK-35228) DynamicKafkaSource does not read re-added topic for the same cluster
ASF GitHub Bot (Jira)
[PR] Update windows.md [flink]
via GitHub
Earlier messages
Later messages