This is an automated email from the ASF dual-hosted git repository.
bhulette pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git.
from 8a9a259 Fix regex in Kotlin MinimalWordCount example. (#13570)
add 6171a36 [BEAM-11456] Fix flaky table provider tests (Kafka and
Pubsub) (#13542)
No new revisions were added by this update.
Summary of changes:
sdks/java/extensions/sql/build.gradle | 12 -
.../provider/kafka/KafkaTableProviderAvroIT.java | 39 ---
.../provider/kafka/KafkaTableProviderCSVIT.java | 42 ----
.../meta/provider/kafka/KafkaTableProviderIT.java | 169 +++++++++++--
.../provider/kafka/KafkaTableProviderJsonIT.java | 40 ---
.../provider/kafka/KafkaTableProviderProtoIT.java | 53 ----
.../sql/meta/provider/pubsub/PubsubAvroIT.java | 102 --------
.../sql/meta/provider/pubsub/PubsubJsonIT.java | 76 ------
.../provider/pubsub/PubsubTableProviderIT.java | 273 ++++++++++++++++-----
9 files changed, 355 insertions(+), 451 deletions(-)
delete mode 100644
sdks/java/extensions/sql/src/test/java/org/apache/beam/sdk/extensions/sql/meta/provider/kafka/KafkaTableProviderAvroIT.java
delete mode 100644
sdks/java/extensions/sql/src/test/java/org/apache/beam/sdk/extensions/sql/meta/provider/kafka/KafkaTableProviderCSVIT.java
delete mode 100644
sdks/java/extensions/sql/src/test/java/org/apache/beam/sdk/extensions/sql/meta/provider/kafka/KafkaTableProviderJsonIT.java
delete mode 100644
sdks/java/extensions/sql/src/test/java/org/apache/beam/sdk/extensions/sql/meta/provider/kafka/KafkaTableProviderProtoIT.java
delete mode 100644
sdks/java/extensions/sql/src/test/java/org/apache/beam/sdk/extensions/sql/meta/provider/pubsub/PubsubAvroIT.java
delete mode 100644
sdks/java/extensions/sql/src/test/java/org/apache/beam/sdk/extensions/sql/meta/provider/pubsub/PubsubJsonIT.java
