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

Topics (27278)

Replies

Last Post

Views

Flink ML recommender system API by Gábor Hermann

by Gábor Hermann

[DISCUSS] Adding a dispose() method in the RichFunction. by Kostas Kloudas

by Kostas Kloudas

[jira] [Created] (FLINK-5048) Kafka Consumer (0.9/0.10) threading model leads problematic cancellation behavior by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

Apache Flink and Kudu integration by ruben.casado.tejedor

by Márton Balassi

[jira] [Created] (FLINK-5047) Add tumbling group-windows for batch tables by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-5046) Avoid redundant serialization when creating the TaskDeploymentDescriptor by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-5045) Latency markers emitted after output buffer pool destroyed by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[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

1 ... 606607608609610611612 ... 780