擅长:python、mysql、java
<p>@blackbishop共享的问题线程确实回答了您的问题,您的<code>Active_Flag</code>和<code>Embargo period ended</code>作为<code>null</code>在模式中</p>
<pre><code>from pyspark.sql.types import StringType
from pyspark.sql.functions import lit
df.withColumn('Active_Flag', lit(None).cast(StringType))
.withColumn('Embargo period ended', lit(None).cast(StringType))
</code></pre>