[incubator-streampipes] branch dev updated: [hotfix] Remove unused imports

[gr...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

grainier pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/incubator-streampipes.git


The following commit(s) were added to refs/heads/dev by this push:
     new e2e0e87  [hotfix] Remove unused imports
     new 68748fd  Merge pull request #46 from vesense/patch-3
e2e0e87 is described below

commit e2e0e870a264f53f207758f111aa691aeae3b62d
Author: Xin Wang <xi...@apache.org>
AuthorDate: Sun Jun 20 20:50:37 2021 +0800

    [hotfix] Remove unused imports
---
 .../org/apache/streampipes/wrapper/flink/sink/MqttFlinkProducer.java    | 2 --
 1 file changed, 2 deletions(-)

diff --git a/streampipes-wrapper-flink/src/main/java/org/apache/streampipes/wrapper/flink/sink/MqttFlinkProducer.java b/streampipes-wrapper-flink/src/main/java/org/apache/streampipes/wrapper/flink/sink/MqttFlinkProducer.java
index c52e352..bda60da 100644
--- a/streampipes-wrapper-flink/src/main/java/org/apache/streampipes/wrapper/flink/sink/MqttFlinkProducer.java
+++ b/streampipes-wrapper-flink/src/main/java/org/apache/streampipes/wrapper/flink/sink/MqttFlinkProducer.java
@@ -20,9 +20,7 @@ package org.apache.streampipes.wrapper.flink.sink;
 
 import org.apache.flink.configuration.Configuration;
 import org.apache.flink.streaming.api.functions.sink.RichSinkFunction;
-import org.apache.streampipes.messaging.jms.ActiveMQPublisher;
 import org.apache.streampipes.messaging.mqtt.MqttPublisher;
-import org.apache.streampipes.model.grounding.JmsTransportProtocol;
 import org.apache.streampipes.model.grounding.MqttTransportProtocol;
 import org.apache.streampipes.wrapper.flink.serializer.ByteArraySerializer;