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

Topics (27508)

Replies

Last Post

Views

[jira] [Created] (FLINK-16650) Support LocalZonedTimestampType for Python UDF of blink planner by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-16649) Support Java 14 by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-16648) Clean up the input parameter StreamQueryConfig of the API in StreamTableEnvironment by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-16647) Miss file extension when inserting to hive table with compression by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-16646) flink read orc file throw a NullPointerException by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-16645) Limit the maximum backlogs in subpartitions for data skew case by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-16644) HadoopS3FileSystemBehaviorITCase failed with null uri host by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-16643) flink-connector-hive_2.11 build fails on retrieving javax.jms:jms:jar:1.1 by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-16642) CSV TableSource / TableSink shouldn't be in flink-table-api-java-bridge package by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-16641) Announce sender's backlog to solve the deadlock issue without exclusive buffers by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[PROPOSAL] Reverse the dependency from flink-streaming-java to flink-client by tison

by tison

[jira] [Created] (FLINK-16640) Expose listStatus latency in flink filesystem by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-16639) Flink SQL Kafka source connector, add the no json format filter params when format.type is json by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

Hope to be Flink contributor by 342622945

by 342622945

[jira] [Created] (FLINK-16638) Flink checkStateMappingCompleteness doesn't include UserDefinedOperatorIDs by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-16637) Flink YARN app terminated before the client receives the result by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

FLIP-117: HBase catalog by Flavio Pompermaier

by Yu Li

[jira] [Created] (FLINK-16636) TableEnvironmentITCase failed on traivs by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-16635) Incompatible okio dependency in flink-metrics-influxdb module by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-16634) The PartitionDiscoverer in FlinkKafkaConsumer should not use the user provided client.id. by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-16633) CI builds without S3 credentials fail by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-16632) Cast string to timestamp fail by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

Question about RocksDBStateBackend Compaction Filter state cleanup by LakeShen

by Andrey Zagrebin-4

[jira] [Created] (FLINK-16631) Flink cache on Travis does not exist by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-16630) '@version' STRING is not support by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-16629) Streaming bucketing end-to-end test output hash mismatch by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-16628) Complex JSON sink into kafka error by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-16627) when insert into kafka ,how can i remove the keys with null value of json by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-16626) Exception Encountered when cancelling a job in yarn per-job mode by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

Flink YARN Job unexpectedly switched to SUCCEEDED final status after CSV deserialization failure by DONG, Weike

by DONG, Weike

[jira] [Created] (FLINK-16625) Extract BootstrapTools#getEnvironmentVariables to a general utility in ConfigurationUtil by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-16624) Support to customize annotations for the rest Service on Kubernetes by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-16623) add the shorthand 'desc' for describe on sql client by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

Cancel the flink task and restore from checkpoint ,can I change the flink operator's parallelism by LakeShen

by Till Rohrmann

[jira] [Created] (FLINK-16622) Type ARRAY<STRING> of table field 'id' does not match with the physical type LEGACY('ARRAY', 'ANY<[Ljava.lang.String;, rO0ABXNyAD......>') of the 'id' field of the TableSource return type. by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

1 ... 224225226227228229230 ... 786