気流xcom_pullフレームが終了する前にピクルスが枯渇しました

Question

前回xcom_pushされた のHTTPレスポンスでxcom_pullを実行していて、pickle exhausted before end of frameを受け取りました。

http応答が短い辞書になると、私はこのエラーを受け取りません。

これはxcom_pull/push'edの制限事項ですか？

Answer 1

私はこの問題か非常によく似た問題を抱えていました。私たちはAirflowのためにMySQL DBを使用しています。これはxcom_pull（）の後に発生し、トレースはsqlalchemyを通過します。 DBへの深い浸透は、pickleがblobとしてdag_pickle.pickleカラムに格納されていることを示唆しています。最大サイズは65,535バイトです。私たちのために

、カップルのテーブルの調整は、問題を修正：

alter table dag_pickle modify pickle MEDIUMBLOB; 
alter table xcom modify value MEDIUMBLOB; 

の両方が必要ではないかもしれません。より永続的な修正には、テーブルがairflow/models.pyによって作成されたときに 'length ='パラメータを使用する必要があります。