(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 ... 675676677678679680681 ... 785

Topics (27475)

Replies

Last Post

Views

[jira] [Created] (FLINK-3295) Flink Kafka consumer fails with NoNodeException if zkConnect string contains chroot-path by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-3294) KafkaConsumer (0.8) commit offsets using SimpleConsumer.commitOffsets() by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[NOTICE] Maven artifacts names now suffixed with Scala version by mxm

by Ufuk Celebi-2

[jira] [Created] (FLINK-3293) Custom Application Name on YARN is ignored in deploy jobmanager mode by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-3292) Bug in flink-jdbc. Not all JDBC drivers supported by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-3291) Object reuse bug in MergeIterator.HeadStream.nextHead by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-3290) [py] Generalize OperationInfo transfer by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-3289) Double reference to flink-contrib by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

Flink Yarn Stack Size by Hilmi Yildirim

by Hilmi Yildirim

Scala 2.10/2.11 Maven dependencies by mxm

by Till Rohrmann

[jira] [Created] (FLINK-3288) KafkaConsumer (0.8) fails with UnknownException by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-3287) Flink Kafka Consumer fails due to Curator version conflict by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

Features only compatible with hadoop 2.x by Gyula Fóra-2

by Stephan Ewen

[jira] [Created] (FLINK-3286) Remove JDEB Debian Package code from flink-dist by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-3285) Skip Maven deployment of flink-java8 by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-3284) Broken web link: Hadoop compatibility in Flink by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-3283) Failed Kafka 0.9 test on duplicate message by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-3282) Add FlinkRelNode interface. by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-3281) IndexOutOfBoundsException when range-partitioning empty DataSet by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

Kafka As Sink in Flink Streaming by Deepak Jha

by Deepak Jha

[jira] [Created] (FLINK-3280) Wrong usage of Boolean.getBoolean() by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-3279) Optionally disable DistinctOperator combiner by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-3278) Add Partitioned State Backend Based on RocksDB by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-3277) Use Value types in Gelly API by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-3276) Move runtime parts of flink-streaming-java to flink-runtime by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-3275) [py] Add support for Dataset.setParallelism() by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

Suggestions on contributions by stefanobaghino

by stefanobaghino

[jira] [Created] (FLINK-3274) Prefix Kafka connector accumulators with unique id by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-3273) Remove Scala dependency from flink-streaming-java by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-3272) Generalize vertex value type in ConnectedComponents by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

Feedback welcome: reworking the examples with ParameterTools by stefanobaghino

by Fabian Hueske-2

What is the topic & offset used for in KeyedDeserializationSchema.deserialize()? by Tzu-Li Tai

by Tzu-Li Tai

[jira] [Created] (FLINK-3271) Using webhdfs in a flink topology throws classnotfound exception by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

Flink distributed cache in scalding by Milosz Tanski

by Milosz Tanski

Deep Learning on Flink by Trevor Grant

by Suneel Marthi-2

1 ... 675676677678679680681 ... 785