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

HBaseLookupFunction can not work with new internal data structure RowData

    XMLWordPrintableJSON

    Details

      Description

       

              at akka.dispatch.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979)
              at akka.dispatch.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107)
      Caused by: java.lang.IllegalArgumentException: unsupported type index:-1
              at org.apache.flink.connector.hbase.util.HBaseTypeUtils.deserializeToObject(HBaseTypeUtils.java:80)
              at org.apache.flink.connector.hbase.util.HBaseReadWriteHelper.parseToRow(HBaseReadWriteHelper.java:161)
              at org.apache.flink.connector.hbase.source.HBaseLookupFunction.eval(HBaseLookupFunction.java:80)
              at LookupFunction$315.flatMap(Unknown Source)
              at org.apache.flink.table.runtime.operators.join.lookup.LookupJoinRunner.processElement(LookupJoinRunner.java:82)
              at org.apache.flink.table.runtime.operators.join.lookup.LookupJoinRunner.processElement(LookupJoinRunner.java:36)
              at org.apache.flink.streaming.api.operators.ProcessOperator.processElement(ProcessOperator.java:66)
      

        Attachments

          Issue Links

            Activity

              People

              • Assignee:
                Leonard Xu Leonard Xu
                Reporter:
                Leonard Xu Leonard Xu
              • Votes:
                0 Vote for this issue
                Watchers:
                3 Start watching this issue

                Dates

                • Created:
                  Updated:
                  Resolved: