security.kerberos.login.use-ticket-cache: true
security.kerberos.login.keytab: /home/flink/p_wanglin.keytab
security.kerberos.login.principal: p_wang...@local.com
但是只有最下面的一个(比如p_wanglin)生效。使用p_zhangjunjie就报错：那如何实现多个keytab用户同时生效呢?
谢谢！麻烦大家帮忙解决一下了。哪怕提供个思路都可以。
zhangjunjie1...@163.com
result = jsonObject1.toString();
return result;
}
})
;
student.print();
student.addSink(new FlinkKafkaProducer010(":9092","test",
new SimpleStringSchema())).name("fli
ut(flag,timeValue+"+"+streamIDValue);
jsonObject1.put("BigeyeValue",opentsdbValue);
//redis.close();
}
result = jsonObject1.toString();
return result;
}
})
;
student.addSink(new FlinkKafkaProducer010(":9092","test",
new SimpleStringSchema())).name("flink-kafka");
万分感谢！
zhangjunjie1...@163.com
您好：
现在Flink使用env.readFile的参数中，watchType只有两种参数：
FileProcessingMode.PROCESS_CONTINUOUSLY -
当输入路径下有文件被修改，整个路径下内容将会被重新处理
FileProcessingMode.PROCESS_ONCE - 只扫描一次，便退出。因此这种模式下输入数据只读取一次
想问一下一种方法，只加载文件中的增量内容？
zhangjunjie1...@163.com
您好：
现在Flink使用env.readFile的参数中，watchType只有两种参数：
FileProcessingMode.PROCESS_CONTINUOUSLY -
当输入路径下有文件被修改，整个路径下内容将会被重新处理
FileProcessingMode.PROCESS_ONCE - 只扫描一次，便退出。因此这种模式下输入数据只读取一次
想问一下一种方法，只加载文件中的增量内容？
zhangjunjie1...@163.com
