Re: [Question] How to use different filesystem between checkpointdata and user data sink

2019-12-23 Thread ouywl
Hi Piotr:     As debug the code, I found The jobmanager classpath is not content “system-plugin.jar”, But when run `configureFileSystems(configuration)` in `ClusterEntrypoint.startCluster()`, It will initialize with the FileSystem plugin in the method 'FileSystem.initialize(confi

Re: [Question] How to use different filesystem between checkpointdata and user data sink

2019-12-19 Thread Piotr Nowojski
Hi, Can you share the full stack trace or just attach job manager and task managers logs? This exception should have had some cause logged below. Piotrek > On 19 Dec 2019, at 04:06, ouywl wrote: > > Hi Piotr Nowojski, >I have move my filesystem plugin to FLINK_HOME/pulgins in flink 1.9.1.

Re: [Question] How to use different filesystem between checkpointdata and user data sink

2019-12-18 Thread ouywl
Hi Piotr Nowojski,   I have move my filesystem plugin to FLINK_HOME/pulgins in flink 1.9.1. The jobmanage don’t start up ,and It load the filesystem plugin in my owner plugin jar . and the log is :  “2019-12-19 10:58:32,394 WARN org.apache.flink.configuration.Configurat