You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@streampipes.apache.org by ze...@apache.org on 2020/03/31 12:46:41 UTC

[incubator-streampipes] branch dev updated: Remove supported formats from flink sink archetype

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

zehnder 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 180a176  Remove supported formats from flink sink archetype
     new e31e043  Merge branch 'dev' of github.com:apache/incubator-streampipes into dev
180a176 is described below

commit 180a176741754316616b11f30a15720cbd37c14c
Author: Philipp Zehnder <ze...@fzi.de>
AuthorDate: Tue Mar 31 14:45:57 2020 +0200

    Remove supported formats from flink sink archetype
---
 .../java/pe/sink/__packageName__/__classNamePrefix__Controller.java     | 2 --
 1 file changed, 2 deletions(-)

diff --git a/archetypes/streampipes-archetype-pe-sinks-flink/src/main/resources/archetype-resources/src/main/java/pe/sink/__packageName__/__classNamePrefix__Controller.java b/archetypes/streampipes-archetype-pe-sinks-flink/src/main/resources/archetype-resources/src/main/java/pe/sink/__packageName__/__classNamePrefix__Controller.java
index 376e375..b9e1f4d 100644
--- a/archetypes/streampipes-archetype-pe-sinks-flink/src/main/resources/archetype-resources/src/main/java/pe/sink/__packageName__/__classNamePrefix__Controller.java
+++ b/archetypes/streampipes-archetype-pe-sinks-flink/src/main/resources/archetype-resources/src/main/java/pe/sink/__packageName__/__classNamePrefix__Controller.java
@@ -34,8 +34,6 @@ public class ${classNamePrefix}Controller extends FlinkDataSinkDeclarer<${classN
 							.create()
 							.requiredProperty(EpRequirements.anyProperty())
 							.build())
-						.supportedFormats(SupportedFormats.jsonFormat())
-						.supportedProtocols(SupportedProtocols.kafka())
 						.requiredTextParameter(Labels.withId(EXAMPLE_KEY))
 						.build();
 	}