This is an automated email from the ASF dual-hosted git repository.
diwu pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/doris-spark-connector.git
The following commit(s) were added to refs/heads/master by this push:
new 157ef07 [typo] change version (#240)
157ef07 is described below
commit 157ef07cbf449ddb990bc85df1653628430c4717
Author: gnehil <[email protected]>
AuthorDate: Tue Dec 3 16:33:59 2024 +0800
[typo] change version (#240)
---
spark-doris-connector/pom.xml | 2 +-
.../main/java/org/apache/doris/spark/rest/PartitionDefinition.java | 4 ++--
2 files changed, 3 insertions(+), 3 deletions(-)
diff --git a/spark-doris-connector/pom.xml b/spark-doris-connector/pom.xml
index 7c363f2..2de4fe0 100644
--- a/spark-doris-connector/pom.xml
+++ b/spark-doris-connector/pom.xml
@@ -76,7 +76,7 @@
</mailingLists>
<properties>
- <revision>1.4.0-SNAPSHOT</revision>
+ <revision>24.0.0-SNAPSHOT</revision>
<spark.version>2.4.8</spark.version>
<spark.major.version>2.4</spark.major.version>
<scala.version>2.11.12</scala.version>
diff --git
a/spark-doris-connector/spark-doris-connector-base/src/main/java/org/apache/doris/spark/rest/PartitionDefinition.java
b/spark-doris-connector/spark-doris-connector-base/src/main/java/org/apache/doris/spark/rest/PartitionDefinition.java
index baa517a..67c612d 100644
---
a/spark-doris-connector/spark-doris-connector-base/src/main/java/org/apache/doris/spark/rest/PartitionDefinition.java
+++
b/spark-doris-connector/spark-doris-connector-base/src/main/java/org/apache/doris/spark/rest/PartitionDefinition.java
@@ -108,7 +108,7 @@ public class PartitionDefinition implements Serializable,
Comparable<PartitionDe
similar.retainAll(o.tabletIds);
diffSelf.removeAll(similar);
diffOther.removeAll(similar);
- if (diffSelf.size() == 0) {
+ if (diffSelf.isEmpty()) {
return 0;
}
long diff = Collections.min(diffSelf) - Collections.min(diffOther);
@@ -127,7 +127,7 @@ public class PartitionDefinition implements Serializable,
Comparable<PartitionDe
return Objects.equals(database, that.database)
&& Objects.equals(table, that.table)
&& Objects.equals(beAddress, that.beAddress)
- && Objects.equals(tabletIds, that.tabletIds)
+ && tabletIds.size() == that.tabletIds.size() &&
tabletIds.containsAll(that.tabletIds)
&& Objects.equals(queryPlan, that.queryPlan)
&& Objects.equals(serializedSettings, that.serializedSettings);
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
