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/streampipes.git
The following commit(s) were added to refs/heads/dev by this push:
new 8e49cbc715 fix(#2954): data type change in adapter causes data storage
failure in influxdb (#2958)
8e49cbc715 is described below
commit 8e49cbc7151e6eeee8279c076021feb7c3f47b1d
Author: Philipp Zehnder <[email protected]>
AuthorDate: Wed Jun 26 16:40:37 2024 +0200
fix(#2954): data type change in adapter causes data storage failure in
influxdb (#2958)
* fix(#2954): Add test to reproduce problem
* fix(#2954): Add warning message to data type change if adapter is edited
---
ui/cypress/support/utils/connect/ConnectBtns.ts | 12 ++++++
.../utils/{ => connect}/ConnectEventSchemaUtils.ts | 44 ++++++++++++--------
ui/cypress/support/utils/connect/ConnectUtils.ts | 10 ++++-
ui/cypress/support/utils/datalake/DataLakeBtns.ts | 23 +++++++++++
ui/cypress/support/utils/datalake/DataLakeUtils.ts | 17 ++++++++
ui/cypress/tests/adapter/editAdapter.smoke.spec.ts | 48 +++++++++++++++++++++-
.../adapter/editAdapterSettingsAndPipeline.spec.ts | 2 +-
.../adapter/editAdapterValuesAndFields.spec.ts | 9 ++--
.../adapter/rules/deleteTransformationRule.spec.ts | 2 +-
.../tests/adapter/rules/schemaRules.smoke.spec.ts | 2 +-
ui/cypress/tests/adapter/rules/streamRules.spec.ts | 2 +-
ui/cypress/tests/adapter/rules/valueRules.ts | 2 +-
.../datalake-configuration.component.html | 4 +-
.../edit-schema-transformation.component.html | 15 +++++++
.../edit-schema-transformation.component.scss | 2 +
.../edit-schema-transformation.component.ts | 6 +++
.../edit-correction-value.component.scss | 8 +---
.../edit-event-property.component.scss | 8 ++++
18 files changed, 179 insertions(+), 37 deletions(-)
diff --git a/ui/cypress/support/utils/connect/ConnectBtns.ts
b/ui/cypress/support/utils/connect/ConnectBtns.ts
index 0fab8973c0..f828bcf148 100644
--- a/ui/cypress/support/utils/connect/ConnectBtns.ts
+++ b/ui/cypress/support/utils/connect/ConnectBtns.ts
@@ -40,6 +40,18 @@ export class ConnectBtns {
return cy.dataCy('store-edit-adapter');
}
+ public static changeRuntimeType() {
+ return cy.dataCy('connect-change-runtime-type', { timeout: 10000 });
+ }
+
+ public static updateAndMigratePipelines() {
+ return cy.dataCy('btn-update-adapter-migrate-pipelines');
+ }
+
+ public static nextBtn() {
+ return cy.get('button').contains('Next').parent();
+ }
+
// ===================== Adapter settings btns ==========================
public static adapterSettingsStartAdapter() {
return cy.dataCy('adapter-settings-start-adapter-btn');
diff --git a/ui/cypress/support/utils/ConnectEventSchemaUtils.ts
b/ui/cypress/support/utils/connect/ConnectEventSchemaUtils.ts
similarity index 85%
rename from ui/cypress/support/utils/ConnectEventSchemaUtils.ts
rename to ui/cypress/support/utils/connect/ConnectEventSchemaUtils.ts
index 663a42edbf..098ea68554 100644
--- a/ui/cypress/support/utils/ConnectEventSchemaUtils.ts
+++ b/ui/cypress/support/utils/connect/ConnectEventSchemaUtils.ts
@@ -1,21 +1,23 @@
/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License. You may obtain a copy of the License at
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
*
- * http://www.apache.org/licenses/LICENSE-2.0
+ * http://www.apache.org/licenses/LICENSE-2.0
*
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
*
*/
+import { ConnectBtns } from './ConnectBtns';
+
export class ConnectEventSchemaUtils {
public static markPropertyAsDimension(propertyName: string) {
cy.dataCy('property-scope-' + propertyName, { timeout: 10000 })
@@ -196,9 +198,13 @@ export class ConnectEventSchemaUtils {
public static changePropertyDataType(
propertyName: string,
dataType: string,
+ warningIsShown: boolean = false,
) {
ConnectEventSchemaUtils.clickEditProperty(propertyName);
- cy.dataCy('connect-change-runtime-type')
+
+ this.checkIfWarningIsShown(warningIsShown);
+
+ ConnectBtns.changeRuntimeType()
.click()
.get('mat-option')
.contains(dataType)
@@ -208,13 +214,19 @@ export class ConnectEventSchemaUtils {
cy.dataCy('edit-' + propertyName, { timeout: 10000 }).click({
force: true,
});
- cy.dataCy('connect-change-runtime-type', { timeout: 10000 }).contains(
- dataType,
- );
+ ConnectBtns.changeRuntimeType().contains(dataType);
cy.wait(1000);
cy.dataCy('sp-save-edit-property').click();
}
+ private static checkIfWarningIsShown(warningIsShown: boolean) {
+ if (warningIsShown) {
+ cy.dataCy('warning-change-data-type').should('be.visible');
+ } else {
+ cy.dataCy('warning-change-data-type').should('not.exist');
+ }
+ }
+
public static eventSchemaNextBtnDisabled() {
cy.get('#event-schema-next-button').should('be.disabled');
}
diff --git a/ui/cypress/support/utils/connect/ConnectUtils.ts
b/ui/cypress/support/utils/connect/ConnectUtils.ts
index 6fe6cfd708..fa30cd01e0 100644
--- a/ui/cypress/support/utils/connect/ConnectUtils.ts
+++ b/ui/cypress/support/utils/connect/ConnectUtils.ts
@@ -18,7 +18,7 @@
import { StaticPropertyUtils } from '../StaticPropertyUtils';
import { AdapterInput } from '../../model/AdapterInput';
-import { ConnectEventSchemaUtils } from '../ConnectEventSchemaUtils';
+import { ConnectEventSchemaUtils } from './ConnectEventSchemaUtils';
import { DataLakeUtils } from '../datalake/DataLakeUtils';
import { ConnectBtns } from './ConnectBtns';
import { AdapterBuilder } from '../../builder/AdapterBuilder';
@@ -208,6 +208,14 @@ export class ConnectUtils {
);
}
+ public static storeAndStartEditedAdapter() {
+ ConnectUtils.finishEventSchemaConfiguration();
+ ConnectBtns.storeEditAdapter().click();
+ ConnectBtns.updateAndMigratePipelines().click();
+ ConnectUtils.closeAdapterPreview();
+ ConnectBtns.startAdapter().click();
+ }
+
public static deleteAdapterAndAssociatedPipelines(switchUserCheck = false)
{
// Delete adapter and associated pipelines
this.goToConnect();
diff --git a/ui/cypress/support/utils/datalake/DataLakeBtns.ts
b/ui/cypress/support/utils/datalake/DataLakeBtns.ts
new file mode 100644
index 0000000000..5bb7083108
--- /dev/null
+++ b/ui/cypress/support/utils/datalake/DataLakeBtns.ts
@@ -0,0 +1,23 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ *
+ */
+
+export class DataLakeBtns {
+ public static refreshDataLakeMeasures() {
+ return cy.dataCy('refresh-data-lake-measures');
+ }
+}
diff --git a/ui/cypress/support/utils/datalake/DataLakeUtils.ts
b/ui/cypress/support/utils/datalake/DataLakeUtils.ts
index 1788212551..41fadcf9b0 100644
--- a/ui/cypress/support/utils/datalake/DataLakeUtils.ts
+++ b/ui/cypress/support/utils/datalake/DataLakeUtils.ts
@@ -332,4 +332,21 @@ export class DataLakeUtils {
return currentDate;
}
+
+ public static waitForCountingResults() {
+ cy.dataCy('datalake-number-of-events-spinner', {
+ timeout: 10000,
+ }).should('exist');
+ cy.dataCy('datalake-number-of-events-spinner', {
+ timeout: 10000,
+ }).should('not.exist');
+ }
+
+ public static getDatalakeNumberOfEvents(): Cypress.Chainable<string> {
+ return cy
+ .dataCy('datalake-number-of-events', { timeout: 10000 })
+ .should('be.visible')
+ .invoke('text')
+ .then(text => text.trim());
+ }
}
diff --git a/ui/cypress/tests/adapter/editAdapter.smoke.spec.ts
b/ui/cypress/tests/adapter/editAdapter.smoke.spec.ts
index ba8a1f54e0..3becf859e8 100644
--- a/ui/cypress/tests/adapter/editAdapter.smoke.spec.ts
+++ b/ui/cypress/tests/adapter/editAdapter.smoke.spec.ts
@@ -19,15 +19,18 @@
import { ConnectUtils } from '../../support/utils/connect/ConnectUtils';
import { ConnectBtns } from '../../support/utils/connect/ConnectBtns';
import { AdapterBuilder } from '../../support/builder/AdapterBuilder';
+import { ConnectEventSchemaUtils } from
'../../support/utils/connect/ConnectEventSchemaUtils';
+import { DataLakeUtils } from '../../support/utils/datalake/DataLakeUtils';
+import { DataLakeBtns } from '../../support/utils/datalake/DataLakeBtns';
describe('Test Edit Adapter', () => {
beforeEach('Setup Test', () => {
// To set up test add a stream adapter that can be configured
cy.initStreamPipesTest();
- ConnectUtils.addMachineDataSimulator('simulator');
});
it('Successfully edit adapter', () => {
+ ConnectUtils.addMachineDataSimulator('simulator');
const newAdapterName = 'Edited Adapter';
ConnectUtils.goToConnect();
@@ -68,4 +71,47 @@ describe('Test Edit Adapter', () => {
cy.dataCy('adapter-name').contains(newAdapterName);
cy.get('.sp-dialog-content').contains(newAdapterName);
});
+
+ it('Successfully edit adapter with persistence pipeline', () => {
+ ConnectUtils.addMachineDataSimulator('simulator', true);
+
+ ConnectUtils.goToConnect();
+
+ // stop adapter and edit adapter
+ ConnectBtns.stopAdapter().click();
+ ConnectBtns.editAdapter().click();
+
+ // change data type of density to integer
+ ConnectBtns.nextBtn().click();
+ ConnectEventSchemaUtils.changePropertyDataType(
+ 'density',
+ 'Integer',
+ true,
+ );
+
+ ConnectUtils.storeAndStartEditedAdapter();
+
+ // Validate that the data is further persisted in the database by
checking if the amount of events in the data lake changes
+ DataLakeUtils.goToDatalakeConfiguration();
+
+ DataLakeUtils.waitForCountingResults();
+
+ let initialValue;
+
+ DataLakeUtils.getDatalakeNumberOfEvents().then(value => {
+ initialValue = value;
+ });
+
+ DataLakeBtns.refreshDataLakeMeasures().click();
+
+ DataLakeUtils.waitForCountingResults();
+
+ DataLakeUtils.getDatalakeNumberOfEvents().then(newValue => {
+ // IMPORTANT: Currently we implemented a workaround by showing the
user a warning message when the data type is changed.
+ // In the future, we need a migration mechanism to automatically
change all the StreamPipes resources that are effected
+ // by the change. Once this is implemented the following line must
be changed to .not.equal.
+ // The issue is tracked here:
https://github.com/apache/streampipes/issues/2954
+ expect(newValue).equal(initialValue);
+ });
+ });
});
diff --git a/ui/cypress/tests/adapter/editAdapterSettingsAndPipeline.spec.ts
b/ui/cypress/tests/adapter/editAdapterSettingsAndPipeline.spec.ts
index 8b63cafac1..da5089a227 100644
--- a/ui/cypress/tests/adapter/editAdapterSettingsAndPipeline.spec.ts
+++ b/ui/cypress/tests/adapter/editAdapterSettingsAndPipeline.spec.ts
@@ -70,7 +70,7 @@ describe('Test Edit Adapter and Pipeline', () => {
cy.dataCy('sp-connect-adapter-edit-warning', {
timeout: 60000,
}).should('be.visible');
- cy.dataCy('btn-update-adapter-migrate-pipelines').click();
+ ConnectBtns.updateAndMigratePipelines().click();
ConnectUtils.closeAdapterPreview();
cy.wait(1000);
diff --git a/ui/cypress/tests/adapter/editAdapterValuesAndFields.spec.ts
b/ui/cypress/tests/adapter/editAdapterValuesAndFields.spec.ts
index 60ce694b21..52269352a0 100644
--- a/ui/cypress/tests/adapter/editAdapterValuesAndFields.spec.ts
+++ b/ui/cypress/tests/adapter/editAdapterValuesAndFields.spec.ts
@@ -50,7 +50,7 @@ describe('Test Edit Adapter', () => {
.clear()
.type('http://schema.org/Numbers');
// Change field data type
- cy.dataCy('connect-change-runtime-type')
+ ConnectBtns.changeRuntimeType()
.click()
.get('mat-option')
.contains('Double')
@@ -83,10 +83,7 @@ describe('Test Edit Adapter', () => {
'have.value',
'http://schema.org/Numbers',
);
- cy.dataCy('connect-change-runtime-type').should(
- 'include.text',
- 'Double',
- );
+ ConnectBtns.changeRuntimeType().should('include.text', 'Double');
cy.dataCy('connect-schema-correction-value').should('have.value', '2');
cy.dataCy('connect-schema-correction-operator').should(
'include.text',
@@ -96,7 +93,7 @@ describe('Test Edit Adapter', () => {
// Delete inserted values in edit field
cy.dataCy('connect-edit-field-runtime-name').clear();
cy.get('[id="domainproperty"]').clear();
- cy.dataCy('connect-change-runtime-type')
+ ConnectBtns.changeRuntimeType()
.click()
.get('mat-option')
.contains('Float')
diff --git a/ui/cypress/tests/adapter/rules/deleteTransformationRule.spec.ts
b/ui/cypress/tests/adapter/rules/deleteTransformationRule.spec.ts
index 6ecb38744b..ad558ab8d2 100644
--- a/ui/cypress/tests/adapter/rules/deleteTransformationRule.spec.ts
+++ b/ui/cypress/tests/adapter/rules/deleteTransformationRule.spec.ts
@@ -17,7 +17,7 @@
*/
import { ConnectUtils } from '../../../support/utils/connect/ConnectUtils';
import { FileManagementUtils } from
'../../../support/utils/FileManagementUtils';
-import { ConnectEventSchemaUtils } from
'../../../support/utils/ConnectEventSchemaUtils';
+import { ConnectEventSchemaUtils } from
'../../../support/utils/connect/ConnectEventSchemaUtils';
import { AdapterBuilder } from '../../../support/builder/AdapterBuilder';
import { ConnectBtns } from '../../../support/utils/connect/ConnectBtns';
diff --git a/ui/cypress/tests/adapter/rules/schemaRules.smoke.spec.ts
b/ui/cypress/tests/adapter/rules/schemaRules.smoke.spec.ts
index 39462cfc06..1aa4d14ce6 100644
--- a/ui/cypress/tests/adapter/rules/schemaRules.smoke.spec.ts
+++ b/ui/cypress/tests/adapter/rules/schemaRules.smoke.spec.ts
@@ -18,7 +18,7 @@
import { ConnectUtils } from '../../../support/utils/connect/ConnectUtils';
import { FileManagementUtils } from
'../../../support/utils/FileManagementUtils';
-import { ConnectEventSchemaUtils } from
'../../../support/utils/ConnectEventSchemaUtils';
+import { ConnectEventSchemaUtils } from
'../../../support/utils/connect/ConnectEventSchemaUtils';
describe('Connect schema rule transformations', () => {
beforeEach('Setup Test', () => {
diff --git a/ui/cypress/tests/adapter/rules/streamRules.spec.ts
b/ui/cypress/tests/adapter/rules/streamRules.spec.ts
index dbfab9dab7..bf9f946a59 100644
--- a/ui/cypress/tests/adapter/rules/streamRules.spec.ts
+++ b/ui/cypress/tests/adapter/rules/streamRules.spec.ts
@@ -18,7 +18,7 @@
import { ConnectUtils } from '../../../support/utils/connect/ConnectUtils';
import { FileManagementUtils } from
'../../../support/utils/FileManagementUtils';
-import { ConnectEventSchemaUtils } from
'../../../support/utils/ConnectEventSchemaUtils';
+import { ConnectEventSchemaUtils } from
'../../../support/utils/connect/ConnectEventSchemaUtils';
describe('Connect aggregation rule transformations', () => {
beforeEach('Setup Test', () => {
diff --git a/ui/cypress/tests/adapter/rules/valueRules.ts
b/ui/cypress/tests/adapter/rules/valueRules.ts
index 60ffdbf21a..2163f454d2 100644
--- a/ui/cypress/tests/adapter/rules/valueRules.ts
+++ b/ui/cypress/tests/adapter/rules/valueRules.ts
@@ -18,7 +18,7 @@
import { ConnectUtils } from '../../../support/utils/connect/ConnectUtils';
import { FileManagementUtils } from
'../../../support/utils/FileManagementUtils';
-import { ConnectEventSchemaUtils } from
'../../../support/utils/ConnectEventSchemaUtils';
+import { ConnectEventSchemaUtils } from
'../../../support/utils/connect/ConnectEventSchemaUtils';
describe('Connect value rule transformations', () => {
beforeEach('Setup Test', () => {
diff --git
a/ui/src/app/configuration/datalake-configuration/datalake-configuration.component.html
b/ui/src/app/configuration/datalake-configuration/datalake-configuration.component.html
index b202b2955f..5044fd3091 100644
---
a/ui/src/app/configuration/datalake-configuration/datalake-configuration.component.html
+++
b/ui/src/app/configuration/datalake-configuration/datalake-configuration.component.html
@@ -36,7 +36,8 @@
<button
color="accent"
mat-icon-button
- matTooltip="Refresh Schema"
+ matTooltip="Refresh"
+ data-cy="refresh-data-lake-measures"
(click)="loadAvailableMeasurements()"
>
<mat-icon>refresh</mat-icon>
@@ -97,6 +98,7 @@
fxLayoutAlign="center"
style="margin: 10px 0 5px 0"
color="accent"
+ data-cy="datalake-number-of-events-spinner"
*ngIf="configurationEntry.events < 0"
>Loading
</mat-spinner>
diff --git
a/ui/src/app/connect/dialog/edit-event-property/components/edit-schema-transformation/edit-schema-transformation.component.html
b/ui/src/app/connect/dialog/edit-event-property/components/edit-schema-transformation/edit-schema-transformation.component.html
index 93b6b012c2..84732adcc3 100644
---
a/ui/src/app/connect/dialog/edit-event-property/components/edit-schema-transformation/edit-schema-transformation.component.html
+++
b/ui/src/app/connect/dialog/edit-event-property/components/edit-schema-transformation/edit-schema-transformation.component.html
@@ -92,6 +92,21 @@
sectionDescription="The data type of the field values"
*ngIf="!isTimestampProperty && !isNestedProperty"
>
+ <div *ngIf="adapterIsInEditMode" class="warning-message">
+ <p data-cy="warning-change-data-type" class="text-center">
+ Changing the data type can result in pipelines no longer
writing
+ the data correctly to the data lake.
+ <br />
+ <br />
+ To resolve this problem, you can:
+ <br />
+ - Rename the property.
+ <br />
+ - Truncate the old data.
+ <br />
+ - Write the data to a new measurement.
+ </p>
+ </div>
<sp-edit-data-type
[cachedProperty]="cachedProperty"
(dataTypeChanged)="dataTypeChanged.emit($event)"
diff --git
a/ui/src/app/connect/dialog/edit-event-property/components/edit-schema-transformation/edit-schema-transformation.component.scss
b/ui/src/app/connect/dialog/edit-event-property/components/edit-schema-transformation/edit-schema-transformation.component.scss
index 13cbc4aacb..0d4d02f4cc 100644
---
a/ui/src/app/connect/dialog/edit-event-property/components/edit-schema-transformation/edit-schema-transformation.component.scss
+++
b/ui/src/app/connect/dialog/edit-event-property/components/edit-schema-transformation/edit-schema-transformation.component.scss
@@ -15,3 +15,5 @@
* limitations under the License.
*
*/
+
+@import '../../edit-event-property.component.scss';
diff --git
a/ui/src/app/connect/dialog/edit-event-property/components/edit-schema-transformation/edit-schema-transformation.component.ts
b/ui/src/app/connect/dialog/edit-event-property/components/edit-schema-transformation/edit-schema-transformation.component.ts
index 80adb96525..608b6c4124 100644
---
a/ui/src/app/connect/dialog/edit-event-property/components/edit-schema-transformation/edit-schema-transformation.component.ts
+++
b/ui/src/app/connect/dialog/edit-event-property/components/edit-schema-transformation/edit-schema-transformation.component.ts
@@ -31,6 +31,7 @@ import {
SemanticType,
SemanticTypesRestService,
} from '@streampipes/platform-services';
+import { Router } from '@angular/router';
@Component({
selector: 'sp-edit-schema-transformation',
@@ -52,9 +53,12 @@ export class EditSchemaTransformationComponent implements
OnInit {
domainPropertyControl = new UntypedFormControl();
semanticTypes: Observable<string[]>;
+ adapterIsInEditMode: boolean;
+
constructor(
private semanticTypesRestService: SemanticTypesRestService,
private shepherdService: ShepherdService,
+ private router: Router,
) {}
ngOnInit(): void {
@@ -68,6 +72,8 @@ export class EditSchemaTransformationComponent implements
OnInit {
: [];
}),
);
+
+ this.adapterIsInEditMode = this.router.url.includes('connect/edit');
}
editTimestampDomainProperty(checked: boolean) {
diff --git
a/ui/src/app/connect/dialog/edit-event-property/components/edit-value-transformation/edit-correction-value/edit-correction-value.component.scss
b/ui/src/app/connect/dialog/edit-event-property/components/edit-value-transformation/edit-correction-value/edit-correction-value.component.scss
index ec202a065d..a1d59b6014 100644
---
a/ui/src/app/connect/dialog/edit-event-property/components/edit-value-transformation/edit-correction-value/edit-correction-value.component.scss
+++
b/ui/src/app/connect/dialog/edit-event-property/components/edit-value-transformation/edit-correction-value/edit-correction-value.component.scss
@@ -16,10 +16,4 @@
*
*/
-.warning-message {
- margin-bottom: 10px;
- padding: 5px;
- border: 1px solid var(--color-warn);
- background: var(--color-bg-1);
- font-size: 14px;
-}
+@import '../../../edit-event-property.component.scss';
diff --git
a/ui/src/app/connect/dialog/edit-event-property/edit-event-property.component.scss
b/ui/src/app/connect/dialog/edit-event-property/edit-event-property.component.scss
index b92834fe68..0c215ed64a 100644
---
a/ui/src/app/connect/dialog/edit-event-property/edit-event-property.component.scss
+++
b/ui/src/app/connect/dialog/edit-event-property/edit-event-property.component.scss
@@ -29,3 +29,11 @@
.full-width {
width: 100%;
}
+
+.warning-message {
+ margin-bottom: 10px;
+ padding: 5px;
+ border: 1px solid var(--color-warn);
+ background: var(--color-bg-1);
+ font-size: 14px;
+}