(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 ... 146147148149150151152 ... 778

Topics (27203)

Replies

Last Post

Views

Inconsistent behavior between different states with ListState.get().iterator().remove() by Ken Krugler

by Ken Krugler

[DISCUSS] Adding Azure Platform Support in DataStream, Table and SQL Connectors by Israel Ekpo

by Robert Metzger

[jira] [Created] (FLINK-18707) Calling remove() for RockDB ListState iterator does nothing by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-18706) Stop with savepoint cannot guarantee exactly-once for kafka source by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-18705) Debezium-JSON throws NPE when tombstone message is received by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-18704) Support DECIMAL types in datagen Table source connector by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-18703) Use new data structure converters when legacy types are not present by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-18702) Flink elasticsearch connector leaks threads and classloaders thereof by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[DISCUSS] FLIP-129: Refactor Descriptor API to register connector in Table API by Jark Wu-2

by Aljoscha Krettek-2

[jira] [Created] (FLINK-18701) NOT NULL constraint is not guaranteed when aggregation split is enabled by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-18700) Debezium-json format throws Exception when PG table's IDENTITY config is not FULL by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-18699) Allow variables for column names in Scala Table API by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-18698) org.apache.flink.sql.parser.utils.ParserResource compile error by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-18697) Adding flink-table-api-java-bridge_2.11 to a Flink job kills the IDE logging by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-18696) Java 14 Records are not recognized as POJOs by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-18695) Allow NettyBufferPool to allocate heap buffers by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-18694) Add unaligned checkpoint config to web ui by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-18692) AvroSerializationSchema does not work with types generated by avrohugger by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-18693) AvroSerializationSchema does not work with types generated by avrohugger by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-18691) add HiveCatalog Construction method with HiveConf by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-18690) Implement LocalInputPreferredSlotSharingStrategy by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-18689) Deterministic Slot Sharing by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-18688) ProjectionCodeGenerator#generateProjectionExpression should remove for loop optimization by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-18687) ProjectionCodeGenerator#generateProjectionExpression should remove for loop optimization by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-18686) Getting the emit time when `table.exec.emit.early-fire.enabled` is true by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

Re: Is it possible to do state migration with checkpoints? by Sivaprasanna

by Sivaprasanna

[jira] [Created] (FLINK-18685) JobClient.getAccumulators() blocks until streaming job has finished in local environment by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-18684) Performance regression around 2020.07.22 in serialization by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-18683) Support @DataTypeHint for TableFunction output types by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[ANNOUNCE] New PMC member: Piotr Nowojski by Stephan Ewen

by Matthias

[jira] [Created] (FLINK-18682) Vector orc reader cannot read Hive 2.0.0 table by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

Flink Redis connectivity by Ramya Ramamurthy

by 范超

[jira] [Created] (FLINK-18681) The jar package version conflict causes the task to continue to increase and grab resources by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-18680) Improve RecordsWithSplitIds API by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-18679) It doesn't support to join two tables containing the same field names in Table API by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

1 ... 146147148149150151152 ... 778