1996fanrui commented on issue #1561:
URL:
https://github.com/apache/incubator-streampark/issues/1561#issuecomment-1246253132
Hi @wangzhen-wudangshan .
From the stack and code(tag=v1.2.3), I think your exception may be caused by
`assert cluster != null;`.
Did you delete your cluster? And did you start an app to a deleted cluster?
BTW, @wolfboys should we optimize the exception? There are too many assert
in the code, and some of these can happen. The `java.lang.AssertionError` is
too unspecific.
We should improve the exception, like this:
```
Preconditions.checkState(cluster != null,
"The clusterId=%s cannot be find, maybe the clusterId is wrong or " +
"the cluster has been deleted. Please contact the Admin.",
application.getFlinkClusterId());
```
It should be useful for users. Do you think so? If yes, other asserts can be
improved too.
<img width="1141" alt="image"
src="https://user-images.githubusercontent.com/38427477/190064930-c40c9ae5-4aa6-4a44-95a0-2ae2ea4bc1c1.png";>
--
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]
![https://user-images.githubusercontent.com/38427477/190064930-c40c9ae5-4aa6-4a44-95a0-2ae2ea4bc1c1.png"](https://user-images.githubusercontent.com/38427477/190064930-c40c9ae5-4aa6-4a44-95a0-2ae2ea4bc1c1.png"){kind=link}