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

Topics (27278)

Replies

Last Post

Views

[DISCUSS] Bump HBase version for hadoop-2 to 1.2.3 by Fabian Hueske-2

by Márton Balassi

[jira] [Created] (FLINK-4735) Migrate some job execution related akka messages to rpc calls by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-4734) Remove use of Tuple setField for fixed position by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

Flink scala or Java - Dataload from CSV to database.. by ram kumar

by Flavio Pompermaier

[jira] [Created] (FLINK-4733) Port WebFrontend to new metric system by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-4732) Maven junction plugin security threat by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-4731) HeapKeyedStateBackend restorig broken for scale-in by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

Does the job name affect checkpointing? by dan bress

by Ufuk Celebi-2

[jira] [Created] (FLINK-4730) Introduce CheckpointMetaData by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-4729) Use optional VertexCentric CombineFunction by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-4728) Replace reference equality with object equality by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-4727) Kafka 0.9 Consumer should also checkpoint auto retrieved offsets even when no data is read by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

Using Flink by Govindarajan Sriniva...

by Govindarajan Sriniva...

[jira] [Created] (FLINK-4726) Quickstart: Java API - Broken by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-4725) BucketingSink throws NPE while restoring state if basePath does not exist by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-4724) When executed in YARN wrong log4j & logback configuration file is used by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-4723) Unify definition of committed offsets to Kafka / ZK for Kafka 0.8 and 0.9 consumer by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-4722) Consumer group concept not working properly with FlinkKafkaConsumer09 by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-4721) Getting exception when using a key of type Option[String] in distinct operation by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-4720) Implement an archived version of the execution graph by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-4719) KryoSerializer random exception by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

Regarding `flink-streaming` project dependencies by Liwei Lin

by Liwei Lin

[jira] [Created] (FLINK-4718) Confusing label in Parallel Streams Diagram by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-4717) Naive version of atomic stop signal with savepoint by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-4716) Add trigger full recovery button to web UI by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-4715) TaskManager should commit suicide after cancellation failure by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-4714) Set task state to RUNNING after state has been restored by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-4713) Implementing ranking evaluation scores for recommender systems by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-4712) Implementing ranking predictions for ALS by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-4711) TaskManager can crash due to failing onPartitionStateUpdate call by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

flink 1.1.2 RichFunction not working by Chen Bekor

by Stephan Ewen

[DISCUSS] Mesos Dispatcher (FF2016) by Eron Wright

by Till Rohrmann

[jira] [Created] (FLINK-4710) Remove transitive Guice dependency from Hadoop by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-4709) InputStreamFSInputWrapper does not close wrapped stream by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-4708) Scope Mini Kerberos Cluster dependencies as test dependencies by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

1 ... 617618619620621622623 ... 780