log4j:ERROR Flume append() failed

報錯

21:52:36.622 [main] DEBUG org.apache.flume.api.NettyAvroRpcClient - Batch size string = null

21:52:36.622 [main] WARN org.apache.flume.api.NettyAvroRpcClient - Using default maxIOWorkers

21:52:36.653 [main] DEBUG org.apache.avro.ipc.NettyTransceiver - Using Netty bootstrap options: {tcpNoDelay=true, connectTimeoutMillis=20000}

21:52:36.653 [main] DEBUG org.apache.avro.ipc.NettyTransceiver - Connecting to /192.168.1.101:4444

21:52:36.654 [main] DEBUG org.apache.avro.ipc.NettyTransceiver - [id: 0x15681dfd] OPEN

21:52:36.656 [New I/O worker #10] DEBUG org.apache.avro.ipc.NettyTransceiver - [id: 0x15681dfd, /192.168.1.101:49235 => /192.168.1.101:4444] BOUND: /192.168.1.101:49235

21:52:36.656 [New I/O worker #10] DEBUG org.apache.avro.ipc.NettyTransceiver - [id: 0x15681dfd, /192.168.1.101:49235 => /192.168.1.101:4444] CONNECTED: /192.168.1.101:4444

21:52:36.660 [New I/O worker #10] DEBUG org.apache.avro.ipc.NettyTransceiver - [id: 0x15681dfd, /192.168.1.101:49235 :> /192.168.1.101:4444] DISCONNECTED

21:52:36.660 [New I/O worker #10] DEBUG org.apache.avro.ipc.NettyTransceiver - [id: 0x15681dfd, /192.168.1.101:49235 :> /192.168.1.101:4444] UNBOUND

21:52:36.660 [New I/O worker #10] DEBUG org.apache.avro.ipc.NettyTransceiver - [id: 0x15681dfd, /192.168.1.101:49235 :> /192.168.1.101:4444] CLOSED

21:52:36.660 [New I/O worker #10] DEBUG org.apache.avro.ipc.NettyTransceiver - Remote peer /192.168.1.101:4444 closed connection.

21:52:36.660 [New I/O worker #10] DEBUG org.apache.avro.ipc.NettyTransceiver - Disconnecting from /192.168.1.101:4444

21:52:36.660 [New I/O worker #10] DEBUG org.apache.avro.ipc.NettyTransceiver - Removing 1 pending request(s).

log4j:ERROR Flume append() failed.

解決

更改 F:\apache-flume-1.7.0-bin\conf\example.conf

 #a1.sources.r1.type = netcat

 a1.sources.r1.type = avro