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