response = boto3.client('glue', region_name=
datasource0 = glueContext.create_dynamic_frame.from_catalog(database = "
resolvedDF = datasource0.toDF().withColumn("column_name", col("column_name").cast(IntegerType()))
mapped_dyf = DynamicFrame.fromDF(resolvedDF, glueContext, "mapped")
注意:将“column_name”替换为正确的列名称和数据类型,例如“IntegerType”等。
如果手动指定列的数据类型仍然无效,请尝试更新表的模式,然后重新运行Crawler。如果表具有分区,请确保分区模式也已更新。
如果以上方法均无效,请考虑手动创建表并导入数据,然后指定正确的列数据类型。