Hello, I am trying to follow this guide and getting an error under the training section:
IllegalArgumentException Traceback (most recent call last) <ipython-input-41-30e01202> in <module> 28 ) 29 ---> 30 model = simpleMultiAnomalyEstimator.fit(df) 31 type(model) /opt/spark/python/lib/pyspark.zip/pyspark/ml/base.py in fit(self, dataset, params) 159 return self.copy(params)._fit(dataset) 160 else: --> 161 return self._fit(dataset) 162 else: 163 raise ValueError("Params must be either a param map or a list/tuple of param maps, " /mnt/var/hadoop/tmp/nm-local-dir/usercache/trusted-service-user/appcache/application_1675178823889_0001/container_1675178823889_0001_01_000001/com.microsoft.azure_synapseml-cognitive_2.12-0.9.5-13-d1b51517-SNAPSHOT.jar/synapse/ml/cognitive/FitMultivariateAnomaly.py in _fit(self, dataset) 652 653 def _fit(self, dataset): --> 654 java_model = self._fit_java(dataset) 655 return self._create_model(java_model) 656 /opt/spark/python/lib/pyspark.zip/pyspark/ml/wrapper.py in _fit_java(self, dataset) 330 """ 331 self._transfer_params_to_java() --> 332 return self._java_obj.fit(dataset._jdf) 333 334 def _fit(self, dataset): ~/cluster-env/env/lib/python3.8/site-packages/py4j/java_gateway.py in __call__(self, *args) 1302 1303 answer = self.gateway_client.send_command(command) -> 1304 return_value = get_return_value( 1305 answer, self.gateway_client, self.target_id, self.name) 1306 /opt/spark/python/lib/pyspark.zip/pyspark/sql/utils.py in deco(*a, **kw) 115 # Hide where the exception came from that shows a non-Pythonic 116 # JVM exception message. --> 117 raise converted from None 118 else: 119 raise IllegalArgumentException: Invalid connection string.
basically line:
model = simpleMultiAnomalyEstimator.fit(df)
I get invalid connection string.
Any thoughts?
Microsoft