(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 ... 643644645646647648649 ... 781

Topics (27324)

Replies

Last Post

Views

[jira] [Created] (FLINK-4053) Return value from Connection should be checked against null by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-4052) Unstable test by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-4051) RabbitMQ Source might not react to cancel signal by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-4050) FlinkKafkaProducer API Refactor by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-4049) Mark RichInputFormat.openInputFormat and closeInputFormat as @PublicEvolving by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-4048) Remove Hadoop dependencies from ExecutionEnvironment by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-4047) Fix documentation about determinism of KeySelectors by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-4046) Failing a restarting job can get stuck in JobStatus.FAILING by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-4045) Test AMQP connector using Apache ActiveMQ by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-4044) Rename RabbitMQ connector to AMQP connector by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-4043) Generalize RabbitMQ connector into AMQP connector by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-4042) TwitterStream example does not work by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

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

1 ... 643644645646647648649 ... 781