You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@streampipes.apache.org by ri...@apache.org on 2022/02/27 20:53:34 UTC
[incubator-streampipes] branch dev updated (6dbcab5 -> 9cb78b7)
This is an automated email from the ASF dual-hosted git repository.
riemer pushed a change to branch dev
in repository https://gitbox.apache.org/repos/asf/incubator-streampipes.git.
from 6dbcab5 [hotfix] Update docker-compose file for release validation
new a63bd4d [hotfix] Modify assignment of groupId
new 9cb78b7 [hotfix] Fix bug in new widget creation
The 2 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../streampipes/messaging/kafka/config/ConsumerConfigFactory.java | 3 +--
.../designer-panel/data-explorer-designer-panel.component.ts | 5 +++++
.../components/panel/data-explorer-dashboard-panel.component.ts | 1 +
3 files changed, 7 insertions(+), 2 deletions(-)
[incubator-streampipes] 01/02: [hotfix] Modify assignment of groupId
Posted by ri...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
riemer pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/incubator-streampipes.git
commit a63bd4d3328d54f76cc1e9914a9798012816d4b9
Author: Dominik Riemer <do...@gmail.com>
AuthorDate: Sun Feb 27 20:41:54 2022 +0100
[hotfix] Modify assignment of groupId
---
.../streampipes/messaging/kafka/config/ConsumerConfigFactory.java | 3 +--
1 file changed, 1 insertion(+), 2 deletions(-)
diff --git a/streampipes-messaging-kafka/src/main/java/org/apache/streampipes/messaging/kafka/config/ConsumerConfigFactory.java b/streampipes-messaging-kafka/src/main/java/org/apache/streampipes/messaging/kafka/config/ConsumerConfigFactory.java
index 30dfbdd..2aa488a 100644
--- a/streampipes-messaging-kafka/src/main/java/org/apache/streampipes/messaging/kafka/config/ConsumerConfigFactory.java
+++ b/streampipes-messaging-kafka/src/main/java/org/apache/streampipes/messaging/kafka/config/ConsumerConfigFactory.java
@@ -19,7 +19,6 @@ package org.apache.streampipes.messaging.kafka.config;
import org.apache.kafka.clients.consumer.ConsumerConfig;
import org.apache.kafka.common.serialization.ByteArrayDeserializer;
-import org.apache.kafka.common.serialization.ByteArraySerializer;
import org.apache.streampipes.model.grounding.KafkaTransportProtocol;
import java.util.Properties;
@@ -42,7 +41,7 @@ public class ConsumerConfigFactory extends AbstractConfigFactory {
public Properties makeDefaultProperties() {
Properties props = new Properties();
props.put(ConsumerConfig.BOOTSTRAP_SERVERS_CONFIG, getBrokerUrl());
- props.put(ConsumerConfig.GROUP_ID_CONFIG, UUID.randomUUID().toString());
+ props.put(ConsumerConfig.GROUP_ID_CONFIG, getConfigOrDefault(protocol::getGroupId, UUID.randomUUID().toString()));
props.put(ConsumerConfig.ENABLE_AUTO_COMMIT_CONFIG, ENABLE_AUTO_COMMIT_CONFIG_DEFAULT);
props.put(ConsumerConfig.AUTO_COMMIT_INTERVAL_MS_CONFIG,
AUTO_COMMIT_INTERVAL_MS_CONFIG_DEFAULT);
[incubator-streampipes] 02/02: [hotfix] Fix bug in new widget creation
Posted by ri...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
riemer pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/incubator-streampipes.git
commit 9cb78b79c9977c04ec04e55b62f8b3f56ef25e03
Author: Dominik Riemer <do...@gmail.com>
AuthorDate: Sun Feb 27 21:52:39 2022 +0100
[hotfix] Fix bug in new widget creation
---
.../designer-panel/data-explorer-designer-panel.component.ts | 5 +++++
.../components/panel/data-explorer-dashboard-panel.component.ts | 1 +
2 files changed, 6 insertions(+)
diff --git a/ui/src/app/data-explorer/components/designer-panel/data-explorer-designer-panel.component.ts b/ui/src/app/data-explorer/components/designer-panel/data-explorer-designer-panel.component.ts
index 572f01a..94af4fa 100644
--- a/ui/src/app/data-explorer/components/designer-panel/data-explorer-designer-panel.component.ts
+++ b/ui/src/app/data-explorer/components/designer-panel/data-explorer-designer-panel.component.ts
@@ -65,4 +65,9 @@ export class DataExplorerDesignerPanelComponent implements OnInit {
closeDesignerPanel() {
this.closeDesignerPanelEmitter.emit();
}
+
+ resetIndex() {
+ this.selectedIndex = 0;
+ this.newWidgetMode = true;
+ }
}
diff --git a/ui/src/app/data-explorer/components/panel/data-explorer-dashboard-panel.component.ts b/ui/src/app/data-explorer/components/panel/data-explorer-dashboard-panel.component.ts
index 62c29e6..16974d4 100644
--- a/ui/src/app/data-explorer/components/panel/data-explorer-dashboard-panel.component.ts
+++ b/ui/src/app/data-explorer/components/panel/data-explorer-dashboard-panel.component.ts
@@ -198,6 +198,7 @@ export class DataExplorerDashboardPanelComponent implements OnInit {
this.newWidgetMode = true;
this.showDesignerPanel = true;
this.newWidgetMode = true;
+ this.designerPanel.resetIndex();
}
closeDesignerPanel() {