source { fields = ["ID"] scheme = file path = "target/test-classes" readerPath = "asf.txt" } destination { fields = ["DOC"] scheme = file path = "target/test-classes" writerPath = "FlinkTwitterFollowingPipelineFriendsIT" } twitter { endpoint = friends ids_only = true } providerWaitMs = 1000 local = true test = true