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

Topics (27279)

Replies

Last Post

Views

[jira] [Created] (FLINK-10342) Kafka duplicate topic consumption when topic name is changed by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-10341) Add option to print flink command when running bin/flink by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-10340) Implement Cosh udf by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-10339) SpillReadBufferPool cannot use off-heap memory by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-10338) Use ZooKeeperStateStore in ZooKeeperMesosWorkerStore by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-10337) Use ZooKeeperStateStore in ZooKeeperCompletedCheckpointStore by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-10336) Use ZooKeeperStateStore in ZooKeeperSubmittedJobGraphStore by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-10335) Create common ZooKeeperStateStore based on ZooKeeperStateHandleStore and RetrievableStateStorageHelper by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-10334) Move RetrievableStateStorageHelper out of ZooKeeperStateHandleStore by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-10333) Rethink ZooKeeper based stores (SubmittedJobGraph, MesosWorker, CompletedCheckpoints) by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-10332) Move data available notification in PipelinedSubpartition out of the synchronized block by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-10331) Fix unnecessary flush requests to the network stack by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-10330) Code Compilation failed in local mode by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-10329) Fail with exception if job cannot be removed by ZooKeeperSubmittedJobGraphStore#removeJobGraph by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-10328) Stopping the ZooKeeperSubmittedJobGraphStore should release all currently held locks by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-10327) Pass processWatermark calls from (Co)ProcessOperator to (Co)ProcessFunction by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-10326) Simplify ZooKeeperSubmittedJobGraphStore constructor by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-10325) [State TTL] Refactor TtlListState to use only loops, no java stream API for performance by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-10324) Replace ZooKeeperStateHandleStore#getAllSortedByNameAndLock by getAllAndLock by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-10323) A single backslash cannot be successfully parsed in Java Table API by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

Jar availability after cluster restart by Ricardo.Costa

by Till Rohrmann

[jira] [Created] (FLINK-10322) Unused instance variable MetricRegistry in ResourceManager by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-10321) Make the condition of broadcast partitioner simple by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-10320) Introduce JobMaster schedule micro-benchmark by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-10319) Avoid requestPartitionState from JM but always try retrigger by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-10318) Add option to build Hadoop-free job image to build.sh by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-10317) Configure Metaspace size by default by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

Elasticsearch InputFormat by Michael Gendelman

by Till Rohrmann

[ANNOUNCE] New committer Gary Yao by Till Rohrmann

by Zhijiang(wangzhijian...

Could you please assign issue-10002 to me? by XinyuZhang

by Tzu-Li (Gordon) Tai

[jira] [Created] (FLINK-10316) Kinesalite bug fix (FLINK-9402) doesn't fully fix the problem. by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-10315) Let JDBCAppendTableSink be built with java.sql.Connection by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-10314) Blocking calls in Execution Graph creation bring down cluster by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-10313) Wrong FileCache warning about improper use of releaseJob() when not using DistributedCache by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-10312) Wrong / missing exception when submitting job by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

1 ... 433434435436437438439 ... 780