(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 (27218)

Replies

Last Post

Views

[jira] [Created] (FLINK-18722) Migrate MesosResourceManager to the new MesosResourceManagerDriver by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-18720) Migrate KubernetesResourceManager to the new KubernetesResourceManagerDriver by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-18719) Define the interfaces and introduce ActiveResourceManager by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-18718) Support for using yarn-cluster CLI parameters on application mode by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-18717) reuse MiniCluster in table integration test class ? by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-18716) Remove the deprecated "execute" and "insert_into" calls in PyFlink Table API docs by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-18715) add cpu usage metric of jobmanager/taskmanager by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-18714) Support consuming multiple topics for KafkaTableSource by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-18713) Allow default ms unit for table.exec.mini-batch.allow-latency etc. by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-18712) Flink RocksDB statebackend memory leak issue by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-18711) Trim the blank space for TableOptions by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-18710) ResourceProfileInfo is not serializable by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-18709) Implement PhysicalSlotProvider by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-18708) The links of the connector sql jar of Kafka 0.10 and 0.11 are extinct by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

Functions in Flick by david david

by Robert Metzger

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

1 ... 146147148149150151152 ... 778