File tree Expand file tree Collapse file tree 4 files changed +8
-108
lines changed Expand file tree Collapse file tree 4 files changed +8
-108
lines changed Original file line number Diff line number Diff line change 1
1
FROM eclipse-temurin:8-jammy
2
2
3
- RUN apt update && apt install -y openssh-server vim --no-install-recommends
4
- RUN service ssh start
5
-
6
3
# Add all migration tools to path
7
4
RUN mkdir -p /assets/
8
5
@@ -19,6 +16,10 @@ RUN cd /assets && \
19
16
tar -xzf ./spark-2.4.8-bin-hadoop2.7.tgz && \
20
17
rm ./spark-2.4.8-bin-hadoop2.7.tgz
21
18
19
+ RUN apt-get update && apt-get install -y openssh-server vim --no-install-recommends && \
20
+ rm -rf /var/lib/apt/lists/*
21
+ RUN service ssh start
22
+
22
23
# Copy CDM jar & template files
23
24
COPY ./target/cassandra-data-migrator-*.jar /assets/
24
25
COPY ./src/resources/sparkConf.properties /assets/
Load Diff This file was deleted.
Original file line number Diff line number Diff line change @@ -39,7 +39,7 @@ if [ $S_IDX -lt -9000000000000000000 ]
39
39
then
40
40
E_IDX=-9000000000000000001
41
41
echo " Running Migrate for Partition Range $S_IDX to $E_IDX .."
42
- $SPARK_SUBMIT --properties-file $PROPS_FILE --master " local[*]" --conf spark.source .minPartition=$S_IDX --conf spark.source .maxPartition=$E_IDX --class datastax.astra.migrate.Migrate cassandra-data-migrator-* .jar
42
+ $SPARK_SUBMIT --properties-file $PROPS_FILE --master " local[*]" --conf spark.origin .minPartition=$S_IDX --conf spark.origin .maxPartition=$E_IDX --class datastax.astra.migrate.Migrate cassandra-data-migrator-* .jar
43
43
S_IDX=-9000000000000000000
44
44
fi
45
45
53
53
E_IDX=$(( $S_IDX + $SLICE ))
54
54
fi
55
55
echo " Running Migrate for Partition Range $S_IDX to $E_IDX .."
56
- $SPARK_SUBMIT --properties-file $PROPS_FILE --master " local[*]" --conf spark.source .minPartition=$S_IDX --conf spark.source .maxPartition=$E_IDX --class datastax.astra.migrate.Migrate cassandra-data-migrator-* .jar
56
+ $SPARK_SUBMIT --properties-file $PROPS_FILE --master " local[*]" --conf spark.origin .minPartition=$S_IDX --conf spark.origin .maxPartition=$E_IDX --class datastax.astra.migrate.Migrate cassandra-data-migrator-* .jar
57
57
S_IDX=$(( $E_IDX + 1 ))
58
58
done
59
59
60
60
# Migrate final partition tokens from 9000000000000000000 to max-long
61
61
E_IDX=9223372036854775807
62
62
echo " Running Migrate for Partition Range $S_IDX to 9223372036854775807 .."
63
- $SPARK_SUBMIT --properties-file $PROPS_FILE --master " local[*]" --conf spark.source .minPartition=$S_IDX --conf spark.source .maxPartition=$E_IDX --class datastax.astra.migrate.Migrate cassandra-data-migrator-* .jar
63
+ $SPARK_SUBMIT --properties-file $PROPS_FILE --master " local[*]" --conf spark.origin .minPartition=$S_IDX --conf spark.origin .maxPartition=$E_IDX --class datastax.astra.migrate.Migrate cassandra-data-migrator-* .jar
64
64
echo " Completed Migration using $PROPS_FILE !!"
Original file line number Diff line number Diff line change @@ -8,7 +8,7 @@ spark-submit --properties-file /<path>/sparkConf.properties --verbose --master "
8
8
spark-submit --properties-file /<path>/sparkConf.properties --master "local[8]" --driver-memory 25G --executor-memory 25G --class datastax.astra.migrate.Migrate /<path>/cassandra-data-migrator-2.x.jar &> table_out.log
9
9
10
10
// Random Partitioner Run Command
11
- spark-submit --properties-file /<path>/sparkConf.properties --verbose --master "local[8]" --conf spark.origin.minPartition=-1 --conf spark.origin.maxPartition=170141183460469231731687303715884105728 --class datastax.astra.migrate.Migrate /<path>/cassandra-data-migrator-1 .x.jar
11
+ spark-submit --properties-file /<path>/sparkConf.properties --verbose --master "local[8]" --conf spark.origin.minPartition=-1 --conf spark.origin.maxPartition=170141183460469231731687303715884105728 --class datastax.astra.migrate.Migrate /<path>/cassandra-data-migrator-2 .x.jar
12
12
13
13
// Validate
14
14
spark-submit --properties-file /<path>/sparkConf.properties --master "local[8]" --driver-memory 25G --executor-memory 25G --class datastax.astra.migrate.DiffData /<path>/cassandra-data-migrator-2.x.jar &> table_out.log
You can’t perform that action at this time.
0 commit comments