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

Topics (27306)

Replies

Last Post

Views

[jira] [Created] (FLINK-6379) Implement FLIP-6 Mesos Resource Manager by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-6378) Implement FLIP-6 Flink-on-Mesos by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-6377) Support map types in the Table / SQL API by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-6376) when deploy flink cluster on the yarn, it is lack of hdfs delegation token. by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-6375) Fix LongValue hashCode by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-6374) In yarn cluster model, the -ys parameter is not take effect. by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-6373) Add runtime support for distinct aggregation over grouped windows by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-6372) change-scala-version.sh does not change version for flink-gelly-examples by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-6371) Return matched patterns as Map<String, List<T>> instead of Map<String, T> by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-6370) FileAlreadyExistsException on startup by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-6369) Better support for overlay networks by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[VOTE] Release Apache Flink 1.2.1 (RC2) by Robert Metzger

by Aljoscha Krettek-2

[jira] [Created] (FLINK-6368) Grouping keys in stream aggregations have wrong order by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

Splitting input stream in to multiple windows and process individually by madhairsilence

by Ufuk Celebi-2

[jira] [Created] (FLINK-6367) support custom header settings of allow origin by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

Mesos component status for 1.3 by Eron Wright

by till.rohrmann

[jira] [Created] (FLINK-6366) KafkaConsumer is not closed in FlinkKafkaConsumer09 by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-6365) Adapt default values of the Kinesis connector by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-6364) Implement incremental checkpointing in RocksDBStateBackend by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-6363) Document precedence rules of Kryo serializer registrations by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-6362) Unprotected access to registeredStates in SharedStateRegistry#getReferenceCount by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-6361) Finalize the AggregateFunction interface and refactoring built-in aggregates by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-6360) Failed to create assembly for Scala 2.11 due to tools/change-scala-version.sh not changing flink-gelly-examples_2.10 by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-6359) Utilize Hierarchical Timing Wheels for performant timer by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-6358) Write job details for Gelly examples by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-6357) Parametertool get unrequested parameters by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-6356) Make times() eager and enable allowing combinations. by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-6355) TableEnvironment support register TableFunction by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-6354) Add documentation for migration away from Checkpointed interface by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-6353) Restoring using CheckpointedRestoring does not work from 1.2 to 1.2 by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[DISCUSS] Planning Release 1.3 by Robert Metzger

by Kostas Kloudas

[jira] [Created] (FLINK-6352) FlinkKafkaConsumer should support to use timestamp to set up start offset by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-6351) Refactoring YarnFlinkApplicationMasterRunner by combining AbstractYarnFlinkApplicationMasterRunner in one class by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-6350) Flink: Windowing does not work with streams from collections and the local execution environment by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-6349) Enforce per-subtask record ordering on resharding for FlinkKinesisConsumer by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

1 ... 563564565566567568569 ... 781