hi all
ok, so I'm using the follow files in my parent pom file.
The flink source connectors intention is to create snmp agents/targets.
user flink sql to define a table,
that will be scraped. at a interval specified.
<properties>
<flink.version>1.20.1</flink.version>
<java.version>17</java.version>
<maven-compiler.version>3.11.0</maven-compiler.version>
<maven-shade.version>3.5.2</maven-shade.version>
<maven-compiler.source>${java.version}</maven-compiler.source>
<maven-compiler.target>${java.version}</maven-compiler.target>
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
<slf4j.version>1.7.36</slf4j.version>
<log4j.version>2.17.1</log4j.version>
<junit.version>5.10.0</junit.version>
<snmp4j.version>3.7.3</snmp4j.version>
<mibble.version>2.10.1</mibble.version>
</properties>
<!-- SNMP4J for SNMP communication -->
<dependency>
<groupId>org.snmp4j</groupId>
<artifactId>snmp4j-source</artifactId>
<version>${snmp4j.version}</version>
<scope>compile</scope>
</dependency>
<dependency>
<groupId>org.snmp4j</groupId>
<artifactId>snmp4j</artifactId>
<version>${snmp4j.version}</version>
<scope>compile</scope>
</dependency>
<!-- Logging dependencies (SLF4J API and Log4j2 binding) -->
<dependency>
<groupId>org.slf4j</groupId>
<artifactId>slf4j-api</artifactId>
<version>${slf4j.version}</version>
<scope>compile</scope>
</dependency>
<dependency>
<groupId>org.apache.logging.log4j</groupId>
<artifactId>log4j-slf4j-impl</artifactId>
<version>${log4j.version}</version>
<scope>compile</scope>
</dependency>
<dependency>
<groupId>org.apache.logging.log4j</groupId>
<artifactId>log4j-api</artifactId>
<version>${log4j.version}</version>
<scope>compile</scope>
</dependency>
<dependency>
<groupId>org.apache.logging.log4j</groupId>
<artifactId>log4j-core</artifactId>
<version>${log4j.version}</version>
<scope>compile</scope>
</dependency>
when I try and run my job I get th following.
flink@jobmanager:~$ /opt/flink/bin/flink run
--detached -c com.snmp.job.SnmpPollingJob
/opt/flink/lib/flink/snmp-job-1.0-SNAPSHOT.jar
hive_catalog snmp
WARNING: Unknown module: jdk.compiler specified to --add-exports
WARNING: Unknown module: jdk.compiler specified to --add-exports
WARNING: Unknown module: jdk.compiler specified to --add-exports
WARNING: Unknown module: jdk.compiler specified to --add-exports
WARNING: Unknown module: jdk.compiler specified to --add-exports
SLF4J: Class path contains multiple SLF4J bindings.
SLF4J: Found binding in
[jar:file:/opt/flink/lib/flink/snmp-job-1.0-SNAPSHOT.jar!/org/slf4j/impl/StaticLoggerBinder.class]
SLF4J: Found binding in
[jar:file:/opt/flink/lib/log4j-slf4j-impl-2.17.1.jar!/org/slf4j/impl/StaticLoggerBinder.class]
SLF4J: See http://www.slf4j.org/codes.html#multiple_bindings for an
explanation.
SLF4J: Actual binding is of type
[org.apache.logging.slf4j.Log4jLoggerFactory]
WARNING: sun.reflect.Reflection.getCallerClass is not supported. This will
impact performance.
flink@jobmanager:~$
G
--
You have the obligation to inform one honestly of the risk, and as a person
you are committed to educate yourself to the total risk in any activity!
Once informed & totally aware of the risk,
every fool has the right to kill or injure themselves as they see fit!
