问题一
java.lang.NoSuchFieldError: GROUP_ID
at org.apache.flink.table.validate.BasicOperatorTable.(FunctionCatalog.scala:362)
at org.apache.flink.table.validate.FunctionCatalog.getSqlOperatorTable(FunctionCatalog.scala:58)
at org.apache.flink.table.api.TableEnvironment.getSqlOperatorTable(TableEnvironment.scala:149)
at org.apache.flink.table.api.TableEnvironment.frameworkConfig$lzycompute(TableEnvironment.scala:93)
at org.apache.flink.table.api.TableEnvironment.frameworkConfig(TableEnvironment.scala:87)
at org.apache.flink.table.api.TableEnvironment.relBuilder$lzycompute(TableEnvironment.scala:100)
at org.apache.flink.table.api.TableEnvironment.relBuilder(TableEnvironment.scala:100)
at org.apache.flink.table.api.TableEnvironment.typeFactory$lzycompute(TableEnvironment.scala:105)
at org.apache.flink.table.api.TableEnvironment.typeFactory(TableEnvironment.scala:105)
at org.apache.flink.table.api.TableEnvironment.registerFunction(TableEnvironment.scala:449)
What you expected to happen:
当我尝试使用 src/dataflow/bksql/bksql-plugin-flinksql 模块,RESTAPI bksql/api/convert/flink-sql 解析 sql 的时候,报上述错误。经过多次尝试仍未解决该问题,希望得到帮助
问题一 java.lang.NoSuchFieldError: GROUP_ID at org.apache.flink.table.validate.BasicOperatorTable.(FunctionCatalog.scala:362)
at org.apache.flink.table.validate.FunctionCatalog.getSqlOperatorTable(FunctionCatalog.scala:58)
at org.apache.flink.table.api.TableEnvironment.getSqlOperatorTable(TableEnvironment.scala:149)
at org.apache.flink.table.api.TableEnvironment.frameworkConfig$lzycompute(TableEnvironment.scala:93)
at org.apache.flink.table.api.TableEnvironment.frameworkConfig(TableEnvironment.scala:87)
at org.apache.flink.table.api.TableEnvironment.relBuilder$lzycompute(TableEnvironment.scala:100)
at org.apache.flink.table.api.TableEnvironment.relBuilder(TableEnvironment.scala:100)
at org.apache.flink.table.api.TableEnvironment.typeFactory$lzycompute(TableEnvironment.scala:105)
at org.apache.flink.table.api.TableEnvironment.typeFactory(TableEnvironment.scala:105)
at org.apache.flink.table.api.TableEnvironment.registerFunction(TableEnvironment.scala:449)
What you expected to happen:
当我尝试使用 src/dataflow/bksql/bksql-plugin-flinksql 模块,RESTAPI bksql/api/convert/flink-sql 解析 sql 的时候,报上述错误。经过多次尝试仍未解决该问题,希望得到帮助
问题二 flink-table 包与你们写的 Calcite 包是否有重名冲突?