AbsaOSS / AbsaOSS/ABRiS

Spark structured streaming schema evolution

オープン
#319 コメント 2 件 リアクション 0 件 担当者 0 名 GitHub で見る
主要言語
Scala
スター
242
フォーク
84
平均マージ
10時間 12分
マージ済み PR(30日)
2

説明

Hi @kevinwallimann
First I'm aware of the [issue](https://github.com/AbsaOSS/ABRiS/issues/176)

I used abris to stream avro to delta table. As mentioned in the issue the schema evolution is not working neither using streaming or foreachbatch.

However using this [code](https://github.com/Orpheuz/SparkAvroSchemaEvolution) I'm able to update the schema for each message at least in the source the problem is that is never reflected on the sink (can be easily adapted to use abris by the way)

You said spark can't handle this out of the box I confirm but **do you've any idea how to implement it ?**
Thanks

コントリビューションガイド

このリポジトリのコントリビューションガイドは索引されていません

評価

この issue はまだ評価されていません。

新しい issue をメールで受け取る

初心者向けの GitHub issue を短くまとめたダイジェスト。