[BAHIR-177] Fixes state recovery/size of the recovered queue

Two issues are meant to be fixed in this PR:

- As described in BAHIR-177 currently the state recovery of
Bahir operators depends on randomly generated IDs, which
basically makes it impossible to recover state properly.
The chagne has been done, so that the outStreamId is
used instead of random names.

-The size of the queue recovered in restoreQueuerState()
was equal to the actual size (number of elements) of the
snapshot queue. If the queue was empty, the method would
try to create queue with the size 0, which is currently
forbidden for the PriorityQueue in Java.

Closes #51
4 files changed
tree: 1134fba4da7b330ac4724751863796df07f6dd6e
  1. dev/
  2. distribution/
  3. flink-connector-activemq/
  4. flink-connector-akka/
  5. flink-connector-flume/
  6. flink-connector-influxdb/
  7. flink-connector-kudu/
  8. flink-connector-netty/
  9. flink-connector-redis/
  10. flink-library-siddhi/
  11. .gitattributes
  12. .gitignore
  13. .travis.yml
  14. LICENSE
  15. NOTICE
  16. pom.xml
  17. README.md
  18. scalastyle-config.xml
README.md

Apache Bahir (Flink)

Apache Bahir provides extensions to distributed analytics platforms such as Apache Spark™ and Apache Flink®.

http://bahir.apache.org/

This repository is for Apache Flink extensions.

Contributing a Flink Connector

The Bahir community is very open to new connector contributions for Apache Flink.

We ask contributors to first open a JIRA issue describing the planned changes. Please make sure to put “Flink Streaming Connector” in the “Component/s” field.

Once the community has agreed that the planned changes are suitable, you can open a pull request at the “bahir-flink” repository. Please follow the same directory structure as the existing code.

The community will review your changes, giving suggestions how to improve the code until we can merge it to the main repository.

Building Bahir

Bahir is built using Apache Maven™. To build Bahir and its example programs, run:

mvn -DskipTests clean install

Running tests

Testing first requires building Bahir. Once Bahir is built, tests can be run using:

mvn test