From 22e1d1e3d54604095abf506e732a53f66c0a6a42 Mon Sep 17 00:00:00 2001 From: Ishan Arya Date: Fri, 11 Oct 2024 12:23:58 +0530 Subject: [PATCH] fix: char len limit --- modules/dagger/config.go | 9 +++++---- 1 file changed, 5 insertions(+), 4 deletions(-) diff --git a/modules/dagger/config.go b/modules/dagger/config.go index bc82405..5cf843e 100644 --- a/modules/dagger/config.go +++ b/modules/dagger/config.go @@ -16,7 +16,7 @@ import ( ) const ( - helmReleaseNameMaxLength = 53 + helmReleaseNameMaxLength = 45 ) // Stream-related constants @@ -253,6 +253,10 @@ func readConfig(r module.ExpandedResource, confJSON json.RawMessage, dc driverCo return nil, errors.ErrInvalid.WithMsgf("deployment_id must not have more than 53 chars") } + //transformation #7 + cfg.EnvVariables[keySinkInfluxURL] = flinkOut.Influx.URL + cfg.EnvVariables[keySinkInfluxUsername] = flinkOut.Influx.Username + //SINK_INFLUX_DB_NAME is added by client //SINK_INFLUX_MEASUREMENT_NAME is added by client //REDIS_SERVER is skipped @@ -274,10 +278,7 @@ func readConfig(r module.ExpandedResource, confJSON json.RawMessage, dc driverCo cfg.EnvVariables[keySinkKafkaKey] = cfg.Sink.SinkKafka.SinkKafkaProtoKey cfg.EnvVariables[keySinkKafkaLingerMs] = cfg.Sink.SinkKafka.SinkKafkaLingerMs } else if cfg.SinkType == SinkTypeInflux { - //transformation #7 - cfg.EnvVariables[keySinkInfluxURL] = flinkOut.Influx.URL cfg.EnvVariables[keySinkInfluxPassword] = flinkOut.Influx.Password - cfg.EnvVariables[keySinkInfluxUsername] = flinkOut.Influx.Username cfg.EnvVariables[keySinkInfluxDBName] = cfg.Sink.SinkInflux.SinkInfluxDBName cfg.EnvVariables[keySinkInfluxMeasurementName] = cfg.Sink.SinkInflux.SinkInfluxMeasurementName } else if cfg.SinkType == SinkTypeBigquery {