请教各位大佬一个问题， 使用flink sql sink数据到hbase (flink版本 1.13.1 hbase版本2.2.6) 提交任务后，一直报错误是 java.lang.RuntimeException: hbase-default.xml file seems to be for an older version of HBase (2.2.3), this version is 2.2.6
已经在连接器参数里面配置了 'properties.hbase.defaults.for.version.skip'='true'， hbase-default.xml也配置了跳过版本检查还是不行。。。 请问下，这个2.2.3这个数字是怎么来的呢？ 该如何解决这个问题呢？ 提前感谢各位大佬 部分异常信息如下： Table options are: 'connector'='hbase-2.2' 'properties.hbase.defaults.for.version.skip'='true' 'table-name'='xxxx' 'zookeeper.quorum'='xxx:xxx' at org.apache.flink.table.factories.FactoryUtil.createTableSink(FactoryUtil.java:171) at org.apache.flink.table.planner.delegation.PlannerBase.getTableSink(PlannerBase.scala:373) at org.apache.flink.table.planner.delegation.PlannerBase.translateToRel(PlannerBase.scala:201) at org.apache.flink.table.planner.delegation.PlannerBase.$anonfun$translate$1(PlannerBase.scala:162) at scala.collection.TraversableLike.$anonfun$map$1(TraversableLike.scala:233) at scala.collection.Iterator.foreach(Iterator.scala:937) at scala.collection.Iterator.foreach$(Iterator.scala:937) at scala.collection.AbstractIterator.foreach(Iterator.scala:1425) at scala.collection.IterableLike.foreach(IterableLike.scala:70) at scala.collection.IterableLike.foreach$(IterableLike.scala:69) at scala.collection.AbstractIterable.foreach(Iterable.scala:54) at scala.collection.TraversableLike.map(TraversableLike.scala:233) at scala.collection.TraversableLike.map$(TraversableLike.scala:226) at scala.collection.AbstractTraversable.map(Traversable.scala:104) at org.apache.flink.table.planner.delegation.PlannerBase.translate(PlannerBase.scala:162) at org.apache.flink.table.api.internal.TableEnvironmentImpl.translate(TableEnvironmentImpl.java:1518) at org.apache.flink.table.api.internal.TableEnvironmentImpl.executeInternal(TableEnvironmentImpl.java:740) at org.apache.flink.table.api.internal.TableEnvironmentImpl.executeInternal(TableEnvironmentImpl.java:856) at org.apache.flink.table.api.internal.TableEnvironmentImpl.executeSql(TableEnvironmentImpl.java:730) at net.matomo.impl.FlinkCDCVisitorChannel.<init>(FlinkCDCVisitorChannel.java:73) at net.matomo.impl.FlinkCDCVisitorChannel.main(FlinkCDCVisitorChannel.java:86) at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) at java.lang.reflect.Method.invoke(Method.java:498) at org.apache.flink.client.program.PackagedProgram.callMainMethod(PackagedProgram.java:355) ... 8 more Caused by: java.lang.RuntimeException: hbase-default.xml file seems to be for an older version of HBase (2.2.3), this version is 2.2.6 at org.apache.hadoop.hbase.HBaseConfiguration.checkDefaultsVersion(HBaseConfiguration.java:74) at org.apache.hadoop.hbase.HBaseConfiguration.addHbaseResources(HBaseConfiguration.java:84) at org.apache.hadoop.hbase.HBaseConfiguration.create(HBaseConfiguration.java:98) at org.apache.flink.connector.hbase.util.HBaseConfigurationUtil.getHBaseConfiguration(HBaseConfigurationUtil.java:49) at org.apache.flink.connector.hbase.options.HBaseOptions.getHBaseConfiguration(HBaseOptions.java:192) at org.apache.flink.connector.hbase2.HBase2DynamicTableFactory.createDynamicTableSink(HBase2DynamicTableFactory.java:101) at org.apache.flink.table.factories.FactoryUtil.createTableSink(FactoryUtil.java:168) ... 33 more
