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

Topics (27215)

Replies

Last Post

Views

[jira] [Created] (FLINK-12584) Add Bucket File Syetem Table Sink by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-12583) Add all format support align with the Java Table API by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-12582) Alterations in GenericInMemoryCatalog should check existing object and new object are of the same class by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-12581) HiveCatalog.alterTable() and alterDatabase() should check the existing object and new object are of same type by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-12580) Rename GenericHiveMetastoreCatalogTest to HiveCatalogFlinkMetadataTest, and HiveCatalogTest to HiveCatalogHiveMetadataTest by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-12579) Influx Metric exporter throws a lot of negative infinity errors by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-12578) Use secure URLs for Maven repositories by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-12577) Flink uses Kryo serializer if given a SpecificRecord type by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-12576) inputQueueLength metric does not work for LocalInputChannels by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-12575) Introduce planner rules to remove redundant shuffle and collation by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-12574) using sink StreamingFileSink files are overwritten when resuming application causing data loss by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-12573) ability to add suffix to part file created in Bucket (StreamingFileSink) by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-12572) Implement TableSource and InputFormat to read Hive tables by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-12571) Make NetworkEnvironment#start() return the binded data port by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-12570) Switch Task from ResultPartition to ResultPartitionWriter interface by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-12569) Broken/Outdated docker/build.sh for flink 1.8.0 by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-12568) Implement TableSink and OutputFormat to write Hive tables by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-12567) Rework DescriptorProperties to adapt unified DDL with clause and Descriptor key value pairs by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-12566) Remove row interval type by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-12565) PythonStreamBinderTest#testProgram test failer by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

Job recovery with task manager restart by Thomas Weise

by Thomas Weise

[jira] [Created] (FLINK-12564) Remove getBufferProvider method from ResultPartitionWriter interface by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-12563) Introduce vector data format in blink by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

Contributor by 何泽雄

by 何泽雄

[DISCUSS] Flink SQL DDL Design by Shuyi Chen

by Danny Chan

[jira] [Created] (FLINK-12562) Improve code in ExpandColumnFunctionsRule by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[ANNOUNCE] Seattle Flink Meetup at AWS on May 30 by bowen.li

by bowen.li

[jira] [Created] (FLINK-12561) Unable to insert into cassandra table using FileWordCount example using Remote Cassandra Host with credentials by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-12560) Documentation language build flags by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-12559) Introduce metadata handlers on window aggregate by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

questions about yarn container（taskmanager）memory allocation by XiangWei Huang

by Xintong Song

[jira] [Created] (FLINK-12558) Yarn application can't stop when flink job finished by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-12557) Unify create table DDL with clause and connector descriptor keys by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-12556) Extend some end-to-end tests to run with custom (input) File System implementation by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-12555) Introduce an incapsulated metric group layout for shuffle API and deprecate old one by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

1 ... 354355356357358359360 ... 778