(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 ... 265266267268269270271 ... 786

Topics (27508)

Replies

Last Post

Views

[jira] [Created] (FLINK-15406) The savepoint is writted by "State Processor API" can't be restore by map or flatmap by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-15405) Make Yarn staging directory configurable by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-15404) How to insert hive table for different catalog by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-15403) 'State Migration end-to-end test from 1.6' is unstable on travis. by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-15402) Add disable quote character feature for serializing row to csv format by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-15401) Planner should set sink field names to setKeyFields of upsert sink by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-15400) elasticsearch sink support dynamic index. by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-15399) Join with a LookupableTableSource：java.lang.RuntimeException: while converting XXXX Caused by: java.lang.AssertionError: Field ordinal 26 is invalid for type by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-15398) Correct catalog doc example mistake by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-15397) Streaming and batch has different value in the case of count function by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-15396) Support to ignore parse errors for JSON format by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

Flink 1.9 SQL Kafka Connector，Json format，how to deal with not json message? by LakeShen

by Jark Wu-2

[jira] [Created] (FLINK-15395) No API for execute insert into statement by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-15394) in yarn mode, jobmanager fails to start in case of rest.port conflict. by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-15393) Change 'ReturnExpiredIfNotCleanedUp' to 'NeverReturnExpired' in JoinRecordStateViews#createTtlConfig by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-15392) SqlClient by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-15391) DATE and TIMESTAMP partition columns don't work by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

Apply for contributing to Apache Flink by hechao

by Congxian Qiu

[jira] [Created] (FLINK-15390) List/Map/Struct support for vectorized orc reader by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

Apply for contributor permission by 余贤圣

by OpenInx

[jira] [Created] (FLINK-15389) JDBCUpsertOutputFormat no need to create schedule flush when flushMaxSize = 1 by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-15388) The assigned slot bae00218c818157649eb9e3c533b86af_32 was removed. by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-15387) Expose missing RocksDB properties out via RocksDBNativeMetricOptions by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

apply for contribute by pu zhang

by Yu Li

[jira] [Created] (FLINK-15386) SingleJobSubmittedJobGraphStore.putJobGraph has a logic error by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-15385) Translate "Concepts & Common API" page of Table API into Chinese by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-15384) Allow to pass ExecutionEnvironment/StreamExecutionEnvironment to TableEnvironment by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-15383) StreamExecSink should use sink Schema field name rather than query Schema field name by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-15382) Flink failed generating python config docs by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-15381) INSERT INTO VALUES statement fails if a cast project is applied by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-15380) Unable to set number of TM and number of Slot for MiniCluster in Scala shell by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-15379) JDBC connector return wrong value if defined dataType contains precision by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-15378) StreamFileSystemSink supported mutil hdfs plugins. by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-15377) Mesos WordCount test fails on travis by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-15376) support "CREATE TABLE AS" in Flink SQL by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

1 ... 265266267268269270271 ... 786