Commits

Branch selector

 master

User selector

WeiZhong94

Datepicker

All time

Commit History

Commits on Dec 6, 2022

• [FLINK-30245][table-runtime] Fix the NPE thrown when filtering decimal(18, x) values after calling DecimalDataUtils.subtract method

  Show description for bca57b7
  WeiZhong94

  authored
  bca57b7

Commits on Mar 31, 2021

• [FLINK-21842][python] Support user defined WindowAssigner, Trigger and ProcessWindowFunction on Python DataStream API

  Show description for 62838c9
  WeiZhong94

  committed
  62838c9

Commits on Mar 29, 2021

• [FLINK-21969][python] Invoke finish bundle method before emitting the max timestamp watermark in PythonTimestampsAndWatermarksOperator

  Show description for 5b3a8f3
  

  WeiZhong94

  authored and

  HuangXingBo

  committed
  5b3a8f3

Commits on Mar 25, 2021

• [FLINK-21294][python] Support state access API for the map/flat_map operation of Python ConnectedStreams

  Show description for 7e49b1a
  WeiZhong94

  committed
  7e49b1a

Commits on Mar 11, 2021

• [FLINK-21242][python] Support state access API for the map/flat_map/filter/reduce operations of Python KeyedStream

  Show description for 582c7b5
  WeiZhong94

  authored
  582c7b5

Commits on Mar 10, 2021

• [FLINK-21679][table] Set output type for transformations from SourceProvider and DataStreamScanProvider in CommonExecTableSourceScan

  Show description for d97c68b
  WeiZhong94

  authored
  d97c68b

Commits on Mar 3, 2021

• [FLINK-21115][python] Add AggregatingState and corresponding StateDescriptor for Python DataStream API

  Show description for 044f8e1
  WeiZhong94

  authored
  044f8e1

• [FLINK-21434][python] Fix encoding error when using the fast coder to encode a row-type field containing more than 14 fields

  Show description for 1b0e592
  WeiZhong94

  authored
  1b0e592

Commits on Mar 2, 2021

• [FLINK-21509][python] add 'withProcessingTime()' method call when creating proctime slide window assigner in 'StreamExecPythonGroupWindowAggregate' class

  Show description for f00da55
  WeiZhong94

  authored
  f00da55

Commits on Feb 26, 2021

• [FLINK-21114][python] Add ReducingState and corresponding StateDescriptor for Python DataStream API

  Show description for 1939e9b
  

  WeiZhong94

  authored and

  HuangXingBo

  committed
  1939e9b

Commits on Feb 23, 2021

• [FLINK-21180][python] Move the state module from 'pyflink.common' to 'pyflink.datastream'

  Show description for 6c99802
  WeiZhong94

  authored
  6c99802

• [FLINK-20994][python] Add public method to create TableEnvironment in PyFlink

  Show description for 3f99f29
  WeiZhong94

  authored
  3f99f29

Commits on Nov 25, 2020

• [FLINK-20333][python] Fix the issue that metaspace OOM will be thrown after submitting PyFlink UDF jobs multiple times to the standalone cluster

  Show description for c354f7b
  

  WeiZhong94

  authored and

  dianfu

  committed
  c354f7b

Commits on Nov 18, 2020

• [FLINK-20207][python] Improve the error message printed when submitting the pyflink jobs via 'flink run'

  Show description for 63aec82
  

  WeiZhong94

  authored and

  dianfu

  committed
  63aec82

Commits on Nov 12, 2020

• [FLINK-20046][python] Fix the unstable test StreamTableAggregateTests.test_map_view_iterate

  Show description for b9b9ff3
  

  WeiZhong94

  authored and

  dianfu

  committed
  b9b9ff3

Commits on Nov 6, 2020

• [FLINK-18926][python][docs] Add a "Environment Variables" document under the "Python API" -> "User Guide" -> "Table API" section

  Show description for e0a0aa6
  

  WeiZhong94

  authored and

  dianfu

  committed
  e0a0aa6

• [FLINK-19284][python][docs] Add documentation about how to use Python UDF in the Java Table API program

  Show description for 51cd11e
  

  WeiZhong94

  authored and

  dianfu

  committed
  51cd11e

Commits on Nov 4, 2020

