(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 ... 668669670671672673674 ... 792

Topics (27713)

Replies

Last Post

Views

[jira] [Created] (FLINK-3682) CEP operator does not set the processing timestamp correctly by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-3681) CEP library does not support Java 8 lambdas as select function by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[DISCUSS] Release 1.0.1 Bugfix release by Aljoscha Krettek-2

by Márton Balassi

[jira] [Created] (FLINK-3680) Remove or improve (not set) text in the Job Plan UI by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

Range partitioning by Dawid Wysakowicz

by Fabian Hueske-2

A whole bag of ML issues by Trevor Grant

by Trevor Grant

[jira] [Created] (FLINK-3679) DeserializationSchema should handle zero or more outputs for every input by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

Effort to add SQL / StreamSQL to Flink by Fabian Hueske-2

by Vasiliki Kalavri

withBroadcastSet for a DataStream missing? by Stavros Kontopoulos

by Stavros Kontopoulos

[jira] [Created] (FLINK-3678) Make Flink logs directory configurable by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-3677) FileInputFormat: Allow to specify include/exclude file name patterns by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-3676) WebClient hasn't been removed from the docs by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-3675) YARN ship folder incosistent behavior by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

Behavior of lib directory shipping on YARN by stefanobaghino

by stefanobaghino

Apache Flink: aligning watermark among parallel tasks by Ozan DENİZ

by mxm

[jira] [Created] (FLINK-3674) Add an interface for EventTime aware User Function by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

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

1 ... 668669670671672673674 ... 792