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%)
