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

Topics (27279)

Replies

Last Post

Views

[jira] [Created] (FLINK-12695) Implement a HeapStatusMonitor by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-12694) Implement a HeapAccountingManager by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-12693) Store state per key-group in CopyOnWriteStateTable by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-12692) Support disk spilling in HeapKeyedStateBackend by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-12691) Make Queue Capacity and Timeout of AsyncWaitOperator changeable during runtime by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-12690) Introduce Planner interface by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-12689) Building flink-dist fails because flink-azure-fs-hadoop jar cannot be added to /opt by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

Apply contribute to Apache Flink by 何建宁

by 何建宁

[jira] [Created] (FLINK-12688) Make serializer lazy initialization thread safe in StateDescriptor by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-12687) ByteHashSet is always in dense mode by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-12686) StreamGraph Supports Blink Batch Mode by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-12685) Supports UNNEST query in blink planner by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-12684) User defined configuration for per job clusters by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-12683) Provide task manager's location information for checkpoint acknowledge message to improve the checkpoint log message by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[DISCUSS] Proposal to support disk spilling in HeapKeyedStateBackend by Yu Li

by Yu Li

[jira] [Created] (FLINK-12682) StringWriter support custom row delimiter by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

Apply for contributor permission by Piyush Goyal

by Piyush Goyal

[RESULT] [VOTE] Release flink-shaded 7.0, release candidate #3 by jincheng sun

by jincheng sun

[VOTE] Release flink-shaded 7.0, release candidate 3 by jincheng sun

by jincheng sun

[jira] [Created] (FLINK-12681) Make SimpleCounter thread-safe. by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-12680) Add timer type to metric system by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-12679) Support 'default-database' config for catalog entries in SQL CLI yaml file by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-12678) Add AbstractCatalog to manage the common catalog name and default database name for catalogs by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-12677) Add descriptor, validator, and factory for HiveCatalog by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-12676) add descriptor, validator, and factory for GenericInMemoryCatalog by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[DISCUSS] FLIP-42: Savepoint Connector by Seth Wiesman-3

by Seth Wiesman-3

[jira] [Created] (FLINK-12675) Event time synchronization in Kafka consumer by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-12674) BoundedBlockingSubpartition#unsynchronizedGetNumberOfQueuedBuffers is not implemented by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-12673) Introduce NetworkEnvironment.getUnreleasedPartitions instead of using getResultPartitionManager by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-12672) Use SingleInputGate.closeFuture in triggerPartitionStateCheck instead of consumer state in RemoteChannelStateChecker by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-12671) Summarizer: summary statistics for Table by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-12670) Implement FailureRateRestartBackoffTimeStrategy by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-12669) Implement FixedDelayRestartBackoffTimeStrategy by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-12668) Introduce fromParallelElements for generating DataStreamSource by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-12667) Add JobID argument to TaskExecutorGateway#releasePartitions by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

1 ... 352353354355356357358 ... 780