This is an automated email from the ASF dual-hosted git repository.
dannycranmer pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from cb3bd04 [hotfix][metrics] Remove unnecessary @Nullable annotation
add 195298a [FLINK-20042][kinesis] Adding Kinesis Table API e2e test
using the Java framework (#15085)
No new revisions were added by this update.
Summary of changes:
.../kinesis/testutils/KinesisPubsubClient.java | 4 +-
.../flink-streaming-kinesis-test/pom.xml | 31 ++++
.../streaming/kinesis/test/filter-large-orders.sql | 46 ++++++
.../kinesis/test/KinesisTableApiITCase.java | 166 +++++++++++++++++++++
.../test/containers/KinesaliteContainer.java | 52 +++++++
.../flink/streaming/kinesis/test/model/Order.java} | 45 +++---
6 files changed, 316 insertions(+), 28 deletions(-)
create mode 100644
flink-end-to-end-tests/flink-streaming-kinesis-test/src/main/resources/org/apache/flink/streaming/kinesis/test/filter-large-orders.sql
create mode 100644
flink-end-to-end-tests/flink-streaming-kinesis-test/src/test/java/org/apache/flink/streaming/kinesis/test/KinesisTableApiITCase.java
create mode 100644
flink-end-to-end-tests/flink-streaming-kinesis-test/src/test/java/org/apache/flink/streaming/kinesis/test/containers/KinesaliteContainer.java
copy
flink-end-to-end-tests/{flink-queryable-state-test/src/main/java/org/apache/flink/streaming/tests/queryablestate/EmailId.java
=>
flink-streaming-kinesis-test/src/test/java/org/apache/flink/streaming/kinesis/test/model/Order.java}
(58%)
