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

Topics (27279)

Replies

Last Post

Views

[jira] [Created] (FLINK-11718) Add onStart method to RpcEndpoint which is run in the actor's main thread by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-11717) Translate the "Material" page into Chinese by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-11716) Introduce Task Manager configuration option to customize address binding mechanism by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-11715) Add optimize program to organize optimization phases by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-11714) Add cost model for both batch and streaming by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-11713) Remove legacy mode from documentation by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

Re: StreamingFileSink causing AmazonS3Exception by Addison Higham

by Padarn Wilson

[jira] [Created] (FLINK-11712) Add cost model for both batch and streaming by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-11711) Add table and column stats by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-11710) Refactor SimpleSlotProvider to TestingLogicalSlotProvider by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-11709) Bump jline version by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

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

1 ... 386387388389390391392 ... 780