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

Topics (27277)

Replies

Last Post

Views

[jira] [Created] (FLINK-3673) Annotations for code generation by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-3672) Code generation for POJO comparators by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-3671) Code generation for POJO serializer by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

Kerberos for Streaming & Kafka by Eron Wright

by mxm

[jira] [Created] (FLINK-3670) Kerberos: Improving long-running streaming jobs by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

watermark in fault tolerance by lonely Feb

by Aljoscha Krettek-2

[jira] [Created] (FLINK-3669) WindowOperator registers a log of timers at StreamTask by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-3668) Potential null deference in HadoopInputFormatBase#createInputSplits() by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

Proposal: YARN session per-job Kerberos authentication by stefanobaghino

by stefanobaghino

Native iterations in PyFlink by Shannon Quinn

by Chesnay Schepler-3

RollingSink by Vijay Srinivasaragha...

by Aljoscha Krettek-2

Streaming KV store abstraction by Gyula Fóra-2

by Nam-Luc Tran

[jira] [Created] (FLINK-3667) Generalize client<->cluster communication by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-3666) Remove Nephele references by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-3665) Range partitioning lacks support to define sort orders by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-3664) Create a method to easily Summarize a DataSet by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-3663) FlinkKafkaConsumerBase.logPartitionInfo is missing a log marker by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-3662) Bump Akka version to 2.4.x for Scala 2.11.x by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-3661) Make Scala 2.11.x the default Scala version by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-3660) Measure latency of elements and expose it through web interface by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-3659) Allow ConnectedStreams to Be Keyed on Only One Side by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-3658) Allow the FlinkKafkaProducer to send data to multiple topics by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-3657) Change access of DataSetUtils.countElements() to 'public' by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-3656) Rework TableAPI tests by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-3655) Allow comma-separated multiple directories to be specified for FileInputFormat by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

Flink-1.0.0 JobManager is not running in Docker Container on AWS by Deepak Jha

by Deepak Jha

[jira] [Created] (FLINK-3654) Disable Write-Ahead-Log in RocksDB State by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-3653) recovery.zookeeper.storageDir is not documented on the configuration page by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-3652) Enable UnusedImports check for Scala checkstyle by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-3651) Fix faulty RollingSink Restore by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-3650) Add maxBy/minBy to Scala DataSet API by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-3649) Document stable API methods maxBy/minBy by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-3648) Introduce Trigger Test Harness by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-3647) Change StreamSource to use Processing-Time Clock Service by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-3646) Use Processing-Time Clock in Window Assigners/Triggers by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

1 ... 656657658659660661662 ... 780