Closed crazyzhou closed 1 year ago
Problem description In the initializeInternalWriter method in FlinkPravegaWriter class, we can add some more logs to debug, as this code path is important when a recovery happens.
initializeInternalWriter
FlinkPravegaWriter
Problem location FlinkPravegaWriter
Suggestions for an improvement
Problem description In the
initializeInternalWriter
method inFlinkPravegaWriter
class, we can add some more logs to debug, as this code path is important when a recovery happens.Problem location
FlinkPravegaWriter
Suggestions for an improvement