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

Topics (27278)

Replies

Last Post

Views

[DISCUSS][FLINK-3414] Scala API for CEP's pattern definition by Ivan Mushketyk

by Ivan Mushketyk

[DISCUSS] [FLINK-3950] Meter interface by Ivan Mushketyk

by Ivan Mushketyk

[jira] [Created] (FLINK-4460) Expose Late Arriving Events by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-4459) Introduce SlotProvider to Scheduler by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-4458) Remove ForkableFlinkMiniCluster by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-4457) Make the ExecutionGraph independent of Akka by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-4456) Replace ActorGateway in RuntimeEnvironment by interface by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-4455) Replace ActorGateways in NetworkEnvironment by interfaces by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-4454) Lookups for JobManager address in config by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-4453) Scala code example in Window documentation shows Java by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-4452) TaskManager network buffer guages by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-4451) Throw exception when remote connection cannot be resolved by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-4450) update storm version to 1.0.0 by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-4449) Heartbeat Manager between ResourceManager and TaskExecutor by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-4448) Use Listeners to monitor execution status by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-4447) Include NettyConfig options on Configurations page by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-4446) Move Flume Sink from Flink to Bahir by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[DISCUSS] FLIP-10: Unify Savepoints and Checkpoints by Ufuk Celebi-2

by Till Rohrmann

[jira] [Created] (FLINK-4445) Ignore unmatched state when restoring from savepoint by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-4444) Add a DFSInputChannel and DFSSubPartition by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-4443) Add support in RpcCompletenessTest for inheritance of RpcGateway and RpcEndpoint by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-4442) Implement Standalone ResourceManager by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-4441) RocksDB statebackend makes all operators appear stateful by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-4440) Make API for edge/vertex creation less verbose by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-4439) Error message KafkaConsumer08 when all 'bootstrap.servers' are invalid by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-4438) FlinkML Quickstart Guide implies incorrect type for test data by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[FLINK-1707] Add an Affinity Propagation Library Method by Josep Rubio

by Josep Rubio

[jira] [Created] (FLINK-4437) Lock evasion around lastTriggeredCheckpoint may lead to lost updates to related fields by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-4436) Unclosed DataOutputBuffer in Utils#setTokensFor() by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-4435) Replace Guava's VisibleForTesting annotation with Flink's annotation by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-4434) Add a testing RPC service by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-4433) Refactor the StreamSource. by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-4432) (YARN) JobManager web port is no longer available in configuration page in web interface by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-4431) Introduce a "VisibleForTesting" annotation by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[DISCUSS] Move Redis and Flume connectors to Apache Bahir and redirect contributions there by Robert Metzger

by subhankar biswas

1 ... 627628629630631632633 ... 780