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

Topics (27215)

Replies

Last Post

Views

[jira] [Created] (FLINK-11950) Add missing dependencies in NOTICE file of flink-dist. by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-11949) Introduce DeclarativeAggregateFunction and AggsHandlerCodeGenerator to blink planner by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-11948) When kafka sink parallelism<kafka partition num，kafka data distribution unbalance by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-11947) Support MapState key / value schema evolution for RocksDB by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-11946) Introduce Exec nodes by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-11945) Support Over aggregation for SQL by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-11944) Support FirstRow and LastRow for SQL by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-11943) Support TopN feature for Flink SQL by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-11942) Flink kinesis connector throws kinesis producer daemon fatalError by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-11941) Reuse single FileSegmentCheckpointStateOutputStream for multiple checkpoints by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-11940) Reduce storage amplification for FSCSOS by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-11939) Adjust components that need be modified by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-11938) Introduce all the new components by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-11937) Resolve small file problem in RocksDB incremental checkpoint by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-11936) Remove AuxiliaryConverter pull-in from calcite and fix auxiliary converter issue. by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-11935) Remove DateTimeUtils pull-in and fix datetime casting problem by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-11934) Remove the deprecate methods in TableEnvironment by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-11933) Exception in thread "main" java.lang.RuntimeException: No data sinks have been created yet. A program needs at least one sink that consumes data. Examples are writing the data set or printing it. by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-11932) Add support for generating optimized logical plan for 'select * from mytable' by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-11931) Avro Bulk Writer Factory for StreamingFileSink Bulk Format by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-11930) Split SegmentsUtil into some dedicated utilities by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-11929) remove useless transientBlobCache in ClusterEntrypoint by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-11928) Create a Compression string writer for flink-connectors-filesystem by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

Apply contributor permission by Jacky Yin 殷传旺

by Fabian Hueske-2

[jira] [Created] (FLINK-11927) Code clean up and refactor BinaryHashTable and LongHybridHashTable by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-11926) The Description of Assigners allowing a fixed amount of lateness is not correct by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-11925) KryoSerializerSnapshot doesn't completely capture state / configuration of Kryo instance by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-11924) Exception in thread "main" org.apache.flink.table.api.SqlParserException: SQL parse failed. Encountered "EXISTS" at line 1, column 40. by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-11923) Move reporter instantiation into MetricRegistryConfiguration by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-11922) Support MetricReporter factories by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-11921) Upgrade Calcite dependency to 1.19 by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

I want to contribute to Apache Flink. by 徐小斌

by Chesnay Schepler-3

[jira] [Created] (FLINK-11920) EnumValueSerializerUpgradeTest fails on Java 9 by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-11919) Exception in thread "main" org.apache.flink.table.api.SqlParserException: SQL parse failed. Encountered "FROM user" at line 1, column 17. by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[VOTE] Release 1.8.0, release candidate #1 by Aljoscha Krettek-2

by jincheng sun

1 ... 376377378379380381382 ... 778