(systemds) branch main updated: [MINOR] Fix parfor result merge tests (disable auto vectorization)

[mboehm7]

This is an automated email from the ASF dual-hosted git repository.

mboehm7 pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/systemds.git


The following commit(s) were added to refs/heads/main by this push:
     new 1590d17748 [MINOR] Fix parfor result merge tests (disable auto 
vectorization)
1590d17748 is described below

commit 1590d17748214078483484f9eef9b0ea05f73ef4
Author: Matthias Boehm <mboe...@gmail.com>
AuthorDate: Fri Nov 29 16:30:27 2024 +0100

    [MINOR] Fix parfor result merge tests (disable auto vectorization)
    
    We have to disable auto vectorization here in order to test the parfor
    specifics (in this case, spark jobs for result merge)
---
 src/test/scripts/functions/parfor/parfor_pr_resultmerge1c.dml |  7 ++++---
 src/test/scripts/functions/parfor/parfor_pr_resultmerge1d.dml | 11 ++++++-----
 2 files changed, 10 insertions(+), 8 deletions(-)

diff --git a/src/test/scripts/functions/parfor/parfor_pr_resultmerge1c.dml 
b/src/test/scripts/functions/parfor/parfor_pr_resultmerge1c.dml
index fa01bfe766..5522bb1c17 100644
--- a/src/test/scripts/functions/parfor/parfor_pr_resultmerge1c.dml
+++ b/src/test/scripts/functions/parfor/parfor_pr_resultmerge1c.dml
@@ -28,8 +28,9 @@ R1 = matrix(0,rows=m,cols=n);
 parfor( i in 1:(n-7), par=8, mode=REMOTE_SPARK, resultmerge=REMOTE_SPARK, 
taskpartitioner=FACTORING, opt=NONE )
 {
    X = V[,i];
+   while(FALSE){} # prevent auto vectorization
    R1[,i] = X;
-}   
+}
 
-R = R1 + R1; 
-write(R, $4);       
\ No newline at end of file
+R = R1 + R1;
+write(R, $4);
diff --git a/src/test/scripts/functions/parfor/parfor_pr_resultmerge1d.dml 
b/src/test/scripts/functions/parfor/parfor_pr_resultmerge1d.dml
index 02e16570f4..da786d91f6 100644
--- a/src/test/scripts/functions/parfor/parfor_pr_resultmerge1d.dml
+++ b/src/test/scripts/functions/parfor/parfor_pr_resultmerge1d.dml
@@ -7,9 +7,9 @@
 # to you under the Apache License, Version 2.0 (the
 # "License"); you may not use this file except in compliance
 # with the License.  You may obtain a copy of the License at
-# 
+#
 #   http://www.apache.org/licenses/LICENSE-2.0
-# 
+#
 # Unless required by applicable law or agreed to in writing,
 # software distributed under the License is distributed on an
 # "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
@@ -28,8 +28,9 @@ R1 = matrix(1,rows=m,cols=n);
 parfor( i in 1:(n-7), par=8, mode=REMOTE_SPARK, resultmerge=REMOTE_SPARK, 
taskpartitioner=FACTORING, opt=NONE )
 {
    X = V[,i];
+   while(FALSE){} # prevent auto vectorization
    R1[,i] = X;
-}   
+}
 
-R = R1 + R1; 
-write(R, $4);       
\ No newline at end of file
+R = R1 + R1;
+write(R, $4);