(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 ... 306307308309310311312 ... 780

Topics (27279)

Replies

Last Post

Views

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

[ANNOUNCE] Java 11 cron builds activated on master by Chesnay Schepler-3

by Yu Li

[jira] [Created] (FLINK-13996) Maven instructions for 3.3+ do not cover all shading special cases by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-13995) Fix shading of the licence information of netty by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[DISCUSS] Releasing Flink 1.8.2 by jincheng sun

by Jark Wu-2

[jira] [Created] (FLINK-13994) Translate "Getting Started" overview to Chinese by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-13993) Using FlinkUserCodeClassLoaders to load the user class in the perjob mode by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

1 ... 306307308309310311312 ... 780