Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

add warmup #15

Closed
wants to merge 49 commits into from
Closed
Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
49 commits
Select commit Hold shift + click to select a range
849acf4
setup allocator for RequestContext
aqni Sep 14, 2024
cf95b00
store
aqni Sep 14, 2024
82cab1b
add some TODO
aqni Sep 18, 2024
e984b88
feat(arrow): add framework of operator executor and impl row-to-colum…
aqni Sep 19, 2024
5d04f2b
feat(core): impl Projector (#452)
jzl18thu Sep 20, 2024
728ff46
feat(core): release resources correctly && adjust some sessions (#455)
jzl18thu Oct 5, 2024
2c5bd8d
start to finish stage 2 (#464)
aqni Oct 14, 2024
e50d7dc
remove type declaration in RowTransform
aqni Oct 15, 2024
12bca48
feat(arrow): row mapping implementation in arrow version (#466)
shinyano Oct 16, 2024
816f7fb
feat(arrow):revert multiply expr (#467)
shinyano Oct 17, 2024
2d33e22
feat(core): impl filter (#468)
aqni Oct 17, 2024
fa2c9cc
feat: refactor accumulator (#469)
aqni Oct 17, 2024
6ee3c0d
refactor: cast (#471)
aqni Oct 18, 2024
cd2e14c
refactor time accumulator (#472)
aqni Oct 18, 2024
f666df3
fix insert (#474)
aqni Oct 18, 2024
72a882d
fix insert again (#475)
aqni Oct 18, 2024
987f91c
feat(arrow): implement constant & bracket expr; bool filter (#479)
shinyano Oct 23, 2024
e203ce2
feat(arrow): impl group-by without distinct (#480)
aqni Oct 23, 2024
537da40
feat(arrow): impl sort inner batch (#482)
aqni Oct 24, 2024
2cb7bb5
feat(arrow): logical & casewhen (#483)
shinyano Oct 31, 2024
f218db1
feat(arrow): impl tpch-h q3 (#486)
aqni Oct 31, 2024
4bcb4d8
fix (#487)
aqni Oct 31, 2024
7eb903b
feat(arrow): impl TPC-H q4 (#489)
aqni Nov 1, 2024
67ba828
feat(arrow): stage4 (#490)
aqni Nov 5, 2024
a9ae96d
feat(arrow): short circuit logic, ConstantPool and constant function …
aqni Nov 6, 2024
f4171b0
feat(arrow): short circuit logic, constant pool, constant function an…
aqni Nov 14, 2024
32fae0c
fix(arrow): max, min, first, last
aqni Nov 14, 2024
0695627
fix(arrow): add prefixed key column in join result
aqni Nov 14, 2024
1b19a0d
feat(arrow): impl remain operator by converting batch to rows (#499)
aqni Nov 18, 2024
3fca3c5
refactor: add hasNext method for BatchStream (#500)
aqni Nov 20, 2024
50aa52f
feat(arrow): fetch async (#501)
aqni Nov 21, 2024
7ea3312
feat(arrow): parallel pipeline task for RowTransform (#504)
aqni Nov 26, 2024
1c20218
feat(arrow): impl value2meta (#506)
aqni Nov 27, 2024
c326dbb
fix(arrow): fix most of SQLSessionIT (#508)
aqni Nov 29, 2024
c21b1c5
fix(arrow): most of SQLSessionIT (#509)
aqni Dec 2, 2024
6d11412
Feat/core/replace rowstream with arrow feat/core/replace rowstream wi…
aqni Dec 2, 2024
b82a042
fix missing bracket (#511)
aqni Dec 3, 2024
3b582cb
fix SQLSessionIT for some of new PR (#512)
aqni Dec 3, 2024
5b13ddc
fix: sqlsessionit and udf (#513)
aqni Dec 4, 2024
8371051
fix unit-test (#515)
aqni Dec 5, 2024
6fbcceb
fix: tpc-h (#519)
aqni Dec 6, 2024
208cc51
fix: logic short-circuit in OrNode
aqni Dec 6, 2024
1cb22e3
fix(arrow): copy logic operator in physical engine (#532)
aqni Dec 12, 2024
02c81ce
fix(arrow): filter push down & add RemoveNullColumnExecutor info (#533)
aqni Dec 13, 2024
979f9c4
test tpch only
aqni Dec 12, 2024
24d831d
add warmup
aqni Dec 12, 2024
b3ccd83
add warmup
aqni Dec 12, 2024
7b14583
add warmup
aqni Dec 13, 2024
728b938
fix influxdb
aqni Dec 13, 2024
File filter

Filter by extension

Filter by extension


Conversations
Failed to load comments.
Loading
Jump to
The table of contents is too big for display.
Diff view
Diff view
  •  
  •  
  •  
59 changes: 46 additions & 13 deletions .github/actions/confWriter/action.yml
Original file line number Diff line number Diff line change
Expand Up @@ -17,6 +17,10 @@ inputs:
description: "make the storage engine read-only"
required: false
default: "false"
Has-Data:
description: "does the storage engine has data"
required: false
default: "false"
Push-Down:
description: "make the IGinX push down filter"
required: false
Expand All @@ -29,18 +33,22 @@ inputs:
description: "the path of IGinX root directory"
required: false
default: "${GITHUB_WORKSPACE}"
zookeeper-port:
description: "zookeeper service port"
required: false
default: "2181"

runs:
using: "composite" # Mandatory parameter
steps:
- if: inputs.DB-name=='FileStore'
name: save config for FileStore
- if: inputs.DB-name=='FileSystem'
name: save config for FileSystem
shell: bash
run: |
cp -f "${{ inputs.Root-Dir-Path }}/conf/config.properties" "${{ inputs.Root-Dir-Path }}/core/target/iginx-core-${VERSION}/conf/config.properties"

- if: inputs.DB-name=='FileStore'
name: save config for FileStore
- if: inputs.DB-name=='FileSystem'
name: save config for FileSystem
shell: bash
run: |
cp -f "${{ inputs.Root-Dir-Path }}/conf/config.properties" "${{ inputs.Root-Dir-Path }}/core/target/iginx-core-${VERSION}/conf/config.properties"
Expand Down Expand Up @@ -74,6 +82,21 @@ runs:
run: |
echo "${{ inputs.DB-name }}" > ${{ inputs.Root-Dir-Path }}/test/src/test/resources/DBName.txt

- if: inputs.zookeeper-port!='2181'
name: Change Zookeeper Port
shell: bash
run: |
if [ "$RUNNER_OS" == "Linux" ]; then
sudo sed -i 's/zookeeperConnectionString=127.0.0.1:2181/zookeeperConnectionString=127.0.0.1:${{ inputs.zookeeper-port }}/g' ${{ inputs.Root-Dir-Path }}/core/target/iginx-core-${VERSION}/conf/config.properties
elif [ "$RUNNER_OS" == "Windows" ]; then
sed -i 's/zookeeperConnectionString=127.0.0.1:2181/zookeeperConnectionString=127.0.0.1:${{ inputs.zookeeper-port }}/g' ${{ inputs.Root-Dir-Path }}/core/target/iginx-core-${VERSION}/conf/config.properties
elif [ "$RUNNER_OS" == "macOS" ]; then
sudo sed -i '' 's/zookeeperConnectionString=127.0.0.1:2181/zookeeperConnectionString=127.0.0.1:${{ inputs.zookeeper-port }}/g' ${{ inputs.Root-Dir-Path }}/core/target/iginx-core-${VERSION}/conf/config.properties
else
echo "$RUNNER_OS is not supported"
exit 1
fi

- name: Change UDF conf
shell: bash
run: |
Expand Down Expand Up @@ -103,25 +126,35 @@ runs:
echo "$RUNNER_OS is not supported"
exit 1
fi

- if: inputs.Has-Data=='true'
name: Set Has-Data
shell: bash
run: |
if [ "$RUNNER_OS" == "Linux" ]; then
sudo sed -i 's/has_data=false/has_data=true/g' ${{ inputs.Root-Dir-Path }}/core/target/iginx-core-${VERSION}/conf/config.properties
elif [ "$RUNNER_OS" == "Windows" ]; then
sed -i 's/has_data=false/has_data=true/g' ${{ inputs.Root-Dir-Path }}/core/target/iginx-core-${VERSION}/conf/config.properties
elif [ "$RUNNER_OS" == "macOS" ]; then
sudo sed -i '' 's/has_data=false/has_data=true/' ${{ inputs.Root-Dir-Path }}/core/target/iginx-core-${VERSION}/conf/config.properties
else
echo "$RUNNER_OS is not supported"
exit 1
fi

- if: inputs.Push-Down=='true'
name: Change push_down
shell: bash
run: |
if [ "$RUNNER_OS" == "Linux" ]; then
sudo sed -i 's/enablePushDown=false/enablePushDown=true/g' ${{ inputs.Root-Dir-Path }}/core/target/iginx-core-${VERSION}/conf/config.properties
sed -i 's/FilterPushDownAddSchemaPrefixRule=off,FilterPushDownAddSchemaPrefixRule=off/FilterPushDownAddSchemaPrefixRule=on,FilterPushDownAddSchemaPrefixRule=on/g' ${{ inputs.Root-Dir-Path }}/core/target/iginx-core-${VERSION}/conf/config.properties
sed -i 's/FilterPushDownPathUnionJoinRule=off,FilterPushDownProjectReorderSortRule=off,FilterPushDownRenameRule=off,FilterPushDownSelectRule=off/FilterPushDownPathUnionJoinRule=on,FilterPushDownProjectReorderSortRule=on,FilterPushDownRenameRule=on,FilterPushDownSelectRule=on/g' ${{ inputs.Root-Dir-Path }}/core/target/iginx-core-${VERSION}/conf/config.properties
sed -i 's/FilterPushDownSetOpRule=off,FilterPushDownTransformRule=off,FilterPushIntoJoinConditionRule=off,FilterPushOutJoinConditionRule=off,FilterPushDownGroupByRule=off/FilterPushDownSetOpRule=on,FilterPushDownTransformRule=on,FilterPushIntoJoinConditionRule=on,FilterPushOutJoinConditionRule=on,FilterPushDownGroupByRule=on/g' ${{ inputs.Root-Dir-Path }}/core/target/iginx-core-${VERSION}/conf/config.properties
sed -i 's/FilterPushDownRule=off/FilterPushDownRule=on/g' ${{ inputs.Root-Dir-Path }}/core/target/iginx-core-${VERSION}/conf/config.properties
elif [ "$RUNNER_OS" == "Windows" ]; then
sed -i 's/enablePushDown=false/enablePushDown=true/g' ${{ inputs.Root-Dir-Path }}/core/target/iginx-core-${VERSION}/conf/config.properties
sed -i 's/FilterPushDownAddSchemaPrefixRule=off,FilterPushDownAddSchemaPrefixRule=off/FilterPushDownAddSchemaPrefixRule=on,FilterPushDownAddSchemaPrefixRule=on/g' ${{ inputs.Root-Dir-Path }}/core/target/iginx-core-${VERSION}/conf/config.properties
sed -i 's/FilterPushDownPathUnionJoinRule=off,FilterPushDownProjectReorderSortRule=off,FilterPushDownRenameRule=off,FilterPushDownSelectRule=off/FilterPushDownPathUnionJoinRule=on,FilterPushDownProjectReorderSortRule=on,FilterPushDownRenameRule=on,FilterPushDownSelectRule=on/g' ${{ inputs.Root-Dir-Path }}/core/target/iginx-core-${VERSION}/conf/config.properties
sed -i 's/FilterPushDownSetOpRule=off,FilterPushDownTransformRule=off,FilterPushIntoJoinConditionRule=off,FilterPushOutJoinConditionRule=off,FilterPushDownGroupByRule=off/FilterPushDownSetOpRule=on,FilterPushDownTransformRule=on,FilterPushIntoJoinConditionRule=on,FilterPushOutJoinConditionRule=on,FilterPushDownGroupByRule=on/g' ${{ inputs.Root-Dir-Path }}/core/target/iginx-core-${VERSION}/conf/config.properties
sed -i 's/FilterPushDownRule=off/FilterPushDownRule=on/g' ${{ inputs.Root-Dir-Path }}/core/target/iginx-core-${VERSION}/conf/config.properties
elif [ "$RUNNER_OS" == "macOS" ]; then
sudo sed -i '' 's/enablePushDown=false/enablePushDown=true/g' ${{ inputs.Root-Dir-Path }}/core/target/iginx-core-${VERSION}/conf/config.properties
sed -i '' 's/FilterPushDownAddSchemaPrefixRule=off,FilterPushDownAddSchemaPrefixRule=off/FilterPushDownAddSchemaPrefixRule=on,FilterPushDownAddSchemaPrefixRule=on/g' ${{ inputs.Root-Dir-Path }}/core/target/iginx-core-${VERSION}/conf/config.properties
sed -i '' 's/FilterPushDownPathUnionJoinRule=off,FilterPushDownProjectReorderSortRule=off,FilterPushDownRenameRule=off,FilterPushDownSelectRule=off/FilterPushDownPathUnionJoinRule=on,FilterPushDownProjectReorderSortRule=on,FilterPushDownRenameRule=on,FilterPushDownSelectRule=on/g' ${{ inputs.Root-Dir-Path }}/core/target/iginx-core-${VERSION}/conf/config.properties
sed -i '' 's/FilterPushDownSetOpRule=off,FilterPushDownTransformRule=off,FilterPushIntoJoinConditionRule=off,FilterPushOutJoinConditionRule=off,FilterPushDownGroupByRule=off/FilterPushDownSetOpRule=on,FilterPushDownTransformRule=on,FilterPushIntoJoinConditionRule=on,FilterPushOutJoinConditionRule=on,FilterPushDownGroupByRule=on/g' ${{ inputs.Root-Dir-Path }}/core/target/iginx-core-${VERSION}/conf/config.properties
sed -i '' 's/FilterPushDownRule=off/FilterPushDownRule=on/g' ${{ inputs.Root-Dir-Path }}/core/target/iginx-core-${VERSION}/conf/config.properties
else
echo "$RUNNER_OS is not supported"
exit 1
Expand Down
28 changes: 26 additions & 2 deletions .github/actions/dbConfWriter/action.yml
Original file line number Diff line number Diff line change
Expand Up @@ -5,6 +5,10 @@ inputs:
description: "DB name"
required: false
default: IoTDB12
DB-port:
description: "DB port"
required: false
default: "0"
Root-Dir-Path:
description: "the path of IGinX root directory"
required: false
Expand Down Expand Up @@ -47,13 +51,13 @@ runs:
paths: ${{ inputs.Root-Dir-Path }}/conf/config.properties
statements: s/#storageEngineList=127.0.0.1#8086/storageEngineList=127.0.0.1#8086/g

- if: inputs.DB-name == 'FileStore'
- if: inputs.DB-name == 'FileSystem'
name: Modify IGinX Config
uses: ./.github/actions/edit
with:
paths: ${{ inputs.Root-Dir-Path }}/conf/config.properties
statements: |
s/^#storageEngineList=127.0.0.1#6667#filestore/storageEngineList=127.0.0.1#6667#filestore/g
s/^#storageEngineList=127.0.0.1#6667#filesystem/storageEngineList=127.0.0.1#6667#filesystem/g
s#dir=data#dir=${PWD}/test/iginx_mn#g
s/data.config.write.buffer.size=104857600/data.config.write.buffer.size=1048576/g
s/write.buffer.size=104857600/write.buffer.size=1048576/g
Expand Down Expand Up @@ -97,3 +101,23 @@ runs:
with:
paths: ${{ inputs.Root-Dir-Path }}/conf/config.properties
statements: s|^#storageEngineList=127.0.0.1#3306#relational#engine=mysql#username=root#password=mysql#has_data=false#meta_properties_path=your-meta-properties-path|storageEngineList=127.0.0.1#3306#relational#engine=mysql#username=root#has_data=false#meta_properties_path=${{ steps.mysql-properties.outputs.path }}|g

# use regex
- if: inputs.DB-port!='0'
name: Change db port
shell: bash
run: |
if [ "$RUNNER_OS" == "Linux" ]; then
sudo sed -i -E "s/^(storageEngineList=127\.0\.0\.1#)[0-9]+(#.*)/\1${{ inputs.DB-port }}\2/" ${{ inputs.Root-Dir-Path }}/conf/config.properties
sudo sed -i -E "s/(mongodb:\/\/127\.0\.0\.1:)[0-9]+(\/)/\1${{ inputs.DB-port }}\2/" ${{ inputs.Root-Dir-Path }}/conf/config.properties
elif [ "$RUNNER_OS" == "Windows" ]; then
sed -i -E "s/^(storageEngineList=127\.0\.0\.1#)[0-9]+(#.*)/\1${{ inputs.DB-port }}\2/" ${{ inputs.Root-Dir-Path }}/conf/config.properties
sed -i -E "s/(mongodb:\/\/127\.0\.0\.1:)[0-9]+(\/)/\1${{ inputs.DB-port }}\2/" ${{ inputs.Root-Dir-Path }}/conf/config.properties
elif [ "$RUNNER_OS" == "macOS" ]; then
sudo sed -i '' -E "s/^(storageEngineList=127\.0\.0\.1#)[0-9]+(#.*)/\1${{ inputs.DB-port }}\2/" ${{ inputs.Root-Dir-Path }}/conf/config.properties
sudo sed -i '' -E "s/(mongodb:\/\/127\.0\.0\.1:)[0-9]+(\/)/\1${{ inputs.DB-port }}\2/" ${{ inputs.Root-Dir-Path }}/conf/config.properties
else
echo "$RUNNER_OS is not supported"
exit 1
fi
cat ${{ inputs.Root-Dir-Path }}/conf/config.properties
6 changes: 3 additions & 3 deletions .github/actions/dbRunner/action.yml
Original file line number Diff line number Diff line change
Expand Up @@ -169,19 +169,19 @@ runs:
paths: conf/config.properties
statements: s|^#storageEngineList=127.0.0.1#3306#relational#engine=mysql#username=root#password=mysql#has_data=false#meta_properties_path=your-meta-properties-path|storageEngineList=127.0.0.1#3306#relational#engine=mysql#username=root#has_data=false#meta_properties_path=${{ steps.mysql-properties.outputs.path }}|g

- if: inputs.DB-name=='FileStore'
- if: inputs.DB-name=='FileSystem'
name: Run DB
shell: bash
run: |
cp -f "${GITHUB_WORKSPACE}/conf/config.properties" "${GITHUB_WORKSPACE}/conf/config.properties.bak"

- if: inputs.DB-name == 'FileStore'
- if: inputs.DB-name == 'FileSystem'
name: Modify IGinX Config
uses: ./.github/actions/edit
with:
paths: conf/config.properties
statements: |
s/^#storageEngineList=127.0.0.1#6667#filestore/storageEngineList=127.0.0.1#6667#filestore/g
s/^#storageEngineList=127.0.0.1#6667#filesystem/storageEngineList=127.0.0.1#6667#filesystem/g
s#dir=data#dir=${{ steps.project.outputs.workspace }}/test/iginx_mn#g
s#dummy_dir=dummy#dummy_dir=${{ steps.project.outputs.workspace }}/test/mn#g
s/data.config.write.buffer.size=104857600/data.config.write.buffer.size=1048576/g
Expand Down
2 changes: 1 addition & 1 deletion .github/actions/dependence/action.yml
Original file line number Diff line number Diff line change
Expand Up @@ -40,7 +40,7 @@ runs:
shell: bash
run: |
brew update
brew install docker
brew install docker qemu
brew install colima
LIMACTL_PATH=$(brew --prefix)/bin/limactl
sudo curl -L -o $LIMACTL_PATH https://github.com/mikekazakov/lima-nohvf/raw/master/limactl && sudo chmod +x $LIMACTL_PATH
Expand Down
2 changes: 1 addition & 1 deletion .github/actions/service/mysql/action.yml
Original file line number Diff line number Diff line change
Expand Up @@ -40,5 +40,5 @@ runs:
run: |
for port in ${{ inputs.ports }}; do
mysqld --defaults-file=./$port.ini --initialize-insecure
mysqld --defaults-file=./$port.ini &
mysqld --defaults-file=./$port.ini & echo $! > ./mysql_$port.pid
done
66 changes: 66 additions & 0 deletions .github/actions/service/portMapper/action.yml
Original file line number Diff line number Diff line change
@@ -0,0 +1,66 @@
name: "Database Ports Mapper"
description: "Map database name to corresponding ports"
inputs:
DB-name:
description: "Name of the database to get ports for"
required: true

outputs:
port1:
description: "port1"
value: ${{ steps.get-ports.outputs.port1 }}
port2:
description: "port2"
value: ${{ steps.get-ports.outputs.port2 }}
port3:
description: "port3"
value: ${{ steps.get-ports.outputs.port3 }}

runs:
using: "composite"
steps:
- id: get-ports
shell: bash
run: |
case "${{ inputs.DB-name }}" in
"InfluxDB")
echo "port1=8086" >> $GITHUB_OUTPUT
echo "port2=8087" >> $GITHUB_OUTPUT
echo "port3=8088" >> $GITHUB_OUTPUT
;;
"IoTDB12")
echo "port1=6667" >> $GITHUB_OUTPUT
echo "port2=6668" >> $GITHUB_OUTPUT
echo "port3=6669" >> $GITHUB_OUTPUT
;;
"FileSystem")
echo "port1=6667" >> $GITHUB_OUTPUT
echo "port2=6668" >> $GITHUB_OUTPUT
echo "port3=6669" >> $GITHUB_OUTPUT
;;
"MySQL")
echo "port1=3306" >> $GITHUB_OUTPUT
echo "port2=3307" >> $GITHUB_OUTPUT
echo "port3=3308" >> $GITHUB_OUTPUT
;;
"PostgreSQL")
echo "port1=5432" >> $GITHUB_OUTPUT
echo "port2=5433" >> $GITHUB_OUTPUT
echo "port3=5434" >> $GITHUB_OUTPUT
;;
"MongoDB")
echo "port1=27017" >> $GITHUB_OUTPUT
echo "port2=27018" >> $GITHUB_OUTPUT
echo "port3=27019" >> $GITHUB_OUTPUT
;;
"Redis")
echo "port1=6379" >> $GITHUB_OUTPUT
echo "port2=6380" >> $GITHUB_OUTPUT
echo "port3=6381" >> $GITHUB_OUTPUT
;;
*)
echo "port1=0" >> $GITHUB_OUTPUT
echo "port2=0" >> $GITHUB_OUTPUT
echo "port3=0" >> $GITHUB_OUTPUT
;;
esac
17 changes: 11 additions & 6 deletions .github/actions/service/zookeeper/action.yml
Original file line number Diff line number Diff line change
Expand Up @@ -10,30 +10,35 @@ inputs:
start:
description: "whether to start"
required: true
port:
description: "zk port"
required: false
default: "2181"

runs:
using: "composite"
steps:
- if: fromJSON(inputs.stop)
name: Stop zookeeper
shell: bash
working-directory: ${{ github.action_path }}
run: zkServer.sh --config conf stop
working-directory: ${{ runner.temp }}/zookeeper-${{ inputs.port }}
run: bin/zkServer.sh --config conf stop

- if: fromJSON(inputs.clean)
name: Clean zookeeper
shell: bash
working-directory: ${{ github.action_path }}
working-directory: ${{ runner.temp }}/zookeeper-${{ inputs.port }}
run: rm -rf data logs conf

- if: fromJSON(inputs.start)
name: Start zookeeper
shell: bash
working-directory: ${{ github.action_path }}
working-directory: ${{ runner.temp }}/zookeeper-${{ inputs.port }}
run: |
mkdir -p conf
echo "dataDir=data" > conf/zoo.cfg
echo "dataLogDir=logs" >> conf/zoo.cfg
echo "clientPort=2181" >> conf/zoo.cfg
echo "clientPort=${{ inputs.port }}" >> conf/zoo.cfg
echo "admin.serverPort=$((${{ inputs.port }} + 10000))" >> conf/zoo.cfg

zkServer.sh --config conf start
bin/zkServer.sh --config conf start
12 changes: 9 additions & 3 deletions .github/actions/setup/zookeeper/action.yml
Original file line number Diff line number Diff line change
Expand Up @@ -5,6 +5,10 @@ inputs:
description: "zookeeper version"
required: false
default: "3.7.2"
port:
description: "zk port"
required: false
default: "2181"

runs:
using: "composite"
Expand Down Expand Up @@ -32,10 +36,12 @@ runs:
subdir: "apache-zookeeper-{version}-bin"
ext: "tar.gz"

- name: Add zookeeper Bin to PATH
- name: Copy ZK to Port Dir
shell: bash
working-directory: ${{ steps.base.outputs.tool-path }}
run: echo "$PWD/bin" >> $GITHUB_PATH
run: |
if [ ! -d "${{ runner.temp }}/zookeeper-${{ inputs.port }}" ]; then
cp -r "${{ steps.base.outputs.tool-path }}" "${{ runner.temp }}/zookeeper-${{ inputs.port }}"
fi

- name: Save zookeeper Cache
if: steps.restore.outputs.cache-hit != 'true'
Expand Down
31 changes: 30 additions & 1 deletion .github/actions/tpchDataWriter/action.yml
Original file line number Diff line number Diff line change
Expand Up @@ -9,10 +9,39 @@ inputs:
runs:
using: "composite" # Mandatory parameter
steps:
- name: Start Old IGinX
shell: bash
run: |
cd IGinX/core/target/iginx-core-${VERSION}
pwd
export IGINX_HOME=$PWD
echo "IGinX home path: $IGINX_HOME"
cd ..
chmod +x iginx-core-${VERSION}/sbin/start_iginx.sh
nohup iginx-core-${VERSION}/sbin/start_iginx.sh > ../../iginx-${VERSION}.log 2>&1 &

# two IGinXs are using different ZKs, we need to insert data & register UDFs in both nodes
- name: Insert Data and Register UDF in Old IGinX
shell: bash
run: |
cd IGinX
mvn test -q -Dtest=TPCHDataGeneratorIT -DfailIfNoTests=false -P-format

- name: Show Old IGinX log
if: always()
shell: bash
run: cat IGinX/iginx-*.log

- name: Stop Old IGinX
uses: ./.github/actions/iginxRunner
with:
version: ${VERSION}
if-stop: "true"

- name: Start New IGinX
uses: ./.github/actions/iginxRunner

- name: Insert Data and Register UDF
- name: Insert Data and Register UDF in new IGinX
shell: bash
run: mvn test -q -Dtest=TPCHDataGeneratorIT -DfailIfNoTests=false -P-format

Expand Down
Loading
Loading