(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 (27218)

Replies

Last Post

Views

[jira] [Created] (FLINK-19257) HBase ConnectorDescriptor can not work in Table API of release-1.11 by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19256) Validate Stateful Functions configuration only where necessary by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19255) Add configuration to make AsyncWaitOperation Chainable by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19254) Invalid UTF-8 start byte exception by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19253) SourceReaderTestBase.testAddSplitToExistingFetcher hangs by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19252) Jaas file created under io.tmp.dirs - folder not created if not exists by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19251) Avoid confusing queue handling in "SplitReader.handleSplitsChanges()" by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19250) SplitFetcherManager does not propagate errors correctly by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[DISCUSS] FLIP-36 - Support Interactive Programming in Flink Table API by Xuannan Su

by Xuannan Su

[jira] [Created] (FLINK-19249) Job would wait sometime(~10 min) before failover if some connection broken by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19248) The main method caused an error: No result found for job, was execute() called before getting the result by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19247) Update Chinese documentation after removal of Kafka 0.10 and 0.11 by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19246) TableSourceITCase.testStreamScanParallelism fails on private Azure accounts by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19245) Set default queue capacity for FLIP-27 source handover queue to 2 by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19244) CsvRowDataDeserializationSchema throws cast exception : Row length mismatch. by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[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...

1 ... 128129130131132133134 ... 778