Cannot discover a connector using option: 'connector'='hbase-2.2'
Could not find any factory for identifier 'hbase-2.2' that implements 'org.apache.flink.table.factories.DynamicTableFactory' in the classpath.
将 flink-connector-hbase-2.2_2.11-${flink.version}.jar放在${Flink_HOME}/lib/下面即可
Caused by: org.apache.flink.table.api.ValidationException: Unable to create a sink for writing table 'default_catalog.default_database.mytable'. Table options are: 'connector'='hbase-2.2' 'table-name'='_dev_test:mytable' 'zookeeper.quorum'='*****:2181' at org.apache.flink.table.factories.FactoryUtil.createTableSink(FactoryUtil.java:171) ~[flink_sql-1.0-jar-with-dependencies.jar:?] at org.apache.flink.table.planner.delegation.Plannerbase.getTableSink(Plannerbase.scala:367) ~[flink-table-planner-blink_2.11-1.13.1.jar:1.13.1] at org.apache.flink.table.planner.delegation.Plannerbase.translateToRel(Plannerbase.scala:201) ~[flink-table-planner-blink_2.11-1.13.1.jar:1.13.1] at org.apache.flink.table.planner.delegation.Plannerbase$$anonfun$1.apply(Plannerbase.scala:162) ~[flink-table-planner-blink_2.11-1.13.1.jar:1.13.1] at org.apache.flink.table.planner.delegation.Plannerbase$$anonfun$1.apply(Plannerbase.scala:162) ~[flink-table-planner-blink_2.11-1.13.1.jar:1.13.1] at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:234) ~[flink_sql-1.0-jar-with-dependencies.jar:?] at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:234) ~[flink_sql-1.0-jar-with-dependencies.jar:?] at scala.collection.Iterator$class.foreach(Iterator.scala:891) ~[flink_sql-1.0-jar-with-dependencies.jar:?] at scala.collection.AbstractIterator.foreach(Iterator.scala:1334) ~[flink_sql-1.0-jar-with-dependencies.jar:?] at scala.collection.IterableLike$class.foreach(IterableLike.scala:72) ~[flink_sql-1.0-jar-with-dependencies.jar:?] at scala.collection.AbstractIterable.foreach(Iterable.scala:54) ~[flink_sql-1.0-jar-with-dependencies.jar:?] at scala.collection.TraversableLike$class.map(TraversableLike.scala:234) ~[flink_sql-1.0-jar-with-dependencies.jar:?] at scala.collection.AbstractTraversable.map(Traversable.scala:104) ~[flink_sql-1.0-jar-with-dependencies.jar:?] at org.apache.flink.table.planner.delegation.Plannerbase.translate(Plannerbase.scala:162) ~[flink-table-planner-blink_2.11-1.13.1.jar:1.13.1] at org.apache.flink.table.api.internal.TableEnvironmentImpl.translate(TableEnvironmentImpl.java:1518) ~[flink_sql-1.0-jar-with-dependencies.jar:?] at org.apache.flink.table.api.internal.TableEnvironmentImpl.executeInternal(TableEnvironmentImpl.java:740) ~[flink_sql-1.0-jar-with-dependencies.jar:?] at org.apache.flink.table.api.internal.TableEnvironmentImpl.executeInternal(TableEnvironmentImpl.java:856) ~[flink_sql-1.0-jar-with-dependencies.jar:?] at org.apache.flink.table.api.internal.TableEnvironmentImpl.executeSql(TableEnvironmentImpl.java:730) ~[flink_sql-1.0-jar-with-dependencies.jar:?] at com.gwm.core.kafka.FlinkKafkaHbase$.main(FlinkKafkaHbase.scala:82) ~[flink_sql-1.0-jar-with-dependencies.jar:?] at com.gwm.core.kafka.FlinkKafkaHbase.main(FlinkKafkaHbase.scala) ~[flink_sql-1.0-jar-with-dependencies.jar:?] at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) ~[?:1.8.0_141] at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) ~[?:1.8.0_141] at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) ~[?:1.8.0_141] at java.lang.reflect.Method.invoke(Method.java:498) ~[?:1.8.0_141] at org.apache.flink.client.program.PackagedProgram.callMainMethod(PackagedProgram.java:355) ~[flink_sql-1.0-jar-with-dependencies.jar:?] at org.apache.flink.client.program.PackagedProgram.invokeInteractiveModeForExecution(PackagedProgram.java:222) ~[flink_sql-1.0-jar-with-dependencies.jar:?] at org.apache.flink.client.ClientUtils.executeProgram(ClientUtils.java:114) ~[flink_sql-1.0-jar-with-dependencies.jar:?] at org.apache.flink.client.deployment.application.ApplicationDispatcherBootstrap.runApplicationEntryPoint(ApplicationDispatcherBootstrap.java:242) ~[flink_sql-1.0-jar-with-dependencies.jar:?] ... 10 more Caused by: org.apache.flink.table.api.ValidationException: Cannot discover a connector using option: 'connector'='hbase-2.2' at org.apache.flink.table.factories.FactoryUtil.enrichNoMatchingConnectorError(FactoryUtil.java:467) ~[flink_sql-1.0-jar-with-dependencies.jar:?] at org.apache.flink.table.factories.FactoryUtil.getDynamicTableFactory(FactoryUtil.java:441) ~[flink_sql-1.0-jar-with-dependencies.jar:?] at org.apache.flink.table.factories.FactoryUtil.createTableSink(FactoryUtil.java:167) ~[flink_sql-1.0-jar-with-dependencies.jar:?] at org.apache.flink.table.planner.delegation.Plannerbase.getTableSink(Plannerbase.scala:367) ~[flink-table-planner-blink_2.11-1.13.1.jar:1.13.1] at org.apache.flink.table.planner.delegation.Plannerbase.translateToRel(Plannerbase.scala:201) ~[flink-table-planner-blink_2.11-1.13.1.jar:1.13.1] at org.apache.flink.table.planner.delegation.Plannerbase$$anonfun$1.apply(Plannerbase.scala:162) ~[flink-table-planner-blink_2.11-1.13.1.jar:1.13.1] at org.apache.flink.table.planner.delegation.Plannerbase$$anonfun$1.apply(Plannerbase.scala:162) ~[flink-table-planner-blink_2.11-1.13.1.jar:1.13.1] at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:234) ~[flink_sql-1.0-jar-with-dependencies.jar:?] at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:234) ~[flink_sql-1.0-jar-with-dependencies.jar:?] at scala.collection.Iterator$class.foreach(Iterator.scala:891) ~[flink_sql-1.0-jar-with-dependencies.jar:?] at scala.collection.AbstractIterator.foreach(Iterator.scala:1334) ~[flink_sql-1.0-jar-with-dependencies.jar:?] at scala.collection.IterableLike$class.foreach(IterableLike.scala:72) ~[flink_sql-1.0-jar-with-dependencies.jar:?] at scala.collection.AbstractIterable.foreach(Iterable.scala:54) ~[flink_sql-1.0-jar-with-dependencies.jar:?] at scala.collection.TraversableLike$class.map(TraversableLike.scala:234) ~[flink_sql-1.0-jar-with-dependencies.jar:?] at scala.collection.AbstractTraversable.map(Traversable.scala:104) ~[flink_sql-1.0-jar-with-dependencies.jar:?] at org.apache.flink.table.planner.delegation.Plannerbase.translate(Plannerbase.scala:162) ~[flink-table-planner-blink_2.11-1.13.1.jar:1.13.1] at org.apache.flink.table.api.internal.TableEnvironmentImpl.translate(TableEnvironmentImpl.java:1518) ~[flink_sql-1.0-jar-with-dependencies.jar:?] at org.apache.flink.table.api.internal.TableEnvironmentImpl.executeInternal(TableEnvironmentImpl.java:740) ~[flink_sql-1.0-jar-with-dependencies.jar:?] at org.apache.flink.table.api.internal.TableEnvironmentImpl.executeInternal(TableEnvironmentImpl.java:856) ~[flink_sql-1.0-jar-with-dependencies.jar:?] at org.apache.flink.table.api.internal.TableEnvironmentImpl.executeSql(TableEnvironmentImpl.java:730) ~[flink_sql-1.0-jar-with-dependencies.jar:?] at com.gwm.core.kafka.FlinkKafkaHbase$.main(FlinkKafkaHbase.scala:82) ~[flink_sql-1.0-jar-with-dependencies.jar:?] at com.gwm.core.kafka.FlinkKafkaHbase.main(FlinkKafkaHbase.scala) ~[flink_sql-1.0-jar-with-dependencies.jar:?] at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) ~[?:1.8.0_141] at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) ~[?:1.8.0_141] at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) ~[?:1.8.0_141] at java.lang.reflect.Method.invoke(Method.java:498) ~[?:1.8.0_141] at org.apache.flink.client.program.PackagedProgram.callMainMethod(PackagedProgram.java:355) ~[flink_sql-1.0-jar-with-dependencies.jar:?] at org.apache.flink.client.program.PackagedProgram.invokeInteractiveModeForExecution(PackagedProgram.java:222) ~[flink_sql-1.0-jar-with-dependencies.jar:?] at org.apache.flink.client.ClientUtils.executeProgram(ClientUtils.java:114) ~[flink_sql-1.0-jar-with-dependencies.jar:?] at org.apache.flink.client.deployment.application.ApplicationDispatcherBootstrap.runApplicationEntryPoint(ApplicationDispatcherBootstrap.java:242) ~[flink_sql-1.0-jar-with-dependencies.jar:?] ... 10 more Caused by: org.apache.flink.table.api.ValidationException: Could not find any factory for identifier 'hbase-2.2' that implements 'org.apache.flink.table.factories.DynamicTableFactory' in the classpath.
