Skip to content

Commit

Permalink
[hotfix][hbase] Fix warnings around decimals in HBaseTestBase
Browse files Browse the repository at this point in the history
  • Loading branch information
@twalthr
twalthr committed May 18, 2021
1 parent 9761019 commit 927a21c
Show file tree
Hide file tree
Showing 2 changed files with 16 additions and 16 deletions.
16 changes: 8 additions & 8 deletions ...nnector-hbase-1.4/src/test/java/org/apache/flink/connector/hbase1/util/HBaseTestBase.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -120,7 +120,7 @@ private static void createHBaseTable1() throws IOException {
Timestamp.valueOf("2019-08-18 19:00:00"),
Date.valueOf("2019-08-18"),
Time.valueOf("19:00:00"),
new BigDecimal(12345678.0001)));
new BigDecimal("12345678.0001")));
puts.add(
putRow(
2,
Expand All @@ -133,7 +133,7 @@ private static void createHBaseTable1() throws IOException {
Timestamp.valueOf("2019-08-18 19:01:00"),
Date.valueOf("2019-08-18"),
Time.valueOf("19:01:00"),
new BigDecimal(12345678.0002)));
new BigDecimal("12345678.0002")));
puts.add(
putRow(
3,
Expand All @@ -146,7 +146,7 @@ private static void createHBaseTable1() throws IOException {
Timestamp.valueOf("2019-08-18 19:02:00"),
Date.valueOf("2019-08-18"),
Time.valueOf("19:02:00"),
new BigDecimal(12345678.0003)));
new BigDecimal("12345678.0003")));
puts.add(
putRow(
4,
Expand All @@ -159,7 +159,7 @@ private static void createHBaseTable1() throws IOException {
Timestamp.valueOf("2019-08-18 19:03:00"),
Date.valueOf("2019-08-18"),
Time.valueOf("19:03:00"),
new BigDecimal(12345678.0004)));
new BigDecimal("12345678.0004")));
puts.add(
putRow(
5,
Expand All @@ -172,7 +172,7 @@ private static void createHBaseTable1() throws IOException {
Timestamp.valueOf("2019-08-19 19:10:00"),
Date.valueOf("2019-08-19"),
Time.valueOf("19:10:00"),
new BigDecimal(12345678.0005)));
new BigDecimal("12345678.0005")));
puts.add(
putRow(
6,
Expand All @@ -185,7 +185,7 @@ private static void createHBaseTable1() throws IOException {
Timestamp.valueOf("2019-08-19 19:20:00"),
Date.valueOf("2019-08-19"),
Time.valueOf("19:20:00"),
new BigDecimal(12345678.0006)));
new BigDecimal("12345678.0006")));
puts.add(
putRow(
7,
Expand All @@ -198,7 +198,7 @@ private static void createHBaseTable1() throws IOException {
Timestamp.valueOf("2019-08-19 19:30:00"),
Date.valueOf("2019-08-19"),
Time.valueOf("19:30:00"),
new BigDecimal(12345678.0007)));
new BigDecimal("12345678.0007")));
puts.add(
putRow(
8,
Expand All @@ -211,7 +211,7 @@ private static void createHBaseTable1() throws IOException {
Timestamp.valueOf("2019-08-19 19:40:00"),
Date.valueOf("2019-08-19"),
Time.valueOf("19:40:00"),
new BigDecimal(12345678.0008)));
new BigDecimal("12345678.0008")));

// append rows to table
table.put(puts);
Expand Down
16 changes: 8 additions & 8 deletions ...nnector-hbase-2.2/src/test/java/org/apache/flink/connector/hbase2/util/HBaseTestBase.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -120,7 +120,7 @@ private static void createHBaseTable1() throws IOException {
Timestamp.valueOf("2019-08-18 19:00:00"),
Date.valueOf("2019-08-18"),
Time.valueOf("19:00:00"),
new BigDecimal(12345678.0001)));
new BigDecimal("12345678.0001")));
puts.add(
putRow(
2,
Expand All @@ -133,7 +133,7 @@ private static void createHBaseTable1() throws IOException {
Timestamp.valueOf("2019-08-18 19:01:00"),
Date.valueOf("2019-08-18"),
Time.valueOf("19:01:00"),
new BigDecimal(12345678.0002)));
new BigDecimal("12345678.0002")));
puts.add(
putRow(
3,
Expand All @@ -146,7 +146,7 @@ private static void createHBaseTable1() throws IOException {
Timestamp.valueOf("2019-08-18 19:02:00"),
Date.valueOf("2019-08-18"),
Time.valueOf("19:02:00"),
new BigDecimal(12345678.0003)));
new BigDecimal("12345678.0003")));
puts.add(
putRow(
4,
Expand All @@ -159,7 +159,7 @@ private static void createHBaseTable1() throws IOException {
Timestamp.valueOf("2019-08-18 19:03:00"),
Date.valueOf("2019-08-18"),
Time.valueOf("19:03:00"),
new BigDecimal(12345678.0004)));
new BigDecimal("12345678.0004")));
puts.add(
putRow(
5,
Expand All @@ -172,7 +172,7 @@ private static void createHBaseTable1() throws IOException {
Timestamp.valueOf("2019-08-19 19:10:00"),
Date.valueOf("2019-08-19"),
Time.valueOf("19:10:00"),
new BigDecimal(12345678.0005)));
new BigDecimal("12345678.0005")));
puts.add(
putRow(
6,
Expand All @@ -185,7 +185,7 @@ private static void createHBaseTable1() throws IOException {
Timestamp.valueOf("2019-08-19 19:20:00"),
Date.valueOf("2019-08-19"),
Time.valueOf("19:20:00"),
new BigDecimal(12345678.0006)));
new BigDecimal("12345678.0006")));
puts.add(
putRow(
7,
Expand All @@ -198,7 +198,7 @@ private static void createHBaseTable1() throws IOException {
Timestamp.valueOf("2019-08-19 19:30:00"),
Date.valueOf("2019-08-19"),
Time.valueOf("19:30:00"),
new BigDecimal(12345678.0007)));
new BigDecimal("12345678.0007")));
puts.add(
putRow(
8,
Expand All @@ -211,7 +211,7 @@ private static void createHBaseTable1() throws IOException {
Timestamp.valueOf("2019-08-19 19:40:00"),
Date.valueOf("2019-08-19"),
Time.valueOf("19:40:00"),
new BigDecimal(12345678.0008)));
new BigDecimal("12345678.0008")));

// append rows to table
table.put(puts);
Expand Down

0 comments on commit 927a21c

Please sign in to comment.