Bulk Operation

FLINK-8970 Add end2end stream sql test for unbounded operators

FLINK-8970 Modify one of the s3 tests to use the Presto S3 s3p schema

FLINK-8970 Add S3 entropy injection end-to-end/IT test

FLINK-8970 Add stress deployment end-to-end test

FLINK-8970 End-to-end test: Take & resume from savepoint when using per-job mode

FLINK-8970 End-to-end test: Metrics accessible via REST API

FLINK-8970 End-to-end test: Prometheus reporter

FLINK-8970 Run general purpose test job with failures in per-job mode

FLINK-8970 Add end-to-end test for REST communication encryption

FLINK-8970 End-to-end test: Elasticsearch 6.x connector

FLINK-8970 End-to-end test: Streaming job with SSL

FLINK-8970 End-to-end test: SQL Client with unified source/sink/format

FLINK-8970 End-to-end test: Flink-Example module [flink-examples-streaming]

FLINK-8970 End-to-end test: Scala Quickstarts

FLINK-8970 Let externalized checkpoint resume e2e also test rescaling

FLINK-8970 End-to-end test: Python API

FLINK-8970 End-to-end test: Kubernetes integration

FLINK-8970 Update `test-ha.sh` end-to-end test to use general purpose DataStream job

FLINK-8970 End-to-end test: Add test that verifies that a specific classloading issue with avro is fixed

FLINK-8970 End-to-end test: Resume from retained checkpoints

FLINK-8970 Resume from savepoint end-to-end tests should be extended for different state backends

FLINK-8970 End-to-end test: Stream SQL query with failure and retry

FLINK-8970 End-to-end test: Quickstarts

FLINK-8970 End-to-end test: Kinesis connector

FLINK-8970 End-to-end test: Ganglia metrics reporter

FLINK-8970 End-to-end test: Dynamic Kafka partition discovery

FLINK-8970 End-to-end test: ElasticSearch connector

FLINK-8970 End-to-end test: Cassandra connector

FLINK-8970 End-to-end test: Avro state evolution

FLINK-8970 End-to-end test: REST

FLINK-8970 End-to-end test: CLI

FLINK-8970 End-to-end test: Confluent schema registry

FLINK-8970 End-to-end test: Queryable state

FLINK-8970 Add end-to-end test for running on YARN with Kerberos

FLINK-8970 End-to-end test: BucketingSink

FLINK-8970 Extend Kafka end-to-end tests to run with different versions

FLINK-8970 End-to-end test: Job upgrade

FLINK-8970 End-to-end test: Manually resume job after terminal failure

FLINK-8970 End-to-end test: Resume with different parallelism

FLINK-8970 End-to-end test: Resume from savepoint

FLINK-8970 End-to-end test: Run general purpose DataSet job with failures in standalone mode

FLINK-8970 End-to-end test: Run general purpose job with failures in standalone mode

FLINK-8970 Introduce automated end-to-end test for local recovery (including sticky scheduling)