in flink-connector-hbase-base/src/main/java/org/apache/flink/connector/hbase/util/HBaseConfigurationUtil.java [132:144]
public static Configuration deserializeConfiguration(
byte[] serializedConfig, Configuration targetConfig) {
if (null == targetConfig) {
targetConfig = new Configuration();
}
try {
deserializeWritable(targetConfig, serializedConfig);
} catch (IOException e) {
throw new RuntimeException(
"Encounter an IOException when deserialize the Configuration.", e);
}
return targetConfig;
}