(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 ... 312313314315316317318 ... 787

Topics (27515)

Replies

Last Post

Views

[jira] [Created] (FLINK-14042) Different RelDataTypes generated for same TemporalTableFunction by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[DISCUSS] Retrieval services in non-high-availability scenario by tison

by tison

[jira] [Created] (FLINK-14041) Refactor LeaderRetrievalServiceHostnameResolutionTest and remove StandaloneUtils by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-14040) Enable a cron job to run MiniCluster tests for schedulerNG by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-14039) Flink Kinesis consumer: configurable per-shard consumption rate when running in adaptive mode by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-14038) ExecutionGraph deploy failed due to akka timeout by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-14037) Deserializing the input/output formats failed: unread block data by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-14036) function log(f0,f1) in Table API do not support decimal type by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-14035) Introduce/Change some log for snapshot to better analysis checkpoint problem by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-14034) In FlinkKafkaProducer, KafkaTransactionState should be made public or invoke should be made final by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-14033) Distributed caches are not registered in Yarn Per Job Cluster Mode by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-14032) Make the cache size of RocksDBPriorityQueueSetFactory configurable by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-14031) flink-examples should add blink dependency on flink-examples-table by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-14030) Nonequivalent conversion happens in Table planner by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[ANNOUNCE] Kostas Kloudas joins the Flink PMC by Fabian Hueske-2

by Biao Liu

[jira] [Created] (FLINK-14029) Update Flink's Mesos scheduling behavior to reject all expired offers by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-14028) Support logging aggregation in Python user-defined functions by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-14027) Add documentation for Python user-defined functions by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-14026) Manage the resource of Python worker properly by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-14025) Support to run the Python worker in docker mode by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-14024) Support use-defined metrics in Python user-defined functions by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-14023) Support accessing job parameters in Python user-defined functions by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-14022) Add validation check for places where Python ScalarFunction cannot be used by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-14021) Add rules to push down the Python ScalarFunctions contained in the join condition of Correlate node by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-14020) User Apache Arrow as the serializer for data transmission between Java operator and Python harness by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-14019) Python environment and dependency management by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-14018) Add Python building blocks to make sure the basic functionality of Python ScalarFunction could work by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-14017) Support to start up Python worker in process mode by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-14016) Introduce RelNodes FlinkLogicalPythonScalarFunctionExec and DataStreamPythonScalarFunctionExec which are containers for Python PythonScalarFunctions by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-14015) Introduce PythonScalarFunctionOperator as a standalone StreamOperator for Python ScalarFunction execution by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-14014) Introduce PythonScalarFunctionRunner to handle the communication with Python worker for Python ScalarFunction execution by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-14013) Support Flink Python User-Defined Stateless Function for Table by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[VOTE] FLIP-58: Flink Python User-Defined Function for Table API by Dian Fu-2

by Dian Fu-2

[DISCUSS] StreamingFile with ParquetBulkWriter bucketing limitations by Enrico Agnoli

by Enrico Agnoli

[jira] [Created] (FLINK-14012) Failed to start job for consuming Secure Kafka after the job cancel by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

1 ... 312313314315316317318 ... 787