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

Topics (27404)

Replies

Last Post

Views

[jira] [Created] (FLINK-12595) KinesisDataFetcherTest.testOriginalExceptionIsPreservedWhenInterruptedDuringShutdown deadlocks by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-12594) Make Job ID Configurable for a Job Cluster by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-12593) Revise the document for CEP by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

Kinesis Connector RuntimeException by PoolakkalMukkath, Sh...

by Thomas Weise

[jira] [Created] (FLINK-12592) StreamTableEnvironment object has no attribute connect by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-12591) StatsDReporterTest is unstable by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-12590) Replace http links in documentation by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

rmetzger@apache.org by 何泽雄

by Robert Metzger

[jira] [Created] (FLINK-12589) SQL end-to-end test fails on Travis by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-12588) Add TableSchema for Python Table API by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-12587) Add pure-API Watermark class by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

contribute to Apache Flink by lujisen@126.com

by Robert Metzger

[jira] [Created] (FLINK-12586) Stderr and stdout are reversed in OptimizerPlanEnvironment by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-12585) Align Stream/BatchTableEnvironment with JAVA Table API by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[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

1 ... 359360361362363364365 ... 783