• [FLINK-19844][python][docs] Add documentation for Python UDAF

  Show description for cddb821
  

  WeiZhong94

  authored and

  dianfu

  committed
  cddb821

• [FLINK-18716][python][docs] Remove the deprecated execute and insert_into calls in PyFlink Table API docs

  Show description for b868639
  

  WeiZhong94

  authored and

  dianfu

  committed
  b868639

Commits on Nov 3, 2020

• [FLINK-19235][python] Support mixed use with most built-in aggs for Python UDAF

  Show description for dc0c5b5
  

  WeiZhong94

  authored and

  dianfu

  committed
  dc0c5b5

Commits on Oct 30, 2020

• [FLINK-19235][python] Support mixed use of built-in aggs with Python UDAF

  Show description for 2dc872a
  

  WeiZhong94

  authored and

  dianfu

  committed
  2dc872a

Commits on Oct 28, 2020

• [FLINK-19233][python] Support distinct and filter keywords on Python UDAF

  Show description for 6ddd2c9
  

  WeiZhong94

  authored and

  dianfu

  committed
  6ddd2c9

Commits on Oct 27, 2020

• [FLINK-19232][python] Support iterating MapState and MapView

  Show description for d30e523
  

  WeiZhong94

  authored and

  dianfu

  committed
  d30e523

Commits on Oct 21, 2020

• [FLINK-19232][python] Support MapState and MapView for Python UDAF

  Show description for 079bbac
  

  WeiZhong94

  authored and

  dianfu

  committed
  079bbac

Commits on Oct 13, 2020

• [FLINK-19231][python] Support ListState and ListView for Python UDAF

  Show description for b60c59d
  

  WeiZhong94

  authored and

  dianfu

  committed
  b60c59d

Commits on Sep 26, 2020

• [FLINK-19421][python] Support Python UDAF in streaming mode

  Show description for ba520e9
  

  WeiZhong94

  authored and

  dianfu

  committed
  ba520e9

Commits on Sep 23, 2020

• [FLINK-19229][python] Introduce the PythonStreamGroupAggregateOperator for Python UDAF. (apache#13420)

  WeiZhong94

  authored
  452b043

Commits on Sep 17, 2020

• [FLINK-17879][python] Update Python row serializer to support RowKind

  Show description for 2f617d0
  

  WeiZhong94

  authored and

  dianfu

  committed
  2f617d0

Commits on Sep 8, 2020

• [FLINK-18913][docs][python] Add a "TableEnvironment" document under the "Python API" -> "Table API User's Guide" section

  Show description for 62c53c4
  

  WeiZhong94

  authored and

  dianfu

  committed
  62c53c4

Commits on Sep 3, 2020

• [FLINK-19110][docs][python] Flatten current PyFlink documentation structure.

  Show description for 85c1506
  

  WeiZhong94

  authored and

  dianfu

  committed
  85c1506

Commits on Sep 2, 2020

• [FLINK-18801][docs][python] Add a "10 minutes to Table API" document under the "Python API" -> "User Guide" -> "Table API" section.

  Show description for 5350bca
  

  WeiZhong94

  authored and

  dianfu

  committed
  5350bca

Commits on Aug 27, 2020

• [FLINK-18917][docs][python] Add a "Built-in Functions" link (linked to dev/table/functions/systemFunctions.md) under the "Python API" -> "User Guide" -> "Table API" section

  Show description for 083933a
  

  WeiZhong94

  authored and

  dianfu

  committed
  083933a

Commits on Aug 18, 2020

• [FLINK-18910][docs][python] Create the new documentation structure for Python documentation according to FLIP-133.

  Show description for 24ba3ba
  

  WeiZhong94

  authored and

  dianfu

  committed
  24ba3ba

Commits on Aug 13, 2020

• [FLINK-18849][docs] Improve the code tabs of the Flink documents.

  Show description for 2c527fb
  

  WeiZhong94

  authored and

  sjwiesman

  committed
  2c527fb

Commits on Jul 17, 2020

• [FLINK-18463][python] Make the "input_types" parameter of the Python UDF/UDTF decorator optional.

  Show description for ef46460
  

  WeiZhong94

  authored and

  dianfu

  committed
  ef46460

Pagination

PreviousNext