马老师Flink实时计算引擎

既然它错了，那我就强行修正呗。这属性还不对外暴露，我只能选择反射。像这样:

       Environment environment = sessionFactory.getConfiguration().getEnvironment();        Field dataSourceField = environment.getClass().getDeclaredField("dataSource");        dataSourceField.setAccessible(true);        dataSourceField.set(environment, dynamicDataSource.determineTargetDataSource());