You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by ch...@apache.org on 2018/04/16 19:18:51 UTC
[10/11] flink git commit: [hotfix][metrics] Allow QueryParameter
converters to throw ConversionExceptions
[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/f579f745
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/f579f745
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/f579f745
Branch: refs/heads/release-1.5
Commit: f579f745dc3868c1807a814695624d98b53f6d50
Parents: a562e5d
Author: zentol <ch...@apache.org>
Authored: Mon Mar 26 14:41:25 2018 +0200
Committer: zentol <ch...@apache.org>
Committed: Mon Apr 16 21:18:33 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/f579f745/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) {