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

Topics (27215)

Replies

Last Post

Views

[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

[jira] [Created] (FLINK-14004) Define SourceReader interface to verify the integration with StreamOneInputProcessor by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[ANNOUNCE] Weekly Community Update 2019/33-36 by Konstantin Knauf-3

by Konstantin Knauf-3

[jira] [Created] (FLINK-14003) Add access to customized state other than built in state types by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-14002) FlinkKafkaProducer constructor that takes KafkaSerializationSchema shouldnt take default topic by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-14001) add a API to enable user to get the operator code generated by Flink engine by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[DISCUSS] Supporting multiple Flink versions vs. tech debt by David Morávek

by David Morávek

[jira] [Created] (FLINK-14000) Remove legacy ProcessShutDownThread by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-13999) Correct the documentation of MATCH_RECOGNIZE by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-13998) Fix ORC test failure with Hive 2.0.x by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-13997) Remove legacy LeaderAddressAndId by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

1 ... 304305306307308309310 ... 778