MINOR: Fix compilation issue in FileStreamSourceConnector
Fix compilation failure introduced in
Reviewers: Mickael Maison
@@ -91,7 +91,7 @@ public class FileStreamSourceConnector extends SourceConnector {
@Override
public ExactlyOnceSupport exactlyOnceSupport(Map<String, String> props) {
AbstractConfig parsedConfig = new AbstractConfig(CONFIG_DEF, props);
- filename = parsedConfig.getString(FILE_CONFIG);
+ String filename = parsedConfig.getString(FILE_CONFIG);
// We can provide exactly-once guarantees if reading from a "real" file
// (as long as the file is only appended to over the lifetime of the connector)
// If we're reading from stdin, we can't provide exactly-once guarantees
