(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 ... 309310311312313314315 ... 783

Topics (27400)

Replies

Last Post

Views

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

[jira] [Created] (FLINK-14011) Make some fields final and initialize them during construction in AsyncWaitOperator by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-14010) Dispatcher & JobManagers don't give up leadership when AM is shut down by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

Checkpointing clarification by Dominik Wosiński

by Till Rohrmann

[jira] [Created] (FLINK-14009) Cron jobs broken due to verifying incorrect NOTICE-binary file by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-14008) Flink Scala 2.12 binary distribution contains incorrect NOTICE-binary file by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[DISCUSS] Support customize state in customized KeyedStateBackend by shimin yang

by shimin yang

[jira] [Created] (FLINK-14007) Add doc for how to using Java user-defined source/sink in Python API by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-14006) Add doc for how to using Java UDFs in Python API by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-14005) Support Hive version 2.2.0 by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

确定取消 by Lynn Chen

by Lynn Chen

1 ... 309310311312313314315 ... 783