(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 ... 637638639640641642643 ... 781

Topics (27324)

Replies

Last Post

Views

[jira] [Created] (FLINK-4218) Sporadic "java.lang.RuntimeException: Error triggering a checkpoint..." causes task restarting by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[Discussion] Query Regarding Operator chaining by Vinay Patil

by Robert Metzger

[jira] [Created] (FLINK-4217) Gelly drivers should read CSV values as strings by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[PROPOSAL] Structure the Flink Open Source Development by Stephan Ewen

by Robert Metzger

[jira] [Created] (FLINK-4216) WordWithCount example with Java has wrong generics type by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

Helping Spread the Word about Apachecon EU 2016 by Sharan Foga

by Sharan Foga

[jira] [Created] (FLINK-4215) timestamp of StreamRecord is lost in WindowOperator by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-4214) JobExceptionsHandler will return all exceptions by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-4213) Provide CombineHint in Gelly algorithms by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-4212) Lock on pid file when starting daemons by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-4211) Dynamic Properties not working for jobs submitted to Yarn session by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-4210) Move close()/isClosed() out of MetricGroup interface by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

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

1 ... 637638639640641642643 ... 781