Skip to content

Commit ca5a4aa

Browse files
jichunferenc-csaky
jichun
authored andcommitted
[FLINK-37212] Skip relocating some region related exceptions
Closes #55
1 parent 7e7d74b commit ca5a4aa

File tree

1 file changed

+5
-1
lines changed

1 file changed

+5
-1
lines changed

Diff for: flink-sql-connector-hbase-2.2/pom.xml

+5-1
Original file line numberDiff line numberDiff line change
@@ -141,9 +141,13 @@ under the License.
141141
<shadedPattern>org.apache.flink.hbase.shaded.org.apache.hadoop.hbase</shadedPattern>
142142
<!-- HBase client uses shaded KeyValueCodec to encode data and put the class name in
143143
the header of request, the HBase region server can not load the shaded
144-
KeyValueCodec class when decode the data, so we exclude them here. -->
144+
KeyValueCodec class when decode the data, so we exclude them here.
145+
Some exceptions also required to keep their original package because the region
146+
server sends it that way, and otherwise the client will not recognize it.-->
145147
<excludes>
146148
<exclude>org.apache.hadoop.hbase.codec.*</exclude>
149+
<exclude>org.apache.hadoop.hbase.NotServingRegionException</exclude>
150+
<exclude>org.apache.hadoop.hbase.exceptions.RegionMovedException</exclude>
147151
</excludes>
148152
</relocation>
149153
</relocations>

0 commit comments

Comments
 (0)