(doris-spark-connector) branch master updated: [typo] change version (#240)

[diwu]

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 <adamlee...@gmail.com>
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: commits-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org