Messages by Date
-
2024/09/03
Re: [PR] [FLINK-35660] Adding parent-child shard ordering for DDB Streams source [flink-connector-aws]
via GitHub
-
2024/09/03
[jira] [Assigned] (FLINK-34735) "Developer Guide - Understanding Flink CDC API" Page for Flink CDC Chinese Documentation
Leonard Xu (Jira)
-
2024/09/03
Re: [PR] [FLINK-35660] Adding parent-child shard ordering for DDB Streams source [flink-connector-aws]
via GitHub
-
2024/09/03
Re: [PR] [FLINK-35660] Adding parent-child shard ordering for DDB Streams source [flink-connector-aws]
via GitHub
-
2024/09/03
Re: [PR] Add release announcement for CDC 3.2.0 [flink-web]
via GitHub
-
2024/09/03
Re: [PR] [FLINK-35660] Adding parent-child shard ordering for DDB Streams source [flink-connector-aws]
via GitHub
-
2024/09/03
Re: [PR] [FLINK-36149][state] Make the RocksdbCompactFilter parameters take effect directly at the statebackend level [flink]
via GitHub
-
2024/09/03
Re: [PR] [FLINK-36001][state] Store operator name and UID in state metadata [flink]
via GitHub
-
2024/09/03
Re: [PR] [FLINK-35660] Adding parent-child shard ordering for DDB Streams source [flink-connector-aws]
via GitHub
-
2024/09/03
Re: [PR] [FLINK-33677][core] Remove flink-conf.yaml from flink dist. [flink]
via GitHub
-
2024/09/03
Re: [PR] [FLINK-36001][state] Store operator name and UID in state metadata [flink]
via GitHub
-
2024/09/03
[jira] [Commented] (FLINK-34043) Remove deprecated Sink V2 interfaces
Weijie Guo (Jira)
-
2024/09/03
[jira] [Comment Edited] (FLINK-34043) Remove deprecated Sink V2 interfaces
Weijie Guo (Jira)
-
2024/09/03
[jira] [Commented] (FLINK-35389) Implement List Async State API for ForStStateBackend
Zakelly Lan (Jira)
-
2024/09/03
[jira] [Resolved] (FLINK-35389) Implement List Async State API for ForStStateBackend
Zakelly Lan (Jira)
-
2024/09/03
Re: [PR] [FLINK-35389][State/ForSt] Async list state [flink]
via GitHub
-
2024/09/03
[jira] [Commented] (FLINK-36125) File not found exception on restoring state handles with file merging
Zakelly Lan (Jira)
-
2024/09/03
[jira] [Resolved] (FLINK-36125) File not found exception on restoring state handles with file merging
Zakelly Lan (Jira)
-
2024/09/03
Re: [PR] [BP-1.20][FLINK-36125][checkpoint] Fix concurrent duplicated discard of logical file in cp file-merging [flink]
via GitHub
-
2024/09/03
Re: [PR] [FLINK-36125][checkpoint] Fix concurrent duplicate discard of logical file in cp file-merging [flink]
via GitHub
-
2024/09/03
[jira] [Updated] (FLINK-36171) Remove APIs about ManagedTable
Weijie Guo (Jira)
-
2024/09/03
[jira] [Updated] (FLINK-36175) Remove `register_table_source` and `register_table_sink` in python module
Weijie Guo (Jira)
-
2024/09/03
[jira] [Updated] (FLINK-36132) Remove codes that references TableSource and TableSink directly at the API level.
Weijie Guo (Jira)
-
2024/09/03
[jira] [Updated] (FLINK-36142) Remove TestTableSourceWithTime and its subclasses to prepare to remove TableEnvironmentInternal#registerTableSourceInternal
Weijie Guo (Jira)
-
2024/09/03
[jira] [Assigned] (FLINK-36171) Remove APIs about ManagedTable
Weijie Guo (Jira)
-
2024/09/03
[jira] [Assigned] (FLINK-36175) Remove `register_table_source` and `register_table_sink` in python module
Weijie Guo (Jira)
-
2024/09/03
[jira] [Updated] (FLINK-13926) `ProcessingTimeSessionWindows` and `EventTimeSessionWindows` should be generic
Weijie Guo (Jira)
-
2024/09/03
[jira] [Updated] (FLINK-5346) Remove all ad-hoc config loading via GlobalConfiguration
Weijie Guo (Jira)
-
2024/09/03
[jira] [Updated] (FLINK-5346) Remove all ad-hoc config loading via GlobalConfiguration
Weijie Guo (Jira)
-
2024/09/03
[jira] [Commented] (FLINK-5346) Remove all ad-hoc config loading via GlobalConfiguration
Weijie Guo (Jira)
-
2024/09/03
[jira] [Updated] (FLINK-6375) Fix LongValue hashCode
Weijie Guo (Jira)
-
2024/09/03
[jira] [Closed] (FLINK-23195) No value for kafka metrics in Flink Web ui
MOBIN (Jira)
-
2024/09/03
[jira] [Updated] (FLINK-3959) Remove implicit sinks
Weijie Guo (Jira)
-
2024/09/03
[jira] [Updated] (FLINK-3959) Remove implicit sinks
Weijie Guo (Jira)
-
2024/09/03
Re: [PR] FLINK-36197 bump curator-test [flink-kubernetes-operator]
via GitHub
-
2024/09/03
Re: [PR] [FLINK-33677][core] Remove flink-conf.yaml from flink dist. [flink]
via GitHub
-
2024/09/03
[jira] [Closed] (FLINK-4147) Consider moving the file sources from the StreamExecutionEnvironment to the flink-connector-filesystem
Weijie Guo (Jira)
-
2024/09/03
[jira] [Updated] (FLINK-4147) Consider moving the file sources from the StreamExecutionEnvironment to the flink-connector-filesystem
Weijie Guo (Jira)
-
2024/09/03
[jira] [Comment Edited] (FLINK-4147) Consider moving the file sources from the StreamExecutionEnvironment to the flink-connector-filesystem
Weijie Guo (Jira)
-
2024/09/03
[jira] [Assigned] (FLINK-34085) Remove deprecated string configuration keys in Flink 2.0
Xuannan Su (Jira)
-
2024/09/03
[jira] [Assigned] (FLINK-34168) Refactor all callers that using the public Xxx getXxx(String key) and public void setXxx(String key, Xxx value)
Xuannan Su (Jira)
-
2024/09/03
[jira] [Assigned] (FLINK-34079) FLIP-405: Migrate string configuration key to ConfigOption
Xuannan Su (Jira)
-
2024/09/03
[jira] [Closed] (FLINK-4367) Offer separate API for watermark generation and timestamp extraction
Weijie Guo (Jira)
-
2024/09/03
[jira] [Updated] (FLINK-4757) Unify "GlobalJobParameters" and "Configuration"
Weijie Guo (Jira)
-
2024/09/03
[jira] [Commented] (FLINK-4757) Unify "GlobalJobParameters" and "Configuration"
Weijie Guo (Jira)
-
2024/09/03
[jira] [Updated] (FLINK-4757) Unify "GlobalJobParameters" and "Configuration"
Weijie Guo (Jira)
-
2024/09/03
[jira] [Updated] (FLINK-13926) `ProcessingTimeSessionWindows` and `EventTimeSessionWindows` should be generic
Weijie Guo (Jira)
-
2024/09/03
[jira] [Assigned] (FLINK-4675) Remove Parameter from WindowAssigner.getDefaultTrigger()
Weijie Guo (Jira)
-
2024/09/03
[jira] [Closed] (FLINK-4971) Unify Stream Sinks and OutputFormats
Weijie Guo (Jira)
-
2024/09/03
[jira] [Updated] (FLINK-4971) Unify Stream Sinks and OutputFormats
Weijie Guo (Jira)
-
2024/09/03
[jira] [Commented] (FLINK-4971) Unify Stream Sinks and OutputFormats
Weijie Guo (Jira)
-
2024/09/03
Re: [PR] [FLINK-36149][state] Make the RocksdbCompactFilter parameters take effect directly at the statebackend level [flink]
via GitHub
-
2024/09/03
Re: [PR] [FLINK-36119][state] Conditional interfaces for StateFuture [flink]
via GitHub
-
2024/09/03
[jira] [Assigned] (FLINK-4503) Remove with method from CoGroupedStream and JoinedStream, and change apply method return type
Weijie Guo (Jira)
-
2024/09/03
[jira] [Assigned] (FLINK-4503) Remove with method from CoGroupedStream and JoinedStream, and change apply method return type
Weijie Guo (Jira)
-
2024/09/03
[jira] [Updated] (FLINK-4758) Remove IOReadableWritable from classes where not needed
Weijie Guo (Jira)
-
2024/09/03
[jira] [Updated] (FLINK-4758) Remove IOReadableWritable from classes where not needed
Weijie Guo (Jira)
-
2024/09/03
Re: [PR] [FLINK-36201][Coordination] Don't use StateLocalitySlotAssigner when local recovery is disabled [flink]
via GitHub
-
2024/09/03
[jira] [Commented] (FLINK-5126) Remove Checked Exceptions from State Interfaces
Weijie Guo (Jira)
-
2024/09/03
[jira] [Updated] (FLINK-5126) Remove Checked Exceptions from State Interfaces
Weijie Guo (Jira)
-
2024/09/03
[jira] [Updated] (FLINK-5126) Remove Checked Exceptions from State Interfaces
Weijie Guo (Jira)
-
2024/09/03
[jira] [Commented] (FLINK-36201) StateLocalitySlotAssigner should be only used when local recovery is enabled for Adaptive Scheduler
Rui Fan (Jira)
-
2024/09/03
[jira] [Assigned] (FLINK-36201) StateLocalitySlotAssigner should be only used when local recovery is enabled for Adaptive Scheduler
Rui Fan (Jira)
-
2024/09/03
[jira] [Updated] (FLINK-36201) StateLocalitySlotAssigner should be only used when local recovery is enabled for Adaptive Scheduler
ASF GitHub Bot (Jira)
-
2024/09/03
[PR] [FLINK-36201][Coordination] Don't use StateLocalitySlotAssigner when local recovery is disabled [flink]
via GitHub
-
2024/09/03
Re: [PR] [FLINK-36191][tests] FsMergingCheckpointStorageLocationTest generates test data not in tmp folder [flink]
via GitHub
-
2024/09/03
[jira] [Closed] (FLINK-3986) Rename readFileStream from the StreamExecutionEnvironment
Weijie Guo (Jira)
-
2024/09/03
[jira] [Assigned] (FLINK-5336) Make Path immutable
Weijie Guo (Jira)
-
2024/09/03
[jira] [Updated] (FLINK-5336) Make Path immutable
Weijie Guo (Jira)
-
2024/09/03
[jira] [Updated] (FLINK-5337) Introduce backwards compatible state to task assignment
Weijie Guo (Jira)
-
2024/09/03
[jira] [Updated] (FLINK-5337) Introduce backwards compatible state to task assignment
Weijie Guo (Jira)
-
2024/09/03
[jira] [Updated] (FLINK-9529) Do not expose keyed operations on ProcessFunction.Context
Weijie Guo (Jira)
-
2024/09/03
[jira] [Commented] (FLINK-9529) Do not expose keyed operations on ProcessFunction.Context
Weijie Guo (Jira)
-
2024/09/03
[jira] [Updated] (FLINK-9529) Do not expose keyed operations on ProcessFunction.Context
Weijie Guo (Jira)
-
2024/09/03
[jira] [Comment Edited] (FLINK-36192) Optimize the logic to make it the common divisor of the partition number of the data source when determining the parallelism of the source task.
yuanfenghu (Jira)
-
2024/09/03
[jira] [Comment Edited] (FLINK-36192) Optimize the logic to make it the common divisor of the partition number of the data source when determining the parallelism of the source task.
yuanfenghu (Jira)
-
2024/09/03
[jira] [Commented] (FLINK-36192) Optimize the logic to make it the common divisor of the partition number of the data source when determining the parallelism of the source task.
yuanfenghu (Jira)
-
2024/09/03
[jira] [Commented] (FLINK-36201) StateLocalitySlotAssigner should be only used when local recovery is enabled for Adaptive Scheduler
Jira
-
2024/09/03
[jira] [Commented] (FLINK-36011) Generalize RescaleManager to become StateTransitionManager
Xintong Song (Jira)
-
2024/09/03
[jira] [Closed] (FLINK-5130) Remove Deprecated Methods from WindowedStream
Weijie Guo (Jira)
-
2024/09/03
[jira] [Updated] (FLINK-36202) Remove all deprecated datastream api
Weijie Guo (Jira)
-
2024/09/03
[jira] [Updated] (FLINK-5130) Remove Deprecated Methods from WindowedStream
Weijie Guo (Jira)
-
2024/09/03
[jira] [Updated] (FLINK-36011) Generalize RescaleManager to become StateTransitionManager
Xintong Song (Jira)
-
2024/09/03
[jira] [Assigned] (FLINK-36202) Remove all deprecated datastream api
Weijie Guo (Jira)
-
2024/09/03
[jira] [Created] (FLINK-36202) Remove all deprecated datastream api
Weijie Guo (Jira)
-
2024/09/03
[jira] [Closed] (FLINK-32378) 2.0 Breaking Metric system changes
Xintong Song (Jira)
-
2024/09/03
[jira] [Commented] (FLINK-4330) Consider removing min()/minBy()/max()/maxBy()/sum() utility methods from the DataStream API
Weijie Guo (Jira)
-
2024/09/03
[jira] [Updated] (FLINK-24078) Remove brackets around variables
Xintong Song (Jira)
-
2024/09/03
[jira] [Updated] (FLINK-4330) Consider removing min()/minBy()/max()/maxBy()/sum() utility methods from the DataStream API
Weijie Guo (Jira)
-
2024/09/03
[jira] [Updated] (FLINK-24078) Remove brackets around variables
Xintong Song (Jira)
-
2024/09/03
[jira] [Updated] (FLINK-24078) Remove brackets around variables
Xintong Song (Jira)
-
2024/09/03
[jira] [Updated] (FLINK-6053) Gauge<T> should only take subclasses of Number, rather than everything
Xintong Song (Jira)
-
2024/09/03
[jira] [Updated] (FLINK-6053) Gauge<T> should only take subclasses of Number, rather than everything
Xintong Song (Jira)
-
2024/09/03
[jira] [Updated] (FLINK-4330) Consider removing min()/minBy()/max()/maxBy()/sum() utility methods from the DataStream API
Weijie Guo (Jira)
-
2024/09/03
[jira] [Updated] (FLINK-6053) Gauge<T> should only take subclasses of Number, rather than everything
Xintong Song (Jira)
-
2024/09/03
[jira] [Updated] (FLINK-7957) Add MetricGroup#getLogicalScope
Xintong Song (Jira)
-
2024/09/03
[jira] [Updated] (FLINK-7957) Add MetricGroup#getLogicalScope
Xintong Song (Jira)
-
2024/09/03
[jira] [Updated] (FLINK-7957) Add MetricGroup#getLogicalScope
Xintong Song (Jira)
-
2024/09/03
[jira] [Updated] (FLINK-14658) Drop ".returns()" for TypeInformation in the DataStream API
Weijie Guo (Jira)
-
2024/09/03
[jira] [Commented] (FLINK-36192) Optimize the logic to make it the common divisor of the partition number of the data source when determining the parallelism of the source task.
Rui Fan (Jira)
-
2024/09/03
[jira] [Commented] (FLINK-14658) Drop ".returns()" for TypeInformation in the DataStream API
Weijie Guo (Jira)
-
2024/09/03
[jira] [Updated] (FLINK-14350) Introduce dedicated MetricScope
Xintong Song (Jira)
-
2024/09/03
[jira] [Updated] (FLINK-14350) Introduce dedicated MetricScope
Xintong Song (Jira)
-
2024/09/03
[jira] [Updated] (FLINK-14350) Introduce dedicated MetricScope
Xintong Song (Jira)
-
2024/09/03
[jira] [Updated] (FLINK-14658) Drop ".returns()" for TypeInformation in the DataStream API
Weijie Guo (Jira)
-
2024/09/03
[jira] [Commented] (FLINK-9798) Drop canEqual() from TypeInformation, TypeSerializer, etc.
Weijie Guo (Jira)
-
2024/09/02
[jira] [Updated] (FLINK-9798) Drop canEqual() from TypeInformation, TypeSerializer, etc.
Weijie Guo (Jira)
-
2024/09/02
[jira] [Updated] (FLINK-36201) StateLocalitySlotAssigner should be only used when local recovery is enabled for Adaptive Scheduler
Rui Fan (Jira)
-
2024/09/02
[jira] [Updated] (FLINK-32597) Drop Yarn specific get rest endpoints
Xintong Song (Jira)
-
2024/09/02
Re: [PR] [FLINK-35827][table-planner] Correcting equality comparisons between rowType fields and constants [flink]
via GitHub
-
2024/09/02
[jira] [Updated] (FLINK-32597) Drop Yarn specific get rest endpoints
Xintong Song (Jira)
-
2024/09/02
[jira] [Updated] (FLINK-32597) Drop Yarn specific get rest endpoints
Xintong Song (Jira)
-
2024/09/02
[jira] [Commented] (FLINK-36201) StateLocalitySlotAssigner should be only used when local recovery is enabled for Adaptive Scheduler
Rui Fan (Jira)
-
2024/09/02
[jira] [Updated] (FLINK-32688) Remove deprecated exception history fields
Xintong Song (Jira)
-
2024/09/02
[jira] [Updated] (FLINK-9798) Drop canEqual() from TypeInformation, TypeSerializer, etc.
Weijie Guo (Jira)
-
2024/09/02
[jira] [Updated] (FLINK-32377) 2.0 Breaking REST API changes
Xintong Song (Jira)
-
2024/09/02
[jira] [Updated] (FLINK-32377) 2.0 Breaking REST API changes
Xintong Song (Jira)
-
2024/09/02
[jira] [Updated] (FLINK-7691) Remove ClassTag in Scala DataSet API
Weijie Guo (Jira)
-
2024/09/02
[jira] [Updated] (FLINK-32198) Enforce single maxExceptions query parameter
Xintong Song (Jira)
-
2024/09/02
[jira] [Closed] (FLINK-7691) Remove ClassTag in Scala DataSet API
Weijie Guo (Jira)
-
2024/09/02
[jira] [Updated] (FLINK-36201) StateLocalitySlotAssigner should be only used when local recovery is enabled for Adaptive Scheduler
Rui Fan (Jira)
-
2024/09/02
[jira] [Updated] (FLINK-15787) Upgrade REST API response to remove '-' from key names.
Xintong Song (Jira)
-
2024/09/02
[jira] [Updated] (FLINK-29863) Properly handle NaN/Infinity in OpenAPI spec
Xintong Song (Jira)
-
2024/09/02
[jira] [Closed] (FLINK-3991) Remove deprecated configuration keys from ConfigConstants
Weijie Guo (Jira)
-
2024/09/02
[jira] [Updated] (FLINK-32198) Enforce single maxExceptions query parameter
Xintong Song (Jira)
-
2024/09/02
[jira] [Updated] (FLINK-32198) Enforce single maxExceptions query parameter
Xintong Song (Jira)
-
2024/09/02
[jira] [Created] (FLINK-36201) StateLocalitySlotAssigner will be used even if local recovery is disable for Adaptive Scheduler
Rui Fan (Jira)
-
2024/09/02
[jira] [Assigned] (FLINK-32383) 2.0 Breaking configuration changes
Weijie Guo (Jira)
-
2024/09/02
[jira] [Assigned] (FLINK-33750) Remove deprecated config options.
Weijie Guo (Jira)
-
2024/09/02
[jira] [Updated] (FLINK-29863) Properly handle NaN/Infinity in OpenAPI spec
Xintong Song (Jira)
-
2024/09/02
[jira] [Updated] (FLINK-29863) Properly handle NaN/Infinity in OpenAPI spec
Xintong Song (Jira)
-
2024/09/02
[jira] [Assigned] (FLINK-32384) Remove deprecated configuration keys which violate YAML spec
Weijie Guo (Jira)
-
2024/09/02
[jira] [Updated] (FLINK-15787) Upgrade REST API response to remove '-' from key names.
Xintong Song (Jira)
-
2024/09/02
[jira] [Assigned] (FLINK-33678) Remove configuration getters/setters that return/set complex Java objects
Weijie Guo (Jira)
-
2024/09/02
[jira] [Assigned] (FLINK-36185) Remove RuntimeContext#getExecutionConfig
Weijie Guo (Jira)
-
2024/09/02
[jira] [Updated] (FLINK-15787) Upgrade REST API response to remove '-' from key names.
Xintong Song (Jira)
-
2024/09/02
[jira] [Updated] (FLINK-36185) Remove RuntimeContext#getExecutionConfig
Weijie Guo (Jira)
-
2024/09/02
[jira] [Updated] (FLINK-33749) Remove deprecated getter method in Configuration.
Weijie Guo (Jira)
-
2024/09/02
[jira] [Updated] (FLINK-32384) Remove deprecated configuration keys which violate YAML spec
Weijie Guo (Jira)
-
2024/09/02
[jira] [Updated] (FLINK-32383) 2.0 Breaking configuration changes
Weijie Guo (Jira)
-
2024/09/02
[jira] [Updated] (FLINK-33678) Remove configuration getters/setters that return/set complex Java objects
Weijie Guo (Jira)
-
2024/09/02
[jira] [Updated] (FLINK-33750) Remove deprecated config options.
Weijie Guo (Jira)
-
2024/09/02
[jira] [Updated] (FLINK-36199) Remove RuntimeContext#getExecutionConfig
Weijie Guo (Jira)
-
2024/09/02
[jira] [Closed] (FLINK-36199) Remove RuntimeContext#getExecutionConfig
Weijie Guo (Jira)
-
2024/09/02
[jira] [Created] (FLINK-36200) Breaking changes for Flink 3.0
Xintong Song (Jira)
-
2024/09/02
[jira] [Created] (FLINK-36199) Remove RuntimeContext#getExecutionConfig
Weijie Guo (Jira)
-
2024/09/02
[jira] [Resolved] (FLINK-36011) Generalize RescaleManager to become StateTransitionManager
Zdenek Tison (Jira)
-
2024/09/02
[jira] [Updated] (FLINK-3957) Breaking changes for Flink 2.0
Weijie Guo (Jira)
-
2024/09/02
[jira] [Updated] (FLINK-3957) Breaking changes for Flink 2.0
Weijie Guo (Jira)
-
2024/09/02
[jira] [Updated] (FLINK-6912) Consider changing the RichFunction#open method signature to take no arguments.
Weijie Guo (Jira)
-
2024/09/02
[jira] [Updated] (FLINK-36198) Remove legacy hybrid shuffle mode
Weijie Guo (Jira)
-
2024/09/02
[jira] [Updated] (FLINK-36198) Remove legacy hybrid shuffle mode
Weijie Guo (Jira)
-
2024/09/02
[jira] [Updated] (FLINK-36198) Remove legacy hybrid shuffle mode
Weijie Guo (Jira)
-
2024/09/02
[jira] [Commented] (FLINK-36192) Optimize the logic to make it the common divisor of the partition number of the data source when determining the parallelism of the source task.
yuanfenghu (Jira)
-
2024/09/02
Re: [PR] [FLINK-36198][network] Remove legacy hybrid shuffle mode [flink]
via GitHub
-
2024/09/02
[jira] [Updated] (FLINK-36198) Remove legacy hybrid shuffle mode
ASF GitHub Bot (Jira)
-
2024/09/02
[PR] [FLINK-36198][network] Remove legacy hybrid shuffle mode [flink]
via GitHub
-
2024/09/02
Re: [PR] FLINK-36197 bump curator-test [flink-kubernetes-operator]
via GitHub
-
2024/09/02
Re: [PR] [FLINK-36149][state] Make the RocksdbCompactFilter parameters take effect directly at the statebackend level [flink]
via GitHub
-
2024/09/02
[jira] [Updated] (FLINK-6912) Consider changing the RichFunction#open method signature to take no arguments.
Weijie Guo (Jira)
-
2024/09/02
[jira] [Assigned] (FLINK-6912) Consider changing the RichFunction#open method signature to take no arguments.
Weijie Guo (Jira)
-
2024/09/02
[jira] [Closed] (FLINK-3610) Scala DataStream#addSink returns Java DataStreamSink
Weijie Guo (Jira)
-
2024/09/02
[jira] [Commented] (FLINK-3610) Scala DataStream#addSink returns Java DataStreamSink
Weijie Guo (Jira)
-
2024/09/02
[jira] [Created] (FLINK-36198) Remove legacy hybrid shuffle mode
Weijie Guo (Jira)
-
2024/09/02
Re: [PR] [FLINK-35389][State/ForSt] Async list state [flink]
via GitHub
-
2024/09/02
[jira] [Commented] (FLINK-35387) PG CDC source support heart beat
Hongshun Wang (Jira)
-
2024/09/02
Re: [PR] [FLINK-36119][state] Conditional interfaces for StateFuture [flink]
via GitHub
-
2024/09/02
[jira] [Commented] (FLINK-36192) Optimize the logic to make it the common divisor of the partition number of the data source when determining the parallelism of the source task.
Rui Fan (Jira)
-
2024/09/02
[jira] [Commented] (FLINK-36192) Optimize the logic to make it the common divisor of the partition number of the data source when determining the parallelism of the source task.
yuanfenghu (Jira)
-
2024/09/02
Re: [PR] [FLINK-36027][cdc-connector][mysql] numRecordsOut/numRecordsOutRate metrics for each OperationType [flink-cdc]
via GitHub
-
2024/09/02
[jira] [Comment Edited] (FLINK-36051) JDBC sink doesn't re-prepare invalidated prepared statements
Jiabao Sun (Jira)
-
2024/09/02
[jira] [Resolved] (FLINK-36051) JDBC sink doesn't re-prepare invalidated prepared statements
Jiabao Sun (Jira)
-
2024/09/02
Re: [PR] [FLINK-36051] Re-prepare invalid statement even if connection is valid [flink-connector-jdbc]
via GitHub
-
2024/09/02
Re: [PR] [FLINK-36051] Re-prepare invalid statement even if connection is valid [flink-connector-jdbc]
via GitHub
-
2024/09/02
Re: [PR] [FLINK-36051] Re-prepare invalid statement even if connection is valid [flink-connector-jdbc]
via GitHub
-
2024/09/02
Re: [PR] [FLINK-35894][Follow] fix Elasticsearch dependency version [flink-cdc]
via GitHub
-
2024/09/02
Re: [PR] [FLINK-35660] Adding parent-child shard ordering for DDB Streams source [flink-connector-aws]
via GitHub
-
2024/09/02
Re: [PR] [FLINK-35660] Adding parent-child shard ordering for DDB Streams source [flink-connector-aws]
via GitHub
-
2024/09/02
Re: [PR] [FLINK-35660] Adding parent-child shard ordering for DDB Streams source [flink-connector-aws]
via GitHub
-
2024/09/02
[jira] [Updated] (FLINK-36197) Bump curator-test version
ASF GitHub Bot (Jira)
-
2024/09/02
[PR] FLINK-36197 bump curator-test [flink-kubernetes-operator]
via GitHub
-
2024/09/02
[jira] [Updated] (FLINK-36197) Bump curator-test version
Siddharth R (Jira)
-
2024/09/02
[jira] [Created] (FLINK-36197) Bump curator-test version
Siddharth R (Jira)
-
2024/09/02
Re: [PR] [FLINK-36051] Re-prepare invalid statement even if connection is valid [flink-connector-jdbc]
via GitHub
-
2024/09/02
Re: [PR] [BP-1.20][FLINK-36191][tests] FsMergingCheckpointStorageLocationTest generates test data not in tmp folder [flink]
via GitHub
-
2024/09/02
[jira] [Commented] (FLINK-36192) Optimize the logic to make it the common divisor of the partition number of the data source when determining the parallelism of the source task.
Maximilian Michels (Jira)
-
2024/09/02
Re: [PR] [FLINK-27355][runtime] Unregister JobManagerRunner after it's closed [flink]
via GitHub
-
2024/09/02
Re: [PR] [FLINK-27355][runtime] Unregister JobManagerRunner after it's closed [flink]
via GitHub
-
2024/09/02
Re: [PR] [FLINK-36011] [runtime] Generalize RescaleManager to become StateTransitionManager [flink]
via GitHub
-
2024/09/02
Re: [PR] [FLINK-35660] Adding parent-child shard ordering for DDB Streams source [flink-connector-aws]
via GitHub
-
2024/09/02
Re: [PR] Parameter spelling correction [flink]
via GitHub
-
2024/09/02
[PR] Parameter spelling correction [flink]
via GitHub
-
2024/09/02
Re: [PR] Release 1.20 The spelling correction of the ogg format parameter in the json format part of the Chinese document [flink]
via GitHub
-
2024/09/02
[PR] Release 1.20 The spelling correction of the ogg format parameter in the json format part of the Chinese document [flink]
via GitHub
-
2024/09/02
[jira] [Updated] (FLINK-35580) Improvements and fix ingestDB recovery mode related bugs
Stefan Richter (Jira)
-
2024/09/02
[jira] [Closed] (FLINK-36179) Bump log4j version
Gyula Fora (Jira)
-
2024/09/02
Re: [PR] [FLINK-36179] bump log4j version [flink-kubernetes-operator]
via GitHub
-
2024/09/02
Re: [PR] [FLINK-36149][state] Make the RocksdbCompactFilter parameters take effect directly at the statebackend level [flink]
via GitHub
-
2024/09/02
Re: [PR] [FLINK-36149][state] Make the RocksdbCompactFilter parameters take effect directly at the statebackend level [flink]
via GitHub
-
2024/09/02
Re: [PR] [BP-1.20][FLINK-36191][tests] FsMergingCheckpointStorageLocationTest generates test data not in tmp folder [flink]
via GitHub