Skip to content

Commit 22d583f

Browse files
twalthrtwalthr
committed
[hotfix][hbase] Fix warnings around decimals in HBaseTestBase
1 parent 8791ed2 commit 22d583f

File tree

2 files changed

+16
-16
lines changed

2 files changed

+16
-16
lines changed

‎flink-connectors/flink-connector-hbase-1.4/src/test/java/org/apache/flink/connector/hbase1/util/HBaseTestBase.java‎

Lines changed: 8 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -120,7 +120,7 @@ private static void createHBaseTable1() throws IOException {
120120
Timestamp.valueOf("2019-08-18 19:00:00"),
121121
Date.valueOf("2019-08-18"),
122122
Time.valueOf("19:00:00"),
123-
new BigDecimal(12345678.0001)));
123+
new BigDecimal("12345678.0001")));
124124
puts.add(
125125
putRow(
126126
2,
@@ -133,7 +133,7 @@ private static void createHBaseTable1() throws IOException {
133133
Timestamp.valueOf("2019-08-18 19:01:00"),
134134
Date.valueOf("2019-08-18"),
135135
Time.valueOf("19:01:00"),
136-
new BigDecimal(12345678.0002)));
136+
new BigDecimal("12345678.0002")));
137137
puts.add(
138138
putRow(
139139
3,
@@ -146,7 +146,7 @@ private static void createHBaseTable1() throws IOException {
146146
Timestamp.valueOf("2019-08-18 19:02:00"),
147147
Date.valueOf("2019-08-18"),
148148
Time.valueOf("19:02:00"),
149-
new BigDecimal(12345678.0003)));
149+
new BigDecimal("12345678.0003")));
150150
puts.add(
151151
putRow(
152152
4,
@@ -159,7 +159,7 @@ private static void createHBaseTable1() throws IOException {
159159
Timestamp.valueOf("2019-08-18 19:03:00"),
160160
Date.valueOf("2019-08-18"),
161161
Time.valueOf("19:03:00"),
162-
new BigDecimal(12345678.0004)));
162+
new BigDecimal("12345678.0004")));
163163
puts.add(
164164
putRow(
165165
5,
@@ -172,7 +172,7 @@ private static void createHBaseTable1() throws IOException {
172172
Timestamp.valueOf("2019-08-19 19:10:00"),
173173
Date.valueOf("2019-08-19"),
174174
Time.valueOf("19:10:00"),
175-
new BigDecimal(12345678.0005)));
175+
new BigDecimal("12345678.0005")));
176176
puts.add(
177177
putRow(
178178
6,
@@ -185,7 +185,7 @@ private static void createHBaseTable1() throws IOException {
185185
Timestamp.valueOf("2019-08-19 19:20:00"),
186186
Date.valueOf("2019-08-19"),
187187
Time.valueOf("19:20:00"),
188-
new BigDecimal(12345678.0006)));
188+
new BigDecimal("12345678.0006")));
189189
puts.add(
190190
putRow(
191191
7,
@@ -198,7 +198,7 @@ private static void createHBaseTable1() throws IOException {
198198
Timestamp.valueOf("2019-08-19 19:30:00"),
199199
Date.valueOf("2019-08-19"),
200200
Time.valueOf("19:30:00"),
201-
new BigDecimal(12345678.0007)));
201+
new BigDecimal("12345678.0007")));
202202
puts.add(
203203
putRow(
204204
8,
@@ -211,7 +211,7 @@ private static void createHBaseTable1() throws IOException {
211211
Timestamp.valueOf("2019-08-19 19:40:00"),
212212
Date.valueOf("2019-08-19"),
213213
Time.valueOf("19:40:00"),
214-
new BigDecimal(12345678.0008)));
214+
new BigDecimal("12345678.0008")));
215215

216216
// append rows to table
217217
table.put(puts);

‎flink-connectors/flink-connector-hbase-2.2/src/test/java/org/apache/flink/connector/hbase2/util/HBaseTestBase.java‎

Lines changed: 8 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -120,7 +120,7 @@ private static void createHBaseTable1() throws IOException {
120120
Timestamp.valueOf("2019-08-18 19:00:00"),
121121
Date.valueOf("2019-08-18"),
122122
Time.valueOf("19:00:00"),
123-
new BigDecimal(12345678.0001)));
123+
new BigDecimal("12345678.0001")));
124124
puts.add(
125125
putRow(
126126
2,
@@ -133,7 +133,7 @@ private static void createHBaseTable1() throws IOException {
133133
Timestamp.valueOf("2019-08-18 19:01:00"),
134134
Date.valueOf("2019-08-18"),
135135
Time.valueOf("19:01:00"),
136-
new BigDecimal(12345678.0002)));
136+
new BigDecimal("12345678.0002")));
137137
puts.add(
138138
putRow(
139139
3,
@@ -146,7 +146,7 @@ private static void createHBaseTable1() throws IOException {
146146
Timestamp.valueOf("2019-08-18 19:02:00"),
147147
Date.valueOf("2019-08-18"),
148148
Time.valueOf("19:02:00"),
149-
new BigDecimal(12345678.0003)));
149+
new BigDecimal("12345678.0003")));
150150
puts.add(
151151
putRow(
152152
4,
@@ -159,7 +159,7 @@ private static void createHBaseTable1() throws IOException {
159159
Timestamp.valueOf("2019-08-18 19:03:00"),
160160
Date.valueOf("2019-08-18"),
161161
Time.valueOf("19:03:00"),
162-
new BigDecimal(12345678.0004)));
162+
new BigDecimal("12345678.0004")));
163163
puts.add(
164164
putRow(
165165
5,
@@ -172,7 +172,7 @@ private static void createHBaseTable1() throws IOException {
172172
Timestamp.valueOf("2019-08-19 19:10:00"),
173173
Date.valueOf("2019-08-19"),
174174
Time.valueOf("19:10:00"),
175-
new BigDecimal(12345678.0005)));
175+
new BigDecimal("12345678.0005")));
176176
puts.add(
177177
putRow(
178178
6,
@@ -185,7 +185,7 @@ private static void createHBaseTable1() throws IOException {
185185
Timestamp.valueOf("2019-08-19 19:20:00"),
186186
Date.valueOf("2019-08-19"),
187187
Time.valueOf("19:20:00"),
188-
new BigDecimal(12345678.0006)));
188+
new BigDecimal("12345678.0006")));
189189
puts.add(
190190
putRow(
191191
7,
@@ -198,7 +198,7 @@ private static void createHBaseTable1() throws IOException {
198198
Timestamp.valueOf("2019-08-19 19:30:00"),
199199
Date.valueOf("2019-08-19"),
200200
Time.valueOf("19:30:00"),
201-
new BigDecimal(12345678.0007)));
201+
new BigDecimal("12345678.0007")));
202202
puts.add(
203203
putRow(
204204
8,
@@ -211,7 +211,7 @@ private static void createHBaseTable1() throws IOException {
211211
Timestamp.valueOf("2019-08-19 19:40:00"),
212212
Date.valueOf("2019-08-19"),
213213
Time.valueOf("19:40:00"),
214-
new BigDecimal(12345678.0008)));
214+
new BigDecimal("12345678.0008")));
215215

216216
// append rows to table
217217
table.put(puts);

0 commit comments

Comments
 (0)