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

Topics (27279)

Replies

Last Post

Views

[jira] [Created] (FLINK-9626) Possible resource leak in FileSystem by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-9625) Enrich the error information to user by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-9624) Move jar/artifact upload logic out of JobGraph by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-9623) Move zipping logic out of blobservice by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-9622) DistributedCacheDfsTest failed on travis by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-9621) Warning when enabling partition discovery by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-9620) Add an alternative option to choose when deal with eventtime cep by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-9619) Always close the task manager connection when the container is completed in YarnResourceManager by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

DataStreamCalcRule$1802" grows beyond 64 KB when execute long sql. by zhangminglei

by zhangminglei

[jira] [Created] (FLINK-9618) NullPointerException in FlinkKinesisProducer when aws.region is not set and aws.endpoint is set by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-9617) Provide alias for whole records in Table API by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-9616) DatadogHttpReporter fails to be created due to missing shaded dependency by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

Please review FLINK-9610 Add Kafka partitioner that uses the key to partition by by Niels Basjes

by Niels Basjes

[jira] [Created] (FLINK-9615) Add by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-9614) Improve the error message for Compiler#compile by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-9613) YARNSessionCapacitySchedulerITCase failed because YarnTestBase.checkClusterEmpty() by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

Improvements to Mesos Deployments Using Docker by Addison Higham

by Till Rohrmann

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

1 ... 457458459460461462463 ... 780