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

Topics (27306)

Replies

Last Post

Views

[jira] [Created] (FLINK-4840) Introduce an OperatorSystemMetricGroup by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-4839) JobManager handle TaskManager's slot offering by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-4838) remove STREAM keyword in StreamSQLExample by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-4837) flink-streaming-akka source connector by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-4836) Implement Mini Cluster by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-4835) Implement standalone High Availability Services by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-4834) Implement unified High Availability Services Abstraction by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

A master project about implementing Cypher on Apache Flink by Mengqi Yang

by Vasiliki Kalavri

[jira] [Created] (FLINK-4833) Unstable test OperatorStatsAccumulatorTest.testAccumulatorHeavyHitterCountMinSketch by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-4832) Count/Sum 0 elements by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-4831) IMplement a log4j metric reporter by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-4830) Show latency statistics in web interface by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[DISCUSS] Deprecate Hadoop source method from (batch) ExecutionEnvironment by Fabian Hueske-2

by Robert Metzger

[jira] [Created] (FLINK-4829) Accumulators are not thread safe by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-4828) execute stream job asynchronously by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-4827) Sql on streaming example use scala with wrong variable name by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-4826) Add keytab based kerberos support to run Flink in Mesos environment by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[ANNOUNCE] Flink 1.1.3 Released by Ufuk Celebi-2

by Ufuk Celebi-2

[jira] [Created] (FLINK-4825) Implement a RexExecutor that uses Flink's code generation by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-4824) CliFrontend shows misleading error message when main() method returns before env.execute() by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-4823) org.apache.flink.types.NullFieldException: Field 0 is null, but expected to hold a value by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

How to contribute to Streaming Table API and StreamSQL by 伍翀(云邪)

by Fabian Hueske-2

[jira] [Created] (FLINK-4822) Ensure that the Kafka 0.8 connector is compatible with kafka-consumer-groups.sh by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-4821) Implement rescalable non-partitioned state for Kinesis Connector by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

java.lang.IllegalArgumentException: JDBC-Class not found. - org.postgresql.jdbc.Driver by sunny patel

by Fabian Hueske-2

[jira] [Created] (FLINK-4820) Slf4j / log4j version upgrade to support dynamic change of log levels. by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-4819) Checkpoint metadata+data inspection tool (view / update) by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-4818) RestartStrategy should track how many failed restore attempts the same checkpoint has and fall back to earlier checkpoints by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-4817) Checkpoint Coordinator should be called to restore state with a specific checkpoint ID by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-4816) Executions from "DEPLOYING" should retain restored checkpoint information by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-4815) Automatic fallback to earlier checkpoints when checkpoint restore fails by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[RESULT] [VOTE] Release Apache Flink 1.1.3 (RC2) by Ufuk Celebi-2

by Ufuk Celebi-2

[VOTE] Release Apache Flink 1.1.3 (RC2) by Ufuk Celebi-2

by Till Rohrmann

[jira] [Created] (FLINK-4814) Remove extra storage location for externalized checkpoint metadata by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[DISCUSS] Removing delete*Timer from the WindowOperator.Context by Kostas Kloudas

by Kostas Kloudas

1 ... 614615616617618619620 ... 781