| commit | 51e381277ea899dbfa9fc9cfe96d6bd1538ca59e | [log] [tgz] |
|---|---|---|
| author | Murtadha Hubail <mhubail@apache.org> | Tue Dec 04 00:46:56 2018 +0300 |
| committer | Murtadha Hubail <mhubail@apache.org> | Tue Dec 04 01:03:57 2018 -0800 |
| tree | a6caf242e53c2cea0784c94a96c6a2ddfc63fd16 | |
| parent | 252d0ccec3122dbbc396e4290c7a522094631b83 [diff] |
[ASTERIXDB-2489][COMP] Allow Negative Compiler Parallelism - user model changes: no - storage format changes: no - interface changes: no Details: - Accept negative compiler parallelism as a hint to use non-storage degree of parallelism. - Add test case. Change-Id: I9edc969f6c434f81b51e7efddda8fceada9ccc52 Reviewed-on: https://asterix-gerrit.ics.uci.edu/3048 Sonar-Qube: Jenkins <jenkins@fulliautomatix.ics.uci.edu> Tested-by: Jenkins <jenkins@fulliautomatix.ics.uci.edu> Integration-Tests: Jenkins <jenkins@fulliautomatix.ics.uci.edu> Contrib: Jenkins <jenkins@fulliautomatix.ics.uci.edu> Reviewed-by: Murtadha Hubail <mhubail@apache.org> Reviewed-by: Ali Alsuliman <ali.al.solaiman@gmail.com>
diff --git a/asterixdb/asterix-app/src/main/java/org/apache/asterix/api/common/APIFramework.java b/asterixdb/asterix-app/src/main/java/org/apache/asterix/api/common/APIFramework.java index 8344d41..0bdc987 100644 --- a/asterixdb/asterix-app/src/main/java/org/apache/asterix/api/common/APIFramework.java +++ b/asterixdb/asterix-app/src/main/java/org/apache/asterix/api/common/APIFramework.java
@@ -443,7 +443,7 @@ // Gets the parallelism parameter. private static int getParallelism(String parameter, int parallelismInConfiguration) { - IOptionType<Integer> integerIPropertyInterpreter = OptionTypes.UNSIGNED_INTEGER; + IOptionType<Integer> integerIPropertyInterpreter = OptionTypes.INTEGER; return parameter == null ? parallelismInConfiguration : integerIPropertyInterpreter.parse(parameter); }
diff --git a/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/replication/bulkload/bulkload.12.query.sqlpp b/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/replication/bulkload/bulkload.12.query.sqlpp index cd777cf..92284f0 100644 --- a/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/replication/bulkload/bulkload.12.query.sqlpp +++ b/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/replication/bulkload/bulkload.12.query.sqlpp
@@ -18,5 +18,5 @@ */ use tpch; - +SET `compiler.parallelism` "-1"; select value count(*) from LineItem; \ No newline at end of file