doesn't this throw an exception? I see your INSERT INTO query contains 3
fields, but TABLE2 has 4 fields. I believe you need to run *INSERT INTO
TABLE2 SELECT * FROM TABLE1;*
On Wed, Dec 20, 2023 at 4:45 PM Flaviu Cicio <flaviuci...@gmail.com> wrote:
> 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
> > >
> > >
> > >
> >
>
