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

Topics (27371)

Replies

Last Post

Views

[jira] [Created] (FLINK-21839) SinkFunction snapshotState don't snapshot all data when trigger a stop-with-drain savepoint by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21838) Retranslate "JDBC SQL Connector" page into Chinese by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21837) Support StreamExecIntervalJoin/StreamExecLookupJoin/StreamExecTemporalJoin json ser/des by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21836) Introduce RegexOperationConverter by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21835) RocksDBStateBackendReaderKeyedStateITCase fail by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21834) org.apache.flink.core.fs.AbstractRecoverableWriterTest.testResumeWithWrongOffset fail by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21833) TemporalRowTimeJoinOperator State Leak Although configure idle.state.retention.time by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21832) Avro Confluent Schema Registry nightly end-to-end fail by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21831) CLONE - Add ChangelogStateBackend (proxy-everything) by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21830) [kinesis][auth] Add support for Session Token by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21829) create HiveCatalog with custom hadoopconfdir first by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21828) Add an AWS-λ example to stateful-playground by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21827) Migrate the Python examples to the new SDK by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21826) Migrate the shopping-cart-example to the new SDK. by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21825) AvroInputFormat doesn't honor -1 length on FileInputSplits by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21824) Add a simple Json Kafka producer script by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21823) RocksDB on FreeBSD by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21822) Migrate CatalogFactory to the new Factory stack by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21821) StreamTask.cancelables was closed concurrent between task canceler and task thread by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[DISCUSS] Removal of flink-swift-fs-hadoop module by Robert Metzger

by Robert Metzger

[jira] [Created] (FLINK-21819) Remove swift FS filesystem by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21818) Refactor SlicingWindowAggOperatorBuilder to accept serializer instead of LogicalType by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21817) FLIP-27 Source might break subtask and split assignment upon rescale by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21816) Support StreamExecGroupTableAggregate json ser/de by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21815) Support StreamExecUnion json ser/de by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21814) flink CollectSink error info unfriendly by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21813) Support StreamExecOverAggregate json ser/de by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21812) How to read data from kafka and sink to Postgresql Database by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21811) Support StreamExecJoin json serialization/deserialization by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21810) PyFlink end-to-end fails with "sorted[*]: unbound variable" by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21809) PyFlink end-to-end test fail by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21808) Support DQL in HiveParser by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21807) Make ApplicationDeployer interface public by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21806) ContinuousEventTimeTrigger should register its first timer base on current watermark by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21805) Support StreamExecRank and StreamExecSortLimit Json ser/de by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

1 ... 50515253545556 ... 783