Commits

Branch selector

 master

User selector

shuiqiangchen

Datepicker

All time

Commit History

Commits on Jan 31, 2021

• [FLINK-21112][python] Add ValueState/ListState/MapState and corresponding StateDescriptors for Python DataStream API.

  Show description for 3796e59
  

  shuiqiangchen

  authored and

  dianfu

  committed
  3796e59

Commits on Dec 23, 2020

• [FLINK-20621][python] Improve the TypeInformation implementation in Python DataStream API

  Show description for dca092f
  

  shuiqiangchen

  authored and

  dianfu

  committed
  dca092f

Commits on Dec 18, 2020

• [FLINK-20647][python] Use yield to generate output data in ProcessFunction of Python DataStream API

  Show description for 1317cab
  

  shuiqiangchen

  authored and

  dianfu

  committed
  1317cab

Commits on Dec 17, 2020

• [FLINK-20601][docs][python] Rework PyFlink CLI documentation.

  Show description for e3c7a59
  

  shuiqiangchen

  authored and

  dianfu

  committed
  e3c7a59

Commits on Dec 3, 2020

• [FLINK-20467][python][docs] Fix the example in Python DataStream API documentation

  Show description for a411abf
  

  shuiqiangchen

  authored and

  dianfu

  committed
  a411abf

Commits on Nov 26, 2020

• [FLINK-20365][python] The native k8s cluster could not be unregistered when executing Python DataStream jobs in attach mode

  Show description for af1b2cf
  

  shuiqiangchen

  authored and

  dianfu

  committed
  af1b2cf

Commits on Nov 24, 2020

• [FLINK-20278][Python] Throw a meaningful exception if the Python DataStream API job executes in batch mode

  Show description for 2817502
  

  shuiqiangchen

  authored and

  dianfu

  committed
  2817502

Commits on Nov 23, 2020

• [FLINK-20275][python] Fix the delimiter of the dependencies of Python DataStream API

  Show description for e245eb1
  

  shuiqiangchen

  authored and

  dianfu

  committed
  e245eb1

Commits on Nov 19, 2020

• [FLINK-20232][python] Handle object reuse properly in the operators of Python DataStream API

  Show description for bd28f52
  

  shuiqiangchen

  authored and

  dianfu

  committed
  bd28f52

• [FLINK-200137][python] Handle the timestamp of elements properly in Python DataStream API

  Show description for 492965c
  

  shuiqiangchen

  authored and

  dianfu

  committed
  492965c

Commits on Nov 9, 2020

• [FLINK-20016][python] Support TimestampAssigner and WatermarkGenerator for Python DataStream API.

  Show description for f24cb3f
  

  shuiqiangchen

  authored and

  dianfu

  committed
  f24cb3f

Commits on Nov 5, 2020

• [FLINK-19821][python] Add ProcessFunction and timer access in Python DataStream API

  Show description for 473d2c5
  

  shuiqiangchen

  authored and

  dianfu

  committed
  473d2c5

Commits on Oct 29, 2020

• [FLINK-19770][python][tests] Extract PythonProgramOptionTest#testConfigurePythonExecution into an ITCase

  Show description for 789d8b6
  

  shuiqiangchen

  authored and

  dianfu

  committed
  789d8b6

Commits on Oct 21, 2020

• [FLINK-18415][python] Support TableResult#collect in the Python Table API to align with the Java Table API

  Show description for 2e5ce09
  

  shuiqiangchen

  authored and

  dianfu

  committed
  2e5ce09

Commits on Oct 13, 2020

• [FLINK-19484][python][tests] Set longer timeout for jobmanager pod availability in PyFlink kubernetes application test (apache#13607)

  shuiqiangchen

  authored
  e8ad578

Commits on Sep 30, 2020

• [FLINK-17480][kubernetes][python] Support running PyFlink on Kubernetes

  Show description for 7050c04
  

  shuiqiangchen

  authored and

  dianfu

  committed
  7050c04

Commits on Sep 25, 2020

• [FLINK-19134][python] Introduce BasicArrayTypeInfo and PrimitiveArrayTypeInfo for Python DataStream API

  Show description for 8525c5c
  

  shuiqiangchen

  authored and

  dianfu

  committed
  8525c5c

Commits on Sep 22, 2020

• [FLINK-18950][python][docs] Add documentation for Operations in Python DataStream API

  Show description for 7569a74
  

  shuiqiangchen

  authored and

  dianfu

  committed
  7569a74

Commits on Sep 10, 2020

• [FLINK-18951][python][docs] Add documentation for dependency management for Python DataStream API.

  Show description for 76aa36c
  

  shuiqiangchen

  authored and

  dianfu

  committed
  76aa36c

• [FLINK-18951][python][docs-zh] Translate Python Table API dependency management documentation into chinese.

  

  shuiqiangchen

  authored and

  dianfu

  committed
  17676eb

Commits on Sep 7, 2020

• [FLINK-19097][python] Support add_jars() in Python StreamExecutionEnvironment.

  Show description for 71ffab6
  

  shuiqiangchen

  authored and

  dianfu

  committed
  71ffab6

Commits on Sep 5, 2020

• [FLINK-18598][python][docs] Add documentation on how to wait for the job execution to finish when using asynchronous APIs

  Show description for 7da74dc
  

  shuiqiangchen

  authored and

  dianfu

  committed
  7da74dc

Commits on Aug 26, 2020

• [FLINK-19041][python] Add dependency management for ConnectedStream in Python DataStream API. (apache#13236)

  shuiqiangchen

  authored
  66797ac

Commits on Aug 24, 2020

• [FLINK-18948][python][e2e] Add E2E test for Python DataStream API

  Show description for fa2739d
  

  shuiqiangchen

  authored and

  dianfu

  committed
  fa2739d

Commits on Aug 18, 2020

• [FLINK-18944][python] Support JDBC connector for Python DataStream API. (apache#13169)

  shuiqiangchen

  authored
  f674c7c

• [FLINK-18886][python] Support Kafka connectors for Python DataStream API. (apache#13161)

  shuiqiangchen

  authored
  3c61dac

• [FLINK-18947][python] Support partition_custom() for Python DataStream API. (apache#13155)

  shuiqiangchen

  authored
  917c3d2

Commits on Aug 15, 2020

• [FLINK-18879][python] Support Row Serialization and Deserialization schemas for Python DataStream API. (apache#13150)

  shuiqiangchen

  authored
  1fc400d

Commits on Aug 14, 2020

• [FLINK-18884][python] Add chaining strategy and slot sharing group interfaces for Python DataStream API. (apache#13140)

  shuiqiangchen

  authored
  d3aa4f3

• [FLINK-18878][python] Support dependency management for Python StreamExecutionEnvironment. (apache#13136)

  shuiqiangchen

  authored
  62b20b0

Commits on Aug 12, 2020

• [FLINK-18888][python] Support execute_async for StreamExecutionEnvironment. (apache#13126)

  shuiqiangchen

  authored
  5dadbf3

• [FLINK-18885][python] Add partitioning interfaces for Python DataStream API. (apache#13119)

  shuiqiangchen

  authored
  82b3669

• [FLINK-18863][python] Support read_text_file() and print() interface for Python DataStream API. (apache#13117)

  shuiqiangchen

  authored
  37d7917

Commits on Aug 11, 2020

• [FLINK-18866][python] Support filter() operation for Python DataStream API. (apache#13098)

  shuiqiangchen

  authored
  f1e34e6

• [FLINK-18874][python] Support conversions between Table and DataStream. (apache#13107)

  shuiqiangchen

  authored
  8b9193a

Pagination

PreviousNext