fix: fix influx sink validate (#2893)

Signed-off-by: yisaer <disxiaofei@163.com>
lf-edge · Jun 24, 2024 · db3afa4 · db3afa4
1 parent b1b2326
commit db3afa4
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
diff --git a/extensions/sinks/influx2/ext/influx2.go b/extensions/sinks/influx2/ext/influx2.go
@@ -105,7 +105,7 @@ func (m *influxSink2) Configure(props map[string]any) error {
 	default:
 		return fmt.Errorf("precision %s is not supported", m.conf.PrecisionStr)
 	}
-	if len(m.conf.Measurement) == 0 && m.conf.UseLineProtocol {
+	if len(m.conf.Measurement) == 0 && !m.conf.UseLineProtocol {
 		return fmt.Errorf("measurement is required")
 	}
 	err = cast.MapToStruct(props, &m.conf.WriteOptions)

diff --git a/extensions/sinks/influx2/ext/influx2_test.go b/extensions/sinks/influx2/ext/influx2_test.go
@@ -116,7 +116,7 @@ func TestConfig(t *testing.T) {
 				"precision":       "ns",
 				"useLineProtocol": true,
 			},
-			error: "measurement is required",
+			error: "",
 		},
 		{
 			name: "no err",
@@ -127,7 +127,7 @@ func TestConfig(t *testing.T) {
 				"precision":       "ns",
 				"useLineProtocol": false,
 			},
-			error: "",
+			error: "measurement is required",
 		},
 		{
 			name: "unmarshall error for tls",