flink-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ches...@apache.org
Subject [10/11] flink git commit: [hotfix][metrics] Allow QueryParameter converters to throw ConversionExceptions
Date Mon, 16 Apr 2018 19:18:51 GMT
[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 <chesnay@apache.org>
Authored: Mon Mar 26 14:41:25 2018 +0200
Committer: zentol <chesnay@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) {


Mime
View raw message