Uploaded image for project: 'Flink'
  1. Flink
  2. FLINK-15858

Unable to use HiveCatalog and kafka together

    XMLWordPrintableJSON

    Details

      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) 

        Attachments

          Issue Links

            Activity

              People

              • Assignee:
                lirui Rui Li
                Reporter:
                zjffdu Jeff Zhang
              • Votes:
                0 Vote for this issue
                Watchers:
                6 Start watching this issue

                Dates

                • Created:
                  Updated:
                  Resolved:

                  Time Tracking

                  Estimated:
                  Original Estimate - Not Specified
                  Not Specified
                  Remaining:
                  Remaining Estimate - 0h
                  0h
                  Logged:
                  Time Spent - 20m
                  20m