blob: 342a8504e2e9ef3ce10a1cf1d4a9d630a5174b90 [file] [log] [blame]
source {
fields = ["ID"]
scheme = file
path = "target/test-classes"
readerPath = "asf.txt"
}
destination {
fields = ["DOC"]
scheme = file
path = "target/test-classes"
writerPath = "FlinkTwitterUserInformationPipelineIT"
}
providerWaitMs = 1000
local = true
test = true