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:52:53 UTC
[incubator-streampipes] branch rel/0.69.0 updated (d29c07e -> c12de67)
This is an automated email from the ASF dual-hosted git repository.
riemer pushed a change to branch rel/0.69.0
in repository https://gitbox.apache.org/repos/asf/incubator-streampipes.git.
from d29c07e [hotfix] Update docker-compose file for release validation
new 2b19458 [hotfix] Modify assignment of groupId
new c12de67 [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 rel/0.69.0
in repository https://gitbox.apache.org/repos/asf/incubator-streampipes.git
commit 2b19458cb3f46beac9179a36cf20e0e95aab3fa6
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 rel/0.69.0
in repository https://gitbox.apache.org/repos/asf/incubator-streampipes.git
commit c12de6761828727041bdb4c5ffc635bda33a3005
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() {