Commits

Commits on Apr 28, 2024

[FLINK-35208][python] Respect pipeline.cached-files during handling Python dependencies
dianfu
committedApr 28, 2024

Commits on Nov 24, 2023

[FLINK-33613][python] Make sure gRPC server is shutdown gracefully if Python process startup failed
dianfu
committedNov 24, 2023
[FLINK-33613][python] Port Beam DefaultJobBundleFactory class to flink-python module
dianfu
committedNov 24, 2023

Commits on Nov 1, 2023

[hotfix][python] Fix Kafka csv example
dianfu
committedNov 1, 2023

Commits on Aug 30, 2023

[FLINK-32758][python] Limit fastavro != 1.8.0
dianfu
committedAug 30, 2023

Commits on Aug 29, 2023

[FLINK-32758][python] Limit fastavro < 1.8
dianfu
committedAug 29, 2023

Commits on Aug 17, 2023

[hotfix][docs] Fix the PyFlink job submission command
dianfu
committedAug 17, 2023

Commits on Jul 6, 2023

[FLINK-32544][python] Fix test_java_sql_ddl to works in JDK17
dianfu
committedJul 6, 2023

Commits on Jul 5, 2023

[FLINK-32536][python] Add java 17 add-opens/add-exports JVM arguments relates to DirectByteBuffer (apache#22955 )
dianfu
committedJul 5, 2023

Commits on Jul 4, 2023

[FLINK-32327][python] Fix PyFlink Kafka support to support JDK17 (apache#22940 )
dianfu
committedJul 4, 2023

Commits on Jun 17, 2023

[FLINK-32136][python] Fix the issue that Pyflink gateway server launch fails when purelib != platlib
dianfu
committedJun 17, 2023

Commits on May 24, 2023

[FLINK-32056][Python][Connector/Pulsar] Add missing APIs in flink-connector-pulsar v4.0.0
dianfu
committedMay 24, 2023

Commits on May 22, 2023

[FLINK-32131][python] Support specifying hadoop config directory for HiveCatalog
dianfu
committedMay 22, 2023

Commits on Apr 27, 2023

[FLINK-28786][python] Check if cython could be enabled in only one place
dianfu
committedApr 27, 2023

Commits on Apr 4, 2023

[FLINK-31707][python] Fix Pandas UDAF to support accepting constant string as inputs
dianfu
committedApr 4, 2023

Commits on Apr 3, 2023

[FLINK-31690][python] Fix KeyedCoProcessFunction to set the current key into the context
dianfu
committedApr 3, 2023

Commits on Mar 19, 2023

[python][docs] Update PyFlink docker image build documentation
dianfu
committedMar 19, 2023
[python][examples] Add Python streaming word count examples
dianfu
committedMar 19, 2023
[FLINK-31503][python] Makes sure it loads Beam classes using the same class loader as the PyFlink classes
dianfu
committedMar 19, 2023

Commits on Mar 17, 2023

[FLINK-31478][python] Fix ds.execute_and_collect to support nested tuple
dianfu
committedMar 17, 2023

Commits on Mar 2, 2023

[FLINK-31286][python] Make sure Python processes are cleaned up when TaskManager crashes
dianfu
committedMar 2, 2023

Commits on Mar 1, 2023

[FLINK-31272][python] Handle properly for SinkTransformation to avoid duplicate operators introduced by chaining optimization
dianfu
committedMar 1, 2023

Commits on Feb 21, 2023

[hotfix][docs] Update outdated documentation of windowing support in Python DataStream API
dianfu
committedFeb 21, 2023

Commits on Feb 15, 2023

[FLINK-31083][python] Make sure OutputTag._j_output_tag is initialized during unpickle
dianfu
committedFeb 15, 2023

Commits on Feb 13, 2023

[FLINK-31031][python] Disable the output buffer of Python process
dianfu
committedFeb 13, 2023

Commits on Feb 2, 2023

[FLINK-30803][python] Fix command line option '-py' to make it work well in per-job mode
dianfu
committedFeb 2, 2023

Commits on Jan 17, 2023

[FLINK-28526][python] Fix Python UDF to support time indicator inputs
dianfu
committedJan 17, 2023

Commits on Jan 16, 2023

Commits on Jan 13, 2023

[minor][python][tests] Add some test cases for binary and char types
dianfu
committedJan 13, 2023
[hotfix][docs] Update the outdated documentation about broadcast state's support in PyFlink
dianfu
committedJan 13, 2023

Commits on Jan 12, 2023

[FLINK-14023][python] Support accessing job parameters in Python user-defined functions
dianfu
committedJan 12, 2023

Commits on Jan 11, 2023

[FLINK-30607][python] Support NoneType for Pandas UDF
dianfu
committedJan 11, 2023
[FLINK-30607][python] Support BinaryType for Pandas UDF
dianfu
committedJan 11, 2023
[FLINK-30607][python] Support MapType for Pandas UDF
dianfu
committedJan 11, 2023