david-streamlio commented on PR #93: URL: https://github.com/apache/pulsar-connectors/pull/93#issuecomment-4937871294
Filed the sink `close()` ordering bug this test surfaced as #94 — `close()` closes the stream via `writer.close()` before the final `hsync()` in `syncThread.halt()`, which throws `ClosedChannelException` against real HDFS (the mock tests use local FS and never hit it). The workaround here (drain the unacked queue before `close()`) is correct for a test-only PR; the underlying fix belongs in #94. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
