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

   ### 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
   
   
![image](https://github.com/user-attachments/assets/d860354d-6633-4fb4-93a9-450a39e9bef4)
   
   
   ### SeaTunnel Version
   
   2.3.5
   
   ### SeaTunnel Config
   
   ```conf
   #定义一些作业的运行参数,具体可以参考 
https://seatunnel.apache.org/docs/2.3.1/concept/JobEnvConfig
   env {
     parallelism=1 # 并行度,这里是启动5个Source Task来并行的读取数据
     #job.mode="STREAMING"  #作业的运行模式,BATCH=离线批同步,STREAMING=实时同步
     #job.name="SeaTunnel_market_new_121_163_sr_STREAMING_Job"
     #checkpoint.interval=20000 #每10000ms进行一次checkpoint,后面会详细介绍checkpoint对JDBC 
Source和StarRocks Sink这两个连接器的影响
   }
   
   source {
     FakeSource {
       parallelism = 2
       result_table_name = "fake"
       row.num = 16
       schema = {
         fields {
           name = "string"
           age = "int"
         }
       }
     }
   }
   transform {
   
   }
   
   sink {
     Mysocket {
       url="xxxx"
       secret="yyyyy"
     }
   }
   ```
   
   
   ### Running Command
   
   ```shell
   org.apache.seatunnel.example.flink.v2.SeaTunnelApiExample
   ```
   
   
   ### Error Exception
   
   ```log
   2025-01-06 14:55:00,101 ERROR org.apache.seatunnel.core.starter.SeaTunnel - 
Fatal Error, 
   
   2025-01-06 14:55:00,101 ERROR org.apache.seatunnel.core.starter.SeaTunnel - 
Please submit bug report in https://github.com/apache/seatunnel/issues
   
   2025-01-06 14:55:00,101 ERROR org.apache.seatunnel.core.starter.SeaTunnel - 
Reason:Flink job executed failed 
   
   2025-01-06 14:55:00,102 ERROR org.apache.seatunnel.core.starter.SeaTunnel - 
Exception 
StackTrace:org.apache.seatunnel.core.starter.exception.CommandExecuteException: 
Flink job executed failed
        at 
org.apache.seatunnel.core.starter.flink.command.FlinkTaskExecuteCommand.execute(FlinkTaskExecuteCommand.java:63)
        at org.apache.seatunnel.core.starter.SeaTunnel.run(SeaTunnel.java:40)
        at 
org.apache.seatunnel.example.flink.v2.SeaTunnelApiExample.main(SeaTunnelApiExample.java:38)
   Caused by: java.lang.RuntimeException: Plugin 
PluginIdentifier{engineType='seatunnel', pluginType='sink', 
pluginName='Mysocket'} not found.
        at 
org.apache.seatunnel.plugin.discovery.AbstractPluginDiscovery.createPluginInstance(AbstractPluginDiscovery.java:234)
        at 
org.apache.seatunnel.plugin.discovery.AbstractPluginDiscovery.createPluginInstance(AbstractPluginDiscovery.java:174)
        at 
org.apache.seatunnel.core.starter.flink.execution.SinkExecuteProcessor.fallbackCreateSink(SinkExecuteProcessor.java:166)
        at 
org.apache.seatunnel.core.starter.flink.execution.SinkExecuteProcessor.execute(SinkExecuteProcessor.java:103)
        at 
org.apache.seatunnel.core.starter.flink.execution.FlinkExecution.execute(FlinkExecution.java:116)
        at 
org.apache.seatunnel.core.starter.flink.command.FlinkTaskExecuteCommand.execute(FlinkTaskExecuteCommand.java:61)
        ... 2 more
    
   2025-01-06 14:55:00,102 ERROR org.apache.seatunnel.core.starter.SeaTunnel - 
   
===============================================================================
   
   
   
   Exception in thread "main" 
org.apache.seatunnel.core.starter.exception.CommandExecuteException: Flink job 
executed failed
        at 
org.apache.seatunnel.core.starter.flink.command.FlinkTaskExecuteCommand.execute(FlinkTaskExecuteCommand.java:63)
        at org.apache.seatunnel.core.starter.SeaTunnel.run(SeaTunnel.java:40)
        at 
org.apache.seatunnel.example.flink.v2.SeaTunnelApiExample.main(SeaTunnelApiExample.java:38)
   Caused by: java.lang.RuntimeException: Plugin 
PluginIdentifier{engineType='seatunnel', pluginType='sink', 
pluginName='Mysocket'} not found.
        at 
org.apache.seatunnel.plugin.discovery.AbstractPluginDiscovery.createPluginInstance(AbstractPluginDiscovery.java:234)
        at 
org.apache.seatunnel.plugin.discovery.AbstractPluginDiscovery.createPluginInstance(AbstractPluginDiscovery.java:174)
        at 
org.apache.seatunnel.core.starter.flink.execution.SinkExecuteProcessor.fallbackCreateSink(SinkExecuteProcessor.java:166)
        at 
org.apache.seatunnel.core.starter.flink.execution.SinkExecuteProcessor.execute(SinkExecuteProcessor.java:103)
        at 
org.apache.seatunnel.core.starter.flink.execution.FlinkExecution.execute(FlinkExecution.java:116)
        at 
org.apache.seatunnel.core.starter.flink.command.FlinkTaskExecuteCommand.execute(FlinkTaskExecuteCommand.java:61)
   ```
   
   
   ### Zeta or Flink or Spark Version
   
   无
   
   ### Java or Scala Version
   
   8
   
   ### Screenshots
   
   
![image](https://github.com/user-attachments/assets/27a4f80d-e273-4452-aa51-66de2551012a)
   
   
   ### Are you willing to submit PR?
   
   - [X] 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: [email protected]

For queries about this service, please contact Infrastructure at:
[email protected]

Reply via email to