Skip to content

Commit b60ecb7

Browse files
authored
Merge branch 'main' into fix-cluster-mode-issue
2 parents d60c828 + 80ee56f commit b60ecb7

File tree

1 file changed

+5
-0
lines changed

1 file changed

+5
-0
lines changed

src/main/java/datastax/astra/migrate/AbstractJobSession.java

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -25,6 +25,11 @@ protected AbstractJobSession(CqlSession sourceSession, CqlSession astraSession,
2525

2626
protected AbstractJobSession(CqlSession sourceSession, CqlSession astraSession, SparkConf sc, boolean isJobMigrateRowsFromFile) {
2727
super(sc);
28+
29+
if (sourceSession == null) {
30+
return;
31+
}
32+
2833
this.sourceSession = sourceSession;
2934
this.astraSession = astraSession;
3035

0 commit comments

Comments
 (0)