Flink ????hive?? ?????? Savepoint

[??????]

??????????flink 1.10 
????????????hive??????????????Savepoint????????????????????????Table????DataSet

EnvironmentSettings settings = 
EnvironmentSettings.newInstance().useBlinkPlanner().inBatchMode().build();
TableEnvironment tableEnv = TableEnvironment.create(settings);
Table table = tableEnv.sqlQuery("select * from test001");

BootstrapTransformation<CurrencyRate&gt; broadcastTransformation = 
OperatorTransformation
        .bootstrapWith(currencyDataSet)
        .transform(new CurrencyBootstrapFunction());

Savepoint
        .create(backend, 128)
        .withOperator(ACCOUNT_UID, transformation)
        .withOperator(CURRENCY_UID, broadcastTransformation)
        .write(savepointPath);