Commits

Branch selector

 master

User selector

dianfu

Datepicker

All time

Commit History

Commits on Feb 14, 2020

• [FLINK-16053][python] Remove redundant metrics in PyFlink (apache#11089)

  dianfu

  authored
  881a3ca

  Copy full SHA for 881a3ca

Commits on Feb 11, 2020

• [FLINK-15875][python] Remove the ProcessManager which is copied from Beam 2.19

  dianfu

  committed
  d1bc10f

  Copy full SHA for d1bc10f

• [FLINK-15875][python] Bump Beam to 2.19.0

  Show description for ef364bb
  dianfu

  committed
  ef364bb

  Copy full SHA for ef364bb

Commits on Feb 7, 2020

• [FLINK-15902][python][docs] Improve the Python API documentation adding the version an API was introduced

  Show description for c858d86
  dianfu

  committed
  c858d86

  Copy full SHA for c858d86

Commits on Feb 6, 2020

• [FLINK-15897][python] Defer the deserialization of the Python UDF execution results

  

  dianfu

  authored and

  hequn8128

  committed
  5c1d7e4

  Copy full SHA for 5c1d7e4

• [FLINK-15929][python] Update the version limit of grpcio to 1.26.0

  Show description for 3808858
  dianfu

  committed
  3808858

  Copy full SHA for 3808858

Commits on Feb 4, 2020

• [hotfix][python] Remove unused variable from class AbstractPythonFunctionRunner

  dianfu

  committed
  4ed552c

  Copy full SHA for 4ed552c

Commits on Dec 26, 2019

• [FLINK-15382][docs] Exclude PythonConfig from configuration docs generator

  Show description for 89ce45b
  

  dianfu

  authored and

  hequn8128

  committed
  89ce45b

  Copy full SHA for 89ce45b

Commits on Dec 7, 2019

• [FLINK-14026][python] Manage the resource of Python worker properly

  Show description for 7c2620f
  

  dianfu

  authored and

  hequn8128

  committed
  7c2620f

  Copy full SHA for 7c2620f

Commits on Dec 4, 2019

• [FLINK-15025][python][build] Include resource directory in jar

  

  dianfu

  authored and

  zentol

  committed
  7a37209

  Copy full SHA for 7a37209

Commits on Dec 2, 2019

• [FLINK-14891][python] Set the default chaining strategy to ALWAYS for Python operators

  Show description for b0fc92b
  

  dianfu

  authored and

  hequn8128

  committed
  b0fc92b

  Copy full SHA for b0fc92b

Commits on Nov 20, 2019

• [FLINK-14066][python] Support to install pyflink in windows

  Show description for 32a3227
  

  dianfu

  authored and

  hequn8128

  committed
  32a3227

  Copy full SHA for 32a3227

Commits on Nov 1, 2019

• [hotfix][python] Clean up test_environment_completeness by removing the legacy excluded methods which are already supported

  

  dianfu

  authored and

  dawidwys

  committed
  b9f51de

  Copy full SHA for b9f51de

• [hotfix][python] Deprecate TableEnvironment.register_table_source and TableEnvironment.register_table_sink

  

  dianfu

  authored and

  dawidwys

  committed
  6c81981

  Copy full SHA for 6c81981

• [FLINK-14488][python] Update python table API with insert_into

  

  dianfu

  authored and

  dawidwys

  committed
  d83b58c

  Copy full SHA for d83b58c

• [FLINK-14488][python] Update python table API adding from_path method

  

  dianfu

  authored and

  dawidwys

  committed
  b6bb09a

  Copy full SHA for b6bb09a

• [FLINK-14488][python] Update python table API with temporary tables & views methods

  

  dianfu

  authored and

  dawidwys

  committed
  8cc74a6

  Copy full SHA for 8cc74a6

Commits on Oct 31, 2019

• [FLINK-14558][python] Fix ClassNotFoundException of PythonScalarFunctionOperator

  Show description for 3a69d5b
  

  dianfu

  authored and

  hequn8128

  committed
  3a69d5b

  Copy full SHA for 3a69d5b

• [FLINK-14557][python] Clean up the py4j package by removing the unused directory __MACOSX.

  Show description for 63b5c94
  

  dianfu

  authored and

  hequn8128

  committed
  63b5c94

  Copy full SHA for 63b5c94

• [FLINK-14556][python] Correct the package structure of cloudpickle

  Show description for 6c6ada5
  

  dianfu

  authored and

  hequn8128

  committed
  6c6ada5

  Copy full SHA for 6c6ada5

Commits on Oct 23, 2019

• [FLINK-14202][table][python] Optimize the execution plan for Python Calc when there is a condition

  Show description for ae043e0
  

  dianfu

  authored and

  hequn8128

  committed
  ae043e0

  Copy full SHA for ae043e0

Commits on Oct 21, 2019

• [FLINK-14469][python] Drop Python 2 support for PyFlink

  Show description for af50b7c
  

  dianfu

  authored and

  hequn8128

  committed
  af50b7c

  Copy full SHA for af50b7c

Commits on Oct 14, 2019

• [FLINK-13999][cep][docs] Correct the example in the section of Aggregations of MATCH_RECOGNIZE

  

  dianfu

  authored and

  dawidwys

  committed
  51bd2f6

  Copy full SHA for 51bd2f6

Commits on Oct 9, 2019

• [FLINK-14306][python] Add the code-generated flink_fn_execution_pb2.py to the source code

  Show description for df44cce
  

  dianfu

  authored and

  hequn8128

  committed
  df44cce

  Copy full SHA for df44cce

Commits on Oct 1, 2019

• [FLINK-14178][build] Downgrade maven-shade-plugin to 3.1.1

  Show description for 81038ff
  

  dianfu

  authored and

  tillrohrmann

  committed
  81038ff

  Copy full SHA for 81038ff

Commits on Sep 30, 2019

• [FLINK-14288][legal] Add Py4J NOTICE for source release

  Show description for 2ac48f0
  

  dianfu

  authored and

  hequn8128

  committed
  2ac48f0

  Copy full SHA for 2ac48f0

Commits on Sep 29, 2019

• [FLINK-14018][python] Package cloudpickle in flink for ease of use for Flink Python users

  Show description for fc4a1df
  

  dianfu

  authored and

  hequn8128

  committed
  fc4a1df

  Copy full SHA for fc4a1df

• [FLINK-14018][python] Add Python building blocks to make sure the basic functionality of Python ScalarFunction could work

  Show description for 06d6dba
  

  dianfu

  authored and

  hequn8128

  committed
  06d6dba

  Copy full SHA for 06d6dba

• [hotfix][python] Use pyflink code with higher priority if it exists

  Show description for 6a67f36
  

  dianfu

  authored and

  hequn8128

  committed
  6a67f36

  Copy full SHA for 6a67f36

Commits on Sep 26, 2019

• [FLINK-14016][python][flink-table-planner] Introduce DataStreamPythonCalc for Python function execution

  Show description for 2b608e3
  

  dianfu

  authored and

  hequn8128

  committed
  2b608e3

  Copy full SHA for 2b608e3

Commits on Sep 23, 2019

• [FLINK-14015][python] Introduces PythonScalarFunctionOperator to execute Python user-defined functions

  Show description for 71fa237
  

  dianfu

  authored and

  hequn8128

  committed
  71fa237

  Copy full SHA for 71fa237

Commits on Sep 18, 2019

• [FLINK-14014][python] Introduce PythonScalarFunctionRunner to handle the communication with Python worker for Python ScalarFunction execution

  Show description for cc3a27b
  

  dianfu

  authored and

  hequn8128

  committed
  cc3a27b

  Copy full SHA for cc3a27b

• [FLINK-14014][python][table-common] Adds basic classes PythonFunction, PythonEnv, PythonFunctionInfo

  Show description for 10cb5ab
  

  dianfu

  authored and

  hequn8128

  committed
  10cb5ab

  Copy full SHA for 10cb5ab

• [FLINK-14014] Bump maven-shade-plugin to 3.2.1

  Show description for e7216ee
  

  dianfu

  authored and

  hequn8128

  committed
  e7216ee

  Copy full SHA for e7216ee

Commits on Aug 4, 2019

• [hotfix][python] Fix the package name of PythonGatewayServer (apache#9351)

  

  dianfu

  authored and

  sunjincheng121

  committed
  2c587b6

  Copy full SHA for 2c587b6

Pagination

Previous

Next