issues
Thread
Date
Earlier messages
Messages by Date
2024/10/04
[jira] [Commented] (FLINK-22748) Allow dynamic target topic selection in SQL Kafka sinks
Jira
2024/10/04
[jira] [Updated] (FLINK-36423) RichMapPartitionFunction does not invoke the open method in the KeyedPartitionWindowedStream
xuhuang (Jira)
2024/10/04
[jira] [Updated] (FLINK-36423) RichMapPartitionFunction not call open method in KeyedPartitionWindowedStream
xuhuang (Jira)
2024/10/04
[jira] [Resolved] (FLINK-31986) Implement Integration test for FLIP-27 DataStreams API
Hong Liang Teoh (Jira)
2024/10/04
[jira] [Created] (FLINK-36425) Use JobStatus enum for status.job.state
Gyula Fora (Jira)
2024/10/04
[jira] [Closed] (FLINK-35414) Cancel jobs through rest api for last-state upgrades
Gyula Fora (Jira)
2024/10/04
[jira] [Comment Edited] (FLINK-36420) Upgrade org.apache.avro:avro to 1.11.4
Danny Cranmer (Jira)
2024/10/04
[jira] [Resolved] (FLINK-36420) Upgrade org.apache.avro:avro to 1.11.4
Danny Cranmer (Jira)
2024/10/04
[jira] [Comment Edited] (FLINK-36420) Upgrade org.apache.avro:avro to 1.11.4
Danny Cranmer (Jira)
2024/10/04
[jira] [Commented] (FLINK-36421) Missing fsync in FsCheckpointStreamFactory
Gabor Somogyi (Jira)
2024/10/04
[jira] [Resolved] (FLINK-36422) Broken PyFlink jar download link for Kafka connector
Danny Cranmer (Jira)
2024/10/03
[jira] [Commented] (FLINK-35650) Incorrect TIMESTAMP_LTZ type behavior in Table SQL
Ammu Parvathy (Jira)
2024/10/03
[jira] [Comment Edited] (FLINK-36423) Fix RichMapPartitionFunction not call open method in KeyedPartitionWindowedStream
xuhuang (Jira)
2024/10/03
[jira] [Updated] (FLINK-36423) Fix RichMapPartitionFunction not call open in KeyedPartitionWindowedStream
xuhuang (Jira)
2024/10/03
[jira] [Commented] (FLINK-36423) Support RichMapPartitionFunction on KeyedPartitionWindowedStream
xuhuang (Jira)
2024/10/03
[jira] [Updated] (FLINK-36423) Fix RichMapPartitionFunction not call open method in KeyedPartitionWindowedStream
xuhuang (Jira)
2024/10/03
[jira] [Updated] (FLINK-36423) Support RichMapPartitionFunction on KeyedPartitionWindowedStream
xuhuang (Jira)
2024/10/03
[jira] [Updated] (FLINK-36423) Support RichMapPartitionFunction on KyedPartitionWindowedStream
xuhuang (Jira)
2024/10/03
[jira] [Created] (FLINK-36423) Support RichMapPartitionFunction on KyedPartitionWindowedStream
xuhuang (Jira)
2024/10/03
[jira] [Resolved] (FLINK-34555) Migrate JoinConditionTypeCoerceRule
Sergey Nuyanzin (Jira)
2024/10/03
[jira] [Commented] (FLINK-36181) Drop support for Java 8 and use Java 17 by default
Danny Cranmer (Jira)
2024/10/03
[jira] [Commented] (FLINK-36181) Drop support for Java 8 and use Java 17 by default
Aleksandr Pilipenko (Jira)
2024/10/03
[jira] [Comment Edited] (FLINK-36181) Drop support for Java 8 and use Java 17 by default
Danny Cranmer (Jira)
2024/10/03
[jira] [Comment Edited] (FLINK-36420) Upgrade org.apache.avro:avro to 1.11.4
Danny Cranmer (Jira)
2024/10/03
[jira] [Commented] (FLINK-36181) Drop support for Java 8 and use Java 17 by default
Danny Cranmer (Jira)
2024/10/03
[jira] [Assigned] (FLINK-36181) Drop support for Java 8 and use Java 17 by default
Danny Cranmer (Jira)
2024/10/03
[jira] [Updated] (FLINK-36422) Broken PyFlink jar download link for Kafka connector
Danny Cranmer (Jira)
2024/10/03
[jira] [Commented] (FLINK-36422) Broken PyFlink jar download link for Kafka connector
Danny Cranmer (Jira)
2024/10/03
[jira] [Assigned] (FLINK-35141) Release flink-connector-pulsar v4.2.0 for Flink 1.19
Danny Cranmer (Jira)
2024/10/03
[jira] [Assigned] (FLINK-35142) Release flink-connector-rabbitmq v3.1.0 for Flink 1.19
Danny Cranmer (Jira)
2024/10/03
[jira] [Updated] (FLINK-36422) Broken PyFlink jar download link for Kafka connector
Danny Cranmer (Jira)
2024/10/03
[jira] [Assigned] (FLINK-36422) Broken PyFlink jar download link for Kafka connector
Danny Cranmer (Jira)
2024/10/03
[jira] [Resolved] (FLINK-36417) STATE_TTL doesn't work with WatermarkAssigner
Sergey Nuyanzin (Jira)
2024/10/03
[jira] [Commented] (FLINK-36417) STATE_TTL doesn't work with WatermarkAssigner
Sergey Nuyanzin (Jira)
2024/10/03
[jira] [Commented] (FLINK-36421) Missing fsync in FsCheckpointStreamFactory
Gabor Somogyi (Jira)
2024/10/03
[jira] [Updated] (FLINK-36420) Upgrade org.apache.avro:avro to 1.11.4
Danny Cranmer (Jira)
2024/10/03
[jira] [Commented] (FLINK-36420) Upgrade org.apache.avro:avro to 1.11.4
Danny Cranmer (Jira)
2024/10/03
[jira] [Updated] (FLINK-36422) Broken PyFlink jar download link for Kafka connector
Aleksandr Pilipenko (Jira)
2024/10/03
[jira] [Created] (FLINK-36422) Broken PyFlink jar download link for Kafka connector
Aleksandr Pilipenko (Jira)
2024/10/03
[jira] [Updated] (FLINK-32483) RescaleCheckpointManuallyITCase.testCheckpointRescalingOutKeyedState fails on AZP
Jira
2024/10/03
[jira] [Commented] (FLINK-32483) RescaleCheckpointManuallyITCase.testCheckpointRescalingOutKeyedState fails on AZP
Jira
2024/10/03
[jira] [Resolved] (FLINK-35706) FLIP-463: Schema Definition in CREATE TABLE AS Statement
Jira
2024/10/03
[jira] [Created] (FLINK-36421) Missing fsync in FsCheckpointStreamFactory
Marc Aurel Fritz (Jira)
2024/10/03
[jira] [Resolved] (FLINK-36336) Remove deprecated dataset API
Weijie Guo (Jira)
2024/10/03
[jira] [Commented] (FLINK-36336) Remove deprecated dataset API
Weijie Guo (Jira)
2024/10/03
[jira] [Commented] (FLINK-36420) Upgrade org.apache.avro:avro to 1.11.4
david radley (Jira)
2024/10/03
[jira] [Created] (FLINK-36420) Upgrade org.apache.avro:avro to 1.11.4
Danny Cranmer (Jira)
2024/10/03
[jira] [Assigned] (FLINK-36420) Upgrade org.apache.avro:avro to 1.11.4
Danny Cranmer (Jira)
2024/10/03
[jira] [Commented] (FLINK-35709) Allow reordering source column names in CTAS / RTAS
Sergey Nuyanzin (Jira)
2024/10/03
[jira] [Resolved] (FLINK-35709) Allow reordering source column names in CTAS / RTAS
Sergey Nuyanzin (Jira)
2024/10/02
[jira] [Commented] (FLINK-36414) NoSuchMethodError while trying flink cdc
Yang Hua Jie (Jira)
2024/10/02
[jira] [Resolved] (FLINK-36368) Fix subtask management in CommittableCollector
Arvid Heise (Jira)
2024/10/02
[jira] [Commented] (FLINK-32483) RescaleCheckpointManuallyITCase.testCheckpointRescalingOutKeyedState fails on AZP
Jira
2024/10/02
[jira] [Assigned] (FLINK-32483) RescaleCheckpointManuallyITCase.testCheckpointRescalingOutKeyedState fails on AZP
Jira
2024/10/02
[jira] [Comment Edited] (FLINK-36355) Remove deprecate API in flink-runtime exclude connector and state part
Weijie Guo (Jira)
2024/10/02
[jira] [Resolved] (FLINK-36355) Remove deprecate API in flink-runtime exclude connector and state part
Weijie Guo (Jira)
2024/10/02
[jira] [Commented] (FLINK-36419) Consider scaling in case of no input records on a source operator with long running job
Sergey Kononov (Jira)
2024/10/02
[jira] [Created] (FLINK-36419) Consider scaling in case of no input records on a source operator with long running job
Sergey Kononov (Jira)
2024/10/02
[jira] [Commented] (FLINK-36356) HadoopRecoverableWriterTest.testRecoverWithState due to IOException
Piotr Nowojski (Jira)
2024/10/02
[jira] [Closed] (FLINK-36393) Flink Operator uses out of date GitHub actions.
Gyula Fora (Jira)
2024/10/01
[jira] [Created] (FLINK-36418) Update Control Flow page with latest developments
Gyula Fora (Jira)
2024/10/01
[jira] [Commented] (FLINK-15333) Using FlinkCostFactory rather than RelOptCostImpl in blink planner
Jim Hughes (Jira)
2024/10/01
[jira] [Commented] (FLINK-36409) Publish some autoscaler metrics during stabilisation period
Sai Sharath Dandi (Jira)
2024/10/01
[jira] [Closed] (FLINK-36260) numBytesInLocal and numBuffersInLocal being reported as remote
Piotr Nowojski (Jira)
2024/10/01
[jira] [Closed] (FLINK-20473) when get metrics option, its hard to see the full name unless u choosed
Ferenc Csaky (Jira)
2024/10/01
[jira] [Created] (FLINK-36417) STATE_TTL doesn't work with WatermarkAssigner
Sergey Nuyanzin (Jira)
2024/10/01
[jira] [Created] (FLINK-36416) Enable splittable timers for temporal join, temporal sort and windowed aggregation in SQL/Table API
Piotr Nowojski (Jira)
2024/10/01
[jira] [Assigned] (FLINK-36416) Enable splittable timers for temporal join, temporal sort and windowed aggregation in SQL/Table API
Piotr Nowojski (Jira)
2024/10/01
[jira] [Updated] (FLINK-36415) ProjectWatermarkAssignerTransposeRule can generate extra casts which do not make sense
Sergey Nuyanzin (Jira)
2024/10/01
[jira] [Resolved] (FLINK-36415) ProjectWatermarkAssignerTransposeRule can generate extra casts which do not make sense
Sergey Nuyanzin (Jira)
2024/10/01
[jira] [Created] (FLINK-36415) ProjectWatermarkAssignerTransposeRule can generate extra casts which do not make sense
Sergey Nuyanzin (Jira)
2024/10/01
[jira] [Updated] (FLINK-36415) ProjectWatermarkAssignerTransposeRule can generate extra casts which do not make sense
Sergey Nuyanzin (Jira)
2024/10/01
[jira] [Updated] (FLINK-36412) Retry strategies on Kinesis Sink
Hong Liang Teoh (Jira)
2024/10/01
[jira] [Updated] (FLINK-36412) Retry strategies on Kinesis Sink
Hong Liang Teoh (Jira)
2024/09/30
[jira] [Commented] (FLINK-33634) Add Conditions to Flink CRD's Status field
lajith (Jira)
2024/09/30
[jira] [Commented] (FLINK-5601) Window operator does not checkpoint watermarks
juntaozhang (Jira)
2024/09/30
[jira] [Created] (FLINK-36414) NoSuchMethodError while trying flink cdc
Yang Hua Jie (Jira)
2024/09/30
[jira] [Comment Edited] (FLINK-36355) Remove deprecate API in flink-runtime exclude connector and state part
Weijie Guo (Jira)
2024/09/30
[jira] [Commented] (FLINK-36336) Remove deprecated dataset API
Weijie Guo (Jira)
2024/09/30
[jira] [Assigned] (FLINK-36336) Remove deprecated dataset API
Weijie Guo (Jira)
2024/09/30
[jira] [Commented] (FLINK-33634) Add Conditions to Flink CRD's Status field
Ryan van Huuksloot (Jira)
2024/09/30
[jira] [Created] (FLINK-36413) Reenable the test case that related to Source/Sink APi deprecated.
LvYanquan (Jira)
2024/09/30
[jira] [Created] (FLINK-36412) Retry strategies on Kinesis Sink
Ed Berezitsky (Jira)
2024/09/30
[jira] [Commented] (FLINK-36411) Allow configuring job vertex throughput limits for auto scaler
Sai Sharath Dandi (Jira)
2024/09/30
[jira] [Created] (FLINK-36411) Allow configuring job vertex throughput limits for auto scaler
Sai Sharath Dandi (Jira)
2024/09/30
[jira] [Commented] (FLINK-36411) Allow configuring job vertex throughput limits for auto scaler
Gyula Fora (Jira)
2024/09/30
[jira] [Updated] (FLINK-36411) Allow configuring job vertex throughput limits for auto scaler
Sai Sharath Dandi (Jira)
2024/09/30
[jira] [Updated] (FLINK-36410) Improve Lineage Info Collection for flink app
Zhenqiu Huang (Jira)
2024/09/30
[jira] [Updated] (FLINK-36410) Improve Lineage Info Collection for flink app
Zhenqiu Huang (Jira)
2024/09/30
[jira] [Created] (FLINK-36410) Improve Lineage Info Collection for flink app
Zhenqiu Huang (Jira)
2024/09/30
[jira] [Commented] (FLINK-32766) Support kafka catalog
melin (Jira)
2024/09/30
[jira] [Assigned] (FLINK-36409) Publish some autoscaler metrics during stabilisation period
Matyas Orhidi (Jira)
2024/09/30
[jira] [Created] (FLINK-36409) Publish some autoscaler metrics during stabilisation period
Gyula Fora (Jira)
2024/09/30
[jira] [Closed] (FLINK-35764) TimerGauge is incorrect when update is called during a measurement
Piotr Nowojski (Jira)
2024/09/30
[jira] [Resolved] (FLINK-36325) Implement basic restore from checkpoint for ForStStateBackend
Zakelly Lan (Jira)
2024/09/30
[jira] [Commented] (FLINK-36325) Implement basic restore from checkpoint for ForStStateBackend
Zakelly Lan (Jira)
2024/09/30
[jira] [Commented] (FLINK-32766) Support kafka catalog
Hongshun Wang (Jira)
2024/09/30
[jira] [Resolved] (FLINK-36323) Remove deprecated MemoryStateBackend and RocksDBStateBackend
Zakelly Lan (Jira)
2024/09/30
[jira] [Commented] (FLINK-36323) Remove deprecated MemoryStateBackend and RocksDBStateBackend
Zakelly Lan (Jira)
2024/09/30
[jira] [Comment Edited] (FLINK-36355) Remove deprecate API in flink-runtime exclude connector and state part
Weijie Guo (Jira)
2024/09/30
[jira] [Assigned] (FLINK-35764) TimerGauge is incorrect when update is called during a measurement
Piotr Nowojski (Jira)
2024/09/30
[jira] [Commented] (FLINK-36245) Remove legacy SourceFunction / SinkFunction / Sink V1 API and deprecated method/interface in Sink V2 in 2.0
Qingsheng Ren (Jira)
2024/09/30
[jira] [Resolved] (FLINK-36245) Remove legacy SourceFunction / SinkFunction / Sink V1 API and deprecated method/interface in Sink V2 in 2.0
Qingsheng Ren (Jira)
2024/09/29
[jira] [Resolved] (FLINK-36344) Introduce lastCheckpointCompletedTimestamp metrics
Yun Tang (Jira)
2024/09/29
[jira] [Commented] (FLINK-35012) ChangelogNormalizeRestoreTest.testRestore failure
Xuannan Su (Jira)
2024/09/29
[jira] [Updated] (FLINK-36064) Refactor REST API for Client and Operator Coordinator Communication to Use operatorUid.
Junrui Li (Jira)
2024/09/29
[jira] [Updated] (FLINK-36064) Refactor CollectResultIterator to eliminate dependency on OperatorID
Junrui Li (Jira)
2024/09/29
[jira] [Created] (FLINK-36408) MySQL pipeline connector could not work with FLOAT type with precision
yux (Jira)
2024/09/29
[jira] [Resolved] (FLINK-36395) Graceful quit for Forst StateBackend
Zakelly Lan (Jira)
2024/09/29
[jira] [Commented] (FLINK-36403) K8s native mode Use ConfigMap to get a better experience
gaoyan (Jira)
2024/09/29
[jira] [Resolved] (FLINK-35666) Implement Aggregating Async State API for ForStStateBackend
Zakelly Lan (Jira)
2024/09/29
[jira] [Commented] (FLINK-35666) Implement Aggregating Async State API for ForStStateBackend
Zakelly Lan (Jira)
2024/09/29
[jira] [Commented] (FLINK-36348) Netty shuffle direct memory consumption end-to-end test failed due to direct memory OOM
Xuannan Su (Jira)
2024/09/29
[jira] [Resolved] (FLINK-36348) Netty shuffle direct memory consumption end-to-end test failed due to direct memory OOM
Xuannan Su (Jira)
2024/09/29
[jira] [Resolved] (FLINK-36396) Remove dependency flink-java in all flink-table-api-xxx module
xuyang (Jira)
2024/09/29
[jira] [Resolved] (FLINK-36386) Remove dependency flink-java in flink-table-planner-loader and flink-table-planner-loader-bundle module
xuyang (Jira)
2024/09/29
[jira] [Resolved] (FLINK-36391) Remove dependency flink-java in flink-table-runtime module
xuyang (Jira)
2024/09/29
[jira] [Commented] (FLINK-36391) Remove dependency flink-java in flink-table-runtime module
xuyang (Jira)
2024/09/29
[jira] [Commented] (FLINK-36386) Remove dependency flink-java in flink-table-planner-loader and flink-table-planner-loader-bundle module
xuyang (Jira)
2024/09/29
[jira] [Commented] (FLINK-36396) Remove dependency flink-java in all flink-table-api-xxx module
xuyang (Jira)
2024/09/29
[jira] [Commented] (FLINK-36387) Remove dependency flink-java in flink-table-planner module
xuyang (Jira)
2024/09/29
[jira] [Resolved] (FLINK-36387) Remove dependency flink-java in flink-table-planner module
xuyang (Jira)
2024/09/29
[jira] [Resolved] (FLINK-36384) Remove dependency flink-java in flink-sql-client module
xuyang (Jira)
2024/09/29
[jira] [Resolved] (FLINK-36383) Remove dependency flink-java in flink-sql-jdbc-driver and flink-sql-jdbc-driver-bundle module
xuyang (Jira)
2024/09/29
[jira] [Commented] (FLINK-36384) Remove dependency flink-java in flink-sql-client module
xuyang (Jira)
2024/09/29
[jira] [Resolved] (FLINK-36385) Remove dependency flink-java in flink-sql-gateway and flink-sql-gateway-api module
xuyang (Jira)
2024/09/29
[jira] [Commented] (FLINK-36385) Remove dependency flink-java in flink-sql-gateway and flink-sql-gateway-api module
xuyang (Jira)
2024/09/29
[jira] [Commented] (FLINK-36383) Remove dependency flink-java in flink-sql-jdbc-driver and flink-sql-jdbc-driver-bundle module
xuyang (Jira)
2024/09/29
[jira] [Commented] (FLINK-36382) Remove dependency flink-java in flink-table-test-utils module
xuyang (Jira)
2024/09/29
[jira] [Resolved] (FLINK-36382) Remove dependency flink-java in flink-table-test-utils module
xuyang (Jira)
2024/09/29
[jira] [Updated] (FLINK-36381) Remove legacy csv format in python module
xuyang (Jira)
2024/09/29
[jira] [Updated] (FLINK-36381) Remove legacy csv source/sink in python module
xuyang (Jira)
2024/09/29
[jira] [Updated] (FLINK-36381) Remove legacy csv format in python module
xuyang (Jira)
2024/09/29
[jira] [Commented] (FLINK-36403) K8s native mode Use ConfigMap to get a better experience
yux (Jira)
2024/09/29
[jira] [Resolved] (FLINK-36362) Remove dependency `flink-java` in table module
Weijie Guo (Jira)
2024/09/29
[jira] [Commented] (FLINK-36362) Remove dependency `flink-java` in table module
Weijie Guo (Jira)
2024/09/29
[jira] [Updated] (FLINK-36362) Remove dependency `flink-java` in table module
Weijie Guo (Jira)
2024/09/29
[jira] [Assigned] (FLINK-36362) Remove dependency `flink-java` in table module
Weijie Guo (Jira)
2024/09/29
[jira] [Updated] (FLINK-36407) SchemaRegistry doesn't shutdown its underlying ExecutorService upon closing
Sergei Morozov (Jira)
2024/09/29
[jira] [Updated] (FLINK-36407) SchemaRegistry doesn't shutdown its underlying ExecutorService upon closing
Sergei Morozov (Jira)
2024/09/29
[jira] [Created] (FLINK-36407) SchemaRegistry doesn't shutdown its underlying ExecutorService upon closing
Sergei Morozov (Jira)
2024/09/29
[jira] [Commented] (FLINK-5601) Window operator does not checkpoint watermarks
David Anderson (Jira)
2024/09/29
[jira] [Closed] (FLINK-36389) Fix DelegationTokenReceiverRepository to check if Delegation Token is enabled
Gabor Somogyi (Jira)
2024/09/29
[jira] [Resolved] (FLINK-36389) Fix DelegationTokenReceiverRepository to check if Delegation Token is enabled
Gabor Somogyi (Jira)
2024/09/29
[jira] [Created] (FLINK-36406) MetadataApplier should be closed when the job stop
Sergei Morozov (Jira)
2024/09/29
[jira] [Comment Edited] (FLINK-14068) Use Java's Duration instead of Flink's Time
Matthias Pohl (Jira)
2024/09/29
[jira] [Comment Edited] (FLINK-14068) Use Java's Duration instead of Flink's Time
Matthias Pohl (Jira)
2024/09/29
[jira] [Commented] (FLINK-33634) Add Conditions to Flink CRD's Status field
david radley (Jira)
2024/09/29
[jira] [Resolved] (FLINK-36310) Remove per-job and run-application deprecated APIs
xuhuang (Jira)
2024/09/29
[jira] [Commented] (FLINK-36310) Remove per-job and run-application deprecated APIs
xuhuang (Jira)
2024/09/29
[jira] [Updated] (FLINK-36405) Fix startup issues on kerberos clusters
Chenyu Zheng (Jira)
2024/09/29
[jira] [Created] (FLINK-36405) Fix startup issues on kerberos clusters
Chenyu Zheng (Jira)
2024/09/29
[jira] [Commented] (FLINK-36378) type extraction problem between java BigDecimal and sql decimal
Jing Ge (Jira)
2024/09/29
[jira] [Closed] (FLINK-36401) CI is not triggered for PRs
Xintong Song (Jira)
2024/09/29
[jira] [Assigned] (FLINK-36401) CI is not triggered for PRs
Xintong Song (Jira)
2024/09/29
[jira] [Commented] (FLINK-36401) CI is not triggered for PRs
Xintong Song (Jira)
2024/09/29
[jira] [Comment Edited] (FLINK-36378) type extraction problem between java BigDecimal and sql decimal
Dylan He (Jira)
2024/09/29
[jira] [Commented] (FLINK-36400) 403 and 404 responses should be fatal
Lorenzo Nicora (Jira)
2024/09/29
[jira] [Updated] (FLINK-36404) PrometheusSinkWriteException thrown by the response callback may not cause job to fail
Lorenzo Nicora (Jira)
2024/09/29
[jira] [Updated] (FLINK-36404) PrometheusSinkWriteException thrown by the response callback may not cause job to fail
Lorenzo Nicora (Jira)
2024/09/29
[jira] [Created] (FLINK-36404) PrometheusSinkWriteException thrown by the response callback may not cause job to fail
Lorenzo Nicora (Jira)
2024/09/29
[jira] [Commented] (FLINK-36369) Move deprecated user-visible classes in table modules to the legacy package to make it easier to delete them later
Xintong Song (Jira)
2024/09/29
[jira] [Created] (FLINK-36403) K8s native mode Use ConfigMap to get a better experience
gaoyan (Jira)
2024/09/28
[jira] [Created] (FLINK-36402) Improper variable naming
altenchen (Jira)
2024/09/28
[jira] [Resolved] (FLINK-33750) Remove deprecated config options.
Xuannan Su (Jira)
2024/09/28
[jira] [Commented] (FLINK-33750) Remove deprecated config options.
Xuannan Su (Jira)
2024/09/28
[jira] [Resolved] (FLINK-36373) Support dispatch state requests in task thread
Yanfei Lei (Jira)
2024/09/28
[jira] [Updated] (FLINK-36373) Support dispatch state requests in task thread
Yanfei Lei (Jira)
2024/09/28
[jira] [Assigned] (FLINK-36373) Support distribute state requests in task thread
Yanfei Lei (Jira)
2024/09/28
[jira] [Commented] (FLINK-36376) More friendly error or warn message for misconfigured statebackend with async state processing
Zakelly Lan (Jira)
2024/09/28
[jira] [Resolved] (FLINK-36376) More friendly error or warn message for misconfigured statebackend with async state processing
Zakelly Lan (Jira)
2024/09/28
[jira] [Commented] (FLINK-36401) CI is not triggered for PRs
Xintong Song (Jira)
2024/09/28
[jira] [Updated] (FLINK-36401) CI is not triggered for PRs
Xintong Song (Jira)
2024/09/28
[jira] [Updated] (FLINK-36401) Pull Request CI not trigger
xuhuang (Jira)
2024/09/28
[jira] [Commented] (FLINK-36401) PR ci failed
xuhuang (Jira)
2024/09/28
[jira] [Created] (FLINK-36401) PR ci failed
xuhuang (Jira)
2024/09/28
[jira] [Commented] (FLINK-36401) PR ci failed
xuhuang (Jira)
2024/09/28
Re: [PR] [FLINK-36323][StateBackend] Remove deprecated MemoryStateBackend, FsStateBackend and RocksDBStateBackend. [flink]
via GitHub
2024/09/28
Re: [PR] [FLINK-34975][state/forst] Implement Aggregating Async State API for ForStStateBackend [flink]
via GitHub
2024/09/28
Re: [PR] [DRAFT] Test PR failed reason [flink]
via GitHub
2024/09/28
[jira] [Resolved] (FLINK-34738) "Deployment - YARN" Page for Flink CDC Chinese Documentation
Zhongqiang Gong (Jira)
2024/09/28
[PR] [DRAFT] Test PR failed reason [flink]
via GitHub
2024/09/28
Re: [PR] [FLINK-34738][cdc][docs-zh] "Deployment - YARN" Page for Flink CDC Chinese Documentation [flink-cdc]
via GitHub
2024/09/28
Re: [PR] [FLINK-34975][state/forst] Implement Aggregating Async State API for ForStStateBackend [flink]
via GitHub
2024/09/28
Re: [PR] [Flink 36245] Remove legacy SourceFunction / SinkFunction / Sink V1 API in 2.0 [flink]
via GitHub
2024/09/28
Re: [PR] [FLINK-36181][build] Bump CI Java version to 11 [flink]
via GitHub
2024/09/28
Re: [PR] [FLINK-36181][build] Bump CI Java version to 11 [flink]
via GitHub
2024/09/28
Re: [PR] [Flink 36245] Remove legacy SourceFunction / SinkFunction / Sink V1 API in 2.0 [flink]
via GitHub
2024/09/28
Re: [PR] [FLINK-36355][runtime] Remove deprecated metrics [flink]
via GitHub
2024/09/28
Re: [PR] Refactored Identifiers [flink-cdc]
via GitHub
2024/09/28
[jira] [Commented] (FLINK-36378) type extraction problem between java BigDecimal and sql decimal
Jing Ge (Jira)
2024/09/28
[jira] [Assigned] (FLINK-36378) type extraction problem between java BigDecimal and sql decimal
Jing Ge (Jira)
2024/09/28
Re: [PR] [FLINK-36378][table] Fix type extraction bug between java BigDecimal … [flink]
via GitHub
2024/09/28
Re: [PR] [FLINK-14068][streaming] Removes deprecated org.apache.flink.streaming.api.windowing.time.Time [flink]
via GitHub
2024/09/28
Re: [PR] [FLINK-36264] Fix can not setup other values for parameter `rest-service.exposed.type` [flink-kubernetes-operator]
via GitHub
2024/09/28
[PR] [FLINK-34975][state/forst] Implement Aggregating Async State API for ForStStateBackend [flink]
via GitHub
2024/09/28
Re: [PR] [FLINK-34975][state/forst] Implement Aggregating Async State API for ForStStateBackend [flink]
via GitHub
2024/09/28
[PR] [FLINK-36286][Connectors/Prometheus] Always handle 403 and 404 as fatal errors [flink-connector-prometheus]
via GitHub
2024/09/28
[jira] [Updated] (FLINK-36400) 403 and 404 responses should be fatal
Lorenzo Nicora (Jira)
2024/09/28
[jira] [Created] (FLINK-36400) 403 and 404 responses should be fatal
Lorenzo Nicora (Jira)
Earlier messages