(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 ... 401402403404405406407 ... 780

Topics (27279)

Replies

Last Post

Views

[jira] [Created] (FLINK-11298) Scheduling job in the unit of concurrent groups by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-11297) Add a doc link of jobmanager ha details by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

Request multiple subpartitions of one partition by Chris Miller

by Zhijiang(wangzhijian...

[jira] [Created] (FLINK-11296) Support truncate in TableAPI by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-11295) Rename configuration options of queryable state from query.x to queryable-state.x by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-11294) Remove legacy JobInfo usage in valid tests by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-11293) KafkaITCase.testConcurrentProducerConsumerTopology times out on Travis by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-11292) Document how to use the new CompositeTypeSerializerSnapshot by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[DISCUSS] Integrate Flink SQL well with Hive ecosystem by Zhang, Xuefu

by Timo Walther-2

[jira] [Created] (FLINK-11291) Reorganize the package of flink-cep module by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-11290) BatchTableEnvironment and StreamTableEnvironment should transparent to users by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-11289) Rework example module structure to account for licensing by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-11288) Add separate flink-ml for building fat jar by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-11287) RocksDBListState creation should use actual registered state serializer instead of serializer provided by descriptor by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-11286) Support to send StreamStatus.IDLE for non-source operators by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-11285) Change the modifier of CsvTableSourceFactoryBase.createTableSource and CsvTableSinkFactoryBase.createTableSink to private[flink] by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-11284) RocksDBStateBackendMigrationTest.testStateBackendRestoreSucceedsIfNewKeySerializerRequiresReconfiguration fails on Travis by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-11283) Accessing the key when processing connected keyed stream by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[DISCUSS] Detection Flink Backpressure by 裴立平

by Piotr Nowojski-2

[attention] now there is a test broken in CI environment by Forward Xu

by Forward Xu

[jira] [Created] (FLINK-11282) Merge StreamRecordWriter into RecordWriter by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-11281) Two test in StateBackendMigrationTestBase failes by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-11280) RocksDBSerializedCompositeKeyBuilder's key serializer is not being reconfigured properly by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-11279) The bug of Error parsing ExpressionParser by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-11278) Add documentation for TableAPI&SQL in scala-shell by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-11277) Queryable state IT test failed by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-11276) Slicing Window Optimization by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-11275) Unified Catalog APIs by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-11274) Scala 2.12 Kryo serialization bug by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-11273) Queryable state (rocksdb) end-to-end test fails by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-11272) Support for parsing multiple --yarnship parameters by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

Why UDF can not be non-static inner class ? by Jeff Zhang

by Jeff Zhang

[jira] [Created] (FLINK-11271) Improve Kerberos Credential Distribution by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-11270) Do not include hadoop in flink-dist by default by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-11269) Extend Download page to list optional components by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

1 ... 401402403404405406407 ... 780