You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by fc...@apache.org on 2025/02/07 05:41:45 UTC

(flink-connector-hbase) branch main updated: [FLINK-37212] Skip relocating some region related exceptions

This is an automated email from the ASF dual-hosted git repository.

fcsaky pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/flink-connector-hbase.git


The following commit(s) were added to refs/heads/main by this push:
     new ca5a4aa  [FLINK-37212] Skip relocating some region related exceptions
ca5a4aa is described below

commit ca5a4aae3e953841371e9a568ad8472a5ef8c1d2
Author: jichun <ji...@shizhuang-inc.com>
AuthorDate: Fri Jan 24 14:30:45 2025 +0800

    [FLINK-37212] Skip relocating some region related exceptions
    
    Closes #55
---
 flink-sql-connector-hbase-2.2/pom.xml | 6 +++++-
 1 file changed, 5 insertions(+), 1 deletion(-)

diff --git a/flink-sql-connector-hbase-2.2/pom.xml b/flink-sql-connector-hbase-2.2/pom.xml
index 8d60df3..680878d 100644
--- a/flink-sql-connector-hbase-2.2/pom.xml
+++ b/flink-sql-connector-hbase-2.2/pom.xml
@@ -141,9 +141,13 @@ under the License.
 									<shadedPattern>org.apache.flink.hbase.shaded.org.apache.hadoop.hbase</shadedPattern>
 									<!-- HBase client uses shaded KeyValueCodec to encode data and put the class name in
  										the header of request, the HBase region server can not load the shaded
-										KeyValueCodec class when decode the data, so we exclude them here. -->
+										KeyValueCodec class when decode the data, so we exclude them here.
+										Some exceptions also required to keep their original package because the region
+										server sends it that way, and otherwise the client will not recognize it.-->
 									<excludes>
 										<exclude>org.apache.hadoop.hbase.codec.*</exclude>
+										<exclude>org.apache.hadoop.hbase.NotServingRegionException</exclude>
+										<exclude>org.apache.hadoop.hbase.exceptions.RegionMovedException</exclude>
 									</excludes>
 								</relocation>
 							</relocations>