(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 ... 416417418419420421422 ... 780

Topics (27279)

Replies

Last Post

Views

[jira] [Created] (FLINK-10857) Conflict between JMX and Prometheus Metrics reporter by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

Kinesis consumer e2e test by Thomas Weise

by Stefan Richter

[jira] [Created] (FLINK-10856) Harden resume from externalized checkpoint E2E test by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-10855) CheckpointCoordinator does not delete checkpoint directory of late/failed checkpoints by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-10853) Provide end-to-end test for Kafka 0.9 connector by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-10854) Provide end-to-end test for Kafka 0.8 connector by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-10852) Decremented number of unfinished producers below 0. This is most likely a bug in the execution state/intermediate result partition management by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-10851) sqlUpdate support complex insert grammar by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-10850) Job may hang on FAILING state if taskmanager updateTaskExecutionState failed by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-10849) The flink Metric has no data when two or more fliter operators are used by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-10848) Flink's Yarn ResourceManager can allocate too many excess containers by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-10847) Add support for IS NOT DISTINCT FROM in code generator by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-10846) Add support for IS DISTINCT FROM in code generator by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-10845) Support DISTINCT aggregates for batch by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-10844) ArrayIndexOutOfBoundsException during checkpoint (Flink 1.5.2) by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[VOTE] Release 1.7.0, release candidate #1 by Till Rohrmann

by jincheng sun

[jira] [Created] (FLINK-10843) Make Kafka version definition more flexible for new Kafka table factory by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-10842) Waiting loops are broken in e2e/common.sh by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-10841) Reduce the number of ListObjects calls when checkpointing to S3 by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-10840) BucketingSink incorrectly clears the pendingFiles List by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-10839) Fix implementation of PojoSerializer.duplicate() w.r.t. subclass serializer by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-10838) Rewrite Kafka tests that fail Kafka brokers by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-10837) Kafka 2.0 test KafkaITCase.testOneToOneSources dead locked on deleteTestTopic? by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

FLINK-9523, PR #6672 by Mikhail Sokolov

by Mikhail Sokolov

[jira] [Created] (FLINK-10836) Add repositories and pluginRepositories in root pom.xml by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

how get job id which job run slot by jing

by vino yang

[jira] [Created] (FLINK-10835) Remove duplicated Round-robin ChannelSelector implementation in RecordWriterTest by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-10834) TableAPI flatten calculated value error by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-10833) FlinkKafkaProducerITCase.testFlinkKafkaProducerFailTransactionCoordinatorBeforeNotify failed on Travis by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-10832) StreamExecutionEnvironment.execute() does not return when all sources end by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-10831) Consider making processing time monotonically increasing by default by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-10830) Consider making processing time provider pluggable by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-10829) Extend FlinkDistribution to support running jars by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

StreamingFileSink Bug? Committing results on stream close by Addison Higham

by Aljoscha Krettek-2

[jira] [Created] (FLINK-10828) Enforce that all TypeSerializers are tested through SerializerTestBase by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

1 ... 416417418419420421422 ... 780