Hi Polarisary,
It's hard to tell what happened without further detail. Just some guesses.
1. Have you completed the "resultFuture" in "asyncInvoke"? Asking this is
because there is only a part of "asyncInvoke" implementation, I can't see
the completion part.
2. The capacity (10) of async waiting q
Hi Polarisary,
IMO, firstly, it would be better to monitor the OS and Flink/HBase metrics.
For example:
- Flink and HBase cluster Network I/O metrics;
- Flink TM CPU/Memory/Backpressure metrics and so on;
You can view these metrics to find some potential reasons. If you can not
figure it
Hi ALL,
When I use RichAsyncFunction read data from hbase, it always timeout after a
few minutes. but the hbase connection is not close, it also can get data in the
override method timeout.
Following is the code, does somebody know why trigger timeout.
==
