Matthias Pohl created FLINK-30109: ------------------------------------- Summary: Checked exceptions are sneakingly transformed into unchecked exceptions in the Pulsar Key: FLINK-30109 URL: https://issues.apache.org/jira/browse/FLINK-30109 Project: Flink Issue Type: Technical Debt Components: Connectors / Pulsar, Documentation Affects Versions: 1.15.2, 1.16.0, 1.17.0 Reporter: Matthias Pohl
[PulsarExceptionUtils|https://github.com/apache/flink/blob/c675f786c51038801161e861826d1c54654f0dde/flink-connectors/flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/common/utils/PulsarExceptionUtils.java#L33] provides {{sneaky*}} utility methods for hiding checked exceptions. This is rather unusual coding. Based on what's provided in the code I would have concerns as a reader that we're not handling errors properly in calling code. Either, we remove these methods and add proper exception handling or we add proper documentation on why this workaround is necessary. [~syhily] already hinted in his [FLINK-29830 PR comment|https://github.com/apache/flink/pull/21252#discussion_r1019822514] that this is related to flaws of the Pulsar API. -- This message was sent by Atlassian Jira (v8.20.10#820010)