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

Topics (27279)

Replies

Last Post

Views

[jira] [Created] (FLINK-9711) Flink CLI does not filter RUNNING only jobs by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-9710) Make ClusterClient be used as multiple instances in a single jvm process by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-9709) Docs: Unnecessary transition in flink job lifecycle visualization by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

Re: Kafka Avro Table Source by Fabian Hueske-2

by Fabian Hueske-2

[jira] [Created] (FLINK-9708) Network buffer leaks when buffer request fails during buffer redistribution by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-9707) LocalFileSystem does not support concurrent directory creations by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-9706) DispatcherTest#testSubmittedJobGraphListener fails on Travis by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-9705) Failed to close kafka producer - Interrupted while joining ioThread by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-9704) QueryableState E2E test failed on travis by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

Flink table api by Amol S - iProgrammer

by Fabian Hueske-2

[jira] [Created] (FLINK-9703) Mesos does not expose TM Prometheus port by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-9702) Improvement in (de)serialization of keys and values for RocksDB state by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-9701) Activate TTL in state descriptors by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-9700) Document FlinkKafkaProducer behaviour for Kafka versions > 0.11 by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[ANNOUNCE] Weekly community update #27 by Till Rohrmann

by Till Rohrmann

[jira] [Created] (FLINK-9699) Add api to replace table by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-9698) "case class must be static and globally accessible" is too constrained by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-9697) Provide connector for Kafka 2.0.0 by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-9696) Deep toString for arrays/map in SQL client by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-9695) Add option for Mesos executor to forcefully pull Docker images by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-9694) potentially NPE in CompositeTypeSerializerConfigSnapshot constructor by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-9693) possible memory link in jobmanager retaining archived checkpoints by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-9692) Adapt maxRecords parameter in the getRecords call to optimize bytes read from Kinesis by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-9691) Modify run loop in Kinesis ShardConsumer to not sleep for a fixed fetchIntervalMillis by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-9690) Restoring state with FlinkKafkaProducer and Kafka 1.1.0 client fails by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-9689) Flink consumer deserialization example by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-9688) ATAN2 Sql Function support by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-9687) Delay the state fetch only when the triggerResult is fire by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-9686) Flink Kinesis Producer: Enable Kinesis authentication via AssumeRole by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

Re: FLINK-6222 by Foster, Craig

by zhangminglei

[jira] [Created] (FLINK-9685) Flink should support hostname-substitution for security.kerberos.login.principal by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-9684) HistoryServerArchiveFetcher not working properly with secure hdfs cluster by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-9683) inconsistent behaviors when setting historyserver.archive.fs.dir by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

Re: [Flink-9407] Question about proposed ORC Sink ! by zhangminglei

by sagar loke

[jira] [Created] (FLINK-9682) Add setDescription to execution environment and display it in the UI by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

1 ... 454455456457458459460 ... 780