应龙团队你好：
我在搭建开发环境时配置数据流组失败，经过查看日志时发现报错，日志内容如下：
org.apache.flink.client.program.ProgramInvocationException: The main method
caused an error: Unable to create a sink for writing table
'default_catalog.default_database.table_12_mysql'.
Table options are:
'connector'='jdbc-inlong'
'inlong.metric.labels'='groupId=museum&streamId=inlong&nodeId=12_mysql'
'password'='******'
'table-name'='rbac'
'url'='jdbc:mysql://10.130.1.12:3306/inlong?useUnicode=true&characterEncoding=UTF-8&zeroDateTimeBehavior=convertToNull&useSSL=false&serverTimezone=Asia/Shanghai&autoDeserialize=false&allowUrlInLocalInfile=false&allowLoadLocalInfile=false'
'username'='root'
at
org.apache.flink.client.program.PackagedProgram.callMainMethod(PackagedProgram.java:372)
~[flink-clients-1.15.4.jar:1.15.4]
at
org.apache.flink.client.program.PackagedProgram.invokeInteractiveModeForExecution(PackagedProgram.java:222)
~[flink-clients-1.15.4.jar:1.15.4]
at
org.apache.flink.client.program.PackagedProgramUtils.getPipelineFromProgram(PackagedProgramUtils.java:158)
~[flink-clients-1.15.4.jar:1.15.4]
at
org.apache.flink.client.program.PackagedProgramUtils.createJobGraph(PackagedProgramUtils.java:82)
~[flink-clients-1.15.4.jar:1.15.4]
at
org.apache.flink.client.program.PackagedProgramUtils.createJobGraph(PackagedProgramUtils.java:117)
~[flink-clients-1.15.4.jar:1.15.4]
at
org.apache.inlong.manager.plugin.flink.FlinkService.submitJobBySavepoint(FlinkService.java:224)
~[manager-plugins-base-1.13.0.jar:1.13.0]
at
org.apache.inlong.manager.plugin.flink.FlinkService.submit(FlinkService.java:174)
~[manager-plugins-base-1.13.0.jar:1.13.0]
at
org.apache.inlong.manager.plugin.flink.IntegrationTaskRunner.run(IntegrationTaskRunner.java:58)
~[manager-plugins-base-1.13.0.jar:1.13.0]
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
~[?:1.8.0_144]
at java.util.concurrent.FutureTask.run(FutureTask.java:266) ~[?:1.8.0_144]
at
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
~[?:1.8.0_144]
at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
~[?:1.8.0_144]
at java.lang.Thread.run(Thread.java:748) ~[?:1.8.0_144]
Caused by: org.apache.flink.table.api.ValidationException: Unable to create a
sink for writing table 'default_catalog.default_database.table_12_mysql'.
Table options are:
'connector'='jdbc-inlong'
'inlong.metric.labels'='groupId=museum&streamId=inlong&nodeId=12_mysql'
'password'='******'
'table-name'='rbac'
'url'='jdbc:mysql://10.130.1.12:3306/inlong?useUnicode=true&characterEncoding=UTF-8&zeroDateTimeBehavior=convertToNull&useSSL=false&serverTimezone=Asia/Shanghai&autoDeserialize=false&allowUrlInLocalInfile=false&allowLoadLocalInfile=false'
'username'='root'
at
org.apache.flink.table.factories.FactoryUtil.createDynamicTableSink(FactoryUtil.java:262)
~[flink-table-common-1.15.4.jar:1.15.4]
at
org.apache.flink.table.planner.delegation.PlannerBase.getTableSink(PlannerBase.scala:434)
~[flink-table-planner_2.12-1.15.4.jar:1.15.4]
at
org.apache.flink.table.planner.delegation.PlannerBase.translateToRel(PlannerBase.scala:227)
~[flink-table-planner_2.12-1.15.4.jar:1.15.4]
at
org.apache.flink.table.planner.delegation.PlannerBase.$anonfun$translate$1(PlannerBase.scala:185)
~[flink-table-planner_2.12-1.15.4.jar:1.15.4]
at
scala.collection.TraversableLike.$anonfun$map$1(TraversableLike.scala:233)
~[scala-library-2.12.7.jar:?]
at scala.collection.Iterator.foreach(Iterator.scala:937)
~[scala-library-2.12.7.jar:?]
at scala.collection.Iterator.foreach$(Iterator.scala:937)
~[scala-library-2.12.7.jar:?]
at scala.collection.AbstractIterator.foreach(Iterator.scala:1425)
~[scala-library-2.12.7.jar:?]
at scala.collection.IterableLike.foreach(IterableLike.scala:70)
~[scala-library-2.12.7.jar:?]
at scala.collection.IterableLike.foreach$(IterableLike.scala:69)
~[scala-library-2.12.7.jar:?]
at scala.collection.AbstractIterable.foreach(Iterable.scala:54)
~[scala-library-2.12.7.jar:?]
at scala.collection.TraversableLike.map(TraversableLike.scala:233)
~[scala-library-2.12.7.jar:?]
at scala.collection.TraversableLike.map$(TraversableLike.scala:226)
~[scala-library-2.12.7.jar:?]
at scala.collection.AbstractTraversable.map(Traversable.scala:104)
~[scala-library-2.12.7.jar:?]
at
org.apache.flink.table.planner.delegation.PlannerBase.translate(PlannerBase.scala:185)
~[flink-table-planner_2.12-1.15.4.jar:1.15.4]
at
org.apache.flink.table.api.internal.TableEnvironmentImpl.translate(TableEnvironmentImpl.java:1656)
~[flink-table-api-java-1.15.4.jar:1.15.4]
at
org.apache.flink.table.api.internal.TableEnvironmentImpl.executeInternal(TableEnvironmentImpl.java:782)
~[flink-table-api-java-1.15.4.jar:1.15.4]
at
org.apache.flink.table.api.internal.StatementSetImpl.execute(StatementSetImpl.java:108)
~[flink-table-api-java-1.15.4.jar:1.15.4]
at
org.apache.inlong.sort.parser.result.FlinkSqlParseResult.executeLoadSqls(FlinkSqlParseResult.java:84)
~[?:?]
at
org.apache.inlong.sort.parser.result.FlinkSqlParseResult.execute(FlinkSqlParseResult.java:63)
~[?:?]
at org.apache.inlong.sort.Entrance.main(Entrance.java:99) ~[?:?]
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
~[?:1.8.0_144]
at
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
~[?:1.8.0_144]
at
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
~[?:1.8.0_144]
at java.lang.reflect.Method.invoke(Method.java:498) ~[?:1.8.0_144]
at
org.apache.flink.client.program.PackagedProgram.callMainMethod(PackagedProgram.java:355)
~[flink-clients-1.15.4.jar:1.15.4]
... 12 more
Caused by: java.lang.IllegalStateException: Could not find any jdbc dialect
factory that can handle url
'jdbc:mysql://10.130.1.12:3306/inlong?useUnicode=true&characterEncoding=UTF-8&zeroDateTimeBehavior=convertToNull&useSSL=false&serverTimezone=Asia/Shanghai&autoDeserialize=false&allowUrlInLocalInfile=false&allowLoadLocalInfile=false'
that implements 'org.apache.inlong.sort.jdbc.dialect.JdbcDialectFactory' in
the classpath.
Available factories are:
org.apache.inlong.sort.jdbc.dialect.clickhouse.ClickHouseDialectFactory
经过分析发现 sort-connector-jdbc-v1.15-1.13.0.jar 没有MysqlDialectFactory
。我不明白为啥v1.15版本为啥删除了MysqlDialect 但是inlong为啥又在用？
