SteNicholas edited a comment on pull request #14028:
URL: https://github.com/apache/flink/pull/14028#issuecomment-737624706


   > Although the `ProgramInvocationException` is not annotated as `Public` or 
`PublicEvolving`, due to the fact that it has been here since forever, it seems 
that in some places we may be handling it specially and even expose it to the 
users. For example, the `ClientUtils.executeProgram()` is public and in the 
mailing list in the past there were people saying that they use it in other 
projects (I think Beam used to use it and I do not know if they still do).
   > 
   > On a separate note, given that this PR although small it has taken more 
than 3 weeks and a lot of discussions, I am starting to doubt if we should move 
forward with it. For example, the question that @tillrohrmann mentioned to have 
a separate exception for the runtime components and a separate for the client 
so that we can handle them differently, seems a deeper issue that requires more 
thought.
   > 
   > I may be wrong on that, but the discussions seem to be disproportionately 
long for the size and also the added value of this PR. What do you think?
   > 
   > BTW sorry for your time @SteNicholas if this does not get merged in the 
end but when I opened the JIRA I did not have a clear view of all the related 
changes that would pop up.
   
   @kl0u , I have followed with the `KafkaConsumerTestBase` comment from 
@tillrohrmann and pushed a commit for this. And I really want to follow the 
remaining comments from @tillrohrmann , and continue to update the commit 
according to Till's above comments. It's better for me to merge this pull 
request in the end.


----------------------------------------------------------------
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.

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org


Reply via email to