Johnlon opened a new pull request #9456: FLINK-13588 flink-streaming-java don't throw away exception info in logging URL: https://github.com/apache/flink/pull/9456 Previously the async error handler threw away the descriptive text provided by the call site. This makes diagnosis of errors really difficult. ## Brief change log This change wraps the error message and cause exception into a wrapper exception that properly conveys the descriptive text to the logs. ## Verifying this change Test added to StreamTaskTest to verify that objects are passed correctly to the Environment object and also to verify that the toString rendering includes the given text. ## Does this pull request potentially affect one of the following parts: - Dependencies (does it add or upgrade a dependency): (no) - The public API, i.e., is any changed class annotated with `@Public(Evolving)`: (no) - The serializers: (no ) - The runtime per-record code paths (performance sensitive): (no ) - Anything that affects deployment or recovery: JobManager (and its components), Checkpointing, Yarn/Mesos, ZooKeeper: (no) - The S3 file system connector: (no) ## Documentation - Does this pull request introduce a new feature? (no)
---------------------------------------------------------------- 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. For queries about this service, please contact Infrastructure at: us...@infra.apache.org With regards, Apache Git Services
