我正在尝试在我的 Spark 应用程序中初始化 spring 上下文。我想要我的从节点中的上下文以及我想要重用 bean。这是相同的代码:-
shipperRD2.foreach(shipper->{
AmazonS3 amazonS3Client = AmazonS3ClientBuilder.standard().build();
FileSystemXmlApplicationContext context2 = new FileSystemXmlApplicationContext("https://s3.console.aws.amazon.com/s3/object/spring-configuration/app-context.xml");
PersistenceWrapper persistenceWrapper = context.getBean(PersistenceWrapper.class);
});
但是,这会导致每次在从节点上运行新任务时都会刷新上下文。有什么办法可以避免这种行为。基本上,只需在第一个任务运行时初始化上下文,并在后续任务中重新使用该上下文。