issues
Thread
Date
Earlier messages
Later messages
Messages by Thread
[jira] [Updated] (FLINK-15787) Upgrade REST API response to remove '-' from key names.
Xintong Song (Jira)
[jira] [Updated] (FLINK-15787) Upgrade REST API response to remove '-' from key names.
Xintong Song (Jira)
[jira] [Updated] (FLINK-15787) Upgrade REST API response to remove '-' from key names.
Xintong Song (Jira)
[jira] [Updated] (FLINK-36199) Remove RuntimeContext#getExecutionConfig
Weijie Guo (Jira)
[jira] [Closed] (FLINK-36199) Remove RuntimeContext#getExecutionConfig
Weijie Guo (Jira)
[jira] [Created] (FLINK-36200) Breaking changes for Flink 3.0
Xintong Song (Jira)
[jira] [Created] (FLINK-36199) Remove RuntimeContext#getExecutionConfig
Weijie Guo (Jira)
[jira] [Resolved] (FLINK-36011) Generalize RescaleManager to become StateTransitionManager
Zdenek Tison (Jira)
[jira] [Updated] (FLINK-36198) Remove legacy hybrid shuffle mode
ASF GitHub Bot (Jira)
[jira] [Updated] (FLINK-36198) Remove legacy hybrid shuffle mode
Weijie Guo (Jira)
[jira] [Updated] (FLINK-36198) Remove legacy hybrid shuffle mode
Weijie Guo (Jira)
[jira] [Updated] (FLINK-36198) Remove legacy hybrid shuffle mode
Weijie Guo (Jira)
[PR] [FLINK-36198][network] Remove legacy hybrid shuffle mode [flink]
via GitHub
Re: [PR] [FLINK-36198][network] Remove legacy hybrid shuffle mode [flink]
via GitHub
Re: [PR] [FLINK-36198][network] Remove legacy hybrid shuffle mode [flink]
via GitHub
[jira] [Assigned] (FLINK-6912) Consider changing the RichFunction#open method signature to take no arguments.
Weijie Guo (Jira)
[jira] [Closed] (FLINK-3610) Scala DataStream#addSink returns Java DataStreamSink
Weijie Guo (Jira)
[jira] [Commented] (FLINK-3610) Scala DataStream#addSink returns Java DataStreamSink
Weijie Guo (Jira)
[jira] [Created] (FLINK-36198) Remove legacy hybrid shuffle mode
Weijie Guo (Jira)
[jira] [Commented] (FLINK-35387) PG CDC source support heart beat
Hongshun Wang (Jira)
[jira] [Comment Edited] (FLINK-36051) JDBC sink doesn't re-prepare invalidated prepared statements
Jiabao Sun (Jira)
[jira] [Resolved] (FLINK-36051) JDBC sink doesn't re-prepare invalidated prepared statements
Jiabao Sun (Jira)
[PR] FLINK-36197 bump curator-test [flink-kubernetes-operator]
via GitHub
Re: [PR] FLINK-36197 bump curator-test [flink-kubernetes-operator]
via GitHub
Re: [PR] FLINK-36197 bump curator-test [flink-kubernetes-operator]
via GitHub
Re: [PR] FLINK-36197 bump curator-test, derby and postgres [flink-kubernetes-operator]
via GitHub
[jira] [Updated] (FLINK-36197) Bump curator-test version
Siddharth R (Jira)
[jira] [Updated] (FLINK-36197) Bump curator-test version
ASF GitHub Bot (Jira)
[jira] [Updated] (FLINK-36197) Bump curator-test version
Siddharth R (Jira)
[jira] [Created] (FLINK-36197) Bump curator-test version
Siddharth R (Jira)
Re: [PR] [FLINK-36051] Re-prepare invalid statement even if connection is valid [flink-connector-jdbc]
via GitHub
Re: [PR] [FLINK-36051] Re-prepare invalid statement even if connection is valid [flink-connector-jdbc]
via GitHub
Re: [PR] [FLINK-36051] Re-prepare invalid statement even if connection is valid [flink-connector-jdbc]
via GitHub
Re: [PR] [FLINK-36051] Re-prepare invalid statement even if connection is valid [flink-connector-jdbc]
via GitHub
Re: [PR] [FLINK-27355][runtime] Unregister JobManagerRunner after it's closed [flink]
via GitHub
Re: [PR] [FLINK-27355][runtime] Unregister JobManagerRunner after it's closed [flink]
via GitHub
Re: [PR] [FLINK-27355][runtime] Unregister JobManagerRunner after it's closed [flink]
via GitHub
[PR] Parameter spelling correction [flink]
via GitHub
Re: [PR] Parameter spelling correction [flink]
via GitHub
Re: [PR] Parameter spelling correction [flink]
via GitHub
Re: [PR] Parameter spelling correction [flink]
via GitHub
[PR] Release 1.20 The spelling correction of the ogg format parameter in the json format part of the Chinese document [flink]
via GitHub
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
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
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
[jira] [Updated] (FLINK-35580) Improvements and fix ingestDB recovery mode related bugs
Stefan Richter (Jira)
[jira] [Closed] (FLINK-36179) Bump log4j version
Gyula Fora (Jira)
[jira] [Updated] (FLINK-36011) Generalize RescaleManager to become StateTransitionManager
ASF GitHub Bot (Jira)
[jira] [Updated] (FLINK-36011) Generalize RescaleManager to become StateTransitionManager
Xintong Song (Jira)
[PR] [FLINK-36011] [runtime] Generalize RescaleManager to become StateTransitionManager [flink]
via GitHub
Re: [PR] [FLINK-36011] [runtime] Generalize RescaleManager to become StateTransitionManager [flink]
via GitHub
Re: [PR] [FLINK-36011] [runtime] Generalize RescaleManager to become StateTransitionManager [flink]
via GitHub
[jira] [Updated] (FLINK-36195) Migrate DDB Streams specific retry configuration to flink-connector-base
Abhi Gupta (Jira)
[jira] [Updated] (FLINK-36195) Migrate DDB Streams specific retry configuration to flink-connector-base
Hong Liang Teoh (Jira)
[jira] [Created] (FLINK-36196) Have a UX for customer where customer just gives table name and gets the stream arn which is enabled
Abhi Gupta (Jira)
[jira] [Created] (FLINK-36195) Migrate DDB Streams specific retry configuration to flink-connector-base
Abhi Gupta (Jira)
[jira] [Updated] (FLINK-24078) Remove brackets around variables
Xintong Song (Jira)
[jira] [Updated] (FLINK-24078) Remove brackets around variables
Xintong Song (Jira)
[jira] [Updated] (FLINK-24078) Remove brackets around variables
Xintong Song (Jira)
[jira] [Updated] (FLINK-24078) Remove brackets around variables
Xintong Song (Jira)
[jira] [Updated] (FLINK-19034) Remove deprecated StreamExecutionEnvironment#set/getNumberOfExecutionRetries
Xintong Song (Jira)
[jira] [Updated] (FLINK-13926) `ProcessingTimeSessionWindows` and `EventTimeSessionWindows` should be generic
Xintong Song (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] [Updated] (FLINK-6375) Fix LongValue hashCode
Xintong Song (Jira)
[jira] [Updated] (FLINK-6375) Fix LongValue hashCode
Weijie Guo (Jira)
[jira] [Updated] (FLINK-9529) Do not expose keyed operations on ProcessFunction.Context
Xintong Song (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)
[jira] [Updated] (FLINK-36194) Shutdown hook for ExecutionGraphInfo store runs concurrently to cluster shutdown hook causing race conditions
Matthias Pohl (Jira)
[jira] [Updated] (FLINK-14658) Drop ".returns()" for TypeInformation in the DataStream API
Xintong Song (Jira)
[jira] [Updated] (FLINK-14658) Drop ".returns()" for TypeInformation in the DataStream API
Weijie Guo (Jira)
[jira] [Updated] (FLINK-14658) Drop ".returns()" for TypeInformation in the DataStream API
Weijie Guo (Jira)
[jira] [Updated] (FLINK-9798) Drop canEqual() from TypeInformation, TypeSerializer, etc.
Xintong Song (Jira)
[jira] [Updated] (FLINK-9798) Drop canEqual() from TypeInformation, TypeSerializer, etc.
Weijie Guo (Jira)
[jira] [Updated] (FLINK-9798) Drop canEqual() from TypeInformation, TypeSerializer, etc.
Weijie Guo (Jira)
[jira] [Updated] (FLINK-5875) Use TypeComparator.hash() instead of Object.hashCode() for keying in DataStream API
Xintong Song (Jira)
[jira] [Updated] (FLINK-5346) Remove all ad-hoc config loading via GlobalConfiguration
Xintong Song (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] [Updated] (FLINK-6912) Consider changing the RichFunction#open method signature to take no arguments.
Xintong Song (Jira)
[jira] [Updated] (FLINK-6912) Consider changing the RichFunction#open method signature to take no arguments.
Weijie Guo (Jira)
[jira] [Updated] (FLINK-6912) Consider changing the RichFunction#open method signature to take no arguments.
Weijie Guo (Jira)
[jira] [Updated] (FLINK-7691) Remove ClassTag in Scala DataSet API
Xintong Song (Jira)
[jira] [Updated] (FLINK-7691) Remove ClassTag in Scala DataSet API
Weijie Guo (Jira)
[jira] [Updated] (FLINK-5336) Make Path immutable
Xintong Song (Jira)
[jira] [Updated] (FLINK-5336) Make Path immutable
Weijie Guo (Jira)
[jira] [Updated] (FLINK-5337) Introduce backwards compatible state to task assignment
Xintong Song (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] [Created] (FLINK-36194) Shutdown hook for ExecutionGraphInfo store runs concurrently to cluster shutdown hook causing race conditions
Matthias Pohl (Jira)
[jira] [Updated] (FLINK-4971) Unify Stream Sinks and OutputFormats
Xintong Song (Jira)
[jira] [Updated] (FLINK-4971) Unify Stream Sinks and OutputFormats
Weijie Guo (Jira)
[jira] [Updated] (FLINK-4758) Remove IOReadableWritable from classes where not needed
Xintong Song (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] [Updated] (FLINK-4757) Unify "GlobalJobParameters" and "Configuration"
Xintong Song (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-4503) Remove with method from CoGroupedStream and JoinedStream, and change apply method return type
Xintong Song (Jira)
[jira] [Updated] (FLINK-4675) Remove Parameter from WindowAssigner.getDefaultTrigger()
Xintong Song (Jira)
[jira] [Updated] (FLINK-5130) Remove Deprecated Methods from WindowedStream
Xintong Song (Jira)
[jira] [Updated] (FLINK-5130) Remove Deprecated Methods from WindowedStream
Weijie Guo (Jira)
[jira] [Updated] (FLINK-5126) Remove Checked Exceptions from State Interfaces
Xintong Song (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] [Updated] (FLINK-3992) Remove Key interface
Xintong Song (Jira)
[jira] [Updated] (FLINK-4367) Offer separate API for watermark generation and timestamp extraction
Xintong Song (Jira)
[jira] [Updated] (FLINK-3986) Rename readFileStream from the StreamExecutionEnvironment
Xintong Song (Jira)
[jira] [Updated] (FLINK-3959) Remove implicit sinks
Xintong Song (Jira)
[jira] [Updated] (FLINK-3959) Remove implicit sinks
Weijie Guo (Jira)
[jira] [Updated] (FLINK-3959) Remove implicit sinks
Weijie Guo (Jira)
[jira] [Updated] (FLINK-3991) Remove deprecated configuration keys from ConfigConstants
Xintong Song (Jira)
[jira] [Updated] (FLINK-4330) Consider removing min()/minBy()/max()/maxBy()/sum() utility methods from the DataStream API
Xintong Song (Jira)
[jira] [Updated] (FLINK-4330) Consider removing min()/minBy()/max()/maxBy()/sum() utility methods from the DataStream API
Weijie Guo (Jira)
[jira] [Updated] (FLINK-4330) Consider removing min()/minBy()/max()/maxBy()/sum() utility methods from the DataStream API
Weijie Guo (Jira)
[jira] [Updated] (FLINK-4147) Consider moving the file sources from the StreamExecutionEnvironment to the flink-connector-filesystem
Xintong Song (Jira)
[jira] [Updated] (FLINK-4147) Consider moving the file sources from the StreamExecutionEnvironment to the flink-connector-filesystem
Weijie Guo (Jira)
[jira] [Updated] (FLINK-3957) Breaking changes for Flink 2.0
Xintong Song (Jira)
[jira] [Updated] (FLINK-3957) Breaking changes for Flink 2.0
Weijie Guo (Jira)
[jira] [Updated] (FLINK-3957) Breaking changes for Flink 2.0
Weijie Guo (Jira)
[jira] [Updated] (FLINK-33749) Remove deprecated getter method in Configuration.
Xintong Song (Jira)
[jira] [Updated] (FLINK-33749) Remove deprecated getter method in Configuration.
Weijie Guo (Jira)
[jira] [Updated] (FLINK-32383) 2.0 Breaking configuration changes
Xintong Song (Jira)
[jira] [Updated] (FLINK-32383) 2.0 Breaking configuration changes
Weijie Guo (Jira)
[jira] [Updated] (FLINK-33677) Remove flink-conf.yaml from flink dist
Xintong Song (Jira)
[jira] [Updated] (FLINK-32384) Remove deprecated configuration keys which violate YAML spec
Xintong Song (Jira)
[jira] [Updated] (FLINK-32384) Remove deprecated configuration keys which violate YAML spec
Weijie Guo (Jira)
[jira] [Updated] (FLINK-34037) FLIP-398: Improve Serialization Configuration And Usage In Flink
Xintong Song (Jira)
[jira] [Updated] (FLINK-4602) Move RocksDB backend to proper package
Xintong Song (Jira)
[jira] [Updated] (FLINK-23620) Introduce proper YAML parsing to Flink's configuration
Xintong Song (Jira)
[jira] [Updated] (FLINK-35573) [FLIP-447] Upgrade FRocksDB from 6.20.3 to 8.10.0
Xintong Song (Jira)
[jira] [Updated] (FLINK-36134) Remove the classes associated with TableSource and TableSink as part of the optimization process.
Xintong Song (Jira)
[jira] [Updated] (FLINK-33750) Remove deprecated config options.
Xintong Song (Jira)
[jira] [Updated] (FLINK-33750) Remove deprecated config options.
Weijie Guo (Jira)
[jira] [Updated] (FLINK-33750) Remove deprecated config options.
ASF GitHub Bot (Jira)
[jira] [Updated] (FLINK-36142) Remove TestTableSourceWithTime and its subclasses to prepare to remove TableEnvironmentInternal#registerTableSourceInternal
Xintong Song (Jira)
[jira] [Updated] (FLINK-36142) Remove TestTableSourceWithTime and its subclasses to prepare to remove TableEnvironmentInternal#registerTableSourceInternal
Weijie Guo (Jira)
[jira] [Updated] (FLINK-33748) Remove legacy TableSource/TableSink API in 2.0
Xintong Song (Jira)
[jira] [Updated] (FLINK-36136) Remove TableSource & TableSink impl and utils, docs and etc.
Xintong Song (Jira)
[jira] [Updated] (FLINK-33747) Remove Sink V1 API in 2.0
Xintong Song (Jira)
[jira] [Updated] (FLINK-36135) Remove the TableSource and TableSink ecosystem APIs like TableFactory, DefinedFieldMapping, FilterableTableSource, etc.
Xintong Song (Jira)
[jira] [Updated] (FLINK-36132) Remove codes that references TableSource and TableSink directly at the API level.
Xintong Song (Jira)
[jira] [Updated] (FLINK-36132) Remove codes that references TableSource and TableSink directly at the API level.
Weijie Guo (Jira)
[jira] [Updated] (FLINK-29741) [FLIP-265] Remove all Scala APIs
Xintong Song (Jira)
[jira] [Updated] (FLINK-29741) [FLIP-265] Remove all Scala APIs
ASF GitHub Bot (Jira)
[jira] [Updated] (FLINK-3610) Scala DataStream#addSink returns Java DataStreamSink
Xintong Song (Jira)
[jira] [Updated] (FLINK-36140) Log a warning when pods are terminated by kubernetes
Xintong Song (Jira)
[jira] [Updated] (FLINK-36140) Log a warning when pods are terminated by kubernetes
Xintong Song (Jira)
[jira] [Updated] (FLINK-34111) Add JSON_QUOTE and JSON_UNQUOTE function
Xintong Song (Jira)
[jira] [Updated] (FLINK-34111) Add JSON_QUOTE and JSON_UNQUOTE function
Xintong Song (Jira)
[jira] [Updated] (FLINK-35702) Support Parquet Nested Read
Xintong Song (Jira)
[jira] [Updated] (FLINK-35702) Support Parquet Nested Read
Xintong Song (Jira)
[jira] [Updated] (FLINK-35768) Use native file copy in RocksDBStateDownloader
Xintong Song (Jira)
[jira] [Updated] (FLINK-35768) Use native file copy in RocksDBStateDownloader
Xintong Song (Jira)
[jira] [Updated] (FLINK-35798) Implement a BatchRestoreTestBase
Xintong Song (Jira)
[jira] [Updated] (FLINK-35798) Implement a BatchRestoreTestBase
Xintong Song (Jira)
[jira] [Updated] (FLINK-35935) CREATE TABLE AS doesn't work with LIMIT
Xintong Song (Jira)
[jira] [Updated] (FLINK-35935) CREATE TABLE AS doesn't work with LIMIT
Xintong Song (Jira)
[jira] [Updated] (FLINK-35835) SnapshotFileMergingCompatibilityITCase.testSwitchFromDisablingToEnablingFileMerging failed on AZP
Xintong Song (Jira)
[jira] [Updated] (FLINK-35835) SnapshotFileMergingCompatibilityITCase.testSwitchFromDisablingToEnablingFileMerging failed on AZP
Xintong Song (Jira)
[jira] [Updated] (FLINK-35575) FRocksDB supports disabling perf context during compilation
Xintong Song (Jira)
[jira] [Updated] (FLINK-35575) FRocksDB supports disabling perf context during compilation
Xintong Song (Jira)
[jira] [Updated] (FLINK-35925) Remove hive connector from Flink main repo
Xintong Song (Jira)
[jira] [Updated] (FLINK-35925) Remove hive connector from Flink main repo
Xintong Song (Jira)
[jira] [Updated] (FLINK-35923) Add CompiledPlan annotations to BatchExecSort/BatchExecExchange
Xintong Song (Jira)
[jira] [Updated] (FLINK-35923) Add CompiledPlan annotations to BatchExecSort/BatchExecExchange
Xintong Song (Jira)
[jira] [Updated] (FLINK-35641) ParquetSchemaConverter should correctly handle field optionality
Xintong Song (Jira)
[jira] [Updated] (FLINK-35641) ParquetSchemaConverter should correctly handle field optionality
Xintong Song (Jira)
[jira] [Updated] (FLINK-35877) Shade protobuf in flink
Xintong Song (Jira)
[jira] [Updated] (FLINK-35877) Shade protobuf in flink
Xintong Song (Jira)
[jira] [Updated] (FLINK-35837) InitOutputPathTest.testErrorOccursUnSynchronized failed in JDK21
Xintong Song (Jira)
[jira] [Updated] (FLINK-35837) InitOutputPathTest.testErrorOccursUnSynchronized failed in JDK21
Xintong Song (Jira)
[jira] [Updated] (FLINK-35790) Update docs for new schema definition in CTAS and RTAS
Xintong Song (Jira)
[jira] [Updated] (FLINK-35790) Update docs for new schema definition in CTAS and RTAS
Xintong Song (Jira)
[jira] [Updated] (FLINK-35771) Limit s5cmd resource usage
Xintong Song (Jira)
[jira] [Updated] (FLINK-35771) Limit s5cmd resource usage
Xintong Song (Jira)
[jira] [Updated] (FLINK-35836) Some S5 related ITCases failed in JDK17 due to reflection issue
Xintong Song (Jira)
[jira] [Updated] (FLINK-35836) Some S5 related ITCases failed in JDK17 due to reflection issue
Xintong Song (Jira)
[jira] [Updated] (FLINK-36063) Migrate StreamGraph and its related classes to flink-runtime
Xintong Song (Jira)
[jira] [Updated] (FLINK-36063) Migrate StreamGraph and its related classes to flink-runtime
Xintong Song (Jira)
[jira] [Updated] (FLINK-35944) Add CompiledPlan annotations to BatchExecUnion
Xintong Song (Jira)
[jira] [Updated] (FLINK-35944) Add CompiledPlan annotations to BatchExecUnion
Xintong Song (Jira)
[jira] [Updated] (FLINK-35770) Interrupt s5cmd call on cancellation
Xintong Song (Jira)
[jira] [Updated] (FLINK-35770) Interrupt s5cmd call on cancellation
Xintong Song (Jira)
[jira] [Updated] (FLINK-35577) Setup the CI environment for FRocksDB-8.10
Xintong Song (Jira)
[jira] [Updated] (FLINK-35577) Setup the CI environment for FRocksDB-8.10
Xintong Song (Jira)
[jira] [Updated] (FLINK-35355) Async aggregating state
Xintong Song (Jira)
[jira] [Updated] (FLINK-35355) Async aggregating state
Xintong Song (Jira)
[jira] [Updated] (FLINK-35767) Provide native file copy support for S3 using s5cmd
Xintong Song (Jira)
[jira] [Updated] (FLINK-35767) Provide native file copy support for S3 using s5cmd
Xintong Song (Jira)
[jira] [Updated] (FLINK-35860) S5CmdOnMinioITCase failed due to IllegalAccessError in JDK17/21
Xintong Song (Jira)
[jira] [Updated] (FLINK-35860) S5CmdOnMinioITCase failed due to IllegalAccessError in JDK17/21
Xintong Song (Jira)
[jira] [Updated] (FLINK-35678) [Release-1.20] Review and update documentation
Xintong Song (Jira)
[jira] [Updated] (FLINK-35678) [Release-1.20] Review and update documentation
Xintong Song (Jira)
[jira] [Updated] (FLINK-36126) Qualification of current catalog and current database should happen during execution, not parsing
Xintong Song (Jira)
[jira] [Updated] (FLINK-36126) Qualification of current catalog and current database should happen during execution, not parsing
Xintong Song (Jira)
[jira] [Updated] (FLINK-36127) Support sorting watermark on flink web
Xintong Song (Jira)
[jira] [Updated] (FLINK-36127) Support sorting watermark on flink web
Xintong Song (Jira)
[jira] [Updated] (FLINK-35932) Add REGEXP_COUNT function
Xintong Song (Jira)
Earlier messages
Later messages