| commit | be9be6418f146d3ff5788a731eadd36b500b062b | [log] [tgz] |
|---|---|---|
| author | Madhavan Sridharan <madhavan.sridharan@datastax.com> | Fri May 27 08:51:05 2022 -0400 |
| committer | Madhavan Sridharan <madhavan.sridharan@datastax.com> | Fri May 27 08:51:05 2022 -0400 |
| tree | 79eb963cda4f7dbd33d49487a06458040239493b | |
| parent | f53c2a5aa19cc148ca0e5a5204a8a590a541cc1b [diff] | |
| parent | 5ecdaac2424ee4b1a194f531bda44c75eb131c5f [diff] |
Merge branch 'SPARKC-682-b3.0' of github.com:msmygit/spark-cassandra-connector into SPARKC-682-b3.0
diff --git a/connector/src/it/scala/com/datastax/spark/connector/sql/CassandraDataFrameSpec.scala b/connector/src/it/scala/com/datastax/spark/connector/sql/CassandraDataFrameSpec.scala index d31fb8f..7d21a2f 100644 --- a/connector/src/it/scala/com/datastax/spark/connector/sql/CassandraDataFrameSpec.scala +++ b/connector/src/it/scala/com/datastax/spark/connector/sql/CassandraDataFrameSpec.scala
@@ -431,7 +431,7 @@ .option("directJoinSetting", "on") .load - val other = df.join(df, df1.col("camelCase").equalTo(df2.col("camelCase"))) + val other = df1.join(df2, df1.col("camelCase").equalTo(df2.col("camelCase"))) other.count should be >= 0L } }