Commits

History for

Commits on Jul 22, 2020

[FLINK-18607][build] Give the maven module a human readable name
nielsbasjes
committedJul 22, 2020

Commits on Jul 21, 2020

[FLINK-18537][table] Replace RowDataTypeInfo with InternalTypeInfo
twalthr
committedJul 21, 2020

Commits on Jul 17, 2020

[FLINK-18588][hive] hive ddl create table support 'if not exists'

wtog
authored and
JingsongLi
committedJul 17, 2020

Commits on Jul 14, 2020

[FLINK-18583][elasticsearch] Fix ElasticSearch6 sink uses index as document id
KarmaGYZ
committedJul 14, 2020
[FLINK-18529][hive] Query Hive table and filter by timestamp partition can fail
lirui-apache
committedJul 14, 2020
[FLINK-18585][elasticsearch] Fix dynamic index doesn't work in new elasticsearch table sink
leonardBang
committedJul 14, 2020

Commits on Jul 13, 2020

[FLINK-18552][tests] Update migration tests of FlinkKafkaConsumerBaseMigrationTest to cover migration till release-1.11

gaoyunhaii
authored and
zhijiangW
committedJul 13, 2020
[FLINK-18552][tests] Update migration tests of BucketingSinkMigrationTest to cover migration till release-1.11

gaoyunhaii
authored and
zhijiangW
committedJul 13, 2020

Commits on Jul 10, 2020

[FLINK-18361][es][table] Support username and password options for new Elasticsearch connector
KarmaGYZ
committedJul 10, 2020
[FLINK-18434] Fix getter methods of AbstractJdbcCatalog
dawidwys
committedJul 10, 2020
[FLINK-15221][kafka][table] Support sink delivery semantic for Kafka in Table API

fsk119
authored and
wuchong
committedJul 10, 2020

Commits on Jul 9, 2020

[FLINK-18534][kafka][table] Fix unstable KafkaTableITCase.testKafkaDebeziumChangelogSource
wuchong
committedJul 9, 2020

Commits on Jul 8, 2020

[FLINK-15414] catch the right KafkaException for binding errors

curcur
authored and
dawidwys
committedJul 8, 2020

Commits on Jul 7, 2020

[hotfix][elasticsearch] Fix validation message for 'sink.bulk-flush.max-actions' of Elasticsearch

liuyongvs
authored and
wuchong
committedJul 7, 2020

Commits on Jul 6, 2020

[FLINK-17761][connector/common] Add a constructor taking capacity as a parameter for FutureCompletingBlockingQueue
pyscala
committedJul 6, 2020

Commits on Jul 3, 2020

Commits on Jul 2, 2020

[hotfix] Fix flink-connector-kinesis NOTICE file
tillrohrmann
committedJul 2, 2020
[hotfix] Fix flink-connector-hive NOTICE file
tillrohrmann
committedJul 2, 2020

Commits on Jun 24, 2020

[FLINK-18428][API/DataStream] Rename StreamExecutionEnvironment#continuousSource() to StreamExecutionEnvironment#source().

becketqin
authored and
StephanEwen
committedJun 24, 2020
[FLINK-14938] Use ConcurrentLinkedQueue in BufferingNoOpRequestIndexer

ysn2233
authored and
aljoscha
committedJun 24, 2020

Commits on Jun 23, 2020

Commits on Jun 22, 2020

[FLINK-18315][table-planner-blink] Fix INSERT INTO partitioned table with VALUES doesn't work correctly

danny0405
authored and
wuchong
committedJun 22, 2020
[FLINK-17544][jdbc] Fix NPE and resource leak problem in JdbcOutputFormat
fsk119
committedJun 22, 2020

Commits on Jun 20, 2020

[FLINK-18320][notice][hive] Merge hive-exec dependencies for hive uber 2.3.6 and 3.1.2
JingsongLi
committedJun 20, 2020

Commits on Jun 17, 2020

Commits on Jun 16, 2020