Я думаю, что событие клона отражает тот факт, что один и тот же поток передается двум разным адресатам (LogMessage и ConvertAvroToORC).Таким образом, существует один файл потока, созданный QueryDatabaseTable, а затем, когда платформа видит, что успех идет в двух местах, она должна клонировать файл потока.