cheyang
/
fluid
mirror of https://github.com/fluid-cloudnative/fluid.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

bugfix: fix jindo-fuse postStart script to make sure fuse mountpoint is ready (#3252) 

* Fix jindo-fuse postStart script

Signed-off-by: trafalgarzzz <trafalgarz@outlook.com>

* Fix jindo test case

Signed-off-by: trafalgarzzz <trafalgarz@outlook.com>

---------

Signed-off-by: trafalgarzzz <trafalgarz@outlook.com>
This commit is contained in:
TzZtzt 2023-05-26 13:42:28 +08:00 committed by GitHub
parent 33e247700d
commit f78f11cd76
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
3 changed files with 7 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
pkg/scripts/poststart/check_fuse.go
View File

@ -45,6 +45,11 @@ ConditionPathIsMountPoint="$1"
MountType="$2"
SubPath="$3"
# grep /dev/fuse if the mountType equals to jindo
if [[ "$MountType" == "jindo" ]]; then
MountType=/dev/fuse
fi
count=0
# while ! mount | grep alluxio | grep $ConditionPathIsMountPoint | grep -v grep
while ! cat /proc/self/mountinfo | grep $ConditionPathIsMountPoint | grep $MountType

2
test/prow/testcases/jindofsx/jindo_oss.py
View File

@ -99,7 +99,7 @@ def main():
flow.append_step(
SimpleStep(
step_name="create data read job",
forth_fn=funcs.create_job_fn(script="time cp -r /data/ /tmp-data && [[ ! -z \"$(ls -l /tmp-data)\" ]]", dataset_name=name, namespace=namespace),
forth_fn=funcs.create_job_fn(script="time cp -r /data/ /tmp-data && [[ ! -z \"$(ls /tmp-data)\" ]]", dataset_name=name, namespace=namespace),
back_fn=funcs.delete_job_fn()
)
)

2
test/prow/testcases/jindofsx/jindo_oss_fusesidecar.py
View File

@ -100,7 +100,7 @@ def main():
flow.append_step(
SimpleStep(
step_name="create data read job",
forth_fn=funcs.create_job_fn(script="time cp -r /data/ /tmp-data && [[ ! -z \"$(ls -l /tmp-data)\" ]]", dataset_name=name, namespace=namespace, serverless=True),
forth_fn=funcs.create_job_fn(script="time cp -r /data/ /tmp-data && [[ ! -z \"$(ls /tmp-data)\" ]]", dataset_name=name, namespace=namespace, serverless=True),
back_fn=funcs.delete_job_fn()
)
)