Repository: flink Updated Branches: refs/heads/master 185b904aa -> 27be32e8a
[hotfix][metrics] Allow QueryParameter converters to throw ConversionExceptions Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/4645d3c0 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/4645d3c0 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/4645d3c0 Branch: refs/heads/master Commit: 4645d3c06736c7adf360a5380cd2a05b4eb752c9 Parents: 1cd7c42 Author: zentol <ches...@apache.org> Authored: Mon Mar 26 14:41:25 2018 +0200 Committer: zentol <ches...@apache.org> Committed: Mon Apr 16 21:17:53 2018 +0200 ---------------------------------------------------------------------- .../flink/runtime/rest/messages/MessageQueryParameter.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flink/blob/4645d3c0/flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/MessageQueryParameter.java ---------------------------------------------------------------------- diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/MessageQueryParameter.java b/flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/MessageQueryParameter.java index 180f011..6799df1 100644 --- a/flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/MessageQueryParameter.java +++ b/flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/MessageQueryParameter.java @@ -35,7 +35,7 @@ public abstract class MessageQueryParameter<X> extends MessageParameter<List<X>> } @Override - public List<X> convertFromString(String values) { + public List<X> convertFromString(String values) throws ConversionException { String[] splitValues = values.split(","); List<X> list = new ArrayList<>(); for (String value : splitValues) { @@ -50,7 +50,7 @@ public abstract class MessageQueryParameter<X> extends MessageParameter<List<X>> * @param value string representation of parameter value * @return parameter value */ - public abstract X convertStringToValue(String value); + public abstract X convertStringToValue(String value) throws ConversionException; @Override public String convertToString(List<X> values) {
