Commits

Breadcrumbs

History for

onbfcd800

User selector

All users

Datepicker

All time

Commit History

Commits on Jun 10, 2020

• [FLINK-18218][python][e2e] Add PyFlink YARN per-job e2e tests

  Show description for 70bfb61
  

  WeiZhong94

  authored and

  dianfu

  committed
  70bfb61

  Copy full SHA for 70bfb61

• [hotfix][python] Remove unnecessary methods in JobExecutionResult

  dianfu

  committed
  f81b2c1

  Copy full SHA for f81b2c1

• [hotfix][python] Add version information for the methods defined in CompletableFuture

  dianfu

  committed
  b1bc266

  Copy full SHA for b1bc266

• [FLINK-18104][python][windows] Fix the test failures on Windows.

  Show description for a160697
  

  WeiZhong94

  authored and

  dianfu

  committed
  a160697

  Copy full SHA for a160697

Commits on Jun 9, 2020

• [FLINK-18126][python] Correct the exception handling of the Python CompletableFuture

  Show description for 8a7093b
  dianfu

  committed
  8a7093b

  Copy full SHA for 8a7093b

• [FLINK-18061] [table] TableResult#collect method should return a closeable iterator to avoid resource leak

  Show description for d27c888
  

  godfreyhe

  authored and

  dawidwys

  committed
  d27c888

  Copy full SHA for d27c888

• [FLINK-17902][python] Support the new interfaces about temporary functions in PyFlink

  Show description for 74231f7
  

  SteNicholas

  authored and

  dianfu

  committed
  74231f7

  Copy full SHA for 74231f7

Commits on Jun 8, 2020

• [FLINK-18151][python] Resolve CWE22 problems in pyflink_gateway_server.py (apache#12503)

  shuiqiangchen

  authored
  c27a7a6

  Copy full SHA for c27a7a6

Commits on Jun 5, 2020

• [FLINK-18143][python] Fix Python meter metric incorrect value problem (apache#12498)

  

  Hequn Cheng

  authored
  dcd764a

  Copy full SHA for dcd764a

Commits on Jun 4, 2020

• [hotfix][python] Improve the error message when converting from Pandas DataFrame in the batch mode of old planner

  dianfu

  committed
  05332b5

  Copy full SHA for 05332b5

• [FLINK-17945][python] Improve the error message when instantiating non-existing Java class

  Show description for 19bbd6d
  dianfu

  committed
  19bbd6d

  Copy full SHA for 19bbd6d

Commits on Jun 3, 2020

• [FLINK-17959][python] Fix the 'call already cancelled' exception when executing Python UDF

  Show description for 66d1300
  dianfu

  committed
  66d1300

  Copy full SHA for 66d1300

• [FLINK-17959][python] Port Beam GrpcStateService class to flink-python module

  Show description for b31b180
  dianfu

  committed
  b31b180

  Copy full SHA for b31b180

• [FLINK-17901][python] Add module interface in PyFlink

  Show description for fbdf920
  

  SteNicholas

  authored and

  dianfu

  committed
  fbdf920

  Copy full SHA for fbdf920

• [hotfix][python] Add the version for the APIs introduced in 1.11.0

  dianfu

  committed
  11e21a4

  Copy full SHA for 11e21a4

• [FLINK-17923][python] Allow Python worker to use off-heap memory

  Show description for 77e5494
  dianfu

  committed
  77e5494

  Copy full SHA for 77e5494

Commits on May 29, 2020

• [FLINK-17952][python] Fix the bug that exception was thrown when creating BatchTableEnvironment via EnvironmentSettings with old planner.

  Show description for be04912
  

  WeiZhong94

  authored and

  dianfu

  committed
  be04912

  Copy full SHA for be04912

• [FLINK-17990][python] Fix the test of ArrowSourceFunctionTestBase.testParallelProcessing to use synchronized list

  Show description for 9579325
  dianfu

  committed
  9579325

  Copy full SHA for 9579325

• [FLINK-17946][python] Fix the bug that the config option 'pipeline.jars' doesn't work.

  Show description for cda25e5
  

  WeiZhong94

  authored and

  dianfu

  committed
  cda25e5

  Copy full SHA for cda25e5

Commits on May 28, 2020

• [FLINK-17865][checkpoint] Increase default size of 'state.backend.fs.memory-threshold'

  Show description for a835f31
  

  Myasuka

  authored and

  carp84

  committed
  a835f31

  Copy full SHA for a835f31

Commits on May 26, 2020

• [FLINK-15621][state][TTL] Remove deprecated option and method to disable TTL compaction filter

  Show description for aa505a4
  

  Jiayi Liao

  authored and

  azagrebin

  committed
  aa505a4

  Copy full SHA for aa505a4

• [FLINK-17395][python] (followups) Don't remove the dist directory during clean

  dianfu

  committed
  8f992e8

  Copy full SHA for 8f992e8

Commits on May 23, 2020

• [FLINK-17303][python] Return TableResult for Python TableEnvironment

  Show description for 6186069
  

  SteNicholas

  authored and

  hequn8128

  committed
  6186069

  Copy full SHA for 6186069

Commits on May 20, 2020

• [FLINK-15947] Fix table implicit conversions structure

  dawidwys

  committed
  5f0183f

  Copy full SHA for 5f0183f

Commits on May 18, 2020

• [FLINK-16998][core] Add a changeflag to Row

  Show description for f356799
  twalthr

  committed
  f356799

  Copy full SHA for f356799

• Update version to 1.12-SNAPSHOT

  pnowojski

  committed
  cd89167

  Copy full SHA for cd89167

Commits on May 17, 2020

• [FLINK-15102][datastream/api] Add continuousSource() methods to the StreamExecutionEvironment.

  Show description for 7abced6
  becketqin

  committed
  7abced6

  Copy full SHA for 7abced6

• [FLINK-15758][MemManager] Remove KeyedBudgetManager and use AtomicLong

  azagrebin

  committed
  32a1b17

  Copy full SHA for 32a1b17

• [FLINK-17772][python] Fix to_pandas to make it work in JDK 11

  Show description for 6a58ce0
  dianfu

  committed
  6a58ce0

  Copy full SHA for 6a58ce0

Commits on May 16, 2020

• [FLINK-17748][table] Remove registration of TableSource/TableSink in table env

  Show description for 32b79d1
  

  docete

  authored and

  KurtYoung

  committed
  32b79d1

  Copy full SHA for 32b79d1

• [hotfix][python] Shows only the slowest 20 tests

  dianfu

  committed
  de5e631

  Copy full SHA for de5e631

• [FLINK-17724][python] Set working directory before running the Python helper scripts.

  Show description for 01abc3f
  

  WeiZhong94

  authored and

  dianfu

  committed
  01abc3f

  Copy full SHA for 01abc3f

Commits on May 15, 2020

• [FLINK-17596][python] Move the Python UDF runner script out of the jar of flink-python

  Show description for 282da0d
  

  WeiZhong94

  authored and

  Dian Fu

  committed
  282da0d

  Copy full SHA for 282da0d

• Revert "[FLINK-17303][python] Support Python TableResult"

  Show description for 70346b2
  hequn8128

  committed
  70346b2

  Copy full SHA for 70346b2

• Revert "[FLINK-17710][python][hotfix] Fix unstable test for StreamSqlTests.test_execute_sql (apache#12160)"

  Show description for 7982281
  hequn8128

  committed
  7982281

  Copy full SHA for 7982281

Pagination

Previous

Next