Hi, @Averell <lvhu...@gmail.com> I renamed the `ElasticsearchFailureHandlerIndexer` to be `BufferingNoOpRequestIndexer`, which explains why you can't find it.
The voting thread for RC#1 of 1.7.2 can be found at [1]. The actual commits which fixes the problem are d9c45af to 2f52227. Cheers, Gordon [1] http://apache-flink-mailing-list-archive.1008284.n3.nabble.com/VOTE-Release-Apache-Flink-1-7-2-release-candidate-1-td26882.html On Thu, Feb 14, 2019 at 9:38 AM Ken Krugler <kkrugler_li...@transpac.com> wrote: > Hi Averell, > > > https://github.com/apache/flink/commit/35af99391dac431c85e30bcc98b89cba79bccfea#diff-51a12ea54593424e195dd5874309a08d > > …is the commit where Gordon made his changes for FLINK-11046 > <https://issues.apache.org/jira/browse/FLINK-11046>. > > The ElasticsearchFailureHandlerIndexer class was removed as part of the > commit. > > — Ken > > > On Feb 13, 2019, at 4:46 PM, Averell <lvhu...@gmail.com> wrote: > > Hi Ken, > > Thanks for that. But I could not find the changes included in Gordon's > mentioned pull request in the repository you gave me (e.g: the new class > /ElasticsearchFailureHandlerIndexer/). > I have found this folder > https://dist.apache.org/repos/dist/dev/flink/flink-1.7.2-rc1/, but it also > doesn't have that new class. > Maybe Gordon meant 1.7.2 rc2? > > Thanks and regards, > Averell > > > > -- > Sent from: > http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/ > > > -------------------------- > Ken Krugler > +1 530-210-6378 > http://www.scaleunlimited.com > Custom big data solutions & training > Flink, Solr, Hadoop, Cascading & Cassandra > >