You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
2024-05-11 14:16:23,410 ERROR [o.a.s.c.s.SeaTunnel ] [main] - Exception StackTrace:org.apache.seatunnel.core.s
at org.apache.seatunnel.core.starter.seatunnel.command.ClientExecuteCommand.execute(ClientExecuteCommand.java:19
at org.apache.seatunnel.core.starter.SeaTunnel.run(SeaTunnel.java:40)
at org.apache.seatunnel.core.starter.seatunnel.SeaTunnelClient.main(SeaTunnelClient.java:34)
Caused by: java.lang.NullPointerException
at sun.nio.fs.UnixPath.normalizeAndCheck(UnixPath.java:77)
at sun.nio.fs.UnixPath.(UnixPath.java:71)
at sun.nio.fs.UnixFileSystem.getPath(UnixFileSystem.java:281)
at java.nio.file.Paths.get(Paths.java:84)
at org.apache.seatunnel.core.starter.utils.FileUtils.getConfigPath(FileUtils.java:49)
at org.apache.seatunnel.core.starter.seatunnel.command.ClientExecuteCommand.execute(ClientExecuteCommand.java:12
... 2 more
Exception in thread "main" org.apache.seatunnel.core.starter.exception.CommandExecuteException: SeaTunnel job executed f
at org.apache.seatunnel.core.starter.seatunnel.command.ClientExecuteCommand.execute(ClientExecuteCommand.java:19
at org.apache.seatunnel.core.starter.SeaTunnel.run(SeaTunnel.java:40)
at org.apache.seatunnel.core.starter.seatunnel.SeaTunnelClient.main(SeaTunnelClient.java:34)
Caused by: java.lang.NullPointerException
at sun.nio.fs.UnixPath.normalizeAndCheck(UnixPath.java:77)
at sun.nio.fs.UnixPath.(UnixPath.java:71)
at sun.nio.fs.UnixFileSystem.getPath(UnixFileSystem.java:281)
at java.nio.file.Paths.get(Paths.java:84)
at org.apache.seatunnel.core.starter.utils.FileUtils.getConfigPath(FileUtils.java:49)
at org.apache.seatunnel.core.starter.seatunnel.command.ClientExecuteCommand.execute(ClientExecuteCommand.java:12
... 2 more
SeaTunnel Version
2.3.4 & 2.3.5
SeaTunnel Config
env {
# You can set SeaTunnel environment configuration here
parallelism = 2
job.mode = "STREAMING"
checkpoint.interval = 2000
}
source {
# This is a example source plugin **only for test and demonstrate the feature source plugin**
FakeSource {
parallelism = 2
result_table_name = "fake"
row.num = 16
schema = {
fields {
name = "string"
age = "int"
}
}
}
# If you would like to get more information about how to configure SeaTunnel and see full list of source plugins,
# please go to https://seatunnel.apache.org/docs/category/source-v2
}
sink {
Console {
}
# If you would like to get more information about how to configure SeaTunnel and see full list of sink plugins,
# please go to https://seatunnel.apache.org/docs/category/sink-v2
}
Search before asking
What happened
1、submit job v2.streaming.conf.template
![image](https://private-user-images.githubusercontent.com/52306466/329759720-63168ccb-6830-4263-8860-58c8d981a8bf.png?jwt=eyJhbGciOiJIUzI1NiIsInR5cCI6IkpXVCJ9.eyJpc3MiOiJnaXRodWIuY29tIiwiYXVkIjoicmF3LmdpdGh1YnVzZXJjb250ZW50LmNvbSIsImtleSI6ImtleTUiLCJleHAiOjE3MjAzMTg4NzgsIm5iZiI6MTcyMDMxODU3OCwicGF0aCI6Ii81MjMwNjQ2Ni8zMjk3NTk3MjAtNjMxNjhjY2ItNjgzMC00MjYzLTg4NjAtNThjOGQ5ODFhOGJmLnBuZz9YLUFtei1BbGdvcml0aG09QVdTNC1ITUFDLVNIQTI1NiZYLUFtei1DcmVkZW50aWFsPUFLSUFWQ09EWUxTQTUzUFFLNFpBJTJGMjAyNDA3MDclMkZ1cy1lYXN0LTElMkZzMyUyRmF3czRfcmVxdWVzdCZYLUFtei1EYXRlPTIwMjQwNzA3VDAyMTYxOFomWC1BbXotRXhwaXJlcz0zMDAmWC1BbXotU2lnbmF0dXJlPWEzMDNkZmE3NDVkNTg0ZGJhZGY5YTZmNjVjZGY4N2NmMmE2NWY2NTM3NzZkZDkzZGVjYmQ0ZTQ0YzU0NTlhNmImWC1BbXotU2lnbmVkSGVhZGVycz1ob3N0JmFjdG9yX2lkPTAma2V5X2lkPTAmcmVwb19pZD0wIn0.8bKQ-oqBXTGE9qTOty8Bj-_COcNi0Zu6wCdxepiLerE)
2、then use seatunnel.sh -s to trigger savepoint
![image](https://private-user-images.githubusercontent.com/52306466/329759733-a9ac3ae9-9b91-46ac-bd73-ce44dc0f05c2.png?jwt=eyJhbGciOiJIUzI1NiIsInR5cCI6IkpXVCJ9.eyJpc3MiOiJnaXRodWIuY29tIiwiYXVkIjoicmF3LmdpdGh1YnVzZXJjb250ZW50LmNvbSIsImtleSI6ImtleTUiLCJleHAiOjE3MjAzMTg4NzgsIm5iZiI6MTcyMDMxODU3OCwicGF0aCI6Ii81MjMwNjQ2Ni8zMjk3NTk3MzMtYTlhYzNhZTktOWI5MS00NmFjLWJkNzMtY2U0NGRjMGYwNWMyLnBuZz9YLUFtei1BbGdvcml0aG09QVdTNC1ITUFDLVNIQTI1NiZYLUFtei1DcmVkZW50aWFsPUFLSUFWQ09EWUxTQTUzUFFLNFpBJTJGMjAyNDA3MDclMkZ1cy1lYXN0LTElMkZzMyUyRmF3czRfcmVxdWVzdCZYLUFtei1EYXRlPTIwMjQwNzA3VDAyMTYxOFomWC1BbXotRXhwaXJlcz0zMDAmWC1BbXotU2lnbmF0dXJlPTIyODE4MWVhNjE3Yzg1Y2IyZDUxMzFhNjhiOTYwMDQyNmQ1OTdhMDg4MzY5ODY4ODBlMjRiMDE5MDkzNTlmNDkmWC1BbXotU2lnbmVkSGVhZGVycz1ob3N0JmFjdG9yX2lkPTAma2V5X2lkPTAmcmVwb19pZD0wIn0.7KdEvHv7kR8jgB-lbZVWYwcNXnJvuugNMP0xDFcwHzc)
![image](https://private-user-images.githubusercontent.com/52306466/329759720-63168ccb-6830-4263-8860-58c8d981a8bf.png?jwt=eyJhbGciOiJIUzI1NiIsInR5cCI6IkpXVCJ9.eyJpc3MiOiJnaXRodWIuY29tIiwiYXVkIjoicmF3LmdpdGh1YnVzZXJjb250ZW50LmNvbSIsImtleSI6ImtleTUiLCJleHAiOjE3MjAzMTg4NzgsIm5iZiI6MTcyMDMxODU3OCwicGF0aCI6Ii81MjMwNjQ2Ni8zMjk3NTk3MjAtNjMxNjhjY2ItNjgzMC00MjYzLTg4NjAtNThjOGQ5ODFhOGJmLnBuZz9YLUFtei1BbGdvcml0aG09QVdTNC1ITUFDLVNIQTI1NiZYLUFtei1DcmVkZW50aWFsPUFLSUFWQ09EWUxTQTUzUFFLNFpBJTJGMjAyNDA3MDclMkZ1cy1lYXN0LTElMkZzMyUyRmF3czRfcmVxdWVzdCZYLUFtei1EYXRlPTIwMjQwNzA3VDAyMTYxOFomWC1BbXotRXhwaXJlcz0zMDAmWC1BbXotU2lnbmF0dXJlPWEzMDNkZmE3NDVkNTg0ZGJhZGY5YTZmNjVjZGY4N2NmMmE2NWY2NTM3NzZkZDkzZGVjYmQ0ZTQ0YzU0NTlhNmImWC1BbXotU2lnbmVkSGVhZGVycz1ob3N0JmFjdG9yX2lkPTAma2V5X2lkPTAmcmVwb19pZD0wIn0.8bKQ-oqBXTGE9qTOty8Bj-_COcNi0Zu6wCdxepiLerE)
3、restore job with sh bin/seatunnel.sh -r 841558753575698433
1、submit job v2.streaming.conf.template
2、then use seatunnel.sh -s to trigger savepoint
![image](https://private-user-images.githubusercontent.com/52306466/329759733-a9ac3ae9-9b91-46ac-bd73-ce44dc0f05c2.png?jwt=eyJhbGciOiJIUzI1NiIsInR5cCI6IkpXVCJ9.eyJpc3MiOiJnaXRodWIuY29tIiwiYXVkIjoicmF3LmdpdGh1YnVzZXJjb250ZW50LmNvbSIsImtleSI6ImtleTUiLCJleHAiOjE3MjAzMTg4NzgsIm5iZiI6MTcyMDMxODU3OCwicGF0aCI6Ii81MjMwNjQ2Ni8zMjk3NTk3MzMtYTlhYzNhZTktOWI5MS00NmFjLWJkNzMtY2U0NGRjMGYwNWMyLnBuZz9YLUFtei1BbGdvcml0aG09QVdTNC1ITUFDLVNIQTI1NiZYLUFtei1DcmVkZW50aWFsPUFLSUFWQ09EWUxTQTUzUFFLNFpBJTJGMjAyNDA3MDclMkZ1cy1lYXN0LTElMkZzMyUyRmF3czRfcmVxdWVzdCZYLUFtei1EYXRlPTIwMjQwNzA3VDAyMTYxOFomWC1BbXotRXhwaXJlcz0zMDAmWC1BbXotU2lnbmF0dXJlPTIyODE4MWVhNjE3Yzg1Y2IyZDUxMzFhNjhiOTYwMDQyNmQ1OTdhMDg4MzY5ODY4ODBlMjRiMDE5MDkzNTlmNDkmWC1BbXotU2lnbmVkSGVhZGVycz1ob3N0JmFjdG9yX2lkPTAma2V5X2lkPTAmcmVwb19pZD0wIn0.7KdEvHv7kR8jgB-lbZVWYwcNXnJvuugNMP0xDFcwHzc)
3、restore job with sh bin/seatunnel.sh -r 841558753575698433
May 11, 2024 2:16:22 PM com.hazelcast.internal.config.AbstractConfigLocator
INFO: Loading configuration '/mnt/data/sdb1/apps/seatunnel-2.3.4/config/seatunnel.yaml' from System property 'seatunnel.
May 11, 2024 2:16:22 PM com.hazelcast.internal.config.AbstractConfigLocator
INFO: Using configuration file at /mnt/data/sdb1/apps/seatunnel-2.3.4/config/seatunnel.yaml
May 11, 2024 2:16:22 PM org.apache.seatunnel.engine.common.config.SeaTunnelConfig
INFO: seatunnel.home is /mnt/data/sdb1/apps/seatunnel-2.3.4
May 11, 2024 2:16:22 PM com.hazelcast.internal.config.AbstractConfigLocator
INFO: Loading configuration '/mnt/data/sdb1/apps/seatunnel-2.3.4/config/hazelcast.yaml' from System property 'hazelcast.
May 11, 2024 2:16:22 PM com.hazelcast.internal.config.AbstractConfigLocator
INFO: Using configuration file at /mnt/data/sdb1/apps/seatunnel-2.3.4/config/hazelcast.yaml
May 11, 2024 2:16:22 PM com.hazelcast.internal.config.AbstractConfigLocator
INFO: Loading configuration '/mnt/data/sdb1/apps/seatunnel-2.3.4/config/hazelcast-client.yaml' from System property 'haz
May 11, 2024 2:16:22 PM com.hazelcast.internal.config.AbstractConfigLocator
INFO: Using configuration file at /mnt/data/sdb1/apps/seatunnel-2.3.4/config/hazelcast-client.yaml
2024-05-11 14:16:23,067 INFO [.c.i.s.ClientInvocationService] [main] - hz.client_1 [seatunnel] [5.1] Running with 2 res
2024-05-11 14:16:23,141 INFO [c.h.c.LifecycleService ] [main] - hz.client_1 [seatunnel] [5.1] HazelcastClient 5.
2024-05-11 14:16:23,142 INFO [c.h.c.LifecycleService ] [main] - hz.client_1 [seatunnel] [5.1] HazelcastClient 5.
2024-05-11 14:16:23,167 INFO [.c.i.c.ClientConnectionManager] [main] - hz.client_1 [seatunnel] [5.1] Trying to connect
2024-05-11 14:16:23,171 INFO [.c.i.c.ClientConnectionManager] [main] - hz.client_1 [seatunnel] [5.1] Trying to connect
2024-05-11 14:16:23,204 INFO [c.h.c.LifecycleService ] [main] - hz.client_1 [seatunnel] [5.1] HazelcastClient 5.
2024-05-11 14:16:23,205 INFO [.c.i.c.ClientConnectionManager] [main] - hz.client_1 [seatunnel] [5.1] Authenticated withion: 5.1, local address: /127.0.0.1:39351
2024-05-11 14:16:23,206 INFO [c.h.i.d.Diagnostics ] [main] - hz.client_1 [seatunnel] [5.1] Diagnostics disabl
2024-05-11 14:16:23,217 INFO [c.h.c.i.s.ClientClusterService] [hz.client_1.event-4] - hz.client_1 [seatunnel] [5.1]
Members [1] {
Member [hygon-input-006]:5801 - f12ff7c0-cfea-4f75-8e7b-ce2e8ad620c2
}
2024-05-11 14:16:23,244 INFO [.c.i.s.ClientStatisticsService] [main] - Client statistics is enabled with period 5 secon
2024-05-11 14:16:23,396 INFO [c.h.c.LifecycleService ] [main] - hz.client_1 [seatunnel] [5.1] HazelcastClient 5.
2024-05-11 14:16:23,403 INFO [.c.i.c.ClientConnectionManager] [main] - hz.client_1 [seatunnel] [5.1] Removed connectionction: ClientConnection{alive=false, connectionId=1, channel=NioChannel{/127.0.0.1:39351->hygon-input-006/127.0.0.1:1, lastWriteTime=2024-05-11 14:16:23.341, closedTime=2024-05-11 14:16:23.397, connected server version=5.1}
2024-05-11 14:16:23,403 INFO [c.h.c.LifecycleService ] [main] - hz.client_1 [seatunnel] [5.1] HazelcastClient 5.
2024-05-11 14:16:23,406 INFO [c.h.c.LifecycleService ] [main] - hz.client_1 [seatunnel] [5.1] HazelcastClient 5.
2024-05-11 14:16:23,406 INFO [s.c.s.s.c.ClientExecuteCommand] [main] - Closed SeaTunnel client......
2024-05-11 14:16:23,406 ERROR [o.a.s.c.s.SeaTunnel ] [main] -
===============================================================================
2024-05-11 14:16:23,406 ERROR [o.a.s.c.s.SeaTunnel ] [main] - Fatal Error,
2024-05-11 14:16:23,406 ERROR [o.a.s.c.s.SeaTunnel ] [main] - Please submit bug report in https://github.com/a
2024-05-11 14:16:23,408 ERROR [o.a.s.c.s.SeaTunnel ] [main] - Reason:SeaTunnel job executed failed
2024-05-11 14:16:23,410 ERROR [o.a.s.c.s.SeaTunnel ] [main] - Exception StackTrace:org.apache.seatunnel.core.s
at org.apache.seatunnel.core.starter.seatunnel.command.ClientExecuteCommand.execute(ClientExecuteCommand.java:19
at org.apache.seatunnel.core.starter.SeaTunnel.run(SeaTunnel.java:40)
at org.apache.seatunnel.core.starter.seatunnel.SeaTunnelClient.main(SeaTunnelClient.java:34)
Caused by: java.lang.NullPointerException
at sun.nio.fs.UnixPath.normalizeAndCheck(UnixPath.java:77)
at sun.nio.fs.UnixPath.(UnixPath.java:71)
at sun.nio.fs.UnixFileSystem.getPath(UnixFileSystem.java:281)
at java.nio.file.Paths.get(Paths.java:84)
at org.apache.seatunnel.core.starter.utils.FileUtils.getConfigPath(FileUtils.java:49)
at org.apache.seatunnel.core.starter.seatunnel.command.ClientExecuteCommand.execute(ClientExecuteCommand.java:12
... 2 more
2024-05-11 14:16:23,410 ERROR [o.a.s.c.s.SeaTunnel ] [main] -
Exception in thread "main" org.apache.seatunnel.core.starter.exception.CommandExecuteException: SeaTunnel job executed f
at org.apache.seatunnel.core.starter.seatunnel.command.ClientExecuteCommand.execute(ClientExecuteCommand.java:19
at org.apache.seatunnel.core.starter.SeaTunnel.run(SeaTunnel.java:40)
at org.apache.seatunnel.core.starter.seatunnel.SeaTunnelClient.main(SeaTunnelClient.java:34)
Caused by: java.lang.NullPointerException
at sun.nio.fs.UnixPath.normalizeAndCheck(UnixPath.java:77)
at sun.nio.fs.UnixPath.(UnixPath.java:71)
at sun.nio.fs.UnixFileSystem.getPath(UnixFileSystem.java:281)
at java.nio.file.Paths.get(Paths.java:84)
at org.apache.seatunnel.core.starter.utils.FileUtils.getConfigPath(FileUtils.java:49)
at org.apache.seatunnel.core.starter.seatunnel.command.ClientExecuteCommand.execute(ClientExecuteCommand.java:12
... 2 more
SeaTunnel Version
2.3.4 & 2.3.5
SeaTunnel Config
Running Command
1、nohup sh bin/seatunnel.sh --config config/v2.streaming.conf.template & 2、sh bin/seatunnel.sh -s 841558753575698433 3、sh bin/seatunnel.sh -r 841558753575698433
Error Exception
Zeta or Flink or Spark Version
No response
Java or Scala Version
1.8
Screenshots
No response
Are you willing to submit PR?
Code of Conduct
The text was updated successfully, but these errors were encountered: