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

Topics (27277)

Replies

Last Post

Views

[jira] [Created] (FLINK-4209) Docker image breaks with multiple NICs by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-4208) Support Running Flink processes in foreground mode by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[DISCUSS] Move Documentation from Wiki to Documentation by Aljoscha Krettek-2

by Aljoscha Krettek-2

[jira] [Created] (FLINK-4207) WindowOperator becomes very slow with allowed lateness by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-4206) Metric names should alle special characters by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

sampling function by Le Quoc Do

by Le Quoc Do

[jira] [Created] (FLINK-4205) Implement stratified sampling for DataSet by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-4204) Clean up gelly-examples by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-4203) Improve Table API documentation by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-4202) Add JM metric which shows the restart duration by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-4201) Checkpoints for jobs in non-terminal state (e.g. suspended) get deleted by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-4200) Kafka consumers should log the offset from which they restore by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-4199) Wrong client behavior when submitting job to non-existing cluster by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-4198) Replace org.apache.flink.streaming.api.windowing.time.Time with org.apache.flink.api.common.time.Time by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-4197) Allow Kinesis Endpoint to be Overridden via Config by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-4196) Remove "recoveryTimestamp" by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-4195) Dedicated Configuration classes for Kinesis Consumer / Producer by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-4194) KinesisDeserializationSchema.isEndOfStream() is never called by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-4193) Task manager JVM crashes while deploying cancelling jobs by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-4192) Move Metrics API to separate module by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-4191) Expose shard information in KinesisDeserializationSchema by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-4190) Generalise RollingSink to work with arbitrary buckets by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-4189) Introduce symbols for internal use by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-4188) Support for outer joins on DataStream by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-4187) Support for outer joins on DataStream by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-4186) Expose Kafka metrics through Flink metrics by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-4185) Reflecting rename from Tachyon to Alluxio by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

Contribute to Flink by Kevin

by Matthias J. Sax-2

[jira] [Created] (FLINK-4184) Ganglia and GraphiteReporter report metric names with invalid characters by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-4183) Move checking for StreamTableEnvironment into validation layer by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-4182) HA recovery not working properly under ApplicationMaster failures. by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-4181) Add a basic streaming Table API example by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-4180) Create a batch SQL example by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-4179) Update TPCHQuery3Table example by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[Discuss] Read from S3 using AvroInputFormat by Vinay Patil

by Vinay Patil

1 ... 636637638639640641642 ... 780