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

Topics (27279)

Replies

Last Post

Views

[jira] [Created] (FLINK-8691) Update table API to support distinct operator on data stream by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-8690) Update logical rule set to generate FlinkLogicalAggregate explicitly allow distinct operator by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-8689) Add runtime support of distinct filter using MapView for GenerateAggregation by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-8688) Enable distinct aggregation for data stream on Table/SQL API by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-8687) MaterializedCollectStreamResult#retrievePage should take resultLock by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-8686) Improve basic embedded SQL client by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-8685) Code of method "processElement(Ljava/lang/Object;Lorg/apache/flink/streaming/api/functions/ProcessFunction$Context;Lorg/apache/flink/util/Collector;)V" of class "DataStreamCalcRule$3069" grows beyond 64 KB by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-8684) Rework MesosTaskManagerParameters#MESOS_RM_TASKS_SLOTS by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-8683) Add test for configuration docs completeness by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-8682) Make start/stop cluster scripts work without SSH for local HA setups by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-8681) Remove planVisualizer.html move notice by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-8680) Name printing sinks by default. by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-8679) RocksDBKeyedBackend.getKeys(stateName, namespace) doesn't filter data with namespace by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-8678) Make AkkaRpcService#stopService non-blocking by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-8677) Make ClusterEntrypoint shut down non-blocking by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-8676) Memory Leak in AbstractKeyedStateBackend.applyToAllKeys() when backend is base on RocksDB by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-8675) Make shut down of RestServerEndpoint non blocking by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-8674) Efficiently handle alwaysFlush case (0ms flushTimeout) by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-8673) Don't let JobManagerRunner shut down itself by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-8672) Support continuous processing in CSV table source by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-8671) Split documented default value if it is too long by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-8670) Make MetricRegistryImpl#shutdown non blocking by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-8669) Extend FutureUtils to have method to wait for the completion of all futures by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

Why are checkpoint failures so serious? by Ron Crocker

by Aljoscha Krettek-2

[jira] [Created] (FLINK-8668) Remove "hadoop classpath" from config.sh by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

Sessions online for #flinkforward SF. Register with 25% discount code. by Fabian Hueske-2

by Fabian Hueske-2

[jira] [Created] (FLINK-8667) expose key in KeyedBroadcastProcessFunction#onTimer() by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

Support distinct aggregation over data stream on Table/SQL API by Rong Rong

by Fabian Hueske-2

[jira] [Created] (FLINK-8666) Use AkkaUtils#testDispatcherConfig in MiniCluster by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-8665) Allow RpcEndpoint#postStop to complete asynchronously by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-8664) Change termination future type of RpcEndpoint to Void by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[VOTE] Release 1.4.1, release candidate #1 by Tzu-Li (Gordon) Tai

by Till Rohrmann

[jira] [Created] (FLINK-8663) Execution of DataStreams result in non functionality of size of Window for countWindow by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-8662) FutureUtilsTest#testRetryWithDelay unstable by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

IO metrics by cw7k

by Till Rohrmann

1 ... 488489490491492493494 ... 780