Github user bbende commented on the pull request: https://github.com/apache/flink/pull/1198#issuecomment-144446028 Good to know, I'll do a full clean verify on the next update. Regarding tests, I don't think we have plans to support running an embedded instance of NiFi for full on IT tests. We currently have a mock framework for testing processors with in NiFi, but we could potentially provide a mock implementation of the SiteToSiteClient which would help a lot for these cases, and would be useful for us in general, besides just the Flink integration. If we were going to provide that, then we would likely need to wait until the next NiFi release (0.4.0) before finalizing this work, unless we incorporated that directly into src/test/java of the flink-connector-nifi module, and removed it later when it was generally available. Sorry, I mistyped before and meant to say other connectors had topologies in src/main/java, twitter and rabbitmq. So it sounds like it is fine to leave the NiFi topology examples there.
--- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is enabled but not working, please contact infrastructure at infrastruct...@apache.org or file a JIRA ticket with INFRA. ---