Skip to content

Commit 6a7d0e5

Browse files
committed
fix rest of localDate/Time occurences
1 parent 4e683cb commit 6a7d0e5

3 files changed

Lines changed: 10 additions & 8 deletions

File tree

sdks/java/extensions/sql/src/test/java/org/apache/beam/sdk/extensions/sql/impl/schema/BeamSqlRowCoderTest.java

Lines changed: 4 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -21,6 +21,7 @@
2121
import java.time.LocalDate;
2222
import java.time.LocalDateTime;
2323
import java.time.LocalTime;
24+
import java.time.ZoneId;
2425
import org.apache.beam.sdk.coders.Coder;
2526
import org.apache.beam.sdk.extensions.sql.impl.utils.CalciteUtils;
2627
import org.apache.beam.sdk.schemas.Schema;
@@ -70,9 +71,9 @@ public void encodeAndDecode() throws Exception {
7071
1.1,
7172
BigDecimal.ZERO,
7273
"hello",
73-
LocalTime.now(),
74-
LocalDate.now(),
75-
LocalDateTime.now(),
74+
LocalTime.now(ZoneId.systemDefault()),
75+
LocalDate.now(ZoneId.systemDefault()),
76+
LocalDateTime.now(ZoneId.systemDefault()),
7677
DateTime.now().toInstant(),
7778
true)
7879
.build();

sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/bigquery/BeamRowToStorageApiProtoTest.java

Lines changed: 4 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -35,6 +35,7 @@
3535
import java.time.LocalDate;
3636
import java.time.LocalDateTime;
3737
import java.time.LocalTime;
38+
import java.time.ZoneId;
3839
import java.time.temporal.ChronoUnit;
3940
import java.util.HashMap;
4041
import java.util.List;
@@ -252,9 +253,9 @@ public class BeamRowToStorageApiProtoTest {
252253
.withFieldValue("arrayValue", ImmutableList.of("one", "two", "red", "blue"))
253254
.withFieldValue("arrayNullValue", null)
254255
.withFieldValue("iterableValue", ImmutableList.of("blue", "red", "two", "one"))
255-
.withFieldValue("sqlDateValue", LocalDate.now())
256-
.withFieldValue("sqlTimeValue", LocalTime.now())
257-
.withFieldValue("sqlDatetimeValue", LocalDateTime.now())
256+
.withFieldValue("sqlDateValue", LocalDate.now(ZoneId.systemDefault()))
257+
.withFieldValue("sqlTimeValue", LocalTime.now(ZoneId.systemDefault()))
258+
.withFieldValue("sqlDatetimeValue", LocalDateTime.now(ZoneId.systemDefault()))
258259
.withFieldValue("sqlTimestampValue", java.time.Instant.now().plus(123, ChronoUnit.MICROS))
259260
.withFieldValue("enumValue", TEST_ENUM.valueOf("RED"))
260261
.build();

sdks/java/io/influxdb/src/test/java/org/apache/beam/sdk/io/influxdb/GenerateData.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -40,7 +40,7 @@ static List<String> getMetric(String metric, int number) {
4040
m.addField("field2", random.nextInt(100));
4141
LocalDateTime time =
4242
LocalDateTime.of(
43-
LocalDate.now(),
43+
LocalDate.now(ZoneId.systemDefault()),
4444
LocalTime.of(
4545
random.nextInt(24),
4646
random.nextInt(60),
@@ -64,7 +64,7 @@ static List<String> getMultipleMetric(List<String> metrics, int number) {
6464
m.addField("field2", random.nextInt(100));
6565
LocalDateTime time =
6666
LocalDateTime.of(
67-
LocalDate.now(),
67+
LocalDate.now(ZoneId.systemDefault()),
6868
LocalTime.of(
6969
random.nextInt(24),
7070
random.nextInt(60),

0 commit comments

Comments
 (0)