(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 ... 387388389390391392393 ... 814

Topics (28484)

Replies

Last Post

Views

[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...

[jira] [Created] (FLINK-12666) Update RM idleness check for TMs to take partitions into account by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-12665) Introduce MiniBatchIntervalInferRule and watermark assigner operators by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

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

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-12663) Implement HiveTableSource to read Hive tables by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-12662) Flink how jobs for failover in history server as well by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

NPE in DataStream by Abderrazak TAZARNI

by Abderrazak TAZARNI

[jira] [Created] (FLINK-12661) test failure: RestAPIStabilityTest.testDispatcherRestAPIStability by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

job specific configs by Moorhead,Richard

by Moorhead,Richard

Application for contributor permission by 杨钊

by 杨钊

[jira] [Created] (FLINK-12660) Integrate Flink with Hive GenericUDAFResolver and GenericUDAFResolver2 by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-12659) Integrate Flink with Hive GenericUDTF by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-12658) Integrate Flink with Hive GenericUDF by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-12657) Integrate Flink with Hive UDF by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-12656) Integrate Flink with Hive user defined functions by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-12655) SlotCountExceedingParallelismTest failed on Travis by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-12654) Enable Azure FS E2E tests on Travis by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

KeyGroup management, data locality by Smirnov Sergey Vladi...

by Smirnov Sergey Vladi...

[jira] [Created] (FLINK-12653) Keyed state backend fails to restore during rescaling by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-12652) Add Glossary to Concepts Section of Documentation by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-12651) Add "Style Guide" to Documentation Contribution Guide by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

1 ... 387388389390391392393 ... 814