maqw666 opened a new issue, #5922:
URL: https://github.com/apache/seatunnel/issues/5922

   ### Search before asking
   
   - [X] I had searched in the 
[issues](https://github.com/apache/seatunnel/issues?q=is%3Aissue+label%3A%22bug%22)
 and found no similar issues.
   
   
   ### What happened
   
   read mongodb data to console report issue:failed send heartbeat to resource 
manager, will retry later. this address: [localhost]:5802
   ERROR org.apache.seatunnel.core.starter.SeaTunnel - Exception 
StackTrace:org.apache.seatunnel.core.starter.exception.CommandExecuteException: 
SeaTunnel job executed failed Caused by: java.lang.IllegalStateException: Node 
failed to start!
   
   ### SeaTunnel Version
   
   2.3.3
   
   ### SeaTunnel Config
   
   ```conf
   env {
     # You can set SeaTunnel environment configuration here
     execution.parallelism = 2
     job.mode = "BATCH"
     #checkpoint.interval = 10000
     #execution.checkpoint.interval = 10000
     #execution.checkpoint.data-uri = "hdfs://localhost:9000/checkpoint"
   }
   
   source {
     MongoDB {
       uri = 
"mongodb://admin:mingyang100@192.168.100.31:27017/admin?connectTimeoutMS=10000&authSource=admin&authMechanism=SCRAM-SHA-1"
       database = "enterprise"
       collection = "TenderProjectSD"
       partition.split-key = "_id"
       partition.split-size = 1024
       schema = {
         fields {
           _id = string
           publicDate = string
           province = string
           URL = string
           WEBNAME = string
           title = string
           tenderType = string
         }
       }
     }
   }
   
   transform {
   }
   
   sink {
     Console {
     }
   }
   ```
   
   
   ### Running Command
   
   ```shell
   ./bin/seatunnel.sh --config ./config/mongo2console -e local
   ```
   
   
   ### Error Exception
   
   ```log
   failed send heartbeat to resource manager, will retry later. this address: 
[localhost]:5802
   ERROR org.apache.seatunnel.core.starter.SeaTunnel 
   - Exception 
StackTrace:org.apache.seatunnel.core.starter.exception.CommandExecuteException: 
SeaTunnel job executed failed Caused by: java.lang.IllegalStateException: Node 
failed to start!
   ```
   
   
   ### Zeta or Flink or Spark Version
   
   _No response_
   
   ### Java or Scala Version
   
   _No response_
   
   ### Screenshots
   
   _No response_
   
   ### Are you willing to submit PR?
   
   - [ ] Yes I am willing to submit a PR!
   
   ### Code of Conduct
   
   - [X] I agree to follow this project's [Code of 
Conduct](https://www.apache.org/foundation/policies/conduct)
   


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: commits-unsubscr...@seatunnel.apache.org.apache.org

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org

Reply via email to