You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@paimon.apache.org by lz...@apache.org on 2024/07/09 05:02:46 UTC

(paimon) branch master updated: [test] Remove unreachable code in PaimonSourceTest class (#3711)

This is an automated email from the ASF dual-hosted git repository.

lzljs3620320 pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/paimon.git


The following commit(s) were added to refs/heads/master by this push:
     new 057bd00aa [test] Remove unreachable code in PaimonSourceTest class (#3711)
057bd00aa is described below

commit 057bd00aaecfb923d07d449eaecc25bdb199e68b
Author: Wei Guo <gu...@gmail.com>
AuthorDate: Tue Jul 9 13:02:41 2024 +0800

    [test] Remove unreachable code in PaimonSourceTest class (#3711)
---
 .../src/test/scala/org/apache/paimon/spark/PaimonSourceTest.scala     | 4 ----
 1 file changed, 4 deletions(-)

diff --git a/paimon-spark/paimon-spark-common/src/test/scala/org/apache/paimon/spark/PaimonSourceTest.scala b/paimon-spark/paimon-spark-common/src/test/scala/org/apache/paimon/spark/PaimonSourceTest.scala
index 585f07187..cd3fade60 100644
--- a/paimon-spark/paimon-spark-common/src/test/scala/org/apache/paimon/spark/PaimonSourceTest.scala
+++ b/paimon-spark/paimon-spark-common/src/test/scala/org/apache/paimon/spark/PaimonSourceTest.scala
@@ -746,8 +746,6 @@ class PaimonSourceTest extends PaimonSparkTestBase with StreamTest {
           mergedData += (row._1 -> row._2)
         case false =>
           unmergedData += row
-        case _ =>
-          throw new IllegalArgumentException("Please provide write mode explicitly.")
       }
     }
 
@@ -759,8 +757,6 @@ class PaimonSourceTest extends PaimonSparkTestBase with StreamTest {
           (mergedData.toArray[(Int, String)].map(toRow), latestChanges.map(toRow))
         case false =>
           (unmergedData.sorted.toArray.map(toRow), latestChanges.map(toRow))
-        case _ =>
-          throw new IllegalArgumentException("Please provide write mode explicitly.")
       }
     }