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

Topics (27218)

Replies

Last Post

Views

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

[jira] [Created] (FLINK-16621) Add support for custom logging configuration in docker-flink by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-16620) Add attempt information in logging by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-16619) Misleading SlotManagerImpl logging for slot reports of unknown task manager by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-16618) Cannot use Hive GenericUDFBaseNumeric with Flink by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-16617) Automatic Any unpacking is broken with type deduction. by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-16616) Drop BucketingSink by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-16615) Introduce data structures and utilities to calculate Job Manager memory components by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-16614) FLIP-116 Unified Memory Configuration for Job Manager by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-16613) Builds on Azure pipeline are not triggered by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-16612) Submit job through the rest api, job name will be lost by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

1 ... 216217218219220221222 ... 778