(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 ... 607608609610611612613 ... 781

Topics (27306)

Replies

Last Post

Views

[jira] [Created] (FLINK-5044) Converting operator and function state from Flink 1.1 for all changed operators in 1.2 by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-5043) Converting keyed state from Flink 1.1 backend implementations to their new counterparts in 1.2 by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-5042) Convert old savepoints to new savepoints by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-5041) Implement savepoint backwards compatibility 1.1 -> 1.2 by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-5040) Set correct input channel types with eager scheduling by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-5039) Avro GenericRecord support is broken by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[DISCUSS] Changing Window Cleanup Semantics by Aljoscha Krettek-2

by Aljoscha Krettek-2

[jira] [Created] (FLINK-5038) Errors in the "cancelTask" method prevent closeables from being closed early by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-5037) Instability in AbstractUdfStreamOperatorLifecycleTest by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-5036) Perform the grouping of keys in restoring instead of checkpointing by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

Left outer join by Thomas FOURNIER

by Fabian Hueske-2

[jira] [Created] (FLINK-5035) Don't Write TypeSerializer to Heap State Snapshot by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-5034) Don't Write StateDescriptor to RocksDB Snapshot by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

Could Not Submit Job DataStream Because No Connection to a JobManager by daviD

by daviD

[jira] [Created] (FLINK-5033) CEP operators don't properly advance time by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-5032) CsvOutputFormatTest fails on Windows OS by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-5031) Consecutive DataStream.split() ignored by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-4898) Refactor HTTP handlers and Netty server/client by Shang Yuanchun (Jira...

by Eron Wright

[jira] [Created] (FLINK-5030) Support hostname verification by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-5029) Implement KvState SSL by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

Deterministic processing with out-of-order streams by Jaromir Vanek

by Vinay Patil

[FLINK-3035] Redis as State Backend by Ovidiu Cristian Marc...

by amir bahmanyari

[jira] [Created] (FLINK-5028) Stream Tasks must not go through clean shutdown logic on cancellation by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-5027) FileSource finishes successfully with a wrong path by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-5026) Rename TimelyFlatMap to Process by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

TopSpeedWindowing - in error: Could not forward element to next operator by Ovidiu Cristian Marc...

by Ovidiu Cristian Marc...

[jira] [Created] (FLINK-5025) Job fails because of Optimizer bug by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

Stream processing via Kafka using Android by lido.flink

by Fabian Hueske-2

[jira] [Created] (FLINK-5024) Add SimpleStateDescriptor to clarify the concepts by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-5023) Add get() method in State interface by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

FLIP-6 and running many "small" jobs by Maciek Próchniak

by Maciek Próchniak

Hadoop Summit EU 2017 by Alan Gates-2

by Alan Gates-2

[jira] [Created] (FLINK-5022) Suppress RejectedExecutionException when the Executor is shut down by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-5021) Make the ContinuousFileReaderOperator rescalable. by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-5020) Make the GenericWriteAheadSink rescalable. by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

1 ... 607608609610611612613 ... 781