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

Topics (27279)

Replies

Last Post

Views

[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...

[jira] [Created] (FLINK-10909) Possible RocksDBStateBackend performance regression with rocksdbjni-5.7.5 by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-10908) Add yarn.application.priority in YarnConfigOptions by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-10907) Job recovery on the same JobManager causes JobManager metrics to report stale values by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-10906) docker-entrypoint.sh logs credentails during startup by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-10905) HadoopConfigLoader logs Credentials on DEBUG level by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-10904) Expose Classloader before Pipeline execution by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-10903) Shade Internal Akka Dependencies by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-10902) Jobmanager in HA setup communicates the ip address instead of hostnames by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-10901) Jobmanager REST ip binds to ip address instead of hostname by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-10900) Mark Kafka 2.0 connector as beta feature by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-10899) Don't explicitly set version in flink-end-to-end-tests sub modules by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-10898) Add yarn.application-attempts-failures-validity-interval in YarnConfigOptions by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-10897) Support POJO state schema evolution by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-10896) Extend state schema evolution support for more composite types by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-10895) TypeSerializerSnapshotMigrationITCase.testSavepoint test failed on travis by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-10894) Resuming Externalized Checkpoint (file, async, scale down) end-to-end test failed on travis by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-10893) Streaming File Sink s3 end-to-end test failed on travis by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-10892) Flink Yarn app name is hard coded by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-10891) Upgrade Kafka client version to 2.0.1 by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-10890) CLONE - Add DataStream HBase Sink by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

Need help with Kinesis related PRs by Thomas Weise

by Thomas Weise

[jira] [Created] (FLINK-10889) Semantic inconsistency between DataSet#print and DataStream#print by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

1 ... 414415416417418419420 ... 780