import os
os.environ[‘TF_CPP_MIN_LOG_LEVEL’] = ‘3’
import tensorflow_io as tfio
import tensorflow as tf
from tensorflow.keras import layers
dataset = tfio.experimental.elasticsearch.ElasticsearchIODataset(
**                nodes=[“XXX.XXX.XXX.XXX:9200”],**
**                index=“test”**
**            )**
dataset = dataset.enumerate(start=0)
for element in dataset.as_numpy_iterator():
**    print(element)**
there are 3462 records, and this code works until 3379
(3379, {‘Type’: b’Cat’, ‘Age’: 4, ‘Breed1’: b’Domestic Medium Hair’, ‘Gender’: b’Female’, ‘Color1’: b’Black’, ‘Color2’: b’No Color’, ‘MaturitySize’: b’Medium’, ‘FurLength’: b’Medium’, ‘Vaccinated’: b’No’, ‘Sterilized’: b’No’, ‘Health’: b’Healthy’, ‘Fee’: 0, ‘PhotoAmt’: 2, ‘target’: 1})
Traceback (most recent call last):
File “/home/cdt/temp/elk.py”, line 13, in 
File “/home/cdt/.local/lib/python3.9/site-packages/tensorflow/python/data/ops/dataset_ops.py”, line 4194, in next
File “/home/cdt/.local/lib/python3.9/site-packages/tensorflow/python/data/ops/iterator_ops.py”, line 761, in next
File “/home/cdt/.local/lib/python3.9/site-packages/tensorflow/python/data/ops/iterator_ops.py”, line 744, in _next_internal
File “/home/cdt/.local/lib/python3.9/site-packages/tensorflow/python/ops/gen_dataset_ops.py”, line 2728, in iterator_get_next
File “/home/cdt/.local/lib/python3.9/site-packages/tensorflow/python/framework/ops.py”, line 6897, in raise_from_not_ok_status
File “”, line 3, in raise_from
tensorflow.python.framework.errors_impl.FailedPreconditionError: Corrupted response from the server null
[[{{node IO>ElasticsearchReadableNext}}]] [Op:IteratorGetNext]