apache / seatunnel

SeaTunnel is a next-generation super high-performance, distributed, massive data integration tool.
https://seatunnel.apache.org/
Apache License 2.0
7.93k stars 1.79k forks source link

Got error when use example conf. #138

Closed jiajie999 closed 6 years ago

jiajie999 commented 6 years ago

command:

./bin/start-waterdrop.sh --master yarn --deploy-mode cluster --config ./config/application.conf.template

Error log:

18/08/07 11:00:58 WARN SparkContext: Using an existing SparkContext; some configuration may not take effect.
18/08/07 11:00:58 ERROR ApplicationMaster: User class threw exception: java.lang.AbstractMethodError
java.lang.AbstractMethodError
        at org.apache.spark.internal.Logging$class.initializeLogIfNecessary(Logging.scala:99)
        at io.github.interestinglab.waterdrop.Waterdrop$.initializeLogIfNecessary(Waterdrop.scala:19)
        at org.apache.spark.internal.Logging$class.log(Logging.scala:46)
        at io.github.interestinglab.waterdrop.Waterdrop$.log(Waterdrop.scala:19)
        at org.apache.spark.internal.Logging$class.logInfo(Logging.scala:54)
        at io.github.interestinglab.waterdrop.Waterdrop$.logInfo(Waterdrop.scala:19)
        at io.github.interestinglab.waterdrop.Waterdrop$.entrypoint(Waterdrop.scala:99)
        at io.github.interestinglab.waterdrop.Waterdrop$.main(Waterdrop.scala:45)
        at io.github.interestinglab.waterdrop.Waterdrop.main(Waterdrop.scala)
        at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
        at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
        at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
        at java.lang.reflect.Method.invoke(Method.java:498)
        at org.apache.spark.deploy.yarn.ApplicationMaster$$anon$4.run(ApplicationMaster.scala:706)
18/08/07 11:00:58 INFO ApplicationMaster: Final app status: FAILED, exitCode: 15, (reason: User class threw exception: java.lang.AbstractMethodError
        at org.apache.spark.internal.Logging$class.initializeLogIfNecessary(Logging.scala:99)
        at io.github.interestinglab.waterdrop.Waterdrop$.initializeLogIfNecessary(Waterdrop.scala:19)
        at org.apache.spark.internal.Logging$class.log(Logging.scala:46)
        at io.github.interestinglab.waterdrop.Waterdrop$.log(Waterdrop.scala:19)
        at org.apache.spark.internal.Logging$class.logInfo(Logging.scala:54)
        at io.github.interestinglab.waterdrop.Waterdrop$.logInfo(Waterdrop.scala:19)
        at io.github.interestinglab.waterdrop.Waterdrop$.entrypoint(Waterdrop.scala:99)
        at io.github.interestinglab.waterdrop.Waterdrop$.main(Waterdrop.scala:45)
        at io.github.interestinglab.waterdrop.Waterdrop.main(Waterdrop.scala)
        at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
        at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
        at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
        at java.lang.reflect.Method.invoke(Method.java:498)
        at org.apache.spark.deploy.yarn.ApplicationMaster$$anon$4.run(ApplicationMaster.scala:706)
)
18/08/07 11:00:58 INFO SparkContext: Invoking stop() from shutdown hook
garyelephant commented 6 years ago

@jiajie999 感谢使用 , 请提供你的spark版本,yarn 版本,和系统版本。java版本

jiajie999 commented 6 years ago
spark 2.3.0 Using Scala version 2.11.8 (OpenJDK 64-Bit Server VM, Java 1.8.0_171)

yarn version
Hadoop 2.8.3-amzn-0
Subversion git@aws157git.com:/pkg/Aws157BigTop -r 300391394352b074b85b529e870816a72c6f314a
Compiled by ec2-user on 2018-03-21T23:38Z
Compiled with protoc 2.5.0
From source with checksum 9b41a26e3c4fb07cef2c4aea29394145
This command was run using /usr/lib/hadoop/hadoop-common-2.8.3-amzn-0.jar
garyelephant commented 6 years ago

我用 spark 2.3.0 Using Scala version 2.11.8 测试后,未报错,你试试这个命令会报错吗?

./bin/start-waterdrop.sh -m local[2] -e client -c config/application.conf.template
jiajie999 commented 6 years ago

local模式没问题,能正确运行

garyelephant commented 6 years ago

@jiajie999 我的微信garyelephant, 加一下我的微信吧,我给你详细查一下,为你解决问题。

garyelephant commented 6 years ago

Close for no responding