xincai98

The reason for the error is that the upper limit of grpc is reached, which can be solved by the following methods: 1. Modify WindowFactory.allWindow() in the code to WindowFactory.createSizeTumblingWindow(${batch...

try { String fromKey = getFromKey(key);\n if (!update(fromKey, columns, new Object[] {valueArray})) { LOGGER.info("key: {}, insert fail, try insert", key); try { insert(fromKey, columns, new Object[] {valueArray}); } catch (Exception...