(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 ... 617618619620621622623 ... 791

Topics (27681)

Replies

Last Post

Views

[jira] [Created] (FLINK-5061) Remove ContinuousEventTimeTrigger by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-5060) only serialise records once in RecordWriter#emit and RecordWriter#broadcastEmit by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-5059) only serialise events once in RecordWriter#broadcastEvent by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-5058) taskManagerMemory attribute set wrong value in FlinkShell by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

Flink 4108 and 4061 by Alberto Ramón

by Alberto Ramón

[jira] [Created] (FLINK-5057) Cancellation timeouts are picked from wrong config by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

RocksDB IO error by zhenhao.li

by Aljoscha Krettek-2

[FLINK-3848] Add ProjectableTableSource by Anton Solovev

by Anton Solovev

[jira] [Created] (FLINK-5056) BucketingSink deletes valid data when checkpoint notification is slow. by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-5055) Security feature crashes JM for certain Hadoop versions even though using no Kerberos by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

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

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-5053) Incremental / lightweight snapshots for checkpoints by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-5052) Changing the maximum parallelism (number of key groups) of a job by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-5051) Backwards compatibility for serializers in backend state by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[FLINK-4541] Support for SQL NOT IN operator by Alexander Shoshin

by Alexander Shoshin

[jira] [Created] (FLINK-5050) JSON.org license is CatX by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[DISCUSS] Releasing Flink 1.1.4 by Ufuk Celebi-2

by Ufuk Celebi-2

[jira] [Created] (FLINK-5049) Instability in QueryableStateITCase.testQueryableStateWithTaskManagerFailure by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

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

1 ... 617618619620621622623 ... 791