merlimat commented on issue #3597: [Issue 3275][pulsar-io]Support source and sink of flume URL: https://github.com/apache/pulsar/pull/3597#issuecomment-484158992 @tuteng I've seen a failure in the tests for this connector. ``` Standard Output Created annotation listener 14:22:32.466 [main:org.apache.flume.source.AvroSource@205] ERROR org.apache.flume.source.AvroSource - Avro source null startup failed. Cannot initialize Netty server org.jboss.netty.channel.ChannelException: Failed to bind to: /0.0.0.0:44444 at org.jboss.netty.bootstrap.ServerBootstrap.bind(ServerBootstrap.java:272) ~[netty-3.10.1.Final.jar:?] at org.apache.avro.ipc.NettyServer.<init>(NettyServer.java:106) ~[avro-ipc-1.8.1.jar:1.8.1] at org.apache.flume.source.AvroSource.start(AvroSource.java:202) [flume-ng-core-1.9.0.jar:1.9.0] at org.apache.pulsar.io.flume.sink.StringSinkTests.setUp(StringSinkTests.java:82) [test-classes/:?] .... at org.apache.maven.surefire.booter.ForkedBooter.main(ForkedBooter.java:413) [surefire-booter-2.21.0.jar:2.21.0] Caused by: java.net.BindException: Address already in use ``` I was trying to see if it's possible to check for an open port and use that from the config files. We have already a class to get that in: ```xml <dependency> <groupId>${project.groupId}</groupId> <artifactId>managed-ledger-original</artifactId> <version>${project.version}</version> <scope>test</scope> </dependency> ``` The you could just call `PortManager.nextFreePort()`.
---------------------------------------------------------------- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org With regards, Apache Git Services
