Pentaho HBase Import: извлечение из HBase с ошибкой выброса типа данных Date - PullRequest
1 голос
/ 30 апреля 2019

Я пытаюсь запросить hbase, используя шаг ввода HBase. но он выдает ошибку "HBase input 2.0 - длина значения столбца даты должна быть равна длине длинного"

ниже скриншоты моей конфигурации enter image description here enter image description here

Это данные, которые у меня есть в моей таблице HBase. enter image description here

Вы можете увидеть messageTimestamp - это строка чисел. Я хочу отфильтровать запрос по этому столбцу, как enter image description here

но это вызывает у меня ошибку, которая, как я подозреваю, связана с приведением типов.

2019/04/26 11:56:05 - HBase input 2.0 - ERROR (version 8.2.0.0-342, build 8.2.0.0-342 from 2018-11-14 10.30.55 by buildguy) : Unexpected error  
2019/04/26 11:56:05 - HBase input 2.0 - ERROR (version 8.2.0.0-342, build 8.2.0.0-342 from 2018-11-14 10.30.55 by buildguy) : org.pentaho.di.core.exception.KettleException:  
2019/04/26 11:56:05 - HBase input 2.0 - Unable to execute source table scan  
2019/04/26 11:56:05 - HBase input 2.0 - java.lang.IllegalArgumentException: java.lang.ClassCastException@75d93487  
2019/04/26 11:56:05 - HBase input 2.0 -  
2019/04/26 11:56:05 - HBase input 2.0 - at org.pentaho.big.data.kettle.plugins.hbase.input.HBaseInput.processRow(HBaseInput.java:245)  
2019/04/26 11:56:05 - HBase input 2.0 - at org.pentaho.di.trans.step.RunThread.run(RunThread.java:62)  
2019/04/26 11:56:05 - HBase input 2.0 - at java.lang.Thread.run(Unknown Source)  
2019/04/26 11:56:05 - HBase input 2.0 - Caused by: java.io.IOException: java.lang.IllegalArgumentException: java.lang.ClassCastException@75d93487  
2019/04/26 11:56:05 - HBase input 2.0 - at com.pentaho.big.data.bundles.impl.shim.hbase.table.ResultScannerBuilderImpl$3.perform(ResultScannerBuilderImpl.java:109)  
2019/04/26 11:56:05 - HBase input 2.0 - at com.pentaho.big.data.bundles.impl.shim.hbase.BatchHBaseConnectionOperation.perform(BatchHBaseConnectionOperation.java:45)  
2019/04/26 11:56:05 - HBase input 2.0 - at com.pentaho.big.data.bundles.impl.shim.hbase.table.ResultScannerBuilderImpl.build(ResultScannerBuilderImpl.java:126)  
2019/04/26 11:56:05 - HBase input 2.0 - at org.pentaho.big.data.kettle.plugins.hbase.input.HBaseInput.processRow(HBaseInput.java:243)  

если я уберу фильтр и попробую вытащить полную таблицу. Я все еще получаю ниже ошибки

2019/04/26 11:59:46 - HBase input 2.0 - ERROR (version 8.2.0.0-342, build 8.2.0.0-342 from 2018-11-14 10.30.55 by buildguy) : Unexpected error  
2019/04/26 11:59:46 - HBase input 2.0 - ERROR (version 8.2.0.0-342, build 8.2.0.0-342 from 2018-11-14 10.30.55 by buildguy) : org.pentaho.di.core.exception.KettleException:  
2019/04/26 11:59:46 - HBase input 2.0 - The length of a date column value must equal that of a long  
2019/04/26 11:59:46 - HBase input 2.0 -  
2019/04/26 11:59:46 - HBase input 2.0 - at org.pentaho.hbase.shim.api.HBaseValueMeta.decodeColumnValue(HBaseValueMeta.java:755)  
2019/04/26 11:59:46 - HBase input 2.0 - at com.pentaho.big.data.bundles.impl.shim.hbase.meta.HBaseValueMetaInterfaceImpl.decodeColumnValue(HBaseValueMetaInterfaceImpl.java:49)  
2019/04/26 11:59:46 - HBase input 2.0 - at org.pentaho.big.data.kettle.plugins.hbase.input.HBaseInputData.getOutputRow(HBaseInputData.java:281)  
2019/04/26 11:59:46 - HBase input 2.0 - at org.pentaho.big.data.kettle.plugins.hbase.input.HBaseInput.processRow(HBaseInput.java:287)  
2019/04/26 11:59:46 - HBase input 2.0 - at org.pentaho.di.trans.step.RunThread.run(RunThread.java:62)  
2019/04/26 11:59:46 - HBase input 2.0 - at java.lang.Thread.run(Unknown Source)  

Есть идеи, что вызвало эту ошибку.

...