Repository: asterixdb
Updated Branches:
  refs/heads/master 252d0ccec -> 51e381277


[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 <jenk...@fulliautomatix.ics.uci.edu>
Tested-by: Jenkins <jenk...@fulliautomatix.ics.uci.edu>
Integration-Tests: Jenkins <jenk...@fulliautomatix.ics.uci.edu>
Contrib: Jenkins <jenk...@fulliautomatix.ics.uci.edu>
Reviewed-by: Murtadha Hubail <mhub...@apache.org>
Reviewed-by: Ali Alsuliman <ali.al.solai...@gmail.com>


Project: http://git-wip-us.apache.org/repos/asf/asterixdb/repo
Commit: http://git-wip-us.apache.org/repos/asf/asterixdb/commit/51e38127
Tree: http://git-wip-us.apache.org/repos/asf/asterixdb/tree/51e38127
Diff: http://git-wip-us.apache.org/repos/asf/asterixdb/diff/51e38127

Branch: refs/heads/master
Commit: 51e381277ea899dbfa9fc9cfe96d6bd1538ca59e
Parents: 252d0cc
Author: Murtadha Hubail <mhub...@apache.org>
Authored: Tue Dec 4 00:46:56 2018 +0300
Committer: Murtadha Hubail <mhub...@apache.org>
Committed: Tue Dec 4 01:03:57 2018 -0800

----------------------------------------------------------------------
 .../src/main/java/org/apache/asterix/api/common/APIFramework.java  | 2 +-
 .../queries_sqlpp/replication/bulkload/bulkload.12.query.sqlpp     | 2 +-
 2 files changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/asterixdb/blob/51e38127/asterixdb/asterix-app/src/main/java/org/apache/asterix/api/common/APIFramework.java
----------------------------------------------------------------------
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 @@ public class APIFramework {
 
     // 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);
     }
 

http://git-wip-us.apache.org/repos/asf/asterixdb/blob/51e38127/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/replication/bulkload/bulkload.12.query.sqlpp
----------------------------------------------------------------------
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

Reply via email to