8e96877a6951f19f06adb646d3eb5ffe24edddb5 - pulsar-connectors

commit	8e96877a6951f19f06adb646d3eb5ffe24edddb5	[log] [tgz]
author	Matteo Merli <mmerli@apache.org>	Thu Oct 24 11:27:30 2019 -0700
committer	GitHub <noreply@github.com>	Thu Oct 24 11:27:30 2019 -0700
tree	253f311ed23587914f3b32a2854c37646e29df87
parent	ae5f87358502a41713a2a0216db972eb6aa9ade7 [diff]

Multiple unit tests improvements (#5439)

* Multiple unit tests improvements

* Fixed Storm integration tests

* Fixed StringSchema static initialization

* Peg number of forks to number of cores

* Updated to 4 forks

* Fixed resourcel leak in managed ledger tests

* Use different temp folders for PulsarFunctionState test

* Increase retries count for PulsarFunctionE2ESecurityTest

* Fixed Flume connector test

* Fixed race conditions in primitive schema types static initialization

* Improve port manager

* Removed PulsarFunctionStateTest to move to integration tests

* Fixed dangling class reference

pulsar-io/file/src/test/java/org/apache/pulsar/io/file/AbstractFileTests.java[diff]
pulsar-io/file/src/test/java/org/apache/pulsar/io/file/FileConsumerThreadTests.java[diff]
pulsar-io/file/src/test/java/org/apache/pulsar/io/file/FileListingThreadTests.java[diff]
pulsar-io/file/src/test/java/org/apache/pulsar/io/file/ProcessedFileThreadTests.java[diff]
pulsar-io/flume/src/test/java/org/apache/pulsar/io/flume/sink/StringSinkTests.java[diff]
pulsar-io/flume/src/test/java/org/apache/pulsar/io/flume/source/StringSourceTests.java[diff]
pulsar-io/flume/src/test/resources/flume/sink.conf[diff]

7 files changed

tree: 253f311ed23587914f3b32a2854c37646e29df87

pulsar-io/