Commits

Branch selector

 master

User selector

dianfu

Datepicker

All time

Commit History

Commits on Feb 14, 2022

• [FLINK-25883][python] Set the default value of DEFAULT_BUNDLE_PROCESSOR_CACHE_SHUTDOWN_THRESHOLD_S to 30 days

  dianfu

  committed
  26bde8b

  Copy full SHA for 26bde8b

• [FLINK-24880][python] Fix PeriodicThread to handle properly for negative wait timeout value

  Show description for 7fb7bdf
  dianfu

  committed
  7fb7bdf

  Copy full SHA for 7fb7bdf

Commits on Jan 19, 2022

• [hotfix][python] Remove the outdated comments in test_environment_completeness

  dianfu

  committed
  064b8fd

  Copy full SHA for 064b8fd

• [FLINK-25676][python] Support set_description in DataStream API

  Show description for 1722a30
  dianfu

  committed
  1722a30

  Copy full SHA for 1722a30

Commits on Jan 7, 2022

• [FLINK-24880][python] Fix PeriodicThread to handle properly for negative wait timeout value

  Show description for 903d91c
  dianfu

  committed
  903d91c

  Copy full SHA for 903d91c

Commits on Oct 27, 2021

• [FLINK-24662][python][tests] Set the version of Docutils to 0.17.1

  dianfu

  committed
  aebd310

  Copy full SHA for aebd310

Commits on Sep 30, 2021

• [hotfix][python][docs] Update the README of PyFlink

  dianfu

  committed
  5b80e1c

  Copy full SHA for 5b80e1c

Commits on Sep 18, 2021

• [FLINK-24287][python][tests] Update grpcio version in tox.ini (apache#17301)

  dianfu

  authored
  aa1cdd0

  Copy full SHA for aa1cdd0

Commits on Sep 14, 2021

• [FLINK-24267][python][docs] Update the example tutorial to use latest API

  Show description for e4b2f0c
  dianfu

  committed
  e4b2f0c

  Copy full SHA for e4b2f0c

Commits on Sep 13, 2021

• [FLINK-24243][python] Cleanup code to use latest API to avoid warnings

  Show description for a9448d2
  dianfu

  committed
  a9448d2

  Copy full SHA for a9448d2

• [FLINK-24244][python] Logging whether it's executed in loopback mode

  Show description for 9f1c2d8
  dianfu

  committed
  9f1c2d8

  Copy full SHA for 9f1c2d8

• [FLINK-18880][python] Respect configurations defined in flink-conf.yaml and environment variables when executing in local mode

  Show description for e3d7167
  dianfu

  committed
  e3d7167

  Copy full SHA for e3d7167

Commits on Sep 10, 2021

• [FLINK-23345][python] Limits the version requests to 2.26.0 or above

  Show description for 0cecdca
  dianfu

  committed
  0cecdca

  Copy full SHA for 0cecdca

Commits on Sep 9, 2021

• [FLINK-24137][python] Fix the issue that tests planned to run in process mode was actually executed in loopback mode

  Show description for 0b4855f
  dianfu

  committed
  0b4855f

  Copy full SHA for 0b4855f

• [FLINK-24137][python] Fix the cases that Python boot process exits before Python SDK harness connects to the Java Operator in lookback mode

  Show description for 7a1b2b3
  dianfu

  committed
  7a1b2b3

  Copy full SHA for 7a1b2b3

Commits on Sep 8, 2021

• [FLINK-24137][python][tests] Upload logs for PyFlink tests

  dianfu

  committed
  5565590

  Copy full SHA for 5565590

• [FLINK-24137][python] Add more logs during starting up Python worker

  dianfu

  committed
  a6f8358

  Copy full SHA for a6f8358

Commits on Sep 6, 2021

• [FLINK-24134][python][docs] Update the documentation about how to install PyFlink in docker

  Show description for 7bee34d
  dianfu

  committed
  7bee34d

  Copy full SHA for 7bee34d

Commits on Sep 2, 2021

• [FLINK-24083][python] Fix Python UDTF to handle properly when the result is str

  Show description for da1912d
  dianfu

  committed
  da1912d

  Copy full SHA for da1912d

• [FLINK-24097][python] Remove is_streaming_mode checks in StreamTableEnvironment

  Show description for f2982ca
  dianfu

  committed
  f2982ca

  Copy full SHA for f2982ca

Commits on Sep 1, 2021

• [FLINK-24062][python] Fix the serialization of timer to avoid serializing timer data partially

  Show description for 4ba14cc
  dianfu

  committed
  4ba14cc

  Copy full SHA for 4ba14cc

Commits on Aug 31, 2021

• [FLINK-23924][python][examples] Add PyFlink examples

  Show description for 8fc624b
  dianfu

  committed
  8fc624b

  Copy full SHA for 8fc624b

• [FLINK-24049][python] Handle properly for field types need conversion in TupleTypeInfo

  Show description for 117c40c
  dianfu

  committed
  117c40c

  Copy full SHA for 117c40c

Commits on Aug 27, 2021

• [FLINK-23984][python][tests] Update test_kubernetes_pyflink_application to use conda to install Python

  Show description for 83987dd
  dianfu

  committed
  83987dd

  Copy full SHA for 83987dd

• Revert "[FLINK-23984][python][tests] Temporary disable the PyFlink end to end tests due to Python 3.7 was removed from debian"

  Show description for d76c98d
  dianfu

  committed
  d76c98d

  Copy full SHA for d76c98d

• [FLINK-23994][python] Handle properly for null values in ArrayDataSerializer and MapDataSerializer

  Show description for 4b89ac8
  dianfu

  committed
  4b89ac8

  Copy full SHA for 4b89ac8

Commits on Aug 26, 2021

• [FLINK-23818][python][docs] Add documentation about tgz files for python archives

  Show description for 5289b0e
  dianfu

  committed
  5289b0e

  Copy full SHA for 5289b0e

• [FLINK-23984][python][tests] Temporary disable the PyFlink end to end tests due to Python 3.7 was removed from debian

  dianfu

  committed
  3555741

  Copy full SHA for 3555741

• [hotfix][python][docs] Add state API in PyDocs

  dianfu

  committed
  0009b0c

  Copy full SHA for 0009b0c

• [FLINK-23941][python][docs] Add missing API in PyDocs

  Show description for e11a5c5
  dianfu

  committed
  e11a5c5

  Copy full SHA for e11a5c5

Commits on Aug 25, 2021

• [FLINK-23923][python] Log the environment variables and command when starting Python process

  Show description for 92d857a
  dianfu

  committed
  92d857a

  Copy full SHA for 92d857a

Commits on Aug 24, 2021

• [FLINK-23936][python] Disable cleanup the Python UDFs which are inactive for a few minutes

  Show description for 418bce6
  dianfu

  committed
  418bce6

  Copy full SHA for 418bce6

• [hotfix][python][docs] Update the examples to use latest API

  dianfu

  committed
  80e4eef

  Copy full SHA for 80e4eef

• [FLINK-23940][python][docs] Improve the documentation about how to use logging in PyFlink jobs

  Show description for 80a459e
  dianfu

  committed
  80a459e

  Copy full SHA for 80a459e

• [FLINK-23931][python] Improve the exception message shown in PythonDriver

  Show description for 9652fd3
  dianfu

  committed
  9652fd3

  Copy full SHA for 9652fd3

Pagination

Previous

Next