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

Topics (27277)

Replies

Last Post

Views

[jira] [Created] (FLINK-3305) Remove JavaKaffee serializer util by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-3304) AvroOutputFormat.setSchema() doesn't work in yarn-cluster mode by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-3303) Move all non-batch specific classes in flink-java to flink-core by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-3302) Save Taskmanager Metrics per Job by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

How it is used internally Akka framework in Flink? by Lorena Reis

by Stephan Ewen

[jira] [Created] (FLINK-3301) Ineffective synchronization in MessageAcknowledgingSourceBase#restoreState by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-3300) Concurrency Bug in Yarn JobManager by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-3299) Remove ApplicationID from Environment by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-3297) Streaming connector for ZeroMQ by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-3298) Streaming connector for ActiveMQ by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-3296) DataStream.write*() methods are not flushing properly by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

Python start scripts broken by Chesnay Schepler-3

by Chesnay Schepler-3

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

1 ... 669670671672673674675 ... 780