[FLINK-15858] Unable to use HiveCatalog and kafka together

• Type: Bug
• Status: Closed
• Priority: Blocker
• Resolution: Fixed
• Affects Version/s: 1.10.0
• Fix Version/s: 1.10.0
• Component/s: Table SQL / Ecosystem
• Labels: pull-request-available
• Assignee: Rui Li
• Reporter: Jeff Zhang
• Created: 03/Feb/20 07:15
• Updated: 06/Feb/20 05:02
• Resolved: 05/Feb/20 10:04

Description

 

HiveCatalog only support timestamp(9), but kafka only support timestamp(3). This make user unable to use HiveCatalog and kafka together

Caused by: org.apache.flink.table.catalog.exceptions.CatalogException: HiveCatalog currently only supports timestamp of precision 9
	at org.apache.flink.table.catalog.hive.util.HiveTypeUtil$TypeInfoLogicalTypeVisitor.visit(HiveTypeUtil.java:272)
	at org.apache.flink.table.catalog.hive.util.HiveTypeUtil$TypeInfoLogicalTypeVisitor.visit(HiveTypeUtil.java:173)
	at org.apache.flink.table.types.logical.TimestampType.accept(TimestampType.java:151)
	at org.apache.flink.table.catalog.hive.util.HiveTypeUtil.toHiveTypeInfo(HiveTypeUtil.java:84)
	at org.apache.flink.table.catalog.hive.util.HiveTableUtil.createHiveColumns(HiveTableUtil.java:106) 

Issue Links

• relates to: FLINK-15901 Support partitioned generic table in HiveCatalog
• links to: GitHub Pull Request #11012