[incubator-inlong] branch master updated: [INLONG-1973][Bug][InLong-Manager] modify demo config class package (#1974)

[go...@apache.org]

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/incubator-inlong.git


The following commit(s) were added to refs/heads/master by this push:
     new 51340d0  [INLONG-1973][Bug][InLong-Manager] modify demo config class package (#1974)
51340d0 is described below

commit 51340d07ce4efbd11df3f10fb60a979026f0e697
Author: baomingyu <ba...@163.com>
AuthorDate: Tue Dec 14 11:33:34 2021 +0800

    [INLONG-1973][Bug][InLong-Manager] modify demo config class package (#1974)
---
 inlong-dataproxy/conf/flume-mulit-pulsar-demo.conf | 14 +++++++-------
 1 file changed, 7 insertions(+), 7 deletions(-)

diff --git a/inlong-dataproxy/conf/flume-mulit-pulsar-demo.conf b/inlong-dataproxy/conf/flume-mulit-pulsar-demo.conf
index f28c274..851ba75 100644
--- a/inlong-dataproxy/conf/flume-mulit-pulsar-demo.conf
+++ b/inlong-dataproxy/conf/flume-mulit-pulsar-demo.conf
@@ -23,8 +23,8 @@ agent1.sinks = pulsar-sink-msg1 pulsar-sink-msg2 pulsar-sink-msg5 pulsar-sink-ms
 
 
 agent1.sources.tcp-source.channels = ch-msg1 ch-msg2 ch-msg5 ch-msg6
-agent1.sources.tcp-source.type = org.apache.flume.source.SimpleTcpSource
-agent1.sources.tcp-source.msg-factory-name = org.apache.flume.source.ServerMessageFactory
+agent1.sources.tcp-source.type = org.apache.inlong.dataproxy.source.SimpleTcpSource
+agent1.sources.tcp-source.msg-factory-name = org.apache.inlong.dataproxy.source.ServerMessageFactory
 agent1.sources.tcp-source.host = 127.0.0.1
 agent1.sources.tcp-source.port = 46801
 agent1.sources.tcp-source.max-msg-length = 524288
@@ -35,7 +35,7 @@ agent1.sources.tcp-source.max-threads = 64
 agent1.sources.tcp-source.receiveBufferSize = 1048576
 agent1.sources.tcp-source.sendBufferSize = 1048576
 agent1.sources.tcp-source.custom-cp = true
-agent1.sources.tcp-source.selector.type = org.apache.flume.channel.FailoverChannelSelector
+agent1.sources.tcp-source.selector.type = org.apache.inlong.dataproxy.channel.FailoverChannelSelector
 agent1.sources.tcp-source.selector.master = ch-msg1 ch-msg2
 agent1.sources.tcp-source.metric-recovery-path=/data/DataProxy/file/recovery
 agent1.sources.tcp-source.metric-agent-port=8003
@@ -72,7 +72,7 @@ agent1.channels.ch-msg6.fsyncInterval = 10
 
 
 agent1.sinks.pulsar-sink-msg1.channel = ch-msg1
-agent1.sinks.pulsar-sink-msg1.type = org.apache.flume.sink.PulsarSink
+agent1.sinks.pulsar-sink-msg1.type = org.apache.inlong.dataproxy.sink.PulsarSink
 agent1.sinks.pulsar-sink-msg1.pulsar_server_url_list = pulsar://127.0.0.1:6650,127.0.0.2:6650|pulsar://127.0.0.3:6650
 agent1.sinks.pulsar-sink-msg1.send_timeout_MILL = 30000
 agent1.sinks.pulsar-sink-msg1.stat_interval_sec = 60
@@ -84,7 +84,7 @@ agent1.sinks.pulsar-sink-msg1.netty_write_buffer_high_water_mark = 20971520
 agent1.sinks.pulsar-sink-msg1.disk-io-rate-per-sec=20000000
 
 agent1.sinks.pulsar-sink-msg2.channel = ch-msg2
-agent1.sinks.pulsar-sink-msg2.type = org.apache.flume.sink.PulsarSink
+agent1.sinks.pulsar-sink-msg2.type = org.apache.inlong.dataproxy.sink.PulsarSink
 agent1.sinks.pulsar-sink-msg2.pulsar_server_url_list = pulsar://127.0.0.1:6650,127.0.0.2:6650|pulsar://127.0.0.3:6650
 agent1.sinks.pulsar-sink-msg2.send_timeout_MILL = 30000
 agent1.sinks.pulsar-sink-msg2.stat_interval_sec = 60
@@ -96,7 +96,7 @@ agent1.sinks.pulsar-sink-msg2.netty_write_buffer_high_water_mark = 20971520
 agent1.sinks.pulsar-sink-msg2.disk-io-rate-per-sec=20000000
 
 agent1.sinks.pulsar-sink-msg5.channel = ch-msg5
-agent1.sinks.pulsar-sink-msg5.type = org.apache.flume.sink.PulsarSink
+agent1.sinks.pulsar-sink-msg5.type = org.apache.inlong.dataproxy.sink.PulsarSink
 agent1.sinks.pulsar-sink-msg5.pulsar_server_url_list = pulsar://127.0.0.1:6650,127.0.0.2:6650|pulsar://127.0.0.3:6650
 agent1.sinks.pulsar-sink-msg5.send_timeout_MILL = 30000
 agent1.sinks.pulsar-sink-msg5.stat_interval_sec = 60
@@ -108,7 +108,7 @@ agent1.sinks.pulsar-sink-msg5.netty_write_buffer_high_water_mark = 20971520
 agent1.sinks.pulsar-sink-msg5.disk-io-rate-per-sec=20000000
 
 agent1.sinks.pulsar-sink-msg6.channel = ch-msg6
-agent1.sinks.pulsar-sink-msg6.type = org.apache.flume.sink.PulsarSink
+agent1.sinks.pulsar-sink-msg6.type = org.apache.inlong.dataproxy.PulsarSink
 agent1.sinks.pulsar-sink-msg6.pulsar_server_url_list = pulsar://127.0.0.1:6650,127.0.0.2:6650|pulsar://127.0.0.3:6650
 agent1.sinks.pulsar-sink-msg6.send_timeout_MILL = 30000
 agent1.sinks.pulsar-sink-msg6.stat_interval_sec = 60