???? ?????? import org.apache.flink.configuration.Configuration; import org.apache.flink.table.api.EnvironmentSettings; import org.apache.flink.table.api.TableConfig; import org.apache.flink.table.api.TableEnvironment;
public class sql { public static void main(String[] args) { EnvironmentSettings settings = EnvironmentSettings .newInstance() .inStreamingMode() // .inBatchMode() .build(); TableEnvironment tenv = TableEnvironment.create(settings); TableConfig config = tenv.getConfig(); config.set("table-store.path","/Users/zhuoyuchen/Desktop/table_storge/temp"); config.set("execution.checkpointing.interval","10 s"); tenv.executeSql("CREATE TABLE IF NOT EXISTS word_count (\n" + " word STRING PRIMARY KEY NOT ENFORCED,\n" + " cnt BIGINT\n" + ") WITH (\n" + ");"); tenv.executeSql("CREATE TABLE word_table (\n" + " word STRING\n" + ") WITH (\n" + " 'connector' = 'datagen',\n" + " 'fields.word.length' = '1'\n" + ");"); tenv.executeSql("INSERT INTO word_count SELECT word, COUNT(*) FROM word_table GROUP BY word;"); } } ???????? flink????1.15 flink-table-store-dist-0.2 flink-shaded-hadoop-2-uber-2.4.1-10.0 <!-- https://mvnrepository.com/artifact/org.apache.flink/flink-table-planner --> <dependency> <groupId>org.apache.flink</groupId> <artifactId>flink-table-planner_2.12</artifactId> <version>${flink.version}</version> </dependency> <dependency> <groupId>org.apache.flink</groupId> <artifactId>flink-table-api-java-bridge</artifactId> <version>${flink.version}</version> </dependency> <dependency> <groupId>org.apache.flink</groupId> <artifactId>flink-table-planner-loader</artifactId> <version>${flink.version}</version> </dependency> <dependency> <groupId>org.apache.flink</groupId> <artifactId>flink-connector-kafka</artifactId> <version>${flink.version}</version> </dependency> <dependency> <groupId>org.apache.flink</groupId> <artifactId>flink-streaming-java</artifactId> <version>${flink.version}</version> </dependency> <dependency> <groupId>org.apache.flink</groupId> <artifactId>flink-clients</artifactId> <version>${flink.version}</version> </dependency> <dependency> <groupId>org.apache.flink</groupId> <artifactId>flink-java</artifactId> <version>${flink.version}</version> </dependency> <dependency> <groupId>org.apache.flink</groupId> <artifactId>flink-json</artifactId> <version>${flink.version}</version> </dependency> ?????? Exception in thread "main" org.apache.flink.table.api.ValidationException: Multiple factories for identifier 'default' that implement 'org.apache.flink.table.delegation.ExecutorFactory' found in the classpath. Ambiguous factory classes are: org.apache.flink.table.planner.delegation.DefaultExecutorFactory org.apache.flink.table.planner.loader.DelegateExecutorFactory at org.apache.flink.table.factories.FactoryUtil.discoverFactory(FactoryUtil.java:553) at org.apache.flink.table.api.internal.TableEnvironmentImpl.create(TableEnvironmentImpl.java:276) at org.apache.flink.table.api.TableEnvironment.create(TableEnvironment.java:93) at sql.main(sql.java:15) ?????????????????????????????????????????????????????????????????????????????????????????? ?????? ------------------ ???????? ------------------ ??????: "user-zh" <jingsongl...@gmail.com>; ????????: 2022??4??28??(??????) ????3:19 ??????: "user-zh"<user-zh@flink.apache.org>; ????: Re: ??Flink Table Store???? ?????????????????? Tison????????Table Store????????????????????????????maven?????? ???????????????????????????? 1.??Table Store???????????? 2.??????flink-table-store-dist???? pre bundled jar??????????????classpath???????? ????????????????SQL???????? TableEnvironment.executeSql("CREATE TABLE XX (...)"); ??classpath?????? table store ?? jar ???????????????? TableStore ?? factory?????????? table store ???????? ??????????????????????????????????????????maven????????????????DataStream API Best, Jingsong On Sun, Apr 24, 2022 at 10:32 AM tison <wander4...@gmail.com> wrote: > > Flink Table Store ???????????????????????????????? Flink > ?????????????????????????????????????????????????????????????????????????????????? > > Best, > tison. > > > ?????? <2572805...@qq.com.invalid> ??2022??4??24?????? 09:59?????? > > > ?????????? > > &nbsp;&nbsp;&nbsp;&nbsp; ????Flink Table > > Store????????????????????????????????flink?????????????????????????????????????? > > > > ?????? > > > > > > &nbsp;