program output ## # Run in the yarn mode in Linux spark.app.dfs.checkpoint.dir=/apps/logistics/dat-hdfs/spark-checkpoint logistics/jars # Run in the local mode in Linux spark.app.local.checkpoint.dir=/apps/logistics/dat-local/spark-checkpoint jars # Running in the local Mode in Windows spark.app.win.checkpoint.dir=D://apps/logistics/dat-local/spark-checkpoint sparkAppDfsCheckpointDir = resourceBundle.getString("spark.app.dfs.checkpoint.dir")// /apps/logistics/dat-hdfs/spark-checkpoint sparkAppWinCheckpointDir = resourceBundle.getString("spark.app.win.checkpoint.dir")// D://apps/logistics/dat-local/spark-checkpoint
9092 \ -t cdc_topic_001 -p emr-cdc-group-02 -s true \ -o earliest \ -i 60 -y cow -p 10 \ -c s3://xxxxx/spark-checkpoint