data-processing/flink/applications/stream-tweets/src/main/java/com/hongbomiao/Main.java
Method main
has 126 lines of code (exceeds 25 allowed). Consider refactoring. Open
Open
public static void main(String[] args) throws Exception {
final StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();
// String paramsFilePath = "data-processing/flink/applications/stream-tweets/src/main/resources/application-development.properties";
String paramsFilePath = "application-production.properties";