(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 ... 420421422423424425426 ... 784

Topics (27406)

Replies

Last Post

Views

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

[jira] [Created] (FLINK-10827) Add test for duplicate() to SerializerTestBase by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-10826) Heavy deployment end-to-end test produces no output on Travis by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-10825) ConnectedComponents test instable on Travis by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-10824) Compile Flink unit test failed with 1.6.0 branch by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-10823) Missing scala suffixes by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-10822) Configurable MetricQueryService interval by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[DISCUSS]Rethink the rescale operation, can we do it async by shimin yang

by Stefan Richter

[jira] [Created] (FLINK-10821) Resuming Externalized Checkpoint E2E test does not Resume from Externalized Checkpoint by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-10820) Simplify the RebalancePartitioner implementation by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-10819) The instability problem of CI, JobManagerHAProcessFailureRecoveryITCase.testDispatcherProcessFailure test fail. by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-10818) RestartStrategies.fixedDelayRestart Occur NoResourceAvailableException: Not enough free slots available to run the job. by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-10817) Upgrade presto dependency to support path-style access by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-10816) Fix LockableTypeSerializer.duplicate() by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

1 ... 420421422423424425426 ... 784