Commits

Commits on Jul 7, 2021

[FLINK-23280][python] Fix the issue that Python ExplainDetails does not have JSON_EXECUTION_PLAN option

SteNicholas
authored and
HuangXingBo
committedJul 7, 2021
[FLINK-23165][python] Add StreamExecutionEnvironment#registerSlotSharingGroup to PyFlink and Scala

SteNicholas
authored and
HuangXingBo
committedJul 7, 2021

Commits on Jun 30, 2021

[FLINK-23017][sql-client] HELP in sql-client still shows the removed SOURCE functionality (apache#16321 )
SteNicholas
committedJun 30, 2021

Commits on Jun 10, 2021

[FLINK-20926][maxwell][json] Allow to read metadata for maxwell-json format

SteNicholas
authored and
lirui-apache
committedJun 10, 2021

Commits on Jun 8, 2021

[FLINK-21742][sql-client] Support REMOVE JAR statement in SQL Client
SteNicholas
committedJun 8, 2021

Commits on Jun 1, 2021

[FLINK-21741][sql-client] Support SHOW JARS statement in SQL Client (apache#16010 )
SteNicholas
committedJun 1, 2021

Commits on May 31, 2021

[FLINK-22782][docs] Remove legacy planner from Chinese docs

SteNicholas
authored and
twalthr
committedMay 31, 2021

Commits on May 17, 2021

[FLINK-22592][runtime] numBuffersInLocal is always zero when using unaligned checkpoints

SteNicholas
authored and
xintongsong
committedMay 17, 2021

Commits on May 11, 2021

[FLINK-22413][WebUI] Hide Checkpointing page for batch jobs
SteNicholas
committedMay 11, 2021

Commits on Apr 26, 2021

[FLINK-22301][runtime] Statebackend and CheckpointStorage type is not shown in the Web UI

SteNicholas
authored and
tillrohrmann
committedApr 26, 2021

Commits on Mar 30, 2021

[FLINK-20557][sql-client] Support STATEMENT SET in SQL CLI

SteNicholas
authored and
wuchong
committedMar 30, 2021

Commits on Mar 28, 2021

[FLINK-21664][sql-parser] Support to parse STATEMENT SET syntax
SteNicholas
committedMar 28, 2021

Commits on Mar 17, 2021

[FLINK-21774][sql-client] Display all the SHOW command result in tableau format
SteNicholas
committedMar 17, 2021

Commits on Mar 15, 2021

[FLINK-21735][coordination] Harden JobMaster#updateTaskExecutionState()

SteNicholas
authored and
tillrohrmann
committedMar 15, 2021

Commits on Mar 6, 2021

[FLINK-21419][coordination] Remove GC cleaner mechanism for unsafe memory segments

SteNicholas
authored and
xintongsong
committedMar 6, 2021

Commits on Feb 24, 2021

[FLINK-21005][table] Introduce new runtime provider for unified Sink API and implement in planner
SteNicholas
committedFeb 24, 2021

Commits on Feb 8, 2021

[FLINK-21303][coordination] Remove LogicalSlot#getPhysicalSlotNumber
SteNicholas
committedFeb 8, 2021

Commits on Feb 5, 2021

[FLINK-21210][coordination] ApplicationClusterEntryPoint explicitly closes PackagedProgram
SteNicholas
committedFeb 5, 2021

Commits on Feb 2, 2021

[FLINK-21172][canal][json] Support 'event-timestampcanal-json format include es field (apache#14792 )
SteNicholas
committedFeb 2, 2021

Commits on Jan 25, 2021

[FLINK-21069][table-planner-blink] Configuration "parallelism.default" doesn't take effect for TableEnvironment#explainSql
SteNicholas
committedJan 25, 2021

Commits on Jan 22, 2021

[FLINK-19446][canal-json] Fix canal-json format parse UPDATE record with null value will get wrong result
SteNicholas
committedJan 22, 2021

Commits on Jan 21, 2021

[hotfix][coordination] Remove resetForNewExecution from ExecutionJobVertex

SteNicholas
authored and
zhuzhurk
committedJan 21, 2021
[FLINK-20931][coordination] Remove globalModVersion from ExecutionGraph

SteNicholas
authored and
zhuzhurk
committedJan 21, 2021

Commits on Jan 15, 2021

[FLINK-20953][canal-json] Support regular expression to filter databases and tables for canal-json
SteNicholas
committedJan 15, 2021

Commits on Jan 14, 2021

[FLINK-20885][canal-json] Fix deserialization exception when using 'canal-json.table.include' to filter binlogs of multiple tables
SteNicholas
committedJan 14, 2021

Commits on Jan 13, 2021

[FLINK-20930][runtime] Remove AbstractExecutionSlotAllocator

SteNicholas
authored and
tillrohrmann
committedJan 13, 2021

Commits on Dec 31, 2020

[FLINK-20385][canal-json] Allow to read metadata for canal-json format
SteNicholas
committedDec 31, 2020

Commits on Dec 8, 2020

[FLINK-20250][table-runtime] Fix NPE when invoking AsyncLookupJoinRunner#close method
SteNicholas
committedDec 8, 2020

Commits on Dec 3, 2020

[FLINK-19984][core] Add TypeSerializerTestCoverageTest

SteNicholas
authored and
aljoscha
committedDec 3, 2020
[FLINK-19989][python] Add collect operation in Python DataStream API

SteNicholas
authored and
dianfu
committedDec 3, 2020

Commits on Nov 10, 2020

[FLINK-20013][network] Release network buffer in BoundedBlockingSubpartition if task is failed or canceled (apache#14008 )
SteNicholas
committedNov 10, 2020

Commits on Nov 9, 2020

[FLINK-19491][avro] Support large schema in AvroSerializerSnapshot

SteNicholas
authored and
aljoscha
committedNov 9, 2020

Commits on Nov 6, 2020

[FLINK-19837][DataStream] Don't emit intermediate watermarks from watermark operators in BATCH execution mode

SteNicholas
authored and
dawidwys
committedNov 6, 2020
[FLINK-19868][csv] Remove 'csv.line-delimiter' option for CSV format
SteNicholas
committedNov 6, 2020

Commits on Oct 31, 2020

[FLINK-19892][python] Replace __metaclass__ field with metaclass keyword

SteNicholas
authored and
dianfu
committedOct 31, 2020