Github user fhueske commented on the pull request: https://github.com/apache/flink/pull/983#issuecomment-127693034 The empty file is exactly the problem. What happens if you read that file with a TypeSerializerInpitFormat typed for Tuple0? It will not return the same amount of Tuple0 objects as were "written" to it. That's the problem with de/serializers that do not read/write anything. This problem can occur anywhere in Flink's engine where data is serialized.
--- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is enabled but not working, please contact infrastructure at infrastruct...@apache.org or file a JIRA ticket with INFRA. ---