-
Notifications
You must be signed in to change notification settings - Fork 35
Float DataType no longer supported #420
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
Comments
Hello @ElioMonaco , Couple of quick questions. can you do a printSchema and show the output of that please. Also, we had a similar issue where we mapped missing numeric types to real/decimal. Just to confirm if there is a fix already, would you be able to use say v5.2.7 the latest version to see if that works. As a temporary work around, changing the type of the field to double on the dataframe and give it a try. |
Hello @ag-ramachandran, Here is the result of the printSchema: root I have tried casting all of the float columns to double, but the same exact error DataType "float" is unsupported for entities of kind "Column" when attempting to write. The issue was eventually solved for me by changing the data type of the column in the Azure Data Explorer sink table itself from real to double. |
Describe the bug
When attempting to write data from a Delta table with a float column to a a table in Azure Data Explorer using the spark kusto connector, the following error occurs:
(com.microsoft.azure.kusto.data.exceptions.DataServiceException) DataType "float" is unsupported for entities of kind "Column". Reason="Column: Name="WarrantySaving" uses unsupported data type, DataType="float""
To Reproduce
Steps to reproduce the behavior:
pyKusto = SparkSession.builder.appName("kustoPySpark").getOrCreate()
dataframe_input.write.
format("com.microsoft.kusto.spark.datasource").
option("kustoCluster",connection_input["kustoCluster"]).
option("kustoDatabase",connection_input["kustoDatabase"]).
option("kustoTable", connection_input["kustoTable"]).
option("kustoAadAppId",connection_input["kustoAadAppId"]).
option("kustoAadAppSecret",connection_input["kustoAadAppSecret"]).
option("kustoAadAuthorityID",connection_input["kustoAadAuthorityID"]).
mode("Append").
save()
Expected behavior
The data is appended to the Kusto table without any error
Additional context
Spark cluster
com.microsoft.azure.kusto:kusto-spark_3.0_2.12:3.1.15 on 13.1 (includes Apache Spark 3.4.0, Scala 2.12)
Kusto cluster
Standard_L8s_v3
The text was updated successfully, but these errors were encountered: