This is an automated email from the ASF dual-hosted git repository. aromanenko pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/beam.git.
from f8d59e4 Merge pull request #8333: [BEAM-7097] Upgrade MqttIO to use fusesource mqtt-client 1.15 new 131f840 [BEAM-7027] Use same method to find a new local available port in IO tests new 8a01b75 [BEAM-7027] IO tests should not be annotated with Categories new 6616870 [BEAM-7027] Add missing @RunWith(JUnit4.class) annotation to IO tests new 894b8c3 [BEAM-7027] Restrict access level in some IO tests utility classes new 1ad61fd Merge pull request #8307: [BEAM-7027] Use same method to find a new local available port in IO tests The 21054 revisions listed above as "new" are entirely new to this repository and will be described in separate emails. The revisions listed as "add" were already present in the repository and have only been added to this reference. Summary of changes: sdks/java/io/amazon-web-services/build.gradle | 2 +- .../beam/sdk/io/cassandra/CassandraIOTest.java | 31 +++++++++------------- .../beam/sdk/io/clickhouse/AtomicInsertTest.java | 3 --- .../beam/sdk/io/clickhouse/ClickHouseIOTest.java | 3 --- .../beam/sdk/io/common/NetworkTestHelper.java} | 22 +++++++-------- .../sdk/io/elasticsearch/ElasticsearchIOTest.java | 6 ++--- .../sdk/io/elasticsearch/ElasticsearchIOIT.java | 3 +++ .../sdk/io/elasticsearch/ElasticsearchIOIT.java | 3 +++ sdks/java/io/elasticsearch/build.gradle | 2 +- .../sdk/io/gcp/bigquery/BigQueryUtilsTest.java | 3 +++ .../beam/sdk/io/gcp/pubsub/PubsubIOTest.java | 5 ---- .../sdk/io/gcp/spanner/MutationKeyEncoderTest.java | 3 +++ .../io/gcp/spanner/MutationSizeEstimatorTest.java | 3 +++ .../beam/sdk/io/gcp/spanner/RandomUtils.java | 4 +-- .../sdk/io/gcp/spanner/ReadSpannerSchemaTest.java | 3 +++ .../sdk/io/gcp/spanner/SpannerIOWriteTest.java | 8 ------ .../beam/sdk/io/gcp/spanner/SpannerSchemaTest.java | 3 +++ .../io/hadoop/format/HDFSSynchronizationTest.java | 3 +++ .../hadoop/format/HadoopFormatIOCassandraTest.java | 18 ++++--------- .../hadoop/format/HadoopFormatIOElasticTest.java | 13 ++++----- .../sdk/io/hadoop/format/HadoopFormatIOIT.java | 3 +++ .../format/HadoopFormatIOSequenceFileTest.java | 7 +++-- .../sdk/io/hadoop/format/IterableCombinerTest.java | 3 +++ .../hadoop/inputformat/HIFIOWithElasticTest.java | 13 ++++----- .../HIFIOWithEmbeddedCassandraTest.java | 14 +++------- .../hadoop/inputformat/HadoopInputFormatIOIT.java | 3 +++ .../sdk/io/hcatalog/HCatalogBeamSchemaTest.java | 3 +++ .../beam/sdk/io/hcatalog/HCatalogIOTest.java | 3 +++ .../org/apache/beam/sdk/io/jdbc/JdbcIOTest.java | 14 +++++----- .../beam/sdk/io/kafka/KafkaIOExternalTest.java | 3 +++ .../beam/sdk/io/kinesis/CustomOptionalTest.java | 3 +++ .../apache/beam/sdk/io/kinesis/KinesisIOIT.java | 3 +++ .../beam/sdk/io/kinesis/KinesisMockReadTest.java | 3 +++ .../sdk/io/kinesis/KinesisRecordCoderTest.java | 3 +++ .../io/kinesis/StartingPointShardsFinderTest.java | 3 +++ .../java/org/apache/beam/sdk/io/kudu/KuduIOIT.java | 3 +++ .../org/apache/beam/sdk/io/kudu/KuduIOTest.java | 3 +++ .../beam/sdk/io/mongodb/MongoDBGridFSIOTest.java | 10 +++---- .../apache/beam/sdk/io/mongodb/MongoDbIOTest.java | 14 +++++----- sdks/java/io/mqtt/build.gradle | 1 + .../org/apache/beam/sdk/io/mqtt/MqttIOTest.java | 11 ++++---- sdks/java/io/rabbitmq/build.gradle | 1 + .../beam/sdk/io/rabbitmq/RabbitMqIOTest.java | 10 +++---- sdks/java/io/redis/build.gradle | 1 + .../org/apache/beam/sdk/io/redis/RedisIOTest.java | 9 ++++--- sdks/java/io/solr/build.gradle | 2 +- .../org/apache/beam/sdk/io/solr/SolrIOTest.java | 3 +++ .../beam/sdk/io/synthetic/SyntheticTestUtils.java | 4 +-- .../apache/beam/sdk/io/tika/ParseResultTest.java | 3 +++ .../org/apache/beam/sdk/io/tika/TikaIOTest.java | 3 +++ .../java/org/apache/beam/sdk/io/xml/XmlIOTest.java | 3 --- .../org/apache/beam/sdk/io/xml/XmlSourceTest.java | 3 --- 52 files changed, 159 insertions(+), 147 deletions(-) copy sdks/java/{core/src/main/java/org/apache/beam/sdk/coders/CoderException.java => io/common/src/test/java/org/apache/beam/sdk/io/common/NetworkTestHelper.java} (66%)