[FLINK-17029] Introduce a new JDBC connector with new property keys

• Type: Sub-task
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 1.11.0
• Component/s: Connectors / JDBC, Table SQL / Ecosystem
• Labels: pull-request-available
• Assignee: Leonard Xu
• Reporter: Jark Wu
• Created: 07/Apr/20 07:20
• Updated: 16/Oct/20 10:36
• Resolved: 18/May/20 04:32

Description

This new JDBC connector should use new interfaces proposed by FLIP-95, e.g. DynamicTableSource, DynamicTableSink, and Factory.

The new proposed keys :

Old key	New key
connector.type	connector
connector.url	url
connector.table	table-name
connector.driver	driver
connector.username	username
connector.password	password
connector.read.partition.column	scan.partition.column
connector.read.partition.num	scan.partition.num
connector.read.partition.lower-bound	scan.partition.lower-bound
connector.read.partition.upper-bound	scan.partition.upper-bound
connector.read.fetch-size	scan.fetch-size
connector.lookup.cache.max-rows	lookup.cache.max-rows
connector.lookup.cache.ttl	lookup.cache.ttl
connector.lookup.max-retries	lookup.max-retries
connector.write.flush.max-rows	sink.buffer-flush.max-rows
connector.write.flush.interval	sink.buffer-flush.interval
connector.write.max-retries	sink.max-retries

 
 

Issue Links

• links to: GitHub Pull Request #12176