You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by ec...@apache.org on 2019/09/05 14:48:17 UTC
[beam] 24/24: Improve exceptions catching
This is an automated email from the ASF dual-hosted git repository.
echauchot pushed a commit to branch spark-runner_structured-streaming
in repository https://gitbox.apache.org/repos/asf/beam.git
commit cfdf4a4ee43091a281d6dcff021f290d698ed2a7
Author: Etienne Chauchot <ec...@apache.org>
AuthorDate: Thu Sep 5 15:53:10 2019 +0200
Improve exceptions catching
---
.../translation/helpers/EncoderHelpers.java | 12 ++++++------
1 file changed, 6 insertions(+), 6 deletions(-)
diff --git a/runners/spark/src/main/java/org/apache/beam/runners/spark/structuredstreaming/translation/helpers/EncoderHelpers.java b/runners/spark/src/main/java/org/apache/beam/runners/spark/structuredstreaming/translation/helpers/EncoderHelpers.java
index f990121..f4ea6fa 100644
--- a/runners/spark/src/main/java/org/apache/beam/runners/spark/structuredstreaming/translation/helpers/EncoderHelpers.java
+++ b/runners/spark/src/main/java/org/apache/beam/runners/spark/structuredstreaming/translation/helpers/EncoderHelpers.java
@@ -147,8 +147,8 @@ public class EncoderHelpers {
$beamCoder.encode(${input.value}, baos);
${ev.value} = baos.toByteArray();
}
- } catch (Exception e) {
- throw new RuntimeException(org.apache.beam.sdk.util.UserCodeException.wrap(e));
+ } catch (java.io.IOException e) {
+ throw org.apache.beam.sdk.util.UserCodeException.wrap(e);
}
*/
List<String> parts = new ArrayList<>();
@@ -160,7 +160,7 @@ public class EncoderHelpers {
parts.add(".encode(");
parts.add(", baos); ");
parts.add(
- " = baos.toByteArray();}} catch (Exception e) {throw new RuntimeException(org.apache.beam.sdk.util.UserCodeException.wrap(e));}");
+ " = baos.toByteArray();}} catch (java.io.IOException e) {throw org.apache.beam.sdk.util.UserCodeException.wrap(e);}");
StringContext sc =
new StringContext(JavaConversions.collectionAsScalaIterable(parts).toSeq());
@@ -262,8 +262,8 @@ public class EncoderHelpers {
${input.isNull} ?
${CodeGenerator.defaultValue(dataType)} :
($javaType) $beamCoder.decode(new java.io.ByteArrayInputStream(${input.value}));
- } catch (Exception e) {
- throw new RuntimeException(org.apache.beam.sdk.util.UserCodeException.wrap(e));
+ } catch (java.io.IOException e) {
+ throw org.apache.beam.sdk.util.UserCodeException.wrap(e);
}
*/
@@ -277,7 +277,7 @@ public class EncoderHelpers {
parts.add(") ");
parts.add(".decode(new java.io.ByteArrayInputStream(");
parts.add(
- ")); } catch (Exception e) {throw new RuntimeException(org.apache.beam.sdk.util.UserCodeException.wrap(e));}");
+ ")); } catch (java.io.IOException e) {throw org.apache.beam.sdk.util.UserCodeException.wrap(e);}");
StringContext sc =
new StringContext(JavaConversions.collectionAsScalaIterable(parts).toSeq());