Commits

Commits on Dec 30, 2022

[FLINK-29718][table] Supports hive sum function by native implementation

lsyldliu
authored and
beyond1920
committedDec 30, 2022

Commits on Dec 29, 2022

[FLINK-22318][table] Support RENAME column name for ALTER TABLE statement, optimize the code implementation

lsyldliu
authored and
fsk119
committedDec 29, 2022

Commits on Sep 27, 2022

[FLINK-29219][table] Fix CREATE TABLE AS statement blocks SQL client's execution
lsyldliu
committedSep 27, 2022

Commits on Sep 19, 2022

[FLINK-29023][docs][table] Update documentation of JAR statement page

lsyldliu
authored and
wuchong
committedSep 19, 2022

Commits on Sep 7, 2022

[FLINK-29074][Connectors/JDBC] Fix ClassNotFound exception when using jdbc connector by add jar syntax

lsyldliu
authored and
wuchong
committedSep 7, 2022
[fixup][table-planner] Using user classloader instead of thread context classloader

lsyldliu
authored and
wuchong
committedSep 7, 2022

Commits on Sep 6, 2022

Commits on Aug 31, 2022

[FLINK-29019][doc][parquet] Updating parquet format document that support read complex type

lsyldliu
authored and
MartijnVisser
committedAug 31, 2022

Commits on Aug 26, 2022

[FLINK-29035][table-planner] Fix bug of ExpressionReducer does not work with jar resources
lsyldliu
committedAug 26, 2022

Commits on Aug 19, 2022

[FLINK-28917][table-runtime] Add SQL test for adaptive hash join
lsyldliu
committedAug 19, 2022

Commits on Aug 18, 2022

[FLINK-29007][e2e] Add missing hadoop-hdfs-client with Hadoop 3
lsyldliu
committedAug 18, 2022

Commits on Aug 15, 2022

[FLINK-28916][e2e] Add e2e test for create function using jar syntax (apache#20545 )
lsyldliu
committedAug 15, 2022

Commits on Aug 10, 2022

[FLINK-26929][table-runtime] Introduce adaptive hash join strategy for batch hash join (apache#20365 )
lsyldliu
committedAug 10, 2022

Commits on Aug 9, 2022

[FLINK-24614][parquet] Support complex types (arrya, map, row) for parquet reader
lsyldliu
committedAug 9, 2022

Commits on Aug 5, 2022

[FLINK-25645][table-runtime] Fix UnsupportedOperationException when hash shuffle by a field with array type
lsyldliu
committedAug 5, 2022

Commits on Jul 20, 2022

[FLINK-27659][table-planner] Support to use jar that is registered by 'CREATE FUNCTION USING JAR' syntax

lsyldliu
authored and
fsk119
committedJul 20, 2022

Commits on Jul 7, 2022

[FLINK-26813[sql-parser] Supports ADD/MODIFY column/watermark/constraint syntax for ALTER TABLE (apache#19193 )
lsyldliu
committedJul 7, 2022

Commits on Jun 30, 2022

[FLINK-28213][runtime] StreamExecutionEnvironment configure method support override pipeline.jars option

lsyldliu
authored and
zhuzhurk
committedJun 30, 2022
[FLINK-28080][runtime] Introduce MutableURLClassLoader as parent class of FlinkUserClassLoader and SafetyNetWrapperClassLoader

lsyldliu
authored and
MartijnVisser
committedJun 30, 2022

Commits on Jun 20, 2022

[FLINK-27861][table] Introduce ResourceManager to manage JAR resources (apache#19859 )
lsyldliu
committedJun 20, 2022

Commits on Jun 14, 2022

[FLINK-27658][runtime] SafetyNetWrapperClassLoader expose addURL method to allow registering jar dynamically

lsyldliu
authored and
zhuzhurk
committedJun 14, 2022

Commits on Jun 12, 2022

[FLINK-27651][table] Support CREATE FUNCTION USING JAR syntax
lsyldliu
committedJun 12, 2022

Commits on Jun 10, 2022

[FLINK-27968][e2e] Fix PlannerScalaFreeITCase
lsyldliu
committedJun 10, 2022

Commits on Jun 8, 2022

[FLINK-15635][table] Improve implementation of user classloader

lsyldliu
authored and
wuchong
committedJun 8, 2022
[fixup][table-planner] Refactoring CodeGeneratorContext by add user ClassLoader

lsyldliu
authored and
wuchong
committedJun 8, 2022
[FLINK-27606][table] Fix CompileException when using UDAF with merge() method
lsyldliu
committedJun 8, 2022

Commits on Apr 29, 2022

[FLINK-27367][table-planner] Support cast int to date in legacy cast behavior (apache#19585 )
lsyldliu
committedApr 29, 2022

Commits on Nov 9, 2021

[FLINK-24822][table-planner] Improve subclasses of CatalogTableSpecBase related method parameter

lsyldliu
authored and
godfreyhe
committedNov 9, 2021

Commits on Jul 27, 2021

[FLINK-23217][table-planner] Support StreamExecValues json serialization/deserialization

lsyldliu
authored and
godfreyhe
committedJul 27, 2021

Commits on Oct 9, 2020

[FLINK-18410][table-runtime-blink] correct PartitionCommitTrigger subclass name
lsyldliu
committedOct 9, 2020

Commits on Sep 30, 2020

[FLINK-19258][docs] Fix the wrong example for "csv.line-delimiter" option

lsyldliu
and
ron.liu
committedSep 30, 2020

Commits on Sep 21, 2020

[FLINK-19280][jdbc] Fix option "sink.buffer-flush.max-rows" for JDBC can't be disabled by setting to zero

lsyldliu
and
dalong01.liu
committedSep 21, 2020

Commits on Jun 9, 2020

[FLINK-17625][table-runtime-blink] Fix ArrayIndexOutOfBoundsException in AppendOnlyTopNFunction
lsyldliu
committedJun 9, 2020

Commits on Apr 17, 2020

[FLINK-16581][table-planner-blink] Support state ttl for Mini-Batch deduplication using StateTtlConfig
lsyldliu
committedApr 17, 2020