issues
Thread
Date
Earlier messages
Later messages
Messages by Date
2024/07/23
[PR] [FLINK-35884] MySQL pipeline support snapshot chunk key-column [flink-cdc]
via GitHub
2024/07/23
[jira] [Updated] (FLINK-35884) Pipeline MySQL connector support scan.incremental.snapshot.chunk.key-column
JunboWang (Jira)
2024/07/23
[jira] [Updated] (FLINK-35884) Pipeline connector MySQL support scan.incremental.snapshot.chunk.key-column
JunboWang (Jira)
2024/07/23
[jira] [Updated] (FLINK-35884) Pipeline connector MySQL support snapshot.chunk.key-column
JunboWang (Jira)
2024/07/23
Re: [PR] [FLINK-35868][cdc-connector][mongodb] Bump dependency version to support MongoDB 7.0 [flink-cdc]
via GitHub
2024/07/23
[jira] [Commented] (FLINK-33977) Adaptive scheduler may not minimize the number of TMs during downscaling
Zhanghao Chen (Jira)
2024/07/23
Re: [PR] [FLINK-35265] Implement FlinkStateSnapshot custom resource [flink-kubernetes-operator]
via GitHub
2024/07/23
[jira] [Updated] (FLINK-35884) Pipeline connector MySQL support snapshot.chunk.key-column
JunboWang (Jira)
2024/07/23
[jira] [Created] (FLINK-35884) Support
JunboWang (Jira)
2024/07/23
Re: [PR] [FLINK-35868][cdc-connector][mongodb] Bump dependency version to support MongoDB 7.0 [flink-cdc]
via GitHub
2024/07/23
Re: [PR] [FLINK-35272][cdc][runtime] Pipeline Transform job supports omitting / renaming calculation column [flink-cdc]
via GitHub
2024/07/23
[jira] [Created] (FLINK-35883) Wildcard projection inserts column at wrong place
yux (Jira)
2024/07/23
[jira] [Commented] (FLINK-35883) Wildcard projection inserts column at wrong place
yux (Jira)
2024/07/23
Re: [PR] [FLINK-33874][runtime] Support resource request wait mechanism at DefaultDeclarativeSlotPool side for Default Scheduler [flink]
via GitHub
2024/07/23
[jira] [Updated] (FLINK-33874) Support resource request wait mechanism at DefaultDeclarativeSlotPool side for Default Scheduler
ASF GitHub Bot (Jira)
2024/07/23
[PR] [FLINK-33874][runtime] Support resource request wait mechanism at DefaultDeclarativeSlotPool side for Default Scheduler [flink]
via GitHub
2024/07/23
[jira] [Updated] (FLINK-35874) Check pureBinlogPhaseTables set before call getBinlogPosition method in BinlogSplitReader
ASF GitHub Bot (Jira)
2024/07/23
Re: [PR] [FLINK-35874][cdc-connector][mysql] Check pureBinlogPhaseTables set before call getBinlogPosition method [flink-cdc]
via GitHub
2024/07/23
[jira] [Commented] (FLINK-33977) Adaptive scheduler may not minimize the number of TMs during downscaling
RocMarshal (Jira)
2024/07/23
[jira] [Updated] (FLINK-33977) Adaptive scheduler may not minimize the number of TMs during downscaling
RocMarshal (Jira)
2024/07/23
Re: [PR] [FLINK-35877] Shade protobuf in flink [flink]
via GitHub
2024/07/23
Re: [PR] [FLINK-33386][runtime] Support tasks balancing at slot level for Default Scheduler [flink]
via GitHub
2024/07/23
[jira] [Resolved] (FLINK-35623) Bump mongo-driver version from 4.7.2 to 5.1.1 to support MongoDB 7.0
Jiabao Sun (Jira)
2024/07/23
Re: [PR] [FLINK-35623] Bump mongo-driver version from 4.7.2 to 5.1.1 to support MongoDB 7.0 [flink-connector-mongodb]
via GitHub
2024/07/23
Re: [PR] [FLINK-35868][cdc-connector][mongodb] Bump dependency version to support MongoDB 7.0 [flink-cdc]
via GitHub
2024/07/23
[jira] [Commented] (FLINK-35877) Shade protobuf in flink
Martijn Visser (Jira)
2024/07/23
Re: [PR] [FLINK-35868][cdc-connector][mongodb] Add MongoDB 6.0 & 7.0 tests [flink-cdc]
via GitHub
2024/07/23
Re: [PR] [FLINK-35623] Bump mongo-driver version from 4.7.2 to 5.1.1 to support MongoDB 7.0 [flink-connector-mongodb]
via GitHub
2024/07/23
[jira] [Assigned] (FLINK-35868) Bump Mongo driver version to support Mongo 7.0+
Jiabao Sun (Jira)
2024/07/23
Re: [PR] [FLINK-35737] Prevent Memory Leak by Closing MemoryExecutionGraphInfoStore on MiniCluster Shutdown [flink]
via GitHub
2024/07/23
Re: [PR] [FLINK-35877] Shade protobuf in flink [flink]
via GitHub
2024/07/23
Re: [PR] [FLINK-35305]Amazon SQS Sink Connector [flink-connector-aws]
via GitHub
2024/07/23
[jira] [Updated] (FLINK-35882) [1.20-rc2] Vote on the release candidate
Weijie Guo (Jira)
2024/07/23
[jira] [Updated] (FLINK-35882) [1.20-rc2] Vote on the release candidate
Weijie Guo (Jira)
2024/07/23
[jira] [Updated] (FLINK-35879) [1.20-rc2] Build and stage Java and Python artifacts
Weijie Guo (Jira)
2024/07/23
[jira] [Updated] (FLINK-35881) [1.20-rc2] Propose a pull request for website updates
Weijie Guo (Jira)
2024/07/23
[jira] [Updated] (FLINK-35880) [1.20-rc2] Stage source and binary releases on dist.apache.org
Weijie Guo (Jira)
2024/07/23
[jira] [Created] (FLINK-35882) CLONE - [Release-1.20] Vote on the release candidate
Weijie Guo (Jira)
2024/07/23
[jira] [Created] (FLINK-35879) CLONE - [Release-1.20] Build and stage Java and Python artifacts
Weijie Guo (Jira)
2024/07/23
[jira] [Created] (FLINK-35878) Build Release Candidate: 1.20.0-rc2
Weijie Guo (Jira)
2024/07/23
[jira] [Created] (FLINK-35881) CLONE - [Release-1.20] Propose a pull request for website updates
Weijie Guo (Jira)
2024/07/23
[jira] [Updated] (FLINK-35881) [1.20-rc2] Propose a pull request for website updates
Weijie Guo (Jira)
2024/07/23
[jira] [Created] (FLINK-35880) CLONE - [Release-1.20] Stage source and binary releases on dist.apache.org
Weijie Guo (Jira)
2024/07/23
[jira] [Updated] (FLINK-35877) Shade protobuf in flink
ASF GitHub Bot (Jira)
2024/07/23
[PR] [FLINK-35877] Shade protobuf in flink [flink]
via GitHub
2024/07/23
[jira] [Updated] (FLINK-35876) mysql cdc may change from snapshot mode to binlog mode failed when cpu load of mysql server is 100%
Youle (Jira)
2024/07/23
[jira] [Created] (FLINK-35877) Shade protobuf in flink
zhuanshenbsj1 (Jira)
2024/07/23
[jira] [Updated] (FLINK-35876) mysql cdc may change from snapshot mode to binlog mode failed when cpu load of mysql server is 100%
Youle (Jira)
2024/07/23
[jira] [Updated] (FLINK-35876) mysql cdc may change from snapshot mode to binlog mode failed when cpu load of mysql server is 100%
Youle (Jira)
2024/07/23
[jira] [Updated] (FLINK-35876) mysql cdc may change from snapshot mode to binlog mode failed when cpu load of mysql server is 100%
Youle (Jira)
2024/07/23
[jira] [Created] (FLINK-35876) mysql cdc may change from snapshot mode to binlog mode failed when cpu load of mysql server is 100%
Youle (Jira)
2024/07/23
[jira] [Updated] (FLINK-35868) Bump Mongo driver version to support Mongo 7.0+
ASF GitHub Bot (Jira)
2024/07/23
Re: [PR] [FLINK-35868][mongo] Add MongoDB 6.0 & 7.0 tests [flink-cdc]
via GitHub
2024/07/23
[PR] [FLINK-35868][mongo] Add MongoDB 6.0 & 7.0 tests [flink-cdc]
via GitHub
2024/07/22
[jira] [Created] (FLINK-35875) Flink cdc frequently encounters LabelAlreadyExists errors
Jira
2024/07/22
[jira] [Closed] (FLINK-35844) Build Release Candidate: 1.20.0-rc1
Weijie Guo (Jira)
2024/07/22
[jira] [Commented] (FLINK-35844) Build Release Candidate: 1.20.0-rc1
Weijie Guo (Jira)
2024/07/22
[jira] [Closed] (FLINK-35848) [Release-1.20] Vote on the release candidate
Weijie Guo (Jira)
2024/07/22
Re: [PR] [FLINK-27355][runtime] Unregister JobManagerRunner after it's closed [flink]
via GitHub
2024/07/22
[jira] [Commented] (FLINK-35835) SnapshotFileMergingCompatibilityITCase.testSwitchFromDisablingToEnablingFileMerging failed on AZP
Zakelly Lan (Jira)
2024/07/22
Re: [PR] [BP-1.20][FLINK-35095][test] Fix unstable tests in `ExecutionEnvironmentImplTest` [flink]
via GitHub
2024/07/22
[jira] [Commented] (FLINK-23598) DataOutputSerializer.writeBytes updates position twice
Shalini M (Jira)
2024/07/22
[jira] [Commented] (FLINK-35810) AsyncWaitOperatorTest.testProcessingTimeRepeatedCompleteUnorderedWithRetry fails
Weijie Guo (Jira)
2024/07/22
[jira] [Commented] (FLINK-33555) LocalRecoveryITCase.testRecoverLocallyFromProcessCrashWithWorkingDirectory:
Weijie Guo (Jira)
2024/07/22
[jira] [Commented] (FLINK-35835) SnapshotFileMergingCompatibilityITCase.testSwitchFromDisablingToEnablingFileMerging failed on AZP
Weijie Guo (Jira)
2024/07/22
[PR] [BP-1.20]][FLINK-35095][test] Fix unstable tests in `ExecutionEnvironmentImplTest` [flink]
via GitHub
2024/07/22
Re: [PR] [FLINK-23598] [core] Fix a bug that caused position to be updated twice when writing a string to a byte array [flink]
via GitHub
2024/07/22
Re: [PR] [cdc-common] add field of defaultValue to Column. [flink-cdc]
via GitHub
2024/07/22
Re: [PR] [FLINK-35713][cdc-compose] Add sink PARALLELISM for flink-cdc. [flink-cdc]
via GitHub
2024/07/22
Re: [PR] [FLINK-31931][runtime] Prevent exception history page from linking to non-existent TM page. [flink]
via GitHub
2024/07/22
[jira] [Assigned] (FLINK-34730) Translate pages of Flink CDC docs to Chinese
Leonard Xu (Jira)
2024/07/22
[jira] [Commented] (FLINK-35740) [mysql] Allow column as chunk key even if not in Primary Keys
ouyangwulin (Jira)
2024/07/22
Re: [PR] [minor][cdc-connector][oracle] OracleSchema getTableSchema Description Modified [flink-cdc]
via GitHub
2024/07/22
Re: [PR] [FLINK-35766][streaming] Fix hang issue in JobGraph generation when StreamGraph contains many YieldingOperatorFactory. [flink]
via GitHub
2024/07/22
[PR] [FLINK-35766][streaming] Fix hang issue in JobGraph generation when StreamGraph contains many YieldingOperatorFactory. [flink]
via GitHub
2024/07/22
[jira] [Updated] (FLINK-35766) When the job contains many YieldingOperatorFactory instances, compiling the JobGraph hangs
ASF GitHub Bot (Jira)
2024/07/22
Re: [PR] [FLINK-35674][cdc-connector][mysql]Fix blocking caused by searching for timestamp in binlog file [flink-cdc]
via GitHub
2024/07/22
Re: [PR] [FLINK-35674][cdc-connector][mysql]Fix blocking caused by searching for timestamp in binlog file [flink-cdc]
via GitHub
2024/07/22
[jira] [Commented] (FLINK-35874) Check pureBinlogPhaseTables set before call getBinlogPosition method in BinlogSplitReader
Leonard Xu (Jira)
2024/07/22
[jira] [Assigned] (FLINK-35873) Add HashFunctionProvider for Paimon DataSink.
Leonard Xu (Jira)
2024/07/22
[jira] [Assigned] (FLINK-35874) Check pureBinlogPhaseTables set before call getBinlogPosition method in BinlogSplitReader
Leonard Xu (Jira)
2024/07/22
[jira] [Resolved] (FLINK-35865) Support Byte and Short in ObjectUtils
Zhongqiang Gong (Jira)
2024/07/22
[jira] [Assigned] (FLINK-35865) Support Byte and Short in ObjectUtils
Zhongqiang Gong (Jira)
2024/07/22
Re: [PR] [FLINK-35865][base] Support Byte and Short in ObjectUtils [flink-cdc]
via GitHub
2024/07/22
Re: [PR] [cdc-runtime]SchemaRegistry Log output is repeated [flink-cdc]
via GitHub
2024/07/22
[jira] [Commented] (FLINK-35095) ExecutionEnvironmentImplTest.testFromSource failure on GitHub CI
Weijie Guo (Jira)
2024/07/22
Re: [PR] [FLINK-35674][cdc-connector][mysql]Fix blocking caused by searching for timestamp in binlog file [flink-cdc]
via GitHub
2024/07/22
[jira] [Commented] (FLINK-35874) Check pureBinlogPhaseTables set before call getBinlogPosition method in BinlogSplitReader
Zhongmin Qiao (Jira)
2024/07/22
Re: [PR] [FLINK-35363] FLIP-449: Reorganization of flink-connector-jdbc [flink-connector-jdbc]
via GitHub
2024/07/22
Re: [PR] [hotfix][docs] Add missing "Submitting a Flink job" section in Chinese version doc and other fixes [flink]
via GitHub
2024/07/22
Re: [PR] [hotfix] [docs] Fix java doc api [flink]
via GitHub
2024/07/22
Re: [PR] [hotfix] [base] Fix the serialization error occurring with table names containing dot [flink-cdc]
via GitHub
2024/07/22
[PR] [cdc-runtime]SchemaRegistry Log output is repeated [flink-cdc]
via GitHub
2024/07/22
Re: [PR] [FLINK-35674][cdc-connector][mysql]Fix blocking caused by searching for timestamp in binlog file [flink-cdc]
via GitHub
2024/07/22
Re: [PR] [FLINK-35674][cdc-connector][mysql]Fix blocking caused by searching for timestamp in binlog file [flink-cdc]
via GitHub
2024/07/22
[jira] [Assigned] (FLINK-33100) Implement YarnJobFetcher for Standalone Autoscaler
Rui Fan (Jira)
2024/07/22
Re: [PR] [hotfix] [base] Fix the serialization error occurring with table names containing dot [flink-cdc]
via GitHub
2024/07/22
Re: [PR] [FLINK-31362][table] Upgrade Calcite version to 1.33.0 [flink]
via GitHub
2024/07/22
Re: [PR] [FLINK-35265] Implement FlinkStateSnapshot custom resource [flink-kubernetes-operator]
via GitHub
2024/07/22
Re: [PR] [FLINK-35265] Implement FlinkStateSnapshot custom resource [flink-kubernetes-operator]
via GitHub
2024/07/22
Re: [PR] [FLINK-35267][snapshot] FlinkStateSnapshot documentation and examples [flink-kubernetes-operator]
via GitHub
2024/07/22
Re: [PR] [FLINK-27355][runtime] Unregister JobManagerRunner after it's closed [flink]
via GitHub
2024/07/22
Re: [PR] [FLINK-27355][runtime] Unregister JobManagerRunner after it's closed [flink]
via GitHub
2024/07/22
Re: [PR] [FLINK-21373] Add RabbitMQ SinkV2 Implementation, Port Flink version to Flink 1.19 [flink-connector-rabbitmq]
via GitHub
2024/07/22
[jira] [Commented] (FLINK-35726) Data Stream to Table API converts Map to RAW 'java.util.Map'
David Perkins (Jira)
2024/07/22
Re: [PR] [FLINK-31215] [autoscaler] Backpropagate processing rate limits from non-scalable bottlenecks to upstream operators [flink-kubernetes-operator]
via GitHub
2024/07/22
Re: [PR] [FLINK-27355][runtime] Unregister JobManagerRunner after it's closed [flink]
via GitHub
2024/07/22
[jira] [Created] (FLINK-35874) Check pureBinlogPhaseTables set before call getBinlogPosition method in BinlogSplitReader
Zhongmin Qiao (Jira)
2024/07/22
Re: [PR] [FLINK-35674][cdc-connector][mysql]Fix blocking caused by searching for timestamp in binlog file [flink-cdc]
via GitHub
2024/07/22
[jira] [Updated] (FLINK-35872) Fix the incorrect partition generation during period refresh in Full Mode
dalongliu (Jira)
2024/07/22
[jira] [Resolved] (FLINK-35872) Fix the incorrect partition generation during period refresh in Full Mode
dalongliu (Jira)
2024/07/22
[jira] [Commented] (FLINK-35872) Fix the incorrect partition generation during period refresh in Full Mode
dalongliu (Jira)
2024/07/22
[jira] [Updated] (FLINK-35873) Add HashFunctionProvider for Paimon DataSink.
ASF GitHub Bot (Jira)
2024/07/22
[PR] [FLINK-35873][cdc-connector][paimon] Add HashFunctionProvider implementation for PaimonDataSink. [flink-cdc]
via GitHub
2024/07/22
[jira] [Commented] (FLINK-35634) Add a CDC quickstart utility
yux (Jira)
2024/07/22
[jira] [Created] (FLINK-35873) Add HashFunctionProvider for Paimon DataSink.
LvYanquan (Jira)
2024/07/22
Re: [PR] [FLINK-35872][table] Fix the incorrect partition generation during period refresh in Full Mode [flink]
via GitHub
2024/07/22
Re: [PR] [FLINK-34877][cdc] Flink CDC pipeline transform supports type conversion [flink-cdc]
via GitHub
2024/07/22
Re: [PR] [FLINK-27355][runtime] Unregister JobManagerRunner after it's closed [flink]
via GitHub
2024/07/22
[jira] [Commented] (FLINK-35853) Regression in checkpoint size when performing full checkpointing in RocksDB
Keith Lee (Jira)
2024/07/22
Re: [PR] [FLINK-35864][Table SQL / API] Add CONV function [flink]
via GitHub
2024/07/22
[jira] [Commented] (FLINK-35864) Add CONV function
Dylan He (Jira)
2024/07/22
[jira] [Updated] (FLINK-35864) Add CONV function
ASF GitHub Bot (Jira)
2024/07/22
[PR] [FLINK-35864][Table SQL / API] Add CONV function [flink]
via GitHub
2024/07/22
Re: [PR] [FLINK-32501][table-planner] Fix wrong plan of a proctime window aggregation generated due to incorrect cost evaluation [flink]
via GitHub
2024/07/22
[jira] [Comment Edited] (FLINK-35576) FRocksDB cherry pick IngestDB related commits
Yue Ma (Jira)
2024/07/22
[jira] [Commented] (FLINK-35576) FRocksDB cherry pick IngestDB related commits
Yue Ma (Jira)
2024/07/22
Re: [PR] [FLINK-35318][table-planner] use UTC timezone to handle TIMESTAMP_WITHOUT_TIME_ZONE type in RexNodeToExpressionConverter [flink]
via GitHub
2024/07/22
Re: [PR] [FLINK-35674][cdc-connector][mysql]Fix blocking caused by searching for timestamp in binlog file [flink-cdc]
via GitHub
2024/07/21
Re: [PR] [FLINK-35872][table] Fix the incorrect partition generation during period refresh in Full Mode [flink]
via GitHub
2024/07/21
Re: [PR] [FLINK-35865][base] Support Byte and Short in ObjectUtils [flink-cdc]
via GitHub
2024/07/21
[jira] [Resolved] (FLINK-35871) Add document for SNAPSHOT startup option mode
Leonard Xu (Jira)
2024/07/21
Re: [PR] [FLINK-35871][doc] add "snapshot" to mysql connector startup options. [flink-cdc]
via GitHub
2024/07/21
[PR] [minor][cdc-connector][mysql] catch all exceptions to display the table info [flink-cdc]
via GitHub
2024/07/21
Re: [PR] [FLINK-27355][runtime] Unregister JobManagerRunner after it's closed [flink]
via GitHub
2024/07/21
Re: [PR] [FLINK-35872][table] Fix the incorrect partition generation during period refresh in Full Mode [flink]
via GitHub
2024/07/21
Re: [PR] [FLINK-35872][table] Fix the incorrect partition generation during period refresh in Full Mode [flink]
via GitHub
2024/07/21
[jira] [Assigned] (FLINK-35871) Add document for SNAPSHOT startup option mode
Leonard Xu (Jira)
2024/07/21
[jira] [Updated] (FLINK-35871) Add document for SNAPSHOT startup option mode
Leonard Xu (Jira)
2024/07/21
[jira] [Resolved] (FLINK-35237) Allow Sink to Choose HashFunction in PrePartitionOperator
Leonard Xu (Jira)
2024/07/21
[jira] [Assigned] (FLINK-35237) Allow Sink to Choose HashFunction in PrePartitionOperator
Leonard Xu (Jira)
2024/07/21
[jira] [Updated] (FLINK-35237) Allow Sink to Choose HashFunction in PrePartitionOperator
Leonard Xu (Jira)
2024/07/21
Re: [PR] [FLINK-35237] Allow Sink to Choose HashFunction in PrePartitionOperator [flink-cdc]
via GitHub
2024/07/21
[jira] [Updated] (FLINK-35872) Fix the incorrect partition generation during period refresh in Full Mode
dalongliu (Jira)
2024/07/21
[jira] [Assigned] (FLINK-35872) Fix the incorrect partition generation during period refresh in Full Mode
dalongliu (Jira)
2024/07/21
Re: [PR] [FLINK-34944] Use Incremental Source Framework in Flink CDC OceanBase Source Connector [flink-cdc]
via GitHub
2024/07/21
Re: [PR] [FLINK-23589][flink-avro] Support microsecond precision for timestamp [flink]
via GitHub
2024/07/21
Re: [PR] [FLINK-35872][table] Fix the incorrect partition generation during period refresh in Full Mode [flink]
via GitHub
2024/07/21
[jira] [Updated] (FLINK-35872) Fix the incorrect partition generation during period refresh in Full Mode
ASF GitHub Bot (Jira)
2024/07/21
[PR] [FLINK-35872][table] Fix the incorrect partition generation during period refresh in Full Mode [flink]
via GitHub
2024/07/21
[jira] [Created] (FLINK-35872) Fix the incorrect partition generation during period refresh in Full Mode
Feng Jin (Jira)
2024/07/21
Re: [PR] [cdc-connector][postgres]Flink cdc pipeline support postgres source [flink-cdc]
via GitHub
2024/07/21
Re: [PR] [cdc-connector][sqlserver]Flink cdc pipeline support sqlserver source [flink-cdc]
via GitHub
2024/07/20
[jira] [Updated] (FLINK-35871) Add document for SNAPSHOT startup option mode
ASF GitHub Bot (Jira)
2024/07/20
[jira] [Created] (FLINK-35871) Add document for SNAPSHOT startup option mode
LvYanquan (Jira)
2024/07/20
Re: [PR] [WIP] [FLINK-XXXX] Generalized watermark wip [flink]
via GitHub
2024/07/20
Re: [PR] [FLINK-34657] extract lineage info for stream API [flink]
via GitHub
2024/07/20
Re: [PR] [FLINK-34657] extract lineage info for stream API [flink]
via GitHub
2024/07/20
[jira] [Updated] (FLINK-35870) Change DEFAULT_KAFKA_TRANSACTION_TIMEOUT in KafkaSinkBuilder
LEE SOMANG (Jira)
2024/07/20
[jira] [Updated] (FLINK-35870) Change DEFAULT_KAFKA_TRANSACTION_TIMEOUT in KafkaSinkBuilder
LEE SOMANG (Jira)
2024/07/20
[jira] [Updated] (FLINK-35870) Change DEFAULT_KAFKA_TRANSACTION_TIMEOUT in KafkaSinkBuilder
LEE SOMANG (Jira)
2024/07/20
[jira] [Created] (FLINK-35870) Change DEFAULT_KAFKA_TRANSACTION_TIMEOUT in KafkaSinkBuilder
LEE SOMANG (Jira)
2024/07/19
Re: [PR] [cdc-runtime]The processedTableIds add is executed twice [flink-cdc]
via GitHub
2024/07/19
Re: [PR] [cdc-runtime]The processedTableIds add is executed twice [flink-cdc]
via GitHub
2024/07/19
[jira] [Commented] (FLINK-35857) Operator restart failed job without latest checkpoint
chenyuzhi (Jira)
2024/07/19
[jira] [Updated] (FLINK-35857) Operator restart failed job without latest checkpoint
ASF GitHub Bot (Jira)
2024/07/19
[PR] [FLINK-FLINK-35857] fix restart failed deployment without latest checkpoint [flink-kubernetes-operator]
via GitHub
2024/07/19
Re: [PR] [FLINK-35847][release] Add release note for version 1.20 [flink]
via GitHub
2024/07/19
Re: [PR] Add protoc service and dynamic deserializer skeleton [flink]
via GitHub
2024/07/19
Re: [PR] Add protoc service and dynamic deserializer skeleton [flink]
via GitHub
2024/07/19
[PR] Add protoc service and dynamic deserializer skeleton [flink]
via GitHub
2024/07/19
Re: [PR] [WIP] [FLINK-XXXX] Generalized watermark wip [flink]
via GitHub
2024/07/19
Re: [PR] [DRAFT][FLINK-34440][formats][protobuf-confluent] add support for protobuf-confluent [flink]
via GitHub
2024/07/19
[jira] [Commented] (FLINK-12450) [Bitwise Functions] Add BIT_LSHIFT, BIT_RSHIFT functions supported in Table API and SQL
Kartikey Pant (Jira)
2024/07/19
[jira] [Updated] (FLINK-35851) autoscaler standlone mode use `GlobalConfiguration.loadConfiguration` load config
ASF GitHub Bot (Jira)
2024/07/19
Re: [PR] [FLINK-35851][autoscaler] Introduce GlobalConfiguration.loadConfiguration load config [flink-kubernetes-operator]
via GitHub
2024/07/19
[jira] [Updated] (FLINK-35869) Right side columns of temporal left join are always null when right side is filtered
Jira
2024/07/19
[jira] [Updated] (FLINK-35869) Right side columns of temporal left join are always null when right side is filtered
Jira
2024/07/19
[jira] [Updated] (FLINK-35869) Right side columns of temporal left join are always null when right side is filtered
Jira
2024/07/19
[jira] [Updated] (FLINK-35869) Right side columns of temporal left join are always null when right side is filtered
Jira
2024/07/19
[jira] [Updated] (FLINK-35869) Right side columns of temporal left join are always null when right side is filtered
Jira
2024/07/19
[jira] [Updated] (FLINK-35869) Right side columns of temporal left join are always null when right side is filtered
Jira
2024/07/19
[jira] [Created] (FLINK-35869) Right side columns of temporal left join are always null when right side is filtered
Jira
2024/07/19
Re: [PR] [FLINK-28893][table] Add built-in conv function. [flink]
via GitHub
2024/07/19
Re: [PR] [FLINK-35815][autoscaler] Introduce GlobalConfiguration.loadConfiguration load config [flink-kubernetes-operator]
via GitHub
2024/07/19
[jira] [Comment Edited] (FLINK-35832) IFNULL returns incorrect result in Flink SQL
dalongliu (Jira)
2024/07/19
[jira] [Resolved] (FLINK-35832) IFNULL returns incorrect result in Flink SQL
dalongliu (Jira)
2024/07/19
[jira] [Comment Edited] (FLINK-35832) IFNULL returns incorrect result in Flink SQL
dalongliu (Jira)
2024/07/19
Re: [PR] [FLINK-35832][Table SQL / Planner] Fix IFNULL outputTypeStrategy [flink]
via GitHub
2024/07/19
Re: [PR] [FLINK-35832][Table SQL / Planner] Fix IFNULL outputTypeStrategy [flink]
via GitHub
2024/07/19
Jira account created: placeholder-flink
ASF Self-serve Portal
2024/07/19
Please verify your email address
ASF Self-serve Portal
2024/07/19
[jira] [Commented] (FLINK-35860) S5CmdOnMinioITCase failed due to IllegalAccessError in JDK17/21
Piotr Nowojski (Jira)
2024/07/19
Re: [PR] [FLINK-34865][pipeline-connector]support sync table and column comments [flink-cdc]
via GitHub
2024/07/19
[PR] [FLINK-34865][pipeline-connector]support sync table and column comments [flink-cdc]
via GitHub
2024/07/19
[jira] [Updated] (FLINK-34865) [enhancement] [StarRocks] When synchronizing tables using Flink CDC 3.x, is it possible to include the comments of the source table's fields when creating the target table?
ASF GitHub Bot (Jira)
2024/07/19
[jira] [Created] (FLINK-35868) Bump Mongo driver version to support Mongo 7.0+
yux (Jira)
2024/07/19
Re: [PR] [FLINK-35237] Allow Sink to Choose HashFunction in PrePartitionOperator [flink-cdc]
via GitHub
2024/07/19
Re: [PR] [FLINK-35237] Allow Sink to Choose HashFunction in PrePartitionOperator [flink-cdc]
via GitHub
2024/07/19
[jira] [Closed] (FLINK-31261) Make AdaptiveScheduler aware of the (local) state size
Roman Khachatryan (Jira)
Earlier messages
Later messages