(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 ... 644645646647648649650 ... 807

Topics (28240)

Replies

Last Post

Views

[jira] [Created] (FLINK-4749) Remove redundant processing time timers and futures in the window operator by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-4748) Fix shutdown of automatic watermark context by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-4747) Instability due to pending processing timers on operator close by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-4746) Replace TaskManagerRuntimeInfo by TaskManagerConfiguration by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-4745) Convert KafkaTableSource test to unit tests by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-4744) Introduce usercode class loader to deserialize partitionable operator state by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[Discuss] Upgrade JUnit to 4.12 by Greg Hogan

by Greg Hogan

Some questions about Table API and FlinkSQL by Anton Mushin

by Anton Mushin

[jira] [Created] (FLINK-4743) The sqrt/power function not accept the real data types. by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

AWS S3 and Reshift by sunny patel

by sunny patel

[jira] [Created] (FLINK-4742) NPE in WindowOperator.trigger() on shutdown by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-4741) WebRuntimeMonitor does not shut down all of it's threads (EventLoopGroups) on exit. by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-4740) Upgrade testing libraries by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-4739) Adding packaging details for the Elasticsearch connector by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-4738) Port TaskManager logic to TaskExecutor by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-4737) Add more compression algorithms to FileInputFormat by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-4736) Don't duplicate fields in Ordering by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[DISCUSS] Bump HBase version for hadoop-2 to 1.2.3 by Fabian Hueske-2

by Márton Balassi

[jira] [Created] (FLINK-4735) Migrate some job execution related akka messages to rpc calls by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-4734) Remove use of Tuple setField for fixed position by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

Flink scala or Java - Dataload from CSV to database.. by ram kumar

by Flavio Pompermaier

[jira] [Created] (FLINK-4733) Port WebFrontend to new metric system by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-4732) Maven junction plugin security threat by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-4731) HeapKeyedStateBackend restorig broken for scale-in by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

Does the job name affect checkpointing? by dan bress

by Ufuk Celebi-2

[jira] [Created] (FLINK-4730) Introduce CheckpointMetaData by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-4729) Use optional VertexCentric CombineFunction by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-4728) Replace reference equality with object equality by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-4727) Kafka 0.9 Consumer should also checkpoint auto retrieved offsets even when no data is read by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

Using Flink by Govindarajan Sriniva...

by Govindarajan Sriniva...

[jira] [Created] (FLINK-4726) Quickstart: Java API - Broken by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-4725) BucketingSink throws NPE while restoring state if basePath does not exist by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-4724) When executed in YARN wrong log4j & logback configuration file is used by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-4723) Unify definition of committed offsets to Kafka / ZK for Kafka 0.8 and 0.9 consumer by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-4722) Consumer group concept not working properly with FlinkKafkaConsumer09 by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

1 ... 644645646647648649650 ... 807