(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 ... 136137138139140141142 ... 786

Topics (27508)

Replies

Last Post

Views

[jira] [Created] (FLINK-19264) MiniCluster is flaky with concurrent job execution by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[DISCUSS] FLIP-134: DataStream Semantics for Bounded Input by Kostas Kloudas-5

by Kostas Kloudas-4

[jira] [Created] (FLINK-19263) Enforce alphabetical order in configuration option docs by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

Flink stateful functions : compensating callback to invoked functions on a timeout by Mazen Ezzeddine

by Mazen Ezzeddine

KeyedCoProcessFunction, processElement1, processElement2, onTimer timeout by Mazen Ezzeddine

by Mazen Ezzeddine

[jira] [Created] (FLINK-19262) Can not setParallelism for FLIP-27 source by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19261) Update document according to RestOptions by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19260) Update documentation based on bin/flink output by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19259) Use classloader release hooks with Kinesis producer to avoid metaspace leak by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19258) Fix the wrong example of "csv.line-delimiter" in CSV documentation by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

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

1 ... 136137138139140141142 ... 786