issues
Thread
Date
Earlier messages
Later messages
Messages by Thread
Re: [PR] [FLINK-14068][streaming] Removes deprecated org.apache.flink.streaming.api.windowing.time.Time [flink]
via GitHub
Re: [PR] [FLINK-14068][streaming] Removes deprecated org.apache.flink.streaming.api.windowing.time.Time [flink]
via GitHub
Re: [PR] [FLINK-14068][streaming] Removes deprecated org.apache.flink.streaming.api.windowing.time.Time [flink]
via GitHub
Re: [PR] [FLINK-14068][streaming] Removes deprecated org.apache.flink.streaming.api.windowing.time.Time [flink]
via GitHub
Re: [PR] [FLINK-14068][streaming] Removes deprecated org.apache.flink.streaming.api.windowing.time.Time [flink]
via GitHub
Re: [PR] [FLINK-14068][streaming] Removes deprecated org.apache.flink.streaming.api.windowing.time.Time [flink]
via GitHub
[jira] [Commented] (FLINK-36169) Support namespace level resource check before scaling up
Gang Li (Jira)
[jira] [Comment Edited] (FLINK-36216) RocksDB: Compaction sees out-of-order keys
Robert Metzger (Jira)
[PR] [FLINK-36206][Connectors/AWS] Adding support for custom override configuration [flink-connector-aws]
via GitHub
Re: [PR] [FLINK-36206][Connectors/AWS] Adding support for custom override configuration [flink-connector-aws]
via GitHub
Re: [PR] [FLINK-36206][Connectors/AWS] Adding support for custom override configuration [flink-connector-aws]
via GitHub
Re: [PR] [FLINK-36206][Connectors/AWS] Adding support for custom override configuration [flink-connector-aws]
via GitHub
Re: [PR] [FLINK-36206][Connectors/AWS] Adding support for custom override configuration [flink-connector-aws]
via GitHub
Re: [PR] [FLINK-36206][Connectors/AWS] Adding support for custom override configuration [flink-connector-aws]
via GitHub
[jira] [Resolved] (FLINK-36215) Child shards are getting started with LATEST shard iterator even when parents are not expired
Hong Liang Teoh (Jira)
[jira] [Updated] (FLINK-36195) Generalized retry configuration in flink-connector-base
Hong Liang Teoh (Jira)
[jira] [Resolved] (FLINK-36196) DDB Streams connector should be able to resolve the stream ARN from given Table name
Hong Liang Teoh (Jira)
[jira] [Updated] (FLINK-36196) DDB Streams connector should be able to resolve the stream ARN from given Table name
Hong Liang Teoh (Jira)
[jira] [Assigned] (FLINK-36215) Child shards are getting started with LATEST shard iterator even when parents are not expired
Hong Liang Teoh (Jira)
[jira] [Created] (FLINK-36215) Child shards are getting started with LATEST shard iterator even when parents are not expired
Abhi Gupta (Jira)
[jira] [Created] (FLINK-36214) Error log when building flink-cdc-pipeline-udf-examples from source code
lincoln lee (Jira)
[PR] [FLINK-35660][dynamodb][BugFix] Removing dependency on sorting of splits [flink-connector-aws]
via GitHub
[jira] [Comment Edited] (FLINK-36201) StateLocalitySlotAssigner should be only used when local recovery is enabled for Adaptive Scheduler
Rui Fan (Jira)
[jira] [Resolved] (FLINK-36201) StateLocalitySlotAssigner should be only used when local recovery is enabled for Adaptive Scheduler
Jira
[jira] [Updated] (FLINK-36165) Support capturing snapshot data with where conditions
Thorne (Jira)
Re: [PR] [cdc-connector][oracle]Flink cdc pipeline support oracle source [flink-cdc]
via GitHub
Re: [PR] [cdc-connector][oracle]Flink cdc pipeline support oracle source [flink-cdc]
via GitHub
[jira] [Assigned] (FLINK-29741) [FLIP-265] Remove all Scala APIs
Weijie Guo (Jira)
[jira] [Commented] (FLINK-29741) [FLIP-265] Remove all Scala APIs
Weijie Guo (Jira)
Re: [PR] [FLINK-36151] Add schema evolution related docs [flink-cdc]
via GitHub
Re: [PR] [FLINK-36151] Add schema evolution related docs [flink-cdc]
via GitHub
Re: [PR] [FLINK-36151] Add schema evolution related docs [flink-cdc]
via GitHub
[PR] [FLINK-36210] Optimize the logic for fetching topic metadata in the TopicPatternSubscriber mode [flink-connector-kafka]
via GitHub
Re: [PR] [FLINK-36210] Optimize the logic for fetching topic metadata in the TopicPatternSubscriber mode [flink-connector-kafka]
via GitHub
Re: [PR] [FLINK-36210] Optimize the logic for fetching topic metadata in the TopicPatternSubscriber mode [flink-connector-kafka]
via GitHub
Re: [PR] [FLINK-36210] Optimize the logic for fetching topic metadata in the TopicPatternSubscriber mode [flink-connector-kafka]
via GitHub
Re: [PR] [FLINK-36210] Optimize the logic for fetching topic metadata in the TopicPatternSubscriber mode [flink-connector-kafka]
via GitHub
Re: [PR] [FLINK-36210] Optimize the logic for fetching topic metadata in the TopicPatternSubscriber mode [flink-connector-kafka]
via GitHub
Re: [PR] [FLINK-36210] Optimize the logic for fetching topic metadata in the TopicPatternSubscriber mode [flink-connector-kafka]
via GitHub
Re: [PR] [FLINK-36210] Optimize the logic for fetching topic metadata in the TopicPatternSubscriber mode [flink-connector-kafka]
via GitHub
Re: [PR] [FLINK-36210] Optimize the logic for fetching topic metadata in the TopicPatternSubscriber mode [flink-connector-kafka]
via GitHub
Re: [PR] [FLINK-36210] Optimize the logic for fetching topic metadata in the TopicPatternSubscriber mode [flink-connector-kafka]
via GitHub
Re: [PR] [FLINK-36210] Optimize the logic for fetching topic metadata in the TopicPatternSubscriber mode [flink-connector-kafka]
via GitHub
[jira] [Updated] (FLINK-36210) Optimize the logic for fetching topic metadata in the TopicPatternSubscriber mode
xiaochen.zhou (Jira)
[jira] [Updated] (FLINK-36210) Optimize the logic for fetching topic metadata in the TopicPatternSubscriber mode
xiaochen.zhou (Jira)
[jira] [Updated] (FLINK-36210) Optimize the logic for fetching topic metadata in the TopicPatternSubscriber mode
xiaochen.zhou (Jira)
[PR] Reduce some redundant operations in the initialization of KafkaSourceEnumState [flink-connector-kafka]
via GitHub
Re: [PR] [FLINK-36209] Remove redundant operations in the initialization of KafkaSourceEnumState [flink-connector-kafka]
via GitHub
Re: [PR] [FLINK-36209] Remove redundant operations in the initialization of KafkaSourceEnumState [flink-connector-kafka]
via GitHub
Re: [PR] [FLINK-36209] Remove redundant operations in the initialization of KafkaSourceEnumState [flink-connector-kafka]
via GitHub
Re: [PR] [FLINK-36209] Remove redundant operations in the initialization of KafkaSourceEnumState [flink-connector-kafka]
via GitHub
Re: [PR] [FLINK-36209] Remove redundant operations in the initialization of KafkaSourceEnumState [flink-connector-kafka]
via GitHub
Re: [PR] [FLINK-36209] Remove redundant operations in the initialization of KafkaSourceEnumState [flink-connector-kafka]
via GitHub
[jira] [Updated] (FLINK-36209) Reduce some redundant operations in the initialization of KafkaSourceEnumState
xiaochen.zhou (Jira)
[jira] [Updated] (FLINK-36209) Reduce some redundant operations in the initialization of KafkaSourceEnumState
xiaochen.zhou (Jira)
[jira] [Updated] (FLINK-36209) Reduce some redundant operations in the initialization of KafkaSourceEnumState
xiaochen.zhou (Jira)
[jira] [Created] (FLINK-36209) Reduce some redundant operations in the initialization of KafkaSourceEnumState
xiaochen.zhou (Jira)
[PR] [FLINK-36208][core] use ThreadLocalRandom in AbstractID [flink]
via GitHub
Re: [PR] [FLINK-36208][core] use ThreadLocalRandom in AbstractID [flink]
via GitHub
Re: [PR] [FLINK-36208][core] use ThreadLocalRandom in AbstractID [flink]
via GitHub
Re: [PR] [FLINK-36208][core] use ThreadLocalRandom in AbstractID [flink]
via GitHub
Re: [PR] [FLINK-36208][core] use ThreadLocalRandom in AbstractID [flink]
via GitHub
Re: [PR] [FLINK-36208][core] use ThreadLocalRandom in AbstractID [flink]
via GitHub
Re: [PR] [FLINK-36208][core] use ThreadLocalRandom in AbstractID [flink]
via GitHub
[jira] [Updated] (FLINK-36208) use ThreadLocalRandom in AbstractID
Sean Sullivan (Jira)
[jira] [Updated] (FLINK-36208) use ThreadLocalRandom in AbstractID
ASF GitHub Bot (Jira)
Re: [PR] [FLINK-30479][doc] Document flink-connector-files for local execution [flink]
via GitHub
Re: [PR] [docs] Add 'scan.incremental.snapshot.backfill.skip' to docs. [flink-cdc]
via GitHub
Re: [PR] [docs] Add 'scan.incremental.snapshot.backfill.skip' to docs. [flink-cdc]
via GitHub
Re: [PR] [FLINK-31215] [autoscaler] Backpropagate processing rate limits from non-scalable bottlenecks to upstream operators [flink-kubernetes-operator]
via GitHub
Re: [PR] [FLINK-31215] [autoscaler] Backpropagate processing rate limits from non-scalable bottlenecks to upstream operators [flink-kubernetes-operator]
via GitHub
[jira] [Updated] (FLINK-36207) Disabling japicmp plugin for deprecated APIs
ASF GitHub Bot (Jira)
[PR] [FLINK-36207][build] Disables deprecated API from japicmp [flink]
via GitHub
Re: [PR] [FLINK-36207][build] Disables deprecated API from japicmp [flink]
via GitHub
Re: [PR] [FLINK-36207][build] Disables deprecated API from japicmp [flink]
via GitHub
Re: [PR] [FLINK-36207][build] Disables deprecated API from japicmp [flink]
via GitHub
Re: [PR] [FLINK-36207][build] Disables deprecated API from japicmp [flink]
via GitHub
[jira] [Assigned] (FLINK-36207) Disabling japicmp plugin for deprecated APIs
Matthias Pohl (Jira)
[jira] [Created] (FLINK-36207) Disabling japicmp plugin for deprecated APIs
Matthias Pohl (Jira)
[jira] [Commented] (FLINK-33040) flink-connector-hive builds might be blocked (but not fail) because Maven tries to access conjars.org repository (which times out)
Martijn Visser (Jira)
[jira] [Assigned] (FLINK-35660) Implement parent-child ordering for DDB Streams source
Hong Liang Teoh (Jira)
[jira] [Assigned] (FLINK-35660) Implement parent-child ordering for DDB Streams source
Hong Liang Teoh (Jira)
[jira] [Commented] (FLINK-35660) Implement parent-child ordering for DDB Streams source
Hong Liang Teoh (Jira)
[jira] [Resolved] (FLINK-35660) Implement parent-child ordering for DDB Streams source
Hong Liang Teoh (Jira)
Re: [PR] [FLINK-35660][Connectors/DynamoDB] Adding parent-child shard ordering for DDB Streams source [flink-connector-aws]
via GitHub
[jira] [Commented] (FLINK-33180) Implement support for processing subset of shards/traffic
Hong Liang Teoh (Jira)
[jira] [Assigned] (FLINK-31980) Implement support for EFO in new KDS Source
Hong Liang Teoh (Jira)
[jira] [Assigned] (FLINK-31922) Port over Kinesis Client configurations for retry and backoff
Hong Liang Teoh (Jira)
[jira] [Updated] (FLINK-36204) Fix dropping records when consuming from LATEST and having a restore from expired snapshot
Hong Liang Teoh (Jira)
[jira] [Updated] (FLINK-36195) Migrate DDB Streams specific retry configuration to flink-connector-base
Hong Liang Teoh (Jira)
[jira] [Updated] (FLINK-36196) Have a UX for customer where customer just gives table name and gets the stream arn which is enabled
Hong Liang Teoh (Jira)
[jira] [Resolved] (FLINK-34339) Add connector abstraction layer to remove reliance on AWS SDK classes
Hong Liang Teoh (Jira)
[jira] [Updated] (FLINK-34341) Add support for DDB Streams for DataStream API
Hong Liang Teoh (Jira)
[jira] [Updated] (FLINK-34340) Implement DDB Streams Table API support
Hong Liang Teoh (Jira)
[jira] [Updated] (FLINK-34341) Implement DDB Streams Table API support
Hong Liang Teoh (Jira)
[jira] [Updated] (FLINK-34340) Add support for DDB Streams for DataStream API
Hong Liang Teoh (Jira)
[jira] [Resolved] (FLINK-34342) Address Shard Consistency Issue for DDB Streams Source
Hong Liang Teoh (Jira)
[jira] [Updated] (FLINK-36206) Support flink-connector-aws-base to allow custom override configuration
Abhi Gupta (Jira)
[jira] [Updated] (FLINK-36206) Support flink-connector-aws-base to allow custom override configuration
ASF GitHub Bot (Jira)
[jira] [Created] (FLINK-36206) Support flink-connector-aws-base to allow custom override configuration
Abhi Gupta (Jira)
[jira] [Created] (FLINK-36205) DDB Streams connector should be able to resolve the stream ARN from given Table name
Hong Liang Teoh (Jira)
Re: [PR] [FLINK-31922][Connectors/AWS] Port over Kinesis Client configurations for retry and backoff [flink-connector-aws]
via GitHub
Re: [PR] [FLINK-31922][Connectors/AWS] Port over Kinesis Client configurations for retry and backoff [flink-connector-aws]
via GitHub
Re: [PR] [FLINK-31922][Connectors/AWS] Port over Kinesis Client configurations for retry and backoff [flink-connector-aws]
via GitHub
Re: [PR] [FLINK-31922][Connectors/AWS] Port over Kinesis Client configurations for retry and backoff [flink-connector-aws]
via GitHub
Re: [PR] [FLINK-31922][Connectors/AWS] Port over Kinesis Client configurations for retry and backoff [flink-connector-aws]
via GitHub
Re: [PR] [FLINK-31922][Connectors/AWS] Port over Kinesis Client configurations for retry and backoff [flink-connector-aws]
via GitHub
Re: [PR] [FLINK-31922][Connectors/AWS] Port over Kinesis Client configurations for retry and backoff [flink-connector-aws]
via GitHub
[jira] [Created] (FLINK-36204) Fix dropping records when consuming from LATEST and having a restore from expired snapshot
Abhi Gupta (Jira)
[jira] [Created] (FLINK-36203) Have some way to control the polling frequency of GetRecords from SplitFetcher
Abhi Gupta (Jira)
[jira] [Closed] (FLINK-36198) Remove legacy hybrid shuffle mode
Weijie Guo (Jira)
[PR] improve query oracle partition table [flink-cdc]
via GitHub
Re: [PR] [FLINK-36345][feature][cdc-connector][oracle] Oracle cdc support partition table [flink-cdc]
via GitHub
[jira] [Commented] (FLINK-32384) Remove deprecated configuration keys which violate YAML spec
Junrui Li (Jira)
[jira] [Assigned] (FLINK-34735) "Developer Guide - Understanding Flink CDC API" Page for Flink CDC Chinese Documentation
Leonard Xu (Jira)
Re: [PR] Add release announcement for CDC 3.2.0 [flink-web]
via GitHub
Re: [PR] Add release announcement for CDC 3.2.0 [flink-web]
via GitHub
Re: [PR] Add release announcement for CDC 3.2.0 [flink-web]
via GitHub
Re: [PR] [FLINK-36001][state] Store operator name and UID in state metadata [flink]
via GitHub
Re: [PR] [FLINK-36001][state] Store operator name and UID in state metadata [flink]
via GitHub
Re: [PR] [FLINK-36001][state] Store operator name and UID in state metadata [flink]
via GitHub
Re: [PR] [FLINK-36001][state] Store operator name and UID in state metadata [flink]
via GitHub
Re: [PR] [FLINK-36001][state] Store operator name and UID in state metadata [flink]
via GitHub
Re: [PR] [FLINK-36001][state] Store operator name and UID in state metadata [flink]
via GitHub
Re: [PR] [FLINK-36001][state] Store operator name and UID in state metadata [flink]
via GitHub
Re: [PR] [FLINK-36001][state] Store operator name and UID in state metadata [flink]
via GitHub
Re: [PR] [FLINK-36001][state] Store operator name and UID in state metadata [flink]
via GitHub
Re: [PR] [FLINK-36001][state] Store operator name and UID in state metadata [flink]
via GitHub
Re: [PR] [FLINK-36001][state] Store operator name and UID in state metadata [flink]
via GitHub
Re: [PR] [FLINK-36001][state] Store operator name and UID in state metadata [flink]
via GitHub
Re: [PR] [FLINK-36001][state] Store operator name and UID in state metadata [flink]
via GitHub
Re: [PR] [FLINK-36001][state] Store operator name and UID in state metadata [flink]
via GitHub
Re: [PR] [FLINK-36001][state] Store operator name and UID in state metadata [flink]
via GitHub
Re: [PR] [FLINK-36001][state] Store operator name and UID in state metadata [flink]
via GitHub
Re: [PR] [FLINK-36001][state] Store operator name and UID in state metadata [flink]
via GitHub
[jira] [Commented] (FLINK-34043) Remove deprecated Sink V2 interfaces
Weijie Guo (Jira)
[jira] [Commented] (FLINK-34043) Remove deprecated Sink V2 interfaces
Peter Vary (Jira)
[jira] [Comment Edited] (FLINK-34043) Remove deprecated Sink V2 interfaces
Weijie Guo (Jira)
[jira] [Comment Edited] (FLINK-34043) Remove deprecated Sink V2 interfaces
Peter Vary (Jira)
[jira] [Commented] (FLINK-35389) Implement List Async State API for ForStStateBackend
Zakelly Lan (Jira)
[jira] [Resolved] (FLINK-35389) Implement List Async State API for ForStStateBackend
Zakelly Lan (Jira)
[jira] [Commented] (FLINK-36125) File not found exception on restoring state handles with file merging
Zakelly Lan (Jira)
[jira] [Resolved] (FLINK-36125) File not found exception on restoring state handles with file merging
Zakelly Lan (Jira)
Re: [PR] [BP-1.20][FLINK-36125][checkpoint] Fix concurrent duplicated discard of logical file in cp file-merging [flink]
via GitHub
Re: [PR] [FLINK-36125][checkpoint] Fix concurrent duplicate discard of logical file in cp file-merging [flink]
via GitHub
[jira] [Updated] (FLINK-36171) Remove APIs about ManagedTable
Weijie Guo (Jira)
[jira] [Updated] (FLINK-36175) Remove `register_table_source` and `register_table_sink` in python module
Weijie Guo (Jira)
[jira] [Updated] (FLINK-36132) Remove codes that references TableSource and TableSink directly at the API level.
Weijie Guo (Jira)
[jira] [Updated] (FLINK-36142) Remove TestTableSourceWithTime and its subclasses to prepare to remove TableEnvironmentInternal#registerTableSourceInternal
Weijie Guo (Jira)
[jira] [Assigned] (FLINK-36171) Remove APIs about ManagedTable
Weijie Guo (Jira)
[jira] [Assigned] (FLINK-36175) Remove `register_table_source` and `register_table_sink` in python module
Weijie Guo (Jira)
[jira] [Updated] (FLINK-5346) Remove all ad-hoc config loading via GlobalConfiguration
Weijie Guo (Jira)
[jira] [Updated] (FLINK-5346) Remove all ad-hoc config loading via GlobalConfiguration
Weijie Guo (Jira)
[jira] [Commented] (FLINK-5346) Remove all ad-hoc config loading via GlobalConfiguration
Weijie Guo (Jira)
[jira] [Updated] (FLINK-6375) Fix LongValue hashCode
Weijie Guo (Jira)
[jira] [Closed] (FLINK-23195) No value for kafka metrics in Flink Web ui
MOBIN (Jira)
[jira] [Updated] (FLINK-3959) Remove implicit sinks
Weijie Guo (Jira)
[jira] [Updated] (FLINK-3959) Remove implicit sinks
Weijie Guo (Jira)
Re: [PR] [FLINK-33677][core] Remove flink-conf.yaml from flink dist. [flink]
via GitHub
Re: [PR] [FLINK-33677][core] Remove flink-conf.yaml from flink dist. [flink]
via GitHub
Re: [PR] [FLINK-33677][core] Remove flink-conf.yaml from flink dist. [flink]
via GitHub
Re: [PR] [FLINK-33677][core] Remove flink-conf.yaml from flink dist. [flink]
via GitHub
Re: [PR] [FLINK-33677][core] Remove flink-conf.yaml from flink dist. [flink]
via GitHub
Re: [PR] [FLINK-33677][core] Remove flink-conf.yaml from flink dist. [flink]
via GitHub
[jira] [Closed] (FLINK-4147) Consider moving the file sources from the StreamExecutionEnvironment to the flink-connector-filesystem
Weijie Guo (Jira)
[jira] [Updated] (FLINK-4147) Consider moving the file sources from the StreamExecutionEnvironment to the flink-connector-filesystem
Weijie Guo (Jira)
[jira] [Comment Edited] (FLINK-4147) Consider moving the file sources from the StreamExecutionEnvironment to the flink-connector-filesystem
Weijie Guo (Jira)
[jira] [Assigned] (FLINK-34085) Remove deprecated string configuration keys in Flink 2.0
Xuannan Su (Jira)
[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)
[jira] [Assigned] (FLINK-34079) FLIP-405: Migrate string configuration key to ConfigOption
Xuannan Su (Jira)
[jira] [Closed] (FLINK-4367) Offer separate API for watermark generation and timestamp extraction
Weijie Guo (Jira)
[jira] [Commented] (FLINK-4757) Unify "GlobalJobParameters" and "Configuration"
Weijie Guo (Jira)
[jira] [Updated] (FLINK-4757) Unify "GlobalJobParameters" and "Configuration"
Weijie Guo (Jira)
[jira] [Updated] (FLINK-4757) Unify "GlobalJobParameters" and "Configuration"
Weijie Guo (Jira)
[jira] [Updated] (FLINK-13926) `ProcessingTimeSessionWindows` and `EventTimeSessionWindows` should be generic
Weijie Guo (Jira)
[jira] [Updated] (FLINK-13926) `ProcessingTimeSessionWindows` and `EventTimeSessionWindows` should be generic
Weijie Guo (Jira)
[jira] [Assigned] (FLINK-4675) Remove Parameter from WindowAssigner.getDefaultTrigger()
Weijie Guo (Jira)
[jira] [Closed] (FLINK-4971) Unify Stream Sinks and OutputFormats
Weijie Guo (Jira)
[jira] [Updated] (FLINK-4971) Unify Stream Sinks and OutputFormats
Weijie Guo (Jira)
[jira] [Commented] (FLINK-4971) Unify Stream Sinks and OutputFormats
Weijie Guo (Jira)
[jira] [Assigned] (FLINK-4503) Remove with method from CoGroupedStream and JoinedStream, and change apply method return type
Weijie Guo (Jira)
[jira] [Assigned] (FLINK-4503) Remove with method from CoGroupedStream and JoinedStream, and change apply method return type
Weijie Guo (Jira)
[jira] [Updated] (FLINK-4758) Remove IOReadableWritable from classes where not needed
Weijie Guo (Jira)
[jira] [Updated] (FLINK-4758) Remove IOReadableWritable from classes where not needed
Weijie Guo (Jira)
[jira] [Commented] (FLINK-5126) Remove Checked Exceptions from State Interfaces
Weijie Guo (Jira)
[jira] [Updated] (FLINK-5126) Remove Checked Exceptions from State Interfaces
Weijie Guo (Jira)
[jira] [Updated] (FLINK-5126) Remove Checked Exceptions from State Interfaces
Weijie Guo (Jira)
[jira] [Assigned] (FLINK-36201) StateLocalitySlotAssigner should be only used when local recovery is enabled for Adaptive Scheduler
Rui Fan (Jira)
[PR] [FLINK-36201][Coordination] Don't use StateLocalitySlotAssigner when local recovery is disabled [flink]
via GitHub
Re: [PR] [FLINK-36201][Coordination] Don't use StateLocalitySlotAssigner when local recovery is disabled [flink]
via GitHub
Re: [PR] [FLINK-36201][Coordination] Don't use StateLocalitySlotAssigner when local recovery is disabled [flink]
via GitHub
Re: [PR] [FLINK-36191][tests] FsMergingCheckpointStorageLocationTest generates test data not in tmp folder [flink]
via GitHub
[jira] [Closed] (FLINK-3986) Rename readFileStream from the StreamExecutionEnvironment
Weijie Guo (Jira)
[jira] [Assigned] (FLINK-5336) Make Path immutable
Weijie Guo (Jira)
[jira] [Updated] (FLINK-5336) Make Path immutable
Weijie Guo (Jira)
[jira] [Updated] (FLINK-5337) Introduce backwards compatible state to task assignment
Weijie Guo (Jira)
[jira] [Updated] (FLINK-5337) Introduce backwards compatible state to task assignment
Weijie Guo (Jira)
[jira] [Commented] (FLINK-9529) Do not expose keyed operations on ProcessFunction.Context
Weijie Guo (Jira)
[jira] [Updated] (FLINK-9529) Do not expose keyed operations on ProcessFunction.Context
Weijie Guo (Jira)
[jira] [Updated] (FLINK-9529) Do not expose keyed operations on ProcessFunction.Context
Weijie Guo (Jira)
Earlier messages
Later messages