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

Topics (27306)

Replies

Last Post

Views

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

[jira] [Created] (FLINK-4707) Including flink-connector-filesystem as dependency fails build by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

ClassNotFoundException by Olga Golovneva

by Olga Golovneva

[jira] [Created] (FLINK-4706) Is there a way to load user classes first? by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

FailureRate Restart Strategy is not picked from Config file by Deepak Jha

by Deepak Jha

[jira] [Created] (FLINK-4705) Instrument FixedLengthRecordSorter by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

DataInputStream read vs. readFully by Ufuk Celebi-2

by mxm

[jira] [Created] (FLINK-4704) Move Table API to org.apache.flink.table by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

1 ... 618619620621622623624 ... 781