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

Topics (27218)

Replies

Last Post

Views

[jira] [Created] (FLINK-17876) Add documents for the Python UDF SQL DDL. by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-17875) Support state TTL for remote functions by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-17874) Writing to hbase throws NPE by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-17873) Add check for max concurrent checkpoints under UC mode by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

本地测试 flink 1.10 hbase sql create table 在反序列化byte之后得到的对象conf配置为null，导致无法连接hbase集群 by shx

by Leonard Xu

[jira] [Created] (FLINK-17872) Update StreamingFileSink documents to add avro formats by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-17871) Make the default value of attemptFailuresValidityInterval more reasonable by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-17870) scala shell jars are missing to be shipped to cluster by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-17869) Fix the race condition of aborting unaligned checkpoint by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-17868) Proctime in DDL can not work in batch mode by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-17867) Fix Hive-3.1.1 test by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-17866) InvalidPathException was thrown when running the test cases of PyFlink on Windows by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[DISCUSS] increase "state.backend.fs.memory-threshold" from 1K to 100K by Stephan Ewen

by Yu Li

[jira] [Created] (FLINK-17865) Increase default size of `state.backend.fs.memory-threshold` by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-17864) Update document about removing #registerTableSource by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-17863) flink streaming sql read hive with lots small files need to control parallelism by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-17862) The internal class StreamingRuntimeContext is leaked in AbstractUdfStreamOperator by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-17861) Channel state handles, when inlined, duplicate underlying data by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-17860) Recursively remove channel state directories by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-17859) [flink-s3-fs-presto] Upgrade the dependent presto-hive jar to latest version by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-17858) Yarn mode, windows and linux environment should be interlinked by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-17857) All Kubernetes e2e tests could not run on Mac after migration by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-17856) Adds the feature of monitoring directory changes for FileSystem table source connector by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-17855) UDF with parameter Array(Row) can not work by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[DISCUSS] Add a material web page under "https://flink.apache.org/" by curcur

by Yu Li

[jira] [Created] (FLINK-17854) Use InputStatus directly in user-facing async input APIs (like source readers) by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-17853) JobGraph is not getting deleted after Job cancelation by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-17852) FlinkSQL support WITH clause in query statement by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-17851) FlinkKafkaProducerITCase.testResumeTransaction:108->assertRecord NoSuchElement by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-17850) PostgresCatalogITCase . testGroupByInsert() fails on CI by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-17849) YARNHighAvailabilityITCase hangs in Azure Pipelines CI by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-17848) Allow scala datastream api to create named sources by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-17847) ArrayIndexOutOfBoundsException happened in when codegen StreamExec operator by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-17846) flink-walkthrough-table-scala failed on azure by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-17845) Can't remove a table connector property with ALTER TABLE by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

1 ... 174175176177178179180 ... 778