This is an automated email from the ASF dual-hosted git repository.
amoghj pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/iceberg.git
The following commit(s) were added to refs/heads/main by this push:
new 496b320985 Flink, Spark: Replace Boolean.getBoolean() with
Boolean.parseBoolean() (#10136)
496b320985 is described below
commit 496b32098587d80ad5812b24598c98ceb6625ab7
Author: Eduard Tudenhoefner <[email protected]>
AuthorDate: Sun Apr 14 05:19:55 2024 +0200
Flink, Spark: Replace Boolean.getBoolean() with Boolean.parseBoolean()
(#10136)
---
.../src/test/java/org/apache/iceberg/flink/source/TestFlinkSource.java | 2 +-
.../src/test/java/org/apache/iceberg/flink/source/TestFlinkSource.java | 2 +-
.../src/test/java/org/apache/iceberg/flink/source/TestFlinkSource.java | 2 +-
.../spark/src/main/java/org/apache/iceberg/spark/SparkTableUtil.java | 2 +-
.../spark/src/main/java/org/apache/iceberg/spark/SparkTableUtil.java | 2 +-
.../spark/src/main/java/org/apache/iceberg/spark/SparkTableUtil.java | 2 +-
6 files changed, 6 insertions(+), 6 deletions(-)
diff --git
a/flink/v1.16/flink/src/test/java/org/apache/iceberg/flink/source/TestFlinkSource.java
b/flink/v1.16/flink/src/test/java/org/apache/iceberg/flink/source/TestFlinkSource.java
index 86c7e8991d..ff78920712 100644
---
a/flink/v1.16/flink/src/test/java/org/apache/iceberg/flink/source/TestFlinkSource.java
+++
b/flink/v1.16/flink/src/test/java/org/apache/iceberg/flink/source/TestFlinkSource.java
@@ -60,7 +60,7 @@ public abstract class TestFlinkSource extends TestFlinkScan {
protected List<Row> runWithOptions(Map<String, String> options) throws
Exception {
FlinkSource.Builder builder = FlinkSource.forRowData();
Optional.ofNullable(options.get("case-sensitive"))
- .ifPresent(value -> builder.caseSensitive(Boolean.getBoolean(value)));
+ .ifPresent(value ->
builder.caseSensitive(Boolean.parseBoolean(value)));
Optional.ofNullable(options.get("snapshot-id"))
.ifPresent(value -> builder.snapshotId(Long.parseLong(value)));
Optional.ofNullable(options.get("tag")).ifPresent(value ->
builder.tag(value));
diff --git
a/flink/v1.17/flink/src/test/java/org/apache/iceberg/flink/source/TestFlinkSource.java
b/flink/v1.17/flink/src/test/java/org/apache/iceberg/flink/source/TestFlinkSource.java
index 86c7e8991d..ff78920712 100644
---
a/flink/v1.17/flink/src/test/java/org/apache/iceberg/flink/source/TestFlinkSource.java
+++
b/flink/v1.17/flink/src/test/java/org/apache/iceberg/flink/source/TestFlinkSource.java
@@ -60,7 +60,7 @@ public abstract class TestFlinkSource extends TestFlinkScan {
protected List<Row> runWithOptions(Map<String, String> options) throws
Exception {
FlinkSource.Builder builder = FlinkSource.forRowData();
Optional.ofNullable(options.get("case-sensitive"))
- .ifPresent(value -> builder.caseSensitive(Boolean.getBoolean(value)));
+ .ifPresent(value ->
builder.caseSensitive(Boolean.parseBoolean(value)));
Optional.ofNullable(options.get("snapshot-id"))
.ifPresent(value -> builder.snapshotId(Long.parseLong(value)));
Optional.ofNullable(options.get("tag")).ifPresent(value ->
builder.tag(value));
diff --git
a/flink/v1.18/flink/src/test/java/org/apache/iceberg/flink/source/TestFlinkSource.java
b/flink/v1.18/flink/src/test/java/org/apache/iceberg/flink/source/TestFlinkSource.java
index 86c7e8991d..ff78920712 100644
---
a/flink/v1.18/flink/src/test/java/org/apache/iceberg/flink/source/TestFlinkSource.java
+++
b/flink/v1.18/flink/src/test/java/org/apache/iceberg/flink/source/TestFlinkSource.java
@@ -60,7 +60,7 @@ public abstract class TestFlinkSource extends TestFlinkScan {
protected List<Row> runWithOptions(Map<String, String> options) throws
Exception {
FlinkSource.Builder builder = FlinkSource.forRowData();
Optional.ofNullable(options.get("case-sensitive"))
- .ifPresent(value -> builder.caseSensitive(Boolean.getBoolean(value)));
+ .ifPresent(value ->
builder.caseSensitive(Boolean.parseBoolean(value)));
Optional.ofNullable(options.get("snapshot-id"))
.ifPresent(value -> builder.snapshotId(Long.parseLong(value)));
Optional.ofNullable(options.get("tag")).ifPresent(value ->
builder.tag(value));
diff --git
a/spark/v3.3/spark/src/main/java/org/apache/iceberg/spark/SparkTableUtil.java
b/spark/v3.3/spark/src/main/java/org/apache/iceberg/spark/SparkTableUtil.java
index 6cb31a3b88..2da0cf7099 100644
---
a/spark/v3.3/spark/src/main/java/org/apache/iceberg/spark/SparkTableUtil.java
+++
b/spark/v3.3/spark/src/main/java/org/apache/iceberg/spark/SparkTableUtil.java
@@ -754,7 +754,7 @@ public class SparkTableUtil {
return PropertyUtil.propertyAsBoolean(
table.properties(),
TableProperties.WRITE_AUDIT_PUBLISH_ENABLED,
-
Boolean.getBoolean(TableProperties.WRITE_AUDIT_PUBLISH_ENABLED_DEFAULT));
+
Boolean.parseBoolean(TableProperties.WRITE_AUDIT_PUBLISH_ENABLED_DEFAULT));
}
/** Class representing a table partition. */
diff --git
a/spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/SparkTableUtil.java
b/spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/SparkTableUtil.java
index 51df02d569..5af6b46b31 100644
---
a/spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/SparkTableUtil.java
+++
b/spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/SparkTableUtil.java
@@ -705,7 +705,7 @@ public class SparkTableUtil {
return PropertyUtil.propertyAsBoolean(
table.properties(),
TableProperties.WRITE_AUDIT_PUBLISH_ENABLED,
-
Boolean.getBoolean(TableProperties.WRITE_AUDIT_PUBLISH_ENABLED_DEFAULT));
+
Boolean.parseBoolean(TableProperties.WRITE_AUDIT_PUBLISH_ENABLED_DEFAULT));
}
/** Class representing a table partition. */
diff --git
a/spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/SparkTableUtil.java
b/spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/SparkTableUtil.java
index 3a2324d891..eb27e1483d 100644
---
a/spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/SparkTableUtil.java
+++
b/spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/SparkTableUtil.java
@@ -770,7 +770,7 @@ public class SparkTableUtil {
return PropertyUtil.propertyAsBoolean(
table.properties(),
TableProperties.WRITE_AUDIT_PUBLISH_ENABLED,
-
Boolean.getBoolean(TableProperties.WRITE_AUDIT_PUBLISH_ENABLED_DEFAULT));
+
Boolean.parseBoolean(TableProperties.WRITE_AUDIT_PUBLISH_ENABLED_DEFAULT));
}
/** Class representing a table partition. */
