Hi Bharath,
Your theory is correct, InfluxDBFactory just return null for
SystemAdmin. Now it’s fixed already! But another problem occurred, below is
stack trace:
2019-06-03 17:26:11.176 [main] KafkaSystemAdmin [INFO] Fetching
SystemStreamMetadata for topics
Here is my theory based on the stack trace and logs.
InfluxDBSystemFactory could not create the admin successfully and returned
a null. Inside JavaSystemConfig, when it tries to get all the admins for
the systems available, Collectors.toMap(..) throws an exception during
reducing due to a null
Hi Bharath,
Below is configuration:
# App
app.name=canal-metrics
app.id=test
app.class=com.antfact.datacenter.canal.task.metrics.MetricsHandlerTask
task.class=com.antfact.datacenter.canal.task.metrics.MetricsHandlerTask
job.factory.class=org.apache.samza.job.yarn.YarnJobFactory
Hi Qi,
Can you share your application configuration? Especially the systems your
application consumes and produces to and its related configuration.
Also, would it be possible for to attach the entire log?
Thanks,
Bharath
On Tue, May 28, 2019 at 7:07 PM QiShu wrote:
> Hi,
>
> Below is
Hi,
Below is the running environment:
Hadoop version 3.1.0
java version “1.8.0_151"
samza-api-1.1.0.jar
samza-core_2.12-1.1.0.jar
samza-kafka_2.12-1.1.0.jar
samza-kv_2.12-1.1.0.jar
samza-kv-inmemory_2.12-1.1.0.jar
samza-kv-rocksdb_2.12-1.1.0.jar
samza-log4j_2.12-1.1.0.jar
