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

Topics (27215)

Replies

Last Post

Views

[jira] [Created] (FLINK-12304) AvroInputFormat should support schema evolution by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

Apache Flink survey by Ververica by Robert Metzger-3

by Robert Metzger-3

[jira] [Created] (FLINK-12303) Scala 2.12 lambdas does not work in event classes inside streams. by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-12302) fix the finalStatus of application when job not finished by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-12301) Scala value classes cannot be serialized anymore in case classes in Flink 1.8.0 by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-12300) Unused Import warning with DataStream[Seq[...]] by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-12299) ExecutionConfig#setAutoWatermarkInterval should check param(interval should not less than zero) by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-12298) Make column functions accept custom by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

Support for ProtoBuf data format in StreamingFileSink by Kailash Dayanand-2

by Driesprong, Fokko

[jira] [Created] (FLINK-12297) We should clean the closure for OutputTags by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-12296) Data loss silently in RocksDBStateBackend when more than one operator chained in a single task by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-12295) use retract aggregate function instead of regular aggregate function for retractable aggregate in code gen by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-12294) kafka consumer, data locality by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-12293) Fix some comment typos in flink-streaming-java. by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-12292) Add benchmarks for the input processors by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-12291) Add benchmarks for the input processors by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-12290) Fix the misleading exception message in SharedSlot class by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-12289) Fix bugs and typos in Memory manager by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-12288) Bump Calcite dependency to 1.19.0 in blink planner by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-12287) A document error in "StreamElement.java" by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-12286) The default log4j.properties will overwrite the customized log4j property file. by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-12285) Memory leak in SavepointITCase and SavepointMigrationTestBase by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-12284) InputBufferPoolUsage is incorrect in credit-based network control flow by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-12283) Allow non static UDF by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-12282) re-estimate row count for batch global Rank operator by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-12281) SortDistinctAggregateITCase>DistinctAggregateITCaseBase.testSomeColumnsBothInDistinctAggAndGroupBy Failed by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-12280) Add documentation for catalog entries in SQL client YAML file by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-12279) Create source to allow streaming data from websocket. by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-12278) Support user implemented and customized catalogs thru dynamic class loading by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-12277) Add documentation for unified catalog APIs by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-12276) Add documentation for HiveCatalog by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-12275) Add documentation for GenericHiveMetastoreCatalog by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-12274) Fix documentation to enable Queryable State by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-12273) The default value of CheckpointRetentionPolicy should be RETAIN_ON_FAILURE, otherwise it cannot be recovered according to checkpoint after failure. by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-12272) Enable session in ExecutionEnvironment by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

1 ... 364365366367368369370 ... 778