You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by tr...@apache.org on 2018/09/21 07:38:51 UTC
[flink] 02/05: [hotfix] Fix checkstyle violations in
ExceptionInChainedStubException
This is an automated email from the ASF dual-hosted git repository.
trohrmann pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
commit da3c6c4e1b079b974c5046e0e6d864ea167a3a8d
Author: Till Rohrmann <tr...@apache.org>
AuthorDate: Thu Sep 20 15:23:33 2018 +0200
[hotfix] Fix checkstyle violations in ExceptionInChainedStubException
---
.../operators/chaining/ExceptionInChainedStubException.java | 9 +++------
1 file changed, 3 insertions(+), 6 deletions(-)
diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/operators/chaining/ExceptionInChainedStubException.java b/flink-runtime/src/main/java/org/apache/flink/runtime/operators/chaining/ExceptionInChainedStubException.java
index e7cebc5..bd55fff 100644
--- a/flink-runtime/src/main/java/org/apache/flink/runtime/operators/chaining/ExceptionInChainedStubException.java
+++ b/flink-runtime/src/main/java/org/apache/flink/runtime/operators/chaining/ExceptionInChainedStubException.java
@@ -16,7 +16,6 @@
* limitations under the License.
*/
-
package org.apache.flink.runtime.operators.chaining;
/**
@@ -24,13 +23,12 @@ package org.apache.flink.runtime.operators.chaining;
* The exception's only purpose is to be identifiable as such and to carry the cause exception.
*/
public class ExceptionInChainedStubException extends RuntimeException {
-
+
private static final long serialVersionUID = -7966910518892776903L;
private String taskName;
-
+
private Exception exception;
-
public ExceptionInChainedStubException(String taskName, Exception wrappedException) {
super("Exception in chained task '" + taskName + "'", exceptionUnwrap(wrappedException));
@@ -38,11 +36,10 @@ public class ExceptionInChainedStubException extends RuntimeException {
this.exception = wrappedException;
}
-
public String getTaskName() {
return taskName;
}
-
+
public Exception getWrappedException() {
return exception;
}