(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 ... 390391392393394395396 ... 784

Topics (27408)

Replies

Last Post

Views

Contributor Request by Kenny Deng

by Fabian Hueske-2

[jira] [Created] (FLINK-11708) There is a big chance that a taskExecutor starts another RegistrationTimeout after successfully registered at RM by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-11707) Make InputGate interface extend AutoCloseable by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-11706) Add the SumFunction to support KeyedStream.sum with field which is array by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-11705) remove org.apache.flink.runtime.testingUtils.TestingUtils by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-11704) Improve AbstractCheckpointStateOutputStreamTestBase with Parameterized by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-11703) Add a basic framework for Blink SQL by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-11702) Introduce a new table type system: InternalType by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-11701) Introduce an abstract set of data formats by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-11700) mvn package field by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-11699) Should use `String.equals()` instead of `==` for String compares in AbstractDispatcherResourceManagerComponentFactory.getHostname() by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-11698) Add readMapRedTextFile API for HadoopInputs by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-11697) Add readMapReduceTextFile API for HadoopInputs by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-11696) [checkpoint] Avoid to send mkdir requests to DFS from task side by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-11695) [checkpoint] Make sharedStateDir could create sub-directories to avoid MaxDirectoryItemsExceededException by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-11694) Enforce space before left curly brace by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-11693) Add KafkaSerializationSchema that directly uses ProducerRecord by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-11692) Add Proxy for DataDog Metric Reporter by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-11691) Introduce ClassLoader in the methods of StateBackendFactory and ConfigurableStateBackend by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-11690) Use configured RPC timeout in MiniCluster by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-11689) Code clean for StreamingJobGraphGenerator by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-11688) Enforce whitespace around TYPE_EXTENSION_AND by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-11687) Remove useless code in StreamingJobGraphGenerator by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-11686) Enforce spaces around lambdas by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-11685) Add plan test infrastructure by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-11684) Checkstyle allows multiple empty lines around static imports by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-11683) Implement standard metrics in Kafka connectors. by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-11682) Add abstract source and sink metric classes. by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-11681) Add an AbstractMetric to combine the metric definition and metric management. by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-11680) make query plan easier to read by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-11679) Create Blink SQL planner and runtime modules by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-11678) Remove suspend logic from ExecutionGraphCache by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-11677) Remove ResourceManagerRunner by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-11676) Make ResultPartitionWriter extend AutoCloseable by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-11675) Add an initial support for running batch jobs with streaming runtime by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

1 ... 390391392393394395396 ... 784