From 6dda19a23f1c61fb0477abb9e4cbe69c1e192d75 Mon Sep 17 00:00:00 2001
From: "junfei.ljf" <junfei.ljf@alibaba-inc.com>
Date: Fri, 23 Oct 2020 11:36:31 +0800
Subject: [PATCH] fix hbase11xsqlreader "No suitable driver found for
 jdbc:phoenix:xxx" error"

---
 .../plugin/reader/hbase11xsqlreader/HbaseSQLHelper.java   | 8 ++++++++
 1 file changed, 8 insertions(+)

diff --git a/hbase11xsqlreader/src/main/java/com/alibaba/datax/plugin/reader/hbase11xsqlreader/HbaseSQLHelper.java b/hbase11xsqlreader/src/main/java/com/alibaba/datax/plugin/reader/hbase11xsqlreader/HbaseSQLHelper.java
index 2aacdddf..5309d1d9 100644
--- a/hbase11xsqlreader/src/main/java/com/alibaba/datax/plugin/reader/hbase11xsqlreader/HbaseSQLHelper.java
+++ b/hbase11xsqlreader/src/main/java/com/alibaba/datax/plugin/reader/hbase11xsqlreader/HbaseSQLHelper.java
@@ -34,6 +34,14 @@ import java.util.Map;
 public class HbaseSQLHelper {
     private static final Logger LOG = LoggerFactory.getLogger(HbaseSQLHelper.class);
 
+    static {
+        try {
+            Class.forName("org.apache.phoenix.jdbc.PhoenixDriver");
+        } catch (Throwable t) {
+            throw new RuntimeException("faild load org.apache.phoenix.jdbc.PhoenixDriver", t);
+        }
+    }
+
     public static org.apache.hadoop.conf.Configuration generatePhoenixConf(HbaseSQLReaderConfig readerConfig) {
         org.apache.hadoop.conf.Configuration conf = new org.apache.hadoop.conf.Configuration();