(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 ... 631632633634635636637 ... 786

Topics (27508)

Replies

Last Post

Views

[jira] [Created] (FLINK-4536) Possible thread leak in Task Manager by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-4535) ResourceManager process registration from TaskExecutor by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-4534) Lack of synchronization in BucketingSink#restoreState() w.r.t. state.bucketStates by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-4533) Unprotected access to meters in StatsDReporter#report() by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

ApacheCon Seville CFP closes September 9th by Rich Bowen-2

by Rich Bowen-2

[jira] [Created] (FLINK-4532) Allow independent metrics reporter for tasks by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[HEADS-UP] Dev Week 35 by Aljoscha Krettek-2

by Aljoscha Krettek-2

[DISCUSS] Some thoughts about unify Stream SQL and Batch SQL grammer by 伍翀(云邪)

by Timo Walther-2

[DISCUSS] Releasing Flink 1.1.2 by Ufuk Celebi-2

by Robert Metzger

Memory Management in Streaming mode by Shen Li

by Robert Metzger

[jira] [Created] (FLINK-4531) Thread.stop() is deprecated by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

why job submit timeout is 21474835 second by Jinkui Shi

by mxm

[jira] [Created] (FLINK-4530) Generalize TaskExecutorToResourceManagerConnection to be reusable by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-4529) Move JobMaster, TaskExecutor and ResourceManager out of the rpc package by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-4528) Mark runAsync and scheduleAsync methods protected by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-4527) Drop the "flinkAccumulators" from the Execution by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-4526) ApplicationClient: remove redundant proxy messages by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-4525) Drop the "eager split pre-assignment" code paths by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

Yarn node went down... by Niels Basjes

by mxm

Check-pointing configuration by Bhupesh Chawda

by Bhupesh Chawda-2

[jira] [Created] (FLINK-4524) JobManagerProcessReapingTest.testReapProcessOnFailure unstable by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

Fwd: Enabling Encryption between slaves in Flink by Vinay Patil

by Till Rohrmann

[jira] [Created] (FLINK-4523) Allow Kinesis Consumer to start from specific timestamp by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-4522) Gelly link broken in homepage by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-4521) Fix "Submit new Job" panel in development mode by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-4520) Integrate Siddhi as a lightweight CEP Library by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-4519) scala maxLineLength increased to 120 by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-4518) maxLineLength change to 120 by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-4517) scala code refactoring by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

Apache siddhi into Flink by Aparup Banerjee (apb...

by Aparup Banerjee (apb...

[jira] [Created] (FLINK-4516) ResourceManager leadership election by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-4515) org.apache.flink.runtime.jobmanager.JobInfo class is not backwards compatible with 1.1 released version by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-4514) ExpiredIteratorException in Kinesis Consumer on long catch-ups to head of stream by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-4513) Kafka connector documentation refers to Flink 1.1-SNAPSHOT by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-4512) Add option for persistent checkpoints by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

1 ... 631632633634635636637 ... 786