Commits

History for

Commits on Feb 5, 2020

[FLINK-15868][kinesis] Resolve version conflict between jackson-core and jackson-dataformat-cbor

tweise
authored and
tillrohrmann
committedFeb 5, 2020
[FLINK-15858][hive] Store generic table schema as properties
lirui-apache
committedFeb 5, 2020

Commits on Feb 3, 2020

[FLINK-15810] Add more description for FlinkKafkaProducerMigrationOperatorTest

yanghua
authored and
aljoscha
committedFeb 3, 2020

Commits on Jan 31, 2020

[FLINK-13689] [Connectors/ElasticSearch] Fix thread leak in Elasticsearch connector when cluster is down

static-max
authored and
aljoscha
committedJan 31, 2020

Commits on Jan 23, 2020

[FLINK-15592][hive] Add black list for Hive built-in functions

lirui-apache
authored and
bowenli86
committedJan 23, 2020
[FLINK-15602][table-planner-blink] Padding zeros for TIMESTAMP type to respect the precision when casting timestamp to varchar

docete
authored and
wuchong
committedJan 23, 2020
[FLINK-15692][state] Enable limiting RocksDB memory consumption by default

Myasuka
authored and
tillrohrmann
committedJan 23, 2020

Commits on Jan 19, 2020

[FLINK-15479][jdbc] Override explainSource method for JDBCTableSource to fix project pushdown (apache#10769 )

wangxlong
authored and
wuchong
committedJan 19, 2020

Commits on Jan 16, 2020

Commits on Jan 15, 2020

[hotfix][docs] Fix typo in class doc of KafkaTopicPartitionStateWithPunctuatedWatermarks

guliziduo
authored and
tisonkun
committedJan 15, 2020

Commits on Jan 13, 2020

[FLINK-15541] Fix unstable case FlinkKinesisConsumerTest

ifndef-SleePy
authored and
aljoscha
committedJan 13, 2020
[FLINK-15115][kafka] Drop Kafka 0.9
zentol
committedJan 13, 2020
[hotfix][kafka][legal] Correct version in NOTICE
zentol
committedJan 13, 2020
[FLINK-15115][kafka] Drop Kafka 0.9 SQL jar
zentol
committedJan 13, 2020
[FLINK-15115][kafka] Drop Kafka 0.8
zentol
committedJan 13, 2020
[FLINK-15115][kafka] Reduce mocking
zentol
committedJan 13, 2020

Commits on Jan 12, 2020

[FLINK-15464][hive] Fix HiveTableSourceTest::testPartitionFilterDateTimestamp for 1.x

lirui-apache
authored and
bowenli86
committedJan 12, 2020

Commits on Jan 10, 2020

[FLINK-15490][kafka][test-stability] Enable idempotence producing in KafkaITCase to avoid intermittent test failure.
becketqin
committedJan 10, 2020

Commits on Jan 7, 2020

[FLINK-15482][table][hive] Fix calling Hive functions with returning decimal type failed (apache#10775 )

lirui-apache
authored and
wuchong
committedJan 7, 2020

Commits on Jan 5, 2020

[FLINK-15453][hive] Remove unneeded HiveShim methods

lirui-apache
authored and
bowenli86
committedJan 5, 2020

Commits on Jan 3, 2020

[FLINK-15371][core][config] Use the new type definition for config options of memory types in TaskManagerOptions.

xintongsong
authored and
tillrohrmann
committedJan 3, 2020
[FLINK-15429][hive] HiveObjectConversion implementations need to handle null values

lirui-apache
authored and
bowenli86
committedJan 3, 2020

Commits on Jan 2, 2020

[FLINK-15381] [table-planner-blink] Fix collation derive logic on RelSubset in RelMdCollation (apache#10694 )

godfreyhe
authored and
wuchong
committedJan 2, 2020
[FLINK-15334][table-api] Fix physical schema mapping in TableFormatFactoryBase to support define orderless computed column (apache#10693 )

leonardBang
authored and
wuchong
committedJan 2, 2020
[FLINK-15411][hive] Fix listPartitions in HiveCatalog & Add time prune partition tests

JingsongLi
authored and
wuchong
committedJan 2, 2020
[FLINK-15443][jdbc] Fix mismatch between Java float and JDBC float (apache#10731 )

JingsongLi
authored and
wuchong
committedJan 2, 2020
[FLINK-15259][hive] HiveInspector.toInspectors() should convert Flink constant to Hive constant

lirui-apache
authored and
bowenli86
committedJan 2, 2020
[FLINK-15290][streaming] Configure user defined function with global configuration

lirui-apache
authored and
bowenli86
committedJan 2, 2020

Commits on Dec 30, 2019

[FLINK-15389][jdbc] Improve JDBCUpsertOutputFormat to schedule flusher when flushMaxSize is not one

zoudaokoulife
authored and
wuchong
committedDec 30, 2019

Commits on Dec 26, 2019

[FLINK-15391][hive] DATE and TIMESTAMP partition columns don't work

lirui-apache
authored and
bowenli86
committedDec 26, 2019
[hotfix][hive] Use TableUtils.collectToList(Table) in TableEnvHiveConnectorTest
wuchong
committedDec 26, 2019
[hotfix][hive] Use TableUtils.collectToList(Table) to verify query result
wuchong
committedDec 26, 2019