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

Topics (27279)

Replies

Last Post

Views

[jira] [Created] (FLINK-11976) PyFlink vectorized python udf with Pandas support by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-11975) Support to run a sql query : 'SELECT * FROM (VALUES (1, 2, 3)) T(a, b, c)' by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-11974) Introduce StreamOperatorSubstitutor to help table perform the whole Operator CodeGen by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-11973) computeSelfCost method should not return null to avoid NPE by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-11972) Fix `Command: start_kubernetes_if_not_ruunning failed` error by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-11971) The classpath is missing the `flink-shaded-hadoop2-uber-2.8.3-1.8.0.jar` JAR during the end-to-end test. by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-11970) TableEnvironment#registerFunction should overwrite if the same name function existed. by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-11969) Add end2end stream sql test for unbounded operators by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-11968) Fix runtime SingleElementIterator.iterator and remove table.SingleElementIterator by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

Re: Backoff strategies for async IO functions? by Rong Rong

by Rong Rong

[DISCUSS] Add column operations in Table API by jincheng sun

by jincheng sun

[jira] [Created] (FLINK-11967) Add Column Operators/Operations by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

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

by Aljoscha Krettek-2

[jira] [Created] (FLINK-11966) Add support for generating optimized logical plan for simple query(project, filter, values and union all) by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-11965) Provide a REST API for flink to submit plain SQL flink jobs. by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-11964) Avoid hash collision of partition and bucket in HybridHashTable by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-11963) Add time-based cleanup mechanism in history server by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-11962) Huge Flink Checkpoint Size When Using "Group By" Clause With Table SQL by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-11961) Clear up and refactor the code generation of scalar functions and operators by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-11960) Check all the builtin functions and operators are reasonable by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-11959) Introduce window operator for blink streaming runtime by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-11958) flink on windows yarn deploy failed by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-11957) Expose failure cause in the API response when dispatcher fails to submit a job by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-11956) Remove shading from filesystems build by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-11955) Modify build to move filesystems from lib to plugins folder by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-11954) Provide unit test(s) for new plugin infrastructure by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-11953) Introduce Plugin/Loading system and integrate it with FileSystem by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-11952) Introduce Plugin Architecture for loading FileSystems by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-11951) Enhance UserDefinedFunction interface to allow more user defined types by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

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

1 ... 377378379380381382383 ... 780