(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 ... 417418419420421422423 ... 784

Topics (27406)

Replies

Last Post

Views

[jira] [Created] (FLINK-10941) Slots prematurely released which still contain unconsumed data by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-10940) Refactor the maven dependencies of Kafka 0.8 connector by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-10939) Add documents for Flink on native k8s by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-10938) Enable Flink on native k8s E2E Tests in Travis CI by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-10937) Add scripts to create docker image for k8s by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-10936) Implement Command line tools by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-10935) Implement KubeClient with Faric8 Kubernetes clients by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-10934) Implement KubernetesJobClusterEntrypoint by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-10933) Implement KubernetesSessionClusterEntrypoint by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-10932) Initial flink-kubernetes module with empty implementation by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-10931) Exclude transitive dependence on Kafka-client by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-10930) Refactor checkpoint directory layout by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-10929) Add support for Apache Arrow by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-10928) Job unable to stabilise after restart by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-10927) Resuming Externalized Checkpoint (r, inc, up) test instable by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

JIRA assignment by Joey Echeverria

by Fabian Hueske-2

[jira] [Created] (FLINK-10926) Add TIMESTAMPDIFFmath function supported in Table API and SQL by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-10925) NPE in PythonPlanStreamer by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-10924) StreamExecutionEnvironment method javadocs incorrect in regards to used charset by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-10923) Make SlotPool Status Machine-Readable by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-10922) Refactor the placement of the Flink Kafka connector end to end test module by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[DISCUSS] Task speculative execution for Flink batch by Tao Yangyu

by Tao Yangyu

[jira] [Created] (FLINK-10921) Prioritize shard consumers in Kinesis Consumer by event time by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-10920) Remove Kafka examples from binary distribution by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-10919) Flink binary distribution too large by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-10918) incremental Keyed state with RocksDB throws cannot create directory error in windows by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-10917) Bump up the version of codahale's metrics-core to 3.2.3 or higher by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-10916) Include duplicated user-specified uid into error message by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-10915) clojure context.collectWithTimestamp Will be blocked. by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-10914) Prefer notifying status changed to waiting and checking in ExecutionGraph tests by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-10913) ExecutionGraphRestartTest.testRestartAutomatically unstable on Travis by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-10912) Configurable RocksDBStateBackend options factory by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

How to use RocksDBStateBackend predefined options by Thomas Weise

by Thomas Weise

[jira] [Created] (FLINK-10911) Flink's flink-scala-shell is not working with Scala 2.12 by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-10910) Harden Kubernetes e2e test by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

1 ... 417418419420421422423 ... 784