Hi Giannis,

Yes, the checkpoint is enabled

I can share part of the code:

```
env = StreamExecutionEnvironment.getExecutionEnvironment();

env.getConfig().setRestartStrategy(RestartStrategies.noRestart());
env.enableCheckpointing(5000);

tEnv = StreamTableEnvironment.create(
         env, EnvironmentSettings.newInstance().inStreamingMode().build());

tEnv.getConfig().getConfiguration().setBoolean("sqlassertrunner.unit.connector.table.dml-sync",
true);

tEnv.executeSql(String.format("CREATE CATALOG paimon WITH (\n"
         + "    'type'='paimon',\n"
         + "    'warehouse'='%s'\n"
         + ");", UNIT_TEST_INPUT_TEMP_PATH));
tEnv.executeSql("USE CATALOG paimon;");
```

```

tEnv.executeSql("CREATE TABLE TABLE1\n"
                 + "(\n"
                 + "    id      STRING NOT NULL,\n"
                 + "    uuid    STRING,\n"
                 + "    assetSubType STRING NOT NULL,\n"
                 + "    isoCode STRING,\n"
                 + "    nameLong  ROW(`de` ROW(`string` STRING)),\n"
                 + "    PRIMARY KEY (id) NOT ENFORCED\n"
                 + ") ;")

  tEnv.executeSql("CREATE TABLE TABLE2"
                 + "(\n"
                 + "        id  STRING NOT NULL,\n"
                 + "        uuid    STRING,\n"
                 + "        assetSubType STRING NOT NULL,\n"
                 + "        isoCode STRING,\n"
                 + "        nameLong  ROW(`de` ROW(`string` STRING)),\n"
                 + "        PRIMARY KEY (id) NOT ENFORCED\n"
                 + ") ;")

tEnv.executeSql(
     "INSERT INTO TABLE1 VALUES ('1',\n"
                 + "        '1111',\n"
                 + "        'CURRENCY',\n"
                 + "        '123145-iso',\n"
                 + "        ROW(ROW('Long Name DE'))\n"
                 + "    );");

tEnv.executeSql(
     "INSERT INTO TABLE2\n"
             + "SELECT id\n"
             + "     , uuid\n"
             + "     , isoCode\n"
             + "FROM TABLE1;\n");

```

On 2023/12/20 13:38:54 Giannis Polyzos wrote:
> Hi Flaviu,
> do you have checkpointing enabled? Can you share your code?
>
> Best
>
> On Wed, Dec 20, 2023 at 3:36 PM Flaviu Cicio <fl...@gmail.com> wrote:
>
> > Hi,
> >
> > I'm currently in the process of integrating Paimon with Flink and have
> > come across an issue.
> > Specifically, I'm using the table environment to insert entries into a
> > table, then reading from it, and finally inserting the entries into another
> > table.
> > The issue is that the entries are not inserted into the second table.
> >
> > I have tried different configurations and approaches, but none have been
> > successful.
> >
> > Best,
> > Flaviu
> >
> >
> >
>

Reply via email to