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

Topics (27278)

Replies

Last Post

Views

[jira] [Created] (FLINK-6079) Ineffective null check in FlinkKafkaConsumerBase#open() by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-6078) ZooKeeper based high availability services should not close the underlying CuratorFramework by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-6077) Support In/Exists/Except/Any /Some/All for Stream SQL by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-6076) Let the HeartbeatManager interface extend HeartbeatTarget by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-6075) Support Limit/Top(Sort) for Stream SQL by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-6074) Fix by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-6073) Support for SQL inner queries for proctime by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-6072) TestCase CheckpointStateRestoreTest::testSetState should be fail by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-6071) Savepoints should not count in the number of retained checkpoints by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-6070) Suggestion: add ComparableTuple types by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[Discuss] Retraction for Flink Streaming by Shaoxuan Wang

by Shaoxuan Wang

[jira] [Created] (FLINK-6069) Add documentation CEP - Watermarks by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-6068) Support If() in built in function of TableAPI by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-6067) ProjectNode and FilterNode cannot merge in Batch TableAPI by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-6066) Separate logical and physical RelNode layer in Flink by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-6065) Make TransportClient for ES5 pluggable by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-6064) wrong BlobServer hostname in TaskExecutor by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-6063) HA Configuration doesn't work with Flink 1.2 by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-6062) Re-read a Kafka topic at the reception of an event by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-6061) NPE on TypeSerializer.serialize with a RocksDBStateBackend calling state.entries in the open() function by Shang Yuanchun (Jira...

by Vladislav Pernin

[jira] [Created] (FLINK-6060) not exist class referance in the scala function annotation by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

Question: RemoteStreamEnvironment submit in detach mode. by Liangfei Su

by Aljoscha Krettek-2

[jira] [Created] (FLINK-6059) Reject DataSet<Row> and DataStream<Row> without RowTypeInformation by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-6058) Don't read DEFAULT_PARALLELISM from GlobalConfiguration by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

回复：[jira] [Created] (FLINK-6057) Better default needed for num network buffers by wangzhijiang

by wangzhijiang

[jira] [Created] (FLINK-6057) Better default needed for num network buffers by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-6056) apache-rat exclude flink directory in tools by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-6055) Supported setting timers on a Non-Keyed Stream by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-6054) Add new state backend that dynamically stores data in memory and external storage by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[DISCUSS] Official policy for release maintenance by Ismaël Mejía

by Ismaël Mejía

[jira] [Created] (FLINK-6053) Gauge<T> should only take subclasses of Number, rather than everything by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[DISCUSS] Flink ML roadmap by Stavros Kontopoulos

by Stephan Ewen

[jira] [Created] (FLINK-6052) Potential null access in ZooKeeperCompletedCheckpointStore#getLatestCheckpoint() by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-6051) Wrong metric scope names in documentation by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-6050) Improve failure reporting when using Future.thenAccept by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

1 ... 572573574575576577578 ... 780