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

Topics (27277)

Replies

Last Post

Views

[jira] [Created] (FLINK-4041) Failure while asking ResourceManager for RegisterResource by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-4040) Same env.java.opts is applied for TM , JM and ZK by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-4039) G1 garbage collector only set if no custom jvm arguments by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-4038) Impossible to set more than 1 JVM argument in env.java.opts by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-4037) Introduce ArchivedExecutionGraph without any user classes by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-4036) Potential deadlock in StreamIterationSink by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-4035) Bump Kafka producer in Kafka sink to Kafka 0.10.0.0 by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-4034) Dependency convergence on com.101tec:zkclient and com.esotericsoftware.kryo:kryo by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-4033) Missing Scala example snippets for the Kinesis Connector documentation by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-4032) Replace all usage of Guava Preconditions by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

Future of Python support by Julius Neuffer

by Chesnay Schepler-3

[jira] [Created] (FLINK-4031) Nightly Jenkins job doesn't deploy sources by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-4030) ScalaShellITCase by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-4029) Multi-field "sum" function just like "keyBy" by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

DataStream split/select behaviour by CPC

by Till Rohrmann

[jira] [Created] (FLINK-4028) AbstractAlignedProcessingTimeWindowOperator creates wrong TimeWindow by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-4027) FlinkKafkaProducer09 sink can lose messages by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

Apache Flink Web Monitor Api by Ozan DENİZ

by Ozan DENİZ

[jira] [Created] (FLINK-4026) Fix code, grammar, and link issues in the Streaming documentation by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

How to run table api in 1.1-SNAPSHOT by Cody Innowhere

by Cody Innowhere

[jira] [Created] (FLINK-4025) Add possiblity for the RMQ Streaming Source to customize the queue by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-4024) FileSourceFunction not adjusted to new IF lifecycle by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-4023) Move Kafka consumer partition discovery from constructor to open() by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-4022) Partition discovery / regex topic subscription for the Kafka consumer by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-4021) Problem of setting autoread for netty channel when more tasks sharing the same Tcp connection by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-4020) Remove shard list querying from Kinesis consumer constructor by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-4019) Expose approximateArrivalTimestamp through the KinesisDeserializationSchema interface by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-4018) Configurable idle time between getRecords requests to Kinesis shards by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-4017) [py] Add Aggregation support to Python API by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[Issue] Unable to pass VM arguments by Vinay Patil

by Ufuk Celebi-2

[jira] [Created] (FLINK-4016) FoldApplyWindowFunction is not properly initialized by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-4015) FlinkKafkaProducer08 fails when partition leader changes by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-4014) Jobs hang， Maybe NetworkBufferPool and Local、 by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-4013) GraphAlgorithms to simplify directed and undirected graphs by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

Flink Kafka Consumer throwing Null Pointer Exception by Akshay Thaka Shingot...

by Aljoscha Krettek-2

1 ... 642643644645646647648 ... 780