?????? ??Flink Table Store????

?????? Thu, 28 Apr 2022 02:22:21 -0700

????
??????
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 
--&gt;
<dependency&gt;
    <groupId&gt;org.apache.flink</groupId&gt;
    <artifactId&gt;flink-table-planner_2.12</artifactId&gt;
    <version&gt;${flink.version}</version&gt;
</dependency&gt;

<dependency&gt;
    <groupId&gt;org.apache.flink</groupId&gt;
    <artifactId&gt;flink-table-api-java-bridge</artifactId&gt;
    <version&gt;${flink.version}</version&gt;
</dependency&gt;

<dependency&gt;
    <groupId&gt;org.apache.flink</groupId&gt;
    <artifactId&gt;flink-table-planner-loader</artifactId&gt;
    <version&gt;${flink.version}</version&gt;
</dependency&gt;

<dependency&gt;
    <groupId&gt;org.apache.flink</groupId&gt;
    <artifactId&gt;flink-connector-kafka</artifactId&gt;
    <version&gt;${flink.version}</version&gt;
</dependency&gt;

<dependency&gt;
    <groupId&gt;org.apache.flink</groupId&gt;
    <artifactId&gt;flink-streaming-java</artifactId&gt;
    <version&gt;${flink.version}</version&gt;
</dependency&gt;

<dependency&gt;
    <groupId&gt;org.apache.flink</groupId&gt;
    <artifactId&gt;flink-clients</artifactId&gt;
    <version&gt;${flink.version}</version&gt;
</dependency&gt;

<dependency&gt;
    <groupId&gt;org.apache.flink</groupId&gt;
    <artifactId&gt;flink-java</artifactId&gt;
    <version&gt;${flink.version}</version&gt;
</dependency&gt;

<dependency&gt;
    <groupId&gt;org.apache.flink</groupId&gt;
    <artifactId&gt;flink-json</artifactId&gt;
    <version&gt;${flink.version}</version&gt;
</dependency&gt;

??????
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)
??????????????????????????????????????????????????????????????????????????????????????????

??????


&nbsp;




------------------ ???????? ------------------
??????:                                                                         
                                               "user-zh"                        
                                                            
<jingsongl...@gmail.com&gt;;
????????:&nbsp;2022??4??28??(??????) ????3:19
??????:&nbsp;"user-zh"<user-zh@flink.apache.org&gt;;

????:&nbsp;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&gt; wrote:
&gt;
&gt; Flink Table Store ???????????????????????????????? Flink
&gt; 
??????????????????????????????????????????????????????????????????????????????????
&gt;
&gt; Best,
&gt; tison.
&gt;
&gt;
&gt; ?????? <2572805...@qq.com.invalid&gt; ??2022??4??24?????? 09:59??????
&gt;
&gt; &gt; ??????????
&gt; &gt; &amp;nbsp;&amp;nbsp;&amp;nbsp;&amp;nbsp; ????Flink Table
&gt; &gt; 
Store????????????????????????????????flink??????????????????????????????????????
&gt; &gt;
&gt; &gt; ??????
&gt; &gt;
&gt; &gt;
&gt; &gt; &amp;nbsp;

?????? ??Flink Table Store????

回复