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