This is an automated email from the ASF dual-hosted git repository.
gosonzhang pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/inlong.git
The following commit(s) were added to refs/heads/master by this push:
new b398084687 [INLONG-8459][DataProxy]Fix code scanning alert - Implicit
narrowing conversion in compound assignment (#8460)
b398084687 is described below
commit b398084687496e4636140706841e183c622bf7fe
Author: Goson Zhang <[email protected]>
AuthorDate: Fri Jul 7 15:20:02 2023 +0800
[INLONG-8459][DataProxy]Fix code scanning alert - Implicit narrowing
conversion in compound assignment (#8460)
---
.../org/apache/inlong/dataproxy/sink/mq/PackProfile.java | 12 ++++++------
1 file changed, 6 insertions(+), 6 deletions(-)
diff --git
a/inlong-dataproxy/dataproxy-source/src/main/java/org/apache/inlong/dataproxy/sink/mq/PackProfile.java
b/inlong-dataproxy/dataproxy-source/src/main/java/org/apache/inlong/dataproxy/sink/mq/PackProfile.java
index 87ebe736c8..1867e6a8ce 100644
---
a/inlong-dataproxy/dataproxy-source/src/main/java/org/apache/inlong/dataproxy/sink/mq/PackProfile.java
+++
b/inlong-dataproxy/dataproxy-source/src/main/java/org/apache/inlong/dataproxy/sink/mq/PackProfile.java
@@ -33,8 +33,8 @@ public abstract class PackProfile {
private final long dispatchTime;
private final long createTime = System.currentTimeMillis();
private final String uid;
- protected int count = 0;
- protected int size = 0;
+ protected long count = 0;
+ protected long size = 0;
protected final boolean enableRetryAfterFailure;
protected final int maxRetries;
protected int retries = 0;
@@ -96,7 +96,7 @@ public abstract class PackProfile {
*
* @return the count
*/
- public int getCount() {
+ public long getCount() {
return count;
}
@@ -105,7 +105,7 @@ public abstract class PackProfile {
*
* @param count the count to set
*/
- public void setCount(int count) {
+ public void setCount(long count) {
this.count = count;
}
@@ -114,7 +114,7 @@ public abstract class PackProfile {
*
* @return the size
*/
- public int getSize() {
+ public long getSize() {
return size;
}
@@ -123,7 +123,7 @@ public abstract class PackProfile {
*
* @param size the size to set
*/
- public void setSize(int size) {
+ public void setSize(long size) {
this.size = size;
}