Peter Huang

@davidradl Thanks for pointing it out. if throwable is not null in whenCompleteAsync, It should be logged rather than being swallowed. As we discussed offline, added error message logging for...

@flinkbot run azure

@flinkbot run azure

@PatrickRen Thanks for reviewing the RP. For the testing purpose, I only added lineage provider implementation for values related source functions and input format. I will add lineage provider for...

@davidradl Thanks for reviewing this PR. This PR is mainly to handle with source/sink level lineage, column level lineage will be need a further discussion in community. Resolved most of...

@PatrickRen I have removed schema facet and config facets, given these info are already provided by CatalogBaseTable. It greatly reduced the size of the PR. Would you please take one...

@X-czh Thanks for giving feedback. I removed unused ColumnLineage Interface, and also refined the code as you suggested.