Apache Phoenix 在源码里修改默认参数


Phoenix:5.0


原因:

用flink jdbc sink写phoenix时,由于phoenix开了namespace,flink写入时报错:

Caused by: java.sql.SQLException: ERROR 726 (43M10):  Inconsistent namespace mapping properties.. Cannot initiate connection as SYSTEM:CATALOG is found but client does not have phoenix.schema.isNamespaceMappingEnabled enabled

Apache Phoenix 在源码里修改默认参数

解决:

修改phoenix代码:https://github.com/apache/phoenix/blob/master/phoenix-core/src/main/java/org/apache/phoenix/query/QueryServicesOptions.java

Apache Phoenix 在源码里修改默认参数

如果修改参数多的话可以在这里全部改掉,重新编译打包,使用新的phoenix-core-5.0.0-alpha-HBase-2.0.jar就可以了