You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by mm...@apache.org on 2021/06/06 13:52:11 UTC
[pulsar] branch master updated: Fix the wrong specification of the
Java modifier in the implementation of Pulsar Connect's Record interface.
(#10836)
This is an automated email from the ASF dual-hosted git repository.
mmerli pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar.git
The following commit(s) were added to refs/heads/master by this push:
new a8e72e0 Fix the wrong specification of the Java modifier in the implementation of Pulsar Connect's Record interface. (#10836)
a8e72e0 is described below
commit a8e72e021d353defb4a46c506d38ca74eb88b335
Author: lzhpo <lz...@qq.com>
AuthorDate: Sun Jun 6 21:51:35 2021 +0800
Fix the wrong specification of the Java modifier in the implementation of Pulsar Connect's Record interface. (#10836)
---
.../src/main/java/org/apache/pulsar/io/canal/CanalAbstractSource.java | 2 +-
.../src/main/java/org/apache/pulsar/io/flume/source/AbstractSource.java | 2 +-
.../java/org/apache/pulsar/io/netty/http/NettyHttpServerHandler.java | 2 +-
.../main/java/org/apache/pulsar/io/netty/tcp/NettyTCPServerHandler.java | 2 +-
.../main/java/org/apache/pulsar/io/netty/udp/NettyUDPServerHandler.java | 2 +-
pulsar-io/nsq/src/main/java/org/apache/pulsar/io/nsq/NSQSource.java | 2 +-
.../src/main/java/org/apache/pulsar/io/rabbitmq/RabbitMQSource.java | 2 +-
7 files changed, 7 insertions(+), 7 deletions(-)
diff --git a/pulsar-io/canal/src/main/java/org/apache/pulsar/io/canal/CanalAbstractSource.java b/pulsar-io/canal/src/main/java/org/apache/pulsar/io/canal/CanalAbstractSource.java
index 65bcc86..10f40b7 100644
--- a/pulsar-io/canal/src/main/java/org/apache/pulsar/io/canal/CanalAbstractSource.java
+++ b/pulsar-io/canal/src/main/java/org/apache/pulsar/io/canal/CanalAbstractSource.java
@@ -143,7 +143,7 @@ public abstract class CanalAbstractSource<V> extends PushSource<V> {
@Getter
@Setter
- static private class CanalRecord<V> implements Record<V> {
+ private static class CanalRecord<V> implements Record<V> {
private V record;
private Long id;
diff --git a/pulsar-io/flume/src/main/java/org/apache/pulsar/io/flume/source/AbstractSource.java b/pulsar-io/flume/src/main/java/org/apache/pulsar/io/flume/source/AbstractSource.java
index fcc4c78..0cf0b1e 100644
--- a/pulsar-io/flume/src/main/java/org/apache/pulsar/io/flume/source/AbstractSource.java
+++ b/pulsar-io/flume/src/main/java/org/apache/pulsar/io/flume/source/AbstractSource.java
@@ -112,7 +112,7 @@ public abstract class AbstractSource<V> extends PushSource<V> {
@Getter
@Setter
- static private class FlumeRecord<V> implements Record<V> {
+ private static class FlumeRecord<V> implements Record<V> {
private V record;
private Long id;
diff --git a/pulsar-io/netty/src/main/java/org/apache/pulsar/io/netty/http/NettyHttpServerHandler.java b/pulsar-io/netty/src/main/java/org/apache/pulsar/io/netty/http/NettyHttpServerHandler.java
index 152815e..9cfa446 100644
--- a/pulsar-io/netty/src/main/java/org/apache/pulsar/io/netty/http/NettyHttpServerHandler.java
+++ b/pulsar-io/netty/src/main/java/org/apache/pulsar/io/netty/http/NettyHttpServerHandler.java
@@ -137,7 +137,7 @@ public class NettyHttpServerHandler extends SimpleChannelInboundHandler<Object>
}
@Data
- static private class NettyHttpRecord implements Record<byte[]>, Serializable {
+ private static class NettyHttpRecord implements Record<byte[]>, Serializable {
private final Optional<String> key;
private final byte[] value;
}
diff --git a/pulsar-io/netty/src/main/java/org/apache/pulsar/io/netty/tcp/NettyTCPServerHandler.java b/pulsar-io/netty/src/main/java/org/apache/pulsar/io/netty/tcp/NettyTCPServerHandler.java
index a619bc3..0d3f837 100644
--- a/pulsar-io/netty/src/main/java/org/apache/pulsar/io/netty/tcp/NettyTCPServerHandler.java
+++ b/pulsar-io/netty/src/main/java/org/apache/pulsar/io/netty/tcp/NettyTCPServerHandler.java
@@ -57,7 +57,7 @@ public class NettyTCPServerHandler extends SimpleChannelInboundHandler<byte[]> {
}
@Data
- static private class NettyTCPRecord implements Record<byte[]>, Serializable {
+ private static class NettyTCPRecord implements Record<byte[]>, Serializable {
private final Optional<String> key;
private final byte[] value;
}
diff --git a/pulsar-io/netty/src/main/java/org/apache/pulsar/io/netty/udp/NettyUDPServerHandler.java b/pulsar-io/netty/src/main/java/org/apache/pulsar/io/netty/udp/NettyUDPServerHandler.java
index 8341628..397d15c 100644
--- a/pulsar-io/netty/src/main/java/org/apache/pulsar/io/netty/udp/NettyUDPServerHandler.java
+++ b/pulsar-io/netty/src/main/java/org/apache/pulsar/io/netty/udp/NettyUDPServerHandler.java
@@ -59,7 +59,7 @@ public class NettyUDPServerHandler extends SimpleChannelInboundHandler<DatagramP
}
@Data
- static private class NettyUDPRecord implements Record<byte[]>, Serializable {
+ private static class NettyUDPRecord implements Record<byte[]>, Serializable {
private final Optional<String> key;
private final byte[] value;
}
diff --git a/pulsar-io/nsq/src/main/java/org/apache/pulsar/io/nsq/NSQSource.java b/pulsar-io/nsq/src/main/java/org/apache/pulsar/io/nsq/NSQSource.java
index 1b7cd87..acb8fa6 100644
--- a/pulsar-io/nsq/src/main/java/org/apache/pulsar/io/nsq/NSQSource.java
+++ b/pulsar-io/nsq/src/main/java/org/apache/pulsar/io/nsq/NSQSource.java
@@ -102,7 +102,7 @@ public class NSQSource extends PushSource<byte[]> {
}
@Data
- static private class NSQRecord implements Record<byte[]> {
+ private static class NSQRecord implements Record<byte[]> {
private final byte[] value;
}
}
diff --git a/pulsar-io/rabbitmq/src/main/java/org/apache/pulsar/io/rabbitmq/RabbitMQSource.java b/pulsar-io/rabbitmq/src/main/java/org/apache/pulsar/io/rabbitmq/RabbitMQSource.java
index 188b219..d00aac4 100644
--- a/pulsar-io/rabbitmq/src/main/java/org/apache/pulsar/io/rabbitmq/RabbitMQSource.java
+++ b/pulsar-io/rabbitmq/src/main/java/org/apache/pulsar/io/rabbitmq/RabbitMQSource.java
@@ -108,7 +108,7 @@ public class RabbitMQSource extends PushSource<byte[]> {
}
@Data
- static private class RabbitMQRecord implements Record<byte[]> {
+ private static class RabbitMQRecord implements Record<byte[]> {
private final Optional<String> key;
private final byte[] value;
}