(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 ... 789790791792793794795 ... 988

Topics (34573)

Replies

Last Post

Views

[jira] [Created] (FLINK-5826) UDF/UDTF should support variable types and variable arguments by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-5825) In yarn mode, a small pic can not be loaded by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-5824) Fix String/byte conversion without explicit encodings by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-5823) Store Checkpoint Root Metadata in StateBackend (not in HA custom store) by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-5822) Make Checkpoint Coordinator aware of State Backend by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-5821) Create StateBackend root interface by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-5820) Extend State Backend Abstraction to support Global Cleanup Hooks by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-5819) Improve metrics reporting by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-5818) change checkpoint dir permission to 700 for security reason by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

Flink Job Exception by Govindarajan Sriniva...

by Aljoscha Krettek-2

[jira] [Created] (FLINK-5817) Fix test concurrent execution failure by test dir conflicts. by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-5816) I would like to stream data from MongoDB using Flink's source function. Is this possible? Thank you. by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-5815) Add resource files configuration for Yarn Mode by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-5814) flink-dist creates wrong symlink when not used with cleaned before by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[ANNOUNCE] Welcome Stefan Richter as a new committer by Ufuk Celebi-2

by Shaoxuan Wang

[jira] [Created] (FLINK-5813) code generation for user-defined aggregate functions by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-5812) Clean up FileSystem by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-5811) Harden YarnClusterDescriptorTest by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-5810) Harden SlotManager by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-5809) Add registerNextWatermarkCallback() to TimerService by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-5808) Missing verification for setParallelism and setMaxParallelism by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-5807) improved wording for doc home page by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-5806) TaskExecutionState toString format have wrong key by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

Handling skewness and Heterogeniety by Anis Nasir

by Anis Nasir

[jira] [Created] (FLINK-5805) improve docs for ProcessFunction by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-5804) Add [non-partitioned] processing time OVER RANGE BETWEEN UNBOUNDED PRECEDING aggregation to SQL by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-5803) Add [partitioned] processing time OVER RANGE BETWEEN UNBOUNDED PRECEDING aggregation to SQL by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-5802) Flink SQL calling Hive User-Defined Functions by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-5801) Queryable State from Scala job/client fails with key of type Long by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-5800) Make sure that the CheckpointStreamFactory is instantiated once per operator only by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-5799) Let RpcService.scheduleRunnable return ScheduledFuture by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-5798) Let the RPCService provide a ScheduledExecutorService by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-5797) incorrect use of port range selector in BootstrapTool by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

Using QueryableState inside Flink jobs (and Parameter Server implementation) by Gábor Hermann

by Gábor Hermann

[jira] [Created] (FLINK-5796) broken links in the docs by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

1 ... 789790791792793794795 ... 988