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

Topics (27218)

Replies

Last Post

Views

Apply for contributor permissions by jun su

by jun su

[jira] [Created] (FLINK-19142) Investigate slot hijacking from preceding pipelined regions after failover by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19141) Flink Job Submitted on Yarn Does not Work by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19140) Join with Table Function (UDTF) SQL example is incorrect by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19139) flink-conf.yml read values from environment variables by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[DISCUSS] FLIP-138: Declarative Resource management by Chesnay Schepler-3

by Zhu Zhu

[jira] [Created] (FLINK-19138) Python UDF supports directly specifying input_types as DataTypes.ROW by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19137) Bump Apache Parquet to 1.11.1 by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19136) MetricsAvailabilityITCase.testReporter failed with "Could not satisfy the predicate within the allowed time" by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19135) (Stream)ExecutionEnvironment.execute() should not throw ExecutionException by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

HadoopOutputFormat has issues with LocalExecutionEnvironment? by Ken Krugler

by Ken Krugler

[jira] [Created] (FLINK-19134) Fix the converter of array coder for Python DataStream API. by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

Bug: Kafka producer always writes to partition 0, because KafkaSerializationSchemaWrapper does not call open() method of FlinkKafkaPartitioner by DONG, Weike

by dwysakowicz

[jira] [Created] (FLINK-19133) User provided partitioners are not initialized correctly by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[DISCUSS] FLIP-139: General Python User-Defined Aggregate Function on Table API by Wei Zhong-2

by Wei Zhong-2

[jira] [Created] (FLINK-19132) Failed to start jobs for consuming Secure Kafka after cluster restart by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[DISCUSS] FLIP-137: Support Pandas UDAF in PyFlink by Xingbo Huang

by Xingbo Huang

[jira] [Created] (FLINK-19131) Add py38 support in PyFlink by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[RESULT][VOTE] Remove deprecated DataStream#fold and DataStream#split in 1.12 by dwysakowicz

by dwysakowicz

[jira] [Created] (FLINK-19130) Expose backpressure metrics / logs for function dispatcher operator by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[DISCUSS] Introduce partitioning strategies to Table/SQL by Jingsong Li

by Benchao Li-2

[jira] [Created] (FLINK-19129) Helm charts are missing the latest log4j-console file by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19128) Remove the runtime execution configuration in sql-client-defaults.yaml by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19127) Provide a replacement of StreamExecutionEnvironment.createRemoteEnvironment for TableEnvironment by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19126) Failed to run job in yarn-cluster mode due to No Executor found. by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19125) Avoid memory fragmentation when running flink docker image by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19124) Some JobClient methods are not ergonomic, require ClassLoader argument by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19123) TestStreamEnvironment does not use shared MiniCluster for executeAsync() by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19122) Prometheus scrape generates huge scrape target. by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19121) Avoid access HDFS in HiveBulkWriterFactory by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19120) Failed to build Flink with HBase2.1 even using the latest Flink release version. by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19119) Update the documentation to use Expression instead of strings in the Python Table API by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19118) Support Expression in the operations of the Python Table API by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19117) FLINK-18620 by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19115) Null value fields cannot be ignored in ElasticSearch Sink by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

1 ... 132133134135136137138 ... 778