?

? ? ? ?DefaultRollingPolicy.builder()
? ? ? ? ? ? ? ?.withRolloverInterval(1000L)
? ? ? ? ? ? ? ?.withInactivityInterval(1000L)
? ? ? ? ? ? ? ?.withMaxPartSize(1024 * 1024 * 1024)
? ? ? ? ? ? ? ?.build())

滾動策略中無法設定多少時間，把checkpoint另存新文件，只能是默認時間間隔。(IDE中也包含設定間隔，但是運行無法通過)

withRollingPolicy(OnCheckpointRollingPolicy.build())?
? ? ? ? ? ? ? ? .withOutputFileConfig(config)//orc,加了文件名前后綴,
? ? ? ? ? ? ? ? .build();