Commits

Branch selector

 master

User selector

dianfu

Datepicker

All time

Commit History

Commits on Apr 28, 2024

• [FLINK-35208][python] Respect pipeline.cached-files during handling Python dependencies

  Show description for 0f01a0e
  dianfu

  committed
  0f01a0e

  Copy full SHA for 0f01a0e

Commits on Nov 24, 2023

• [FLINK-33613][python] Make sure gRPC server is shutdown gracefully if Python process startup failed

  Show description for 977463c
  dianfu

  committed
  977463c

  Copy full SHA for 977463c

• [FLINK-33613][python] Port Beam DefaultJobBundleFactory class to flink-python module

  dianfu

  committed
  bcca67d

  Copy full SHA for bcca67d

Commits on Nov 1, 2023

• [hotfix][python] Fix Kafka csv example

  dianfu

  committed
  eef2270

  Copy full SHA for eef2270

Commits on Aug 30, 2023

• [FLINK-32758][python] Limit fastavro != 1.8.0

  dianfu

  committed
  5b5a0af

  Copy full SHA for 5b5a0af

Commits on Aug 29, 2023

• [FLINK-32758][python] Limit fastavro < 1.8

  dianfu

  committed
  345dece

  Copy full SHA for 345dece

Commits on Aug 17, 2023

• [hotfix][docs] Fix the PyFlink job submission command

  dianfu

  committed
  56bbd1d

  Copy full SHA for 56bbd1d

Commits on Jul 6, 2023

• [FLINK-32544][python] Fix test_java_sql_ddl to works in JDK17

  dianfu

  authored
  0e44dcc

  Copy full SHA for 0e44dcc

Commits on Jul 5, 2023

• [FLINK-32536][python] Add java 17 add-opens/add-exports JVM arguments relates to DirectByteBuffer (#22955)

  dianfu

  authored
  7f34df4

  Copy full SHA for 7f34df4

Commits on Jul 4, 2023

• [FLINK-32327][python] Fix PyFlink Kafka support to support JDK17 (#22940)

  dianfu

  authored
  940cb74

  Copy full SHA for 940cb74

Commits on Jun 17, 2023

• [FLINK-32136][python] Fix the issue that Pyflink gateway server launch fails when purelib != platlib

  Show description for f64563b
  dianfu

  committed
  f64563b

  Copy full SHA for f64563b

Commits on May 24, 2023

• [FLINK-32056][Python][Connector/Pulsar] Add missing APIs in flink-connector-pulsar v4.0.0

  dianfu

  committed
  ae9e38a

  Copy full SHA for ae9e38a

Commits on May 22, 2023

• [FLINK-32131][python] Support specifying hadoop config directory for HiveCatalog

  Show description for 5a89d22
  dianfu

  committed
  5a89d22

  Copy full SHA for 5a89d22

Commits on Apr 27, 2023

• [FLINK-28786][python] Check if cython could be enabled in only one place

  Show description for a336863
  dianfu

  committed
  a336863

  Copy full SHA for a336863

Commits on Apr 4, 2023

• [FLINK-31707][python] Fix Pandas UDAF to support accepting constant string as inputs

  Show description for 7c6d8b0
  dianfu

  committed
  7c6d8b0

  Copy full SHA for 7c6d8b0

Commits on Apr 3, 2023

• [FLINK-31690][python] Fix KeyedCoProcessFunction to set the current key into the context

  Show description for 6c1ffe5
  dianfu

  committed
  6c1ffe5

  Copy full SHA for 6c1ffe5

Commits on Mar 19, 2023

• [python][docs] Update PyFlink docker image build documentation

  dianfu

  committed
  770d361

  Copy full SHA for 770d361

• [python][examples] Add Python streaming word count examples

  dianfu

  committed
  0a8bf94

  Copy full SHA for 0a8bf94

• [FLINK-31503][python] Makes sure it loads Beam classes using the same class loader as the PyFlink classes

  Show description for de258f3
  dianfu

  committed
  de258f3

  Copy full SHA for de258f3

Commits on Mar 17, 2023

• [FLINK-31478][python] Fix ds.execute_and_collect to support nested tuple

  Show description for 5e059ef
  dianfu

  committed
  5e059ef

  Copy full SHA for 5e059ef

Commits on Mar 2, 2023

• [FLINK-31286][python] Make sure Python processes are cleaned up when TaskManager crashes

  Show description for ab4e85e
  dianfu

  committed
  ab4e85e

  Copy full SHA for ab4e85e

Commits on Mar 1, 2023

• [FLINK-31272][python] Handle properly for SinkTransformation to avoid duplicate operators introduced by chaining optimization

  Show description for 753734f
  dianfu

  committed
  753734f

  Copy full SHA for 753734f

Commits on Feb 21, 2023

• [hotfix][docs] Update outdated documentation of windowing support in Python DataStream API

  dianfu

  committed
  3f65eea

  Copy full SHA for 3f65eea

Commits on Feb 15, 2023

• [FLINK-31083][python] Make sure OutputTag._j_output_tag is initialized during unpickle

  dianfu

  committed
  a0e9e67

  Copy full SHA for a0e9e67

Commits on Feb 13, 2023

• [FLINK-31031][python] Disable the output buffer of Python process

  dianfu

  committed
  e22f061

  Copy full SHA for e22f061

Commits on Feb 2, 2023

• [FLINK-30803][python] Fix command line option '-py' to make it work well in per-job mode

  Show description for 68c78dc
  dianfu

  committed
  68c78dc

  Copy full SHA for 68c78dc

Commits on Jan 17, 2023

• [FLINK-28526][python] Fix Python UDF to support time indicator inputs

  Show description for d841756
  dianfu

  committed
  d841756

  Copy full SHA for d841756

Commits on Jan 16, 2023

• [FLINK-30168][python] Fix DataStream.execute_and_collect to support None data and ObjectArray

  Show description for 4675773
  dianfu

  committed
  4675773

  Copy full SHA for 4675773

• [FLINK-29231][python] Fix the issue that Python UDAF may produce multiple results for the same window

  Show description for addca4e
  dianfu

  committed
  addca4e

  Copy full SHA for addca4e

Commits on Jan 13, 2023

• [minor][python][tests] Add some test cases for binary and char types

  dianfu

  committed
  6b3a5db

  Copy full SHA for 6b3a5db

• [hotfix][docs] Update the outdated documentation about broadcast state's support in PyFlink

  dianfu

  committed
  2ef6f26

  Copy full SHA for 2ef6f26

Commits on Jan 12, 2023

• [FLINK-14023][python] Support accessing job parameters in Python user-defined functions

  Show description for 5cb434c
  dianfu

  committed
  5cb434c

  Copy full SHA for 5cb434c

Commits on Jan 11, 2023

• [FLINK-30607][python] Support NoneType for Pandas UDF

  Show description for afc8fb0
  dianfu

  committed
  afc8fb0

  Copy full SHA for afc8fb0

• [FLINK-30607][python] Support BinaryType for Pandas UDF

  Show description for 72c9cfd
  dianfu

  committed
  72c9cfd

  Copy full SHA for 72c9cfd

• [FLINK-30607][python] Support MapType for Pandas UDF

  Show description for b781a13
  dianfu

  committed
  b781a13

  Copy full SHA for b781a13

Pagination

Previous

Next