Fix GeoParquet geography support

Author: davidchaava

flink-formats/flink-parquet/src/test/java/org/apache/flink/formats/parquet/row/ParquetRowDataWriterTest.java

@@ -295,31 +295,31 @@ void testGeoParquetMixedSchemaRoundTrip(@TempDir java.nio.file.Path folder) thro
         byte[] polygonWkb =
                 bytesFromHex(
                         "010300000001000000050000000000000000000000000000000000000000000000"
-                                + "00000000000000000000000F03F000000000000F03F000000000000F03F"
-                                + "000000000000F03F000000000000000000000000000000000000000000000000");
+                                + "0000000000000000000000F03F000000000000F03F000000000000F03F"
+                                + "000000000000F03F0000000000000000000000000000000000000000000000");
         byte[] multiPointWkb =
                 bytesFromHex(
                         "0104000000020000000101000000000000000000F03F000000000000F03F"
                                 + "010100000000000000000000400000000000000040");
         byte[] multiLineStringWkb =
                 bytesFromHex(
                         "010500000002000000010200000002000000000000000000000000000000000000"
-                                + "000000000000000F03F000000000000F03F010200000002000000000000"
+                                + "00000000000000F03F000000000000F03F010200000002000000000000"
                                 + "0000000040000000000000004000000000000008400000000000000840");
         byte[] multiPolygonWkb =
                 bytesFromHex(
                         "010600000002000000010300000001000000050000000000000000000000000000"
-                                + "000000000000000000000000000000000000000000F03F000000000000F03F"
-                                + "000000000000F03F000000000000F03F00000000000000000000000000000000"
-                                + "00000000000000000103000000010000000500000000000000000000040000000"
-                                + "00000000040000000000000004000000000000008400000000000000840000000"
-                                + "0000000840000000000000084000000000000000400000000000000040000000"
-                                + "0000000040");
+                                + "00000000000000000000000000000000000000F03F000000000000F03F0000"
+                                + "00000000F03F000000000000F03F0000000000000000000000000000000000"
+                                + "00000000000000010300000001000000050000000000000000000040000000"
+                                + "00000000400000000000000040000000000000084000000000000008400000"
+                                + "000000000840000000000000084000000000000000400000000000000040"
+                                + "0000000000000040");
         byte[] geometryCollectionWkb =
                 bytesFromHex(
                         "0107000000020000000101000000000000000000F03F0000000000000040"
                                 + "010200000002000000000000000000000000000000000000000000000000"
-                                + "0000F03F000000000000F03F");
+                                + "00F03F000000000000F03F");
 
         List<RowData> rows = new ArrayList<>();
         rows.add(

flink-table/flink-table-common/src/main/java/org/apache/flink/table/data/binary/BinaryGeographyData.java

@@ -115,7 +115,6 @@ private static void validatePayload(MemorySegment[] segments, int offset, int si
                             "Malformed ISO WKB payload. Found %d trailing byte(s).",
                             endOffset - consumedOffset));
         }
-        return header.subtypeId;
     }
 
     private static int readSubtypeId(MemorySegment[] segments, int offset, int sizeInBytes) {

flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/calcite/FlinkCalciteSqlValidatorTest.java

@@ -34,9 +34,7 @@
 import org.junit.jupiter.params.ParameterizedTest;
 import org.junit.jupiter.params.provider.ValueSource;
 
-import static org.assertj.core.api.Assertions.assertThat;
 import static org.assertj.core.api.Assertions.assertThatThrownBy;
-import static org.assertj.core.api.Assertions.catchThrowable;
 import static org.junit.jupiter.api.Assertions.assertDoesNotThrow;
 
 /** Test for {@link FlinkCalciteSqlValidator}. */