(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 ... 461462463464465466467 ... 783

Topics (27402)

Replies

Last Post

Views

Why not put "FLIP: Network Stack Improvements" into Confluence page? by 魏偉哲

by 魏偉哲

[jira] [Created] (FLINK-9612) Add option for minimal artifacts being pulled in meseos by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-9611) Allow for user-defined artifacts to be specified as part of a mesos overlay by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-9610) Add Kafka partitioner that uses the key to partition by by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[ANNOUNCE] Weekly community update #25. by Till Rohrmann

by Till Rohrmann

[jira] [Created] (FLINK-9609) Add bucket ready notification mechanism for BucketingSink when checkpoint complete by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-9608) Add test base for TypeSerializer snapshotting / restore / migration to be used by all Flink serializers by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-9607) Support ParquetTableSink by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-9606) Support ParquetTableSource by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-9605) Support KafkaProtoBufTableSink by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-9604) Support KafkaProtoBufTableSource by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

v1.5 cancel job rest API by Jake Croft

by dwysakowicz

[jira] [Created] (FLINK-9603) Incorrect indexing of part files, when part suffix is specified (FileAlreadyExistsException) by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-9602) Extend CommonOption section by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-9601) Snapshot of CopyOnWriteStateTable will failed, when the amount of record is more than MAXIMUM_CAPACITY by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-9600) Add DataStream transformation variants that pass timestamp to the user function by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-9599) Implement generic mechanism to receive files via rest by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[DISCUSS] Flink 1.4 and below STOPS writing to Kinesis after June 12th. by bowen.li

by Thomas Weise

[jira] [Created] (FLINK-9598) [Checkpoints] The config Minimum Pause Between Checkpoints doesn't work when there's a checkpoint failure by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-9597) Flink fail to scale! by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-9596) Ability to configure logging using the same log4j file by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-9595) Add instructions to docs about ceased support of KPL version used in Kinesis connector by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-9594) Add documentation for e2e test changes introduced with FLINK-9257 by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-9593) Unify AfterMatch semantics with SQL MATCH_RECOGNIZE by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-9592) Notify on moving into pending/ final state by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-9591) Remove remnants of distributed-cache logic by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-9590) HistogramDump should be immutable by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-9589) PythonOperationInfo should be immutable by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[ANNOUNCE] Registration for Flink Forward Berlin is open by Fabian Hueske-2

by Fabian Hueske-2

[jira] [Created] (FLINK-9588) Reuse the same conditionContext with in a same computationState by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

Static code analysis for Flink project by simeon.arkhipov

by Joern Kottmann

[jira] [Created] (FLINK-9587) ContinuousFileMonitoringFunction crashes on short living files by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-9586) Make collection sources parallelisable by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-9585) Logger in ZooKeeperStateHandleStore is public and non-final by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-9584) Unclosed streams in Bucketing-/RollingSink by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

1 ... 461462463464465466467 ... 783