(DEPRECATED) Apache Flink Mailing List archive.

This used to be a public archive of the Flink mailing mailing list.

We recommend using the official Apache Mailing List Archive: https://lists.apache.org/list.html?dev@flink.apache.org

New Topic

People

1 ... 128129130131132133134 ... 778

Topics (27203)

Replies

Last Post

Views

[jira] [Created] (FLINK-19243) Bump Snakeyaml to 1.27 by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19242) org.apache.flink.table.api.ValidationException: Cannot resolve field by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19241) Forward ClusterEntrypoint ioExecutor to ResourceManager by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19240) Hello, I have a job with multiple Kafka sources. They all contain certain historical data. If you use the events-time window, it will cause sources with less data to cover more sources through water mark. Is there a solution? by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19239) FlinkKafkaProducer by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[ANNOUNCE] Weekly Community Update 2020/37 by Konstantin Knauf-4

by Konstantin Knauf-4

[jira] [Created] (FLINK-19238) RocksDB performance issue with low managed memory and high parallelism by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[RESULT][VOTE] Release 1.11.2, release candidate #1 by Zhu Zhu-2

by Zhu Zhu-2

[VOTE] Release 1.11.2, release candidate #1 by Zhu Zhu-2

by Zhu Zhu

[jira] [Created] (FLINK-19237) LeaderChangeClusterComponentsTest.testReelectionOfJobMaster failed with "NoResourceAvailableException: Could not allocate the required slot within slot request timeout" by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19236) Optimize the performance of Python UDAF by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19234) Support FILTER KeyWord for Python UDAF by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19235) Support mixed use with built-in aggs for Python UDAF by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19233) Support DISTINCT KeyWord for Python UDAF by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19231) Support ListState and ListView for Python UDAF by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19232) Support MapState and MapView for Python UDAF by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19230) Support Python UDAF on blink batch planner by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19229) Support ValueState and Python UDAF on blink stream planner by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19228) Avoid accessing FileSystem in client for file system connector by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19227) The catalog is still created after opening failed in catalog registering by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19226) [Kinesis] [EFO] Connector reaches default max attempts for describeStream and describeStreamConsumer when parallelism is high by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19225) Improve code and logging in SourceReaderBase by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19224) Provide an easy way to read window state by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19223) Simplify Availability Future Model in Base Connector by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19222) Elevate external SDKs by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19221) Exploit LocatableFileStatus from Hadoop by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19220) Add a way to close internal resources by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

Java and Scala code format by Darion Yaphet

by Darion Yaphet

[jira] [Created] (FLINK-19219) Run JobManager initialization in a separate thread, to make it cancellable by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19218) Remove inconsistent host logic for LocalFileSystem by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19217) Functions repeated extend Serializable interface by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19216) Reduce the duplicate argument check by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19215) "Resuming Savepoint (rocks, scale down, rocks timers) end-to-end test" failed with "Dispatcher REST endpoint has not started within a timeout of 20 sec" by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19214) Update the flink-web by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19213) Update the Chinese documentation by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

1 ... 128129130131132133134 ... 778