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

Topics (27218)

Replies

Last Post

Views

[jira] [Created] (FLINK-19608) Support window TVF based window aggreagte in planner by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19607) Implement streaming window TopN operator by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19606) Implement streaming window join operator by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19605) Implement cumulative windowing for window aggregate operator by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19604) FLIP-145: Support SQL windowing table-valued function by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19603) Introduce shuffle data compression to sort-merge based blocking shuffle by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19602) Introduce new config options to enable sort-merge based blocking shuffle by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19601) Introduce sort-merge based blocking result partition SortMergeResultPartition and the corresponding subpartition reader by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19600) Introduce PartitionedFile and the corresponding writer/reader for sort-merge based blocking shuffle by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19599) Introduce ParquetBulkFormatFactory to integrate new FileSource to table by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19598) E2E test Kerberized YARN application on Docker test (default input) fails on CI by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19597) Introduce SortBuffer and its implementation PartitionSortedBuffer for sort-merge based blocking shuffle by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19596) Do not recover CompletedCheckpointStore on each failover by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19595) Flink SQL support S3 select by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19594) SubTasks start index don't unified and may confuse users by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19593) FlinkKafkaInternalProducer should be @Internal annotation ? by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[DISCUSS]Why not emit messages to prevent too early state eviction in MiniBatchGroupAggFunction? by Smile

by Smile

[jira] [Created] (FLINK-19592) MiniBatchGroupAggFunction should emit messages to prevent too early state eviction of downstream operators by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19591) Missing @Internal annotation SimpleJdbcConnectionProvider by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19590) flink-streaming-java module failed to compile by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19589) Expose extra options in the S3 FileSystem by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19588) HBase zookeeper connection not released in hbase batch table source while flink job failover by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19587) Error result when casting binary type as varchar by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19586) Implement the stream committer operator by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19585) UnalignedCheckpointCompatibilityITCase.test:97->runAndTakeSavepoint by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19584) HBaseSinkFunction no needs to create thread to flush when bufferFlushMaxMutations = 1 by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19583) Expose the execution.runtime-mode to the users by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19582) Introduce sort-merge based blocking shuffle to Flink by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19581) Introduce OrcColumnarRowInputFormat by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19580) Creating PackagedProgram overwrites an actual job name with default JobName by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

Wrapping a Flink Function by Lorenzo Pirazzini

by Aljoscha Krettek-2

[jira] [Created] (FLINK-19579) Create the SideOutputTransformation translator by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19577) Create the UnionTransformation translator by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19578) Create the PartitionTransformation translator by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19576) Create the SinkTransformation translator by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

1 ... 116117118119120121122 ... 778