(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 ... 280281282283284285286 ... 933

Topics (32649)

Replies

Last Post

Views

Does Flink support such a feature currently? by RocMarshal

by Marta Paes Moreira

[jira] [Created] (FLINK-19342) stop overriding convertFrom() in FlinkPlannerImpl after upgrade calcite to 1.23 by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19341) Update API module for FLIP-107 by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19340) AggregateITCase.testListAggWithDistinct failed with "expected:<List(1,A, 2,B, 3,C#A, 4,EF)> but was:<List(1,A, 2,B, 3,C#A, 4,EF#EF)>" by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[ANNOUNCE] Weekly Community Update 2020/38 by Konstantin Knauf-4

by Konstantin Knauf-4

[DISCUSS] FLIP-33: Standardize connector metrics by Becket Qin

by Konstantin Knauf-4

[jira] [Created] (FLINK-19339) Support Avro's unions with logical types by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19338) New source interface cannot unregister unregistered source by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

Automatically get udf's resource files from hdfs when running a job that uses hive-udf by Husky Zeng

by Jark Wu-2

[jira] [Created] (FLINK-19337) Make a little bit improvement for PyFlink package structure and class name. by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19336) EncodingUtils#encodeObjectToString should propagate inner exception by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19335) Automatically get udf's resource files from hdfs when running a job that uses hive-udf by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19334) Translate page 'Streaming File Sink' into Chinese by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19333) Introduce BatchArrowPythonOverWindowAggregateFunctionOperator by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19332) Special characters issue using Kinesis Data Analytics for Apache Flink by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19331) State processor api has native resouce leak when working with RocksDB by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19330) Recovery with async operations fails due to unitialized runtimeContext by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19329) FunctionGroupOperator#dispose might throw an NPE by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19328) flink sql by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19327) Helm charts specify a too low value for the job manager's heap size by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19326) Allow explicitly configuring time behaviour on CEP PatternStream by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19325) Optimize the consumed time for checkpoint completion by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19324) Map requested/allocated containers with priority on YARN by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19323) Small optimization of network layer record serialization by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19322) Specified parallelism in create table operation by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19321) CollectSinkFunction does not define serialVersionUID by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19320) Remove clearBuffers from the public interfaces of RecordWriter by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19319) Deprecate StreamExecutionEnvironment.setStreamTimeCharacteristic() by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19318) Deprecate timeWindow() operations in DataStream API by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19317) Make EventTime the default StreamTimeCharacteristic by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19316) FLIP-134: Batch execution for the DataStream API by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19315) Move slot-bookkeeping into separate component by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19314) Add compatibility layer by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19313) Implement declarative SlotPool by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19312) Introduce BufferWritingResultPartition which wraps the logic of writing buffers to ResultSubpartition by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

1 ... 280281282283284285286 ... 933