目前我们正在我们的项目中使用flink1.9.2，我们正在从jar提交作业。
下面是我们目前用于提交作业的代码：

clusterClient.setDetached(true);
clusterClient.run(packagedProgram, Integer.valueOf(params.get(Constants.PARAMS_PARALLELISM)));

升级到Flink1.11.1之后，上面的代码就不起作用了。另外，新的packagedprogram构造函数期望“configuration”作为参数。
我们如何才能改变这一点来满足我们的需要？