issues
Thread
Date
Earlier messages
Messages by Thread
[jira] [Commented] (FLINK-37540) Introduce SupportsTargetColumnWriting sink ability
dalongliu (Jira)
[jira] [Created] (FLINK-37548) FLIP-507 : Add Model DDL methods in TABLE API
Yash Anand (Jira)
[jira] [Commented] (FLINK-33933) SerializedThrowable will be java.lang.StackOverflowError when AsyncLookupFunction throw an exception
Ian Stewart (Jira)
[PR] [hotfix] Fix the broken TOC [flink-web]
via GitHub
Re: [PR] [hotfix] Fix the broken TOC [flink-web]
via GitHub
Re: [PR] [hotfix] Fix the broken TOC [flink-web]
via GitHub
[jira] [Comment Edited] (FLINK-37524) State Serializer in ForState should restore from oldStateInfo in Checkpoint
Yue Ma (Jira)
[jira] [Assigned] (FLINK-37524) State Serializer in ForState should restore from oldStateInfo in Checkpoint
Yanfei Lei (Jira)
[jira] [Closed] (FLINK-37423) Add support for PTFs in Table API
Timo Walther (Jira)
Re: [PR] [FLINK-37539] Replace stream with parallelStream to optimize the performance. [flink-cdc]
via GitHub
[jira] [Created] (FLINK-37545) StackOverflowError when using MetricGroup in custom WatermarkStrategy
Grzegorz Liter (Jira)
[jira] [Created] (FLINK-37529) Add flink-cdc-commo to the package to all the incremental source framework
Hongshun Wang (Jira)
[jira] [Commented] (FLINK-37516) Whether to only synchronize the structure of the table.
david radley (Jira)
[jira] [Comment Edited] (FLINK-34992) FLIP-437: Support ML Models in Flink SQL
Thomas Cooper (Jira)
[jira] [Comment Edited] (FLINK-34992) FLIP-437: Support ML Models in Flink SQL
Thomas Cooper (Jira)
[jira] [Commented] (FLINK-34992) FLIP-437: Support ML Models in Flink SQL
Thomas Cooper (Jira)
Re: [PR] Fixed the problem of using the same executor to process schema change requests and flush event requests, resulting in blocking timeout. [flink-cdc]
via GitHub
[jira] [Commented] (FLINK-37534) Add Liniting checks to all PRs
david radley (Jira)
[jira] [Commented] (FLINK-37534) Add Liniting checks to all PRs
Thomas Cooper (Jira)
[jira] [Updated] (FLINK-37544) Replace Timer with single thread scheduled executor for BlobServer
ASF GitHub Bot (Jira)
[PR] [hotfix] Preconditions.checkState should follows the Flink code style [flink]
via GitHub
Re: [PR] [hotfix] Preconditions.checkState should follows the Flink code style [flink]
via GitHub
Re: [PR] [hotfix] Preconditions.checkState should follows the Flink code style [flink]
via GitHub
Re: [PR] [hotfix] Preconditions.checkState should follows the Flink code style [flink]
via GitHub
[jira] [Updated] (FLINK-37546) KryoSerializer breaks without Twitter Chill library
Maximilian Michels (Jira)
[jira] [Commented] (FLINK-35886) Incorrect watermark idleness timeout accounting when subtask is backpressured/blocked
Grzegorz Liter (Jira)
[jira] [Updated] (FLINK-37547) Add initial document for PTFs
Timo Walther (Jira)
Re: [PR] Update generating_watermarks.md [flink]
via GitHub
[jira] [Updated] (FLINK-37545) StackOverflowError when using MetricGroup in custom WatermarkStrategy
Grzegorz Liter (Jira)
[jira] [Updated] (FLINK-37545) StackOverflowError when using MetricGroup in custom WatermarkStrategy
Grzegorz Liter (Jira)
[jira] [Updated] (FLINK-37545) StackOverflowError when using MetricGroup in custom WatermarkStrategy
Grzegorz Liter (Jira)
[jira] [Updated] (FLINK-37545) StackOverflowError when using MetricGroup in custom WatermarkStrategy
Grzegorz Liter (Jira)
[jira] [Updated] (FLINK-37545) StackOverflowError when using MetricGroup in custom WatermarkStrategy
Grzegorz Liter (Jira)
[jira] [Updated] (FLINK-37545) StackOverflowError when using MetricGroup in custom WatermarkStrategy
Grzegorz Liter (Jira)
[jira] [Created] (FLINK-37546) KryoSerializer breaks without Twitter Chill library
Maximilian Michels (Jira)
[PR] [FLINK-37544] Replace Timer with single thread scheduled executor for BlobServer [flink]
via GitHub
Re: [PR] [FLINK-37544] Replace Timer with single thread scheduled executor for BlobServer [flink]
via GitHub
[jira] [Created] (FLINK-37544) Replace Timer with single thread scheduled executor for BlobServer
Jiaan Geng (Jira)
[jira] [Created] (FLINK-37541) Deprecate getTargetColumns in DynamicTableSink.Context
xiangyu feng (Jira)
Re: [PR] [FLINK-36813][cdc-connectors][mysql] support mysql sync part columns [flink-cdc]
via GitHub
[jira] [Commented] (FLINK-37524) State Serializer in ForState should restore from oldStateInfo in Checkpoint
Yue Ma (Jira)
[jira] [Commented] (FLINK-37524) State Serializer in ForState should restore from oldStateInfo in Checkpoint
Yanfei Lei (Jira)
[jira] [Commented] (FLINK-37524) State Serializer in ForState should restore from oldStateInfo in Checkpoint
Yue Ma (Jira)
[jira] [Commented] (FLINK-37524) State Serializer in ForState should restore from oldStateInfo in Checkpoint
Yanfei Lei (Jira)
[jira] [Commented] (FLINK-37524) State Serializer in ForState should restore from oldStateInfo in Checkpoint
Yue Ma (Jira)
[jira] [Commented] (FLINK-37524) State Serializer in ForState should restore from oldStateInfo in Checkpoint
Yanfei Lei (Jira)
[jira] [Created] (FLINK-37542) Support sink reuse in streaming mode
xiangyu feng (Jira)
[jira] [Created] (FLINK-37543) Support sink reuse in batch mode
xiangyu feng (Jira)
[jira] [Created] (FLINK-37540) Introduce SupportsTargetColumnWriting sink ability
xiangyu feng (Jira)
[jira] [Assigned] (FLINK-37536) Improve SQL gateway documentation
Shengkai Fang (Jira)
[jira] [Commented] (FLINK-37539) performance optimization in Paimon Sink to reduce end-to-end checkpoint time
Yanquan Lv (Jira)
[jira] [Commented] (FLINK-37539) performance optimization in Paimon Sink to reduce end-to-end checkpoint time
Yanquan Lv (Jira)
[jira] [Updated] (FLINK-37539) performance optimization in Paimon Sink to reduce end-to-end checkpoint time
Yanquan Lv (Jira)
[jira] [Updated] (FLINK-37539) performance optimization in Paimon Sink to reduce end-to-end checkpoint time
ASF GitHub Bot (Jira)
[jira] [Resolved] (FLINK-37532) Job recovery always starts from initialSavepointPath when JobManager HA is disabled in case of jobManger failure
Gyula Fora (Jira)
Re: [PR] [FLINK-37222][table] Don't resolve the CatalogView to QueryOperationCatalogView [flink]
via GitHub
[PR] [hotfix] Short circuit judgment for create blob storage dir [flink]
via GitHub
Re: [PR] [hotfix] Short circuit judgment for create blob storage dir [flink]
via GitHub
Re: [PR] [hotfix] Short circuit judgment for create blob storage dir [flink]
via GitHub
Re: [PR] [hotfix] Short circuit judgment for create blob storage dir [flink]
via GitHub
Re: [PR] [hotfix] Short circuit judgment for create blob storage dir [flink]
via GitHub
Re: [PR] [hotfix] Short circuit judgment for create blob storage dir [flink]
via GitHub
Re: [PR] [FLINK-37507] Fix MySQL CDC accidentally captures common-prefix database when `scan.binlog.newly-added-table` is enabled [flink-cdc]
via GitHub
Re: [PR] [FLINK-37507] Fix MySQL CDC accidentally captures common-prefix database when `scan.binlog.newly-added-table` is enabled [flink-cdc]
via GitHub
Re: [PR] [FLINK-37507] Fix MySQL CDC accidentally captures common-prefix database when `scan.binlog.newly-added-table` is enabled [flink-cdc]
via GitHub
[PR] [hotfix] Rename VoidBlobStore to NoOperationBlobStore [flink]
via GitHub
Re: [PR] [hotfix] Rename VoidBlobStore to NoOperationBlobStore [flink]
via GitHub
Re: [PR] [hotfix] Rename VoidBlobStore to NoOperationBlobStore [flink]
via GitHub
Re: [PR] [hotfix] Rename VoidBlobStore to NoOperationBlobStore [flink]
via GitHub
Re: [PR] [hotfix] Rename VoidBlobStore to NoOperationBlobStore [flink]
via GitHub
Re: [PR] [hotfix] Rename VoidBlobStore to NoOperationBlobStore [flink]
via GitHub
Re: [PR] [hotfix] Rename VoidBlobStore to NoOperationBlobStore [flink]
via GitHub
Re: [PR] [FLINK-35670][cdc-connector][postgres]Flink cdc pipeline support postgres source [flink-cdc]
via GitHub
Re: [PR] [hotfix] [base] Fix the serialization error occurring with table names containing dot [flink-cdc]
via GitHub
Re: [PR] [FLINK-37128][pipeline-connector/mysql] Binlog reader skip `shouldEmit` filter when snapshot reader skip backfill [flink-cdc]
via GitHub
Re: [PR] [FLINK-37128][pipeline-connector/mysql] Binlog reader skip `shouldEmit` filter when snapshot reader skip backfill [flink-cdc]
via GitHub
[PR] [FLINK-37531] Respect the design of chain programming for RpcServiceBuilder [flink]
via GitHub
Re: [PR] [FLINK-37531] Respect the design of chain programming for RpcServiceBuilder [flink]
via GitHub
Re: [PR] [FLINK-37531] Respect the design of chain programming for RpcServiceBuilder [flink]
via GitHub
Re: [PR] [FLINK-37531] Respect the design of chain programming for RpcServiceBuilder [flink]
via GitHub
Re: [PR] [FLINK-37531] Respect the design of chain programming for RpcServiceBuilder [flink]
via GitHub
Re: [PR] [FLINK-37531] Respect the design of chain programming for RpcServiceBuilder [flink]
via GitHub
Re: [PR] [FLINK-37531] Respect the design of chain programming for RpcServiceBuilder [flink]
via GitHub
Re: [PR] [FLINK-37531] Respect the design of chain programming for RpcServiceBuilder [flink]
via GitHub
Re: [PR] [FLINK-37531] Respect the design of chain programming for RpcServiceBuilder [flink]
via GitHub
Re: [PR] [FLINK-37531] Respect the design of chain programming for RpcServiceBuilder [flink]
via GitHub
Re: [PR] [FLINK-37531] Respect the design of chain programming for RpcServiceBuilder [flink]
via GitHub
Re: [PR] [FLINK-37531] Respect the design of chain programming for RpcServiceBuilder [flink]
via GitHub
Re: [PR] [FLINK-37531] Respect the design of chain programming for RpcServiceBuilder [flink]
via GitHub
Re: [PR] [FLINK-37531] Respect the design of chain programming for RpcServiceBuilder [flink]
via GitHub
[jira] [Created] (FLINK-37537) Duplicate key when job failover in SchemaOperator
linqigeng (Jira)
[jira] [Closed] (FLINK-37222) Table planner exception when sql client submit job
Shengkai Fang (Jira)
Re: [PR] [FLINK-37506][transform] Print more descriptive error messages when TransformOperator throws an exception [flink-cdc]
via GitHub
Re: [PR] [FLINK-37506][transform] Print more descriptive error messages when TransformOperator throws an exception [flink-cdc]
via GitHub
Re: [PR] [FLINK-37506][transform] Print more descriptive error messages when TransformOperator throws an exception [flink-cdc]
via GitHub
Re: [PR] [FLINK-37506][transform] Print more descriptive error messages when TransformOperator throws an exception [flink-cdc]
via GitHub
[PR] [FLINK-36443][table][test] Improve flaky table source sink tests [flink]
via GitHub
Re: [PR] [FLINK-36443][table][test] Improve flaky table source sink tests [flink]
via GitHub
Re: [PR] [FLINK-36443][table][test] Improve flaky table source sink tests [flink]
via GitHub
Re: [PR] [FLINK-36443][table][test] Improve flaky table source sink tests [flink]
via GitHub
Re: [PR] [FLINK-36443][table][test] Improve flaky table source sink tests [flink]
via GitHub
Re: [PR] [FLINK-36443][table][test] Improve flaky table source sink tests [flink]
via GitHub
Re: [PR] [FLINK-36443][table][test] Improve flaky table source sink tests [flink]
via GitHub
[jira] [Commented] (FLINK-37535) [Metrics] Add InfluxDB v3 Metrics Reporter
Michael Koepf (Jira)
[jira] [Updated] (FLINK-37535) [Metrics] Add InfluxDB v3 Metrics Reporter
Michael Koepf (Jira)
[jira] [Updated] (FLINK-37535) [Metrics] Add InfluxDB v3 Metrics Reporter
Michael Koepf (Jira)
[jira] [Updated] (FLINK-37535) [Metrics] Add InfluxDB v3 Metrics Reporter
Michael Koepf (Jira)
[jira] [Updated] (FLINK-37535) [Metrics] Add InfluxDB v3 Metrics Reporter
Michael Koepf (Jira)
[jira] [Created] (FLINK-37535) [Metrics] Add InfluxDB v3 Metrics Reporter
Michael Koepf (Jira)
[jira] [Commented] (FLINK-28516) UI is misleading when source doesn't emit watermark due to misconfigured idleness
Poorvank Bhatia (Jira)
[PR] [WIP][FLINK-37453][tests] Port Ruby migration tests to Java [flink-cdc]
via GitHub
Re: [PR] [WIP][FLINK-37453][tests] Port Ruby migration tests to Java [flink-cdc]
via GitHub
[jira] [Created] (FLINK-37533) Reduce Stale PR Action timeouts
Thomas Cooper (Jira)
Re: [PR] [FLINK-19059]: Add NonTimeRangeUnboundedPrecedingFunction for OverAggregate [flink]
via GitHub
[jira] [Created] (FLINK-37534) Add Liniting checks to all PRs
Thomas Cooper (Jira)
Re: [PR] [FLINK-37533][CI] Reduce the stale PR github action timouts [flink]
via GitHub
Re: [PR] [FLINK-37533][CI] Reduce the stale PR github action timouts [flink]
via GitHub
Re: [PR] [FLINK-37533][CI] Reduce the stale PR github action timouts [flink]
via GitHub
[jira] [Updated] (FLINK-37533) Reduce Stale PR Action timeouts
ASF GitHub Bot (Jira)
[jira] [Commented] (FLINK-37532) Job recovery always starts from initialSavepointPath when JobManager HA is disabled in case of jobManger failure
Gyula Fora (Jira)
[jira] [Commented] (FLINK-37532) Job recovery always starts from initialSavepointPath when JobManager HA is disabled in case of jobManger failure
Jun He (Jira)
[jira] [Created] (FLINK-37532) Job recovery always starts from initialSavepointPath when JobManager HA is disabled in case of jobManger failure
Jun He (Jira)
[jira] [Updated] (FLINK-35350) Add documentation for Kudu connector
Ferenc Csaky (Jira)
[jira] [Updated] (FLINK-37531) Respect the design of chain programming for RpcServiceBuilder
ASF GitHub Bot (Jira)
[jira] [Created] (FLINK-37531) Respect the design of chain programming for RpcServiceBuilder
Jiaan Geng (Jira)
[jira] [Closed] (FLINK-37527) Add `KuduSource` documentation
Ferenc Csaky (Jira)
[jira] [Created] (FLINK-37530) Upgrade savepoints are not added to deprecated savepointinfo
Gyula Fora (Jira)
Re: [PR] [FLINK-36829] Add better validation of pipeline config [flink-cdc]
via GitHub
Re: [PR] [FLINK-35713][common] Support set parallelism in source and sink [flink-cdc]
via GitHub
[PR] [hotfix] Rename the variable `result` to `config` [flink]
via GitHub
Re: [PR] [hotfix] Rename the variable `result` to `config` [flink]
via GitHub
Re: [PR] [hotfix] Rename the variable `result` to `config` [flink]
via GitHub
[jira] [Updated] (FLINK-37525) Introduce overload findModuleFactory to improve the performance of installModules
Jiaan Geng (Jira)
[jira] [Updated] (FLINK-37525) Introduce overload findModuleFactory to improve the performance of installModules
Jiaan Geng (Jira)
[jira] [Updated] (FLINK-37525) Introduce overload findModuleFactory to improve the performance of installModules
Jiaan Geng (Jira)
[jira] [Updated] (FLINK-37525) Introduce overload findModuleFactory to improve the performance of installModules
Jiaan Geng (Jira)
Re: [PR] [hotfix] change bytesReceivedPerInterface to AtomicLongArray for thread safety [flink]
via GitHub
Re: [PR] [hotfix] change bytesReceivedPerInterface to AtomicLongArray for thread safety [flink]
via GitHub
Re: [PR] [hotfix] change bytesReceivedPerInterface to AtomicLongArray for thread safety [flink]
via GitHub
[jira] [Updated] (FLINK-37528) Protobuf Format (proto3): Handle default values for optional primitive types and primitive types in one of fields
Sai Sharath Dandi (Jira)
[jira] [Resolved] (FLINK-37460) Using State Processor API and Kafka Sink with Exactly once delivery leads to org.apache.kafka.common.errors.InvalidPidMappingException
Gabor Somogyi (Jira)
Re: [PR] [FLINK-30284][flink-metrics] Adding datacenter url property to datadog [flink]
via GitHub
[jira] [Closed] (FLINK-37460) Using State Processor API and Kafka Sink with Exactly once delivery leads to org.apache.kafka.common.errors.InvalidPidMappingException
Gabor Somogyi (Jira)
[PR] [FLINK-37527] Add `KuduSource` documentation [flink-connector-kudu]
via GitHub
Re: [PR] [FLINK-37527] Add `KuduSource` documentation [flink-connector-kudu]
via GitHub
Re: [PR] [FLINK-37527] Add `KuduSource` documentation [flink-connector-kudu]
via GitHub
[jira] [Updated] (FLINK-37527) Add `KuduSource` documentation
ASF GitHub Bot (Jira)
[jira] [Resolved] (FLINK-37505) Pyflink is not able to handle the new YAML based configs
Gabor Somogyi (Jira)
[jira] [Closed] (FLINK-37505) Pyflink is not able to handle the new YAML based configs
Gabor Somogyi (Jira)
Re: [PR] Cp FLINK-37222 [flink]
via GitHub
[jira] [Commented] (FLINK-27419) Endpoint to cancel savepoints
Anirudh Prabhakaran (Jira)
[PR] [FLINK-37423][table] Support PTFs in Table API [flink]
via GitHub
Re: [PR] [FLINK-37423][table] Support PTFs in Table API [flink]
via GitHub
Re: [PR] [FLINK-37423][table] Support PTFs in Table API [flink]
via GitHub
Re: [PR] [FLINK-37423][table] Support PTFs in Table API [flink]
via GitHub
Re: [PR] [FLINK-37423][table] Support PTFs in Table API [flink]
via GitHub
Re: [PR] [FLINK-37423][table] Support PTFs in Table API [flink]
via GitHub
Re: [PR] [FLINK-37423][table] Support PTFs in Table API [flink]
via GitHub
[jira] [Created] (FLINK-37527) Add `KuduSource` documentation
Ferenc Csaky (Jira)
Re: [PR] [FLINK-37375][checkpointing] Checkpoint supports the Operator to cust… [flink]
via GitHub
Re: [PR] [FLINK-37375][checkpointing] Checkpoint supports the Operator to cust… [flink]
via GitHub
Re: [PR] [FLINK-37375][checkpointing] Checkpoint supports the Operator to cust… [flink]
via GitHub
Re: [PR] [FLINK-37375][checkpointing] Checkpoint supports the Operator to cust… [flink]
via GitHub
[jira] [Updated] (FLINK-37375) Checkpoint supports the Operator to customize asynchronous snapshot state
ASF GitHub Bot (Jira)
[jira] [Updated] (FLINK-37375) Checkpoint supports the Operator to customize asynchronous snapshot state
Zakelly Lan (Jira)
[PR] [FLINK-37525] Introduce a overload findModuleFactory to improve the performance of installModules [flink]
via GitHub
Re: [PR] [FLINK-37525] Introduce a overload findModuleFactory to improve the performance of installModules [flink]
via GitHub
[jira] [Created] (FLINK-37525) Introduce overload findModuleFactory to improve the performance of installModules
Jiaan Geng (Jira)
[jira] [Created] (FLINK-37524) State Serializer in ForState should restore from oldStateInfo in Checkpoint
Yue Ma (Jira)
[jira] [Updated] (FLINK-37523) e2e: Test stream python udf sql job fails
Fabian Paul (Jira)
[jira] [Created] (FLINK-37523) e2e: Test stream python udf sql job fails
Fabian Paul (Jira)
[jira] [Updated] (FLINK-37520) Introduce KeyedCoProcessOperator with async state API
Yanfei Lei (Jira)
[PR] [FLINK-37521][runtime] Introduce KeyedCoProcessOperator with async state API [flink]
via GitHub
Re: [PR] [FLINK-37521][runtime] Introduce KeyedCoProcessOperator with async state API [flink]
via GitHub
Re: [PR] [FLINK-37521][runtime] Introduce KeyedCoProcessOperator with async state API [flink]
via GitHub
Re: [PR] [FLINK-37521][runtime] Introduce KeyedCoProcessOperator with async state API [flink]
via GitHub
Re: [PR] [FLINK-37521][runtime] Introduce KeyedCoProcessOperator with async state API [flink]
via GitHub
Re: [PR] [FLINK-37521][runtime] Introduce KeyedCoProcessOperator with async state API [flink]
via GitHub
Re: [PR] [FLINK-37521][runtime] Introduce KeyedCoProcessOperator with async state API [flink]
via GitHub
Re: [PR] [FLINK-37521][runtime] Introduce KeyedCoProcessOperator with async state API [flink]
via GitHub
Re: [PR] [FLINK-37521][runtime] Introduce KeyedCoProcessOperator with async state API [flink]
via GitHub
Re: [PR] [FLINK-37521][runtime] Introduce KeyedCoProcessOperator with async state API [flink]
via GitHub
Re: [PR] [FLINK-37521][runtime] Introduce KeyedCoProcessOperator with async state API [flink]
via GitHub
Re: [PR] [FLINK-37521][runtime] Introduce KeyedCoProcessOperator with async state API [flink]
via GitHub
Re: [PR] [FLINK-37521][runtime] Introduce KeyedCoProcessOperator with async state API [flink]
via GitHub
Re: [PR] [FLINK-37521][runtime] Introduce KeyedCoProcessOperator with async state API [flink]
via GitHub
Re: [PR] [FLINK-37521][runtime] Introduce KeyedCoProcessOperator with async state API [flink]
via GitHub
Re: [PR] [FLINK-37521][runtime] Introduce KeyedCoProcessOperator with async state API [flink]
via GitHub
Re: [PR] [FLINK-37521][runtime] Introduce KeyedCoProcessOperator with async state API [flink]
via GitHub
Re: [PR] [FLINK-37521][runtime] Introduce KeyedCoProcessOperator with async state API [flink]
via GitHub
Re: [PR] [FLINK-37521][runtime] Introduce KeyedCoProcessOperator with async state API [flink]
via GitHub
Re: [PR] [FLINK-37521][runtime] Introduce KeyedCoProcessOperator with async state API [flink]
via GitHub
[jira] [Updated] (FLINK-37521) Introduce CoStreamFlatMap with async state API
ASF GitHub Bot (Jira)
[jira] [Updated] (FLINK-37521) Introduce CoStreamFlatMap with async state API
Yanfei Lei (Jira)
[jira] [Commented] (FLINK-37505) Pyflink is not able to handle the new YAML based configs
Gabor Somogyi (Jira)
[jira] [Commented] (FLINK-37505) Pyflink is not able to handle the new YAML based configs
Gabor Somogyi (Jira)
[jira] [Updated] (FLINK-37522) Add description for the config about file system connection limit
ASF GitHub Bot (Jira)
[PR] [FLINK-37522][docs] Add description for the config about file system connection limit [flink]
via GitHub
Re: [PR] [FLINK-37522][docs] Add description for the config about file system connection limit [flink]
via GitHub
Re: [PR] [FLINK-37522][docs] Add description for the config about file system connection limit [flink]
via GitHub
Earlier messages