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/17 20:35:10 UTC
[incubator-streampipes-extensions] branch dev updated:
STREAMPIPES-56 Password field in postgres sink is not markes as a password
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-extensions.git
The following commit(s) were added to refs/heads/dev by this push:
new fc24b8a STREAMPIPES-56 Password field in postgres sink is not markes as a password
fc24b8a is described below
commit fc24b8a1775aeec4ac9eaf8d2822c52974fb2d97
Author: Philipp Zehnder <ze...@fzi.de>
AuthorDate: Tue Mar 17 21:34:31 2020 +0100
STREAMPIPES-56 Password field in postgres sink is not markes as a password
---
.../streampipes/sinks/databases/jvm/influxdb/InfluxDbController.java | 4 ++--
.../sinks/databases/jvm/postgresql/PostgreSqlController.java | 4 ++--
2 files changed, 4 insertions(+), 4 deletions(-)
diff --git a/streampipes-sinks-databases-jvm/src/main/java/org/apache/streampipes/sinks/databases/jvm/influxdb/InfluxDbController.java b/streampipes-sinks-databases-jvm/src/main/java/org/apache/streampipes/sinks/databases/jvm/influxdb/InfluxDbController.java
index 4b75ce5..3f098f5 100644
--- a/streampipes-sinks-databases-jvm/src/main/java/org/apache/streampipes/sinks/databases/jvm/influxdb/InfluxDbController.java
+++ b/streampipes-sinks-databases-jvm/src/main/java/org/apache/streampipes/sinks/databases/jvm/influxdb/InfluxDbController.java
@@ -62,7 +62,7 @@ public class InfluxDbController extends StandaloneEventSinkDeclarer<InfluxDbPara
.requiredTextParameter(Labels.withId(DATABASE_NAME_KEY))
.requiredTextParameter(Labels.withId(DATABASE_MEASUREMENT_KEY))
.requiredTextParameter(Labels.withId(DATABASE_USER_KEY))
- .requiredTextParameter(Labels.withId(DATABASE_PASSWORD_KEY))
+ .requiredSecret(Labels.withId(DATABASE_PASSWORD_KEY))
.build();
}
@@ -75,7 +75,7 @@ public class InfluxDbController extends StandaloneEventSinkDeclarer<InfluxDbPara
String dbName = extractor.singleValueParameter(DATABASE_NAME_KEY, String.class);
String measureName = extractor.singleValueParameter(DATABASE_MEASUREMENT_KEY, String.class);
String user = extractor.singleValueParameter(DATABASE_USER_KEY, String.class);
- String password = extractor.singleValueParameter(DATABASE_PASSWORD_KEY, String.class);
+ String password = extractor.secretValue(DATABASE_PASSWORD_KEY);
String timestampField = extractor.mappingPropertyValue(TIMESTAMP_MAPPING_KEY);
Integer batch_size = extractor.singleValueParameter(BATCH_INTERVAL_ACTIONS_KEY, Integer.class);
Integer flush_duration = extractor.singleValueParameter(MAX_FLUSH_DURATION_KEY, Integer.class);
diff --git a/streampipes-sinks-databases-jvm/src/main/java/org/apache/streampipes/sinks/databases/jvm/postgresql/PostgreSqlController.java b/streampipes-sinks-databases-jvm/src/main/java/org/apache/streampipes/sinks/databases/jvm/postgresql/PostgreSqlController.java
index 2b637e7..b7a5838 100644
--- a/streampipes-sinks-databases-jvm/src/main/java/org/apache/streampipes/sinks/databases/jvm/postgresql/PostgreSqlController.java
+++ b/streampipes-sinks-databases-jvm/src/main/java/org/apache/streampipes/sinks/databases/jvm/postgresql/PostgreSqlController.java
@@ -54,7 +54,7 @@ public class PostgreSqlController extends StandaloneEventSinkDeclarer<PostgreSql
.requiredTextParameter(Labels.withId(DATABASE_NAME_KEY))
.requiredTextParameter(Labels.withId(DATABASE_TABLE_KEY))
.requiredTextParameter(Labels.withId(DATABASE_USER_KEY))
- .requiredTextParameter(Labels.withId(DATABASE_PASSWORD_KEY))
+ .requiredSecret(Labels.withId(DATABASE_PASSWORD_KEY))
.build();
}
@@ -67,7 +67,7 @@ public class PostgreSqlController extends StandaloneEventSinkDeclarer<PostgreSql
String dbName = extractor.singleValueParameter(DATABASE_NAME_KEY, String.class);
String tableName = extractor.singleValueParameter(DATABASE_TABLE_KEY, String.class);
String user = extractor.singleValueParameter(DATABASE_USER_KEY, String.class);
- String password = extractor.singleValueParameter(DATABASE_PASSWORD_KEY, String.class);
+ String password = extractor.secretValue(DATABASE_PASSWORD_KEY);
PostgreSqlParameters params = new PostgreSqlParameters(graph,
hostname,