Skip to main content
Filter by
Sorted by
Tagged with
-2 votes
1 answer
363 views

I am trying to read dat from kafka topic and writing it to HDFS filesystem, I buid my project using the apex malhar from [ https://github.com/apache/apex-malhar/tree/master/examples/kafka]. ...
AMLOCO's user avatar
  • 43
0 votes
1 answer
155 views

I'm quite new to Apache Apex platform. Does it have some web ui? I was able to run docker sandbox and some example app. Nevertheless, yarn tracking url points to 404 pages. For example http://...
Matzz's user avatar
  • 689
1 vote
1 answer
66 views

I am currently working on apache apex. My application gets reset after window ID 59 is reached and starts again from 0. I get an error which says that there is only 1 datanode running and no nodes are ...
neeraj goidani's user avatar
0 votes
0 answers
2k views

I am executing the mvn clean install -DskipTests -X command in apex-core folder lying under my work directory to run an apache apex application. But there is a build error which says : Failed to ...
Pranoti Bulakh's user avatar
-1 votes
1 answer
88 views

I am trying to execute an apex application consisting of an operator which uses the malhar library for generating random strings. Even though I have included the malhar-library dependency in my pom....
Pranoti Bulakh's user avatar
1 vote
1 answer
296 views

I would like to understand how I can see my application logs using log4j in Apache Apex when using the official RTS Test Sandbox in docker. To be more specific, I would like to know where Apex stores ...
ice_chrysler's user avatar
  • 2,863
7 votes
1 answer
3k views

As both are streaming frameworks which processes event at a time, What are the core architectural differences between these two technologies/streaming framework? Also, what are some particular use ...
Biplob Biswas's user avatar
1 vote
3 answers
128 views

I need to sync customer data from several on-premise databases into the cloud. In a second step, the customer data there needs some cleanup in order to remove duplicates (of different types). Based on ...
Andreas Hof's user avatar
0 votes
2 answers
128 views

I have been searching the INTERNET extensively for a way to use web-sphere MQ in Apache Apex to stream the MQ message through and into a DAG. However, there seems to be no IBM documentation on the ...
RandomUser's user avatar
3 votes
0 answers
71 views

I have a basic Apex stream with a Kafka input operator feeding into a Couchbase set operator. The Kafka sides works fine and have proven it by removing the couch operator. I have tried switching ...
Mark Kouba's user avatar
2 votes
1 answer
92 views

Is it possible to add input operator for different source in the running Apex application? For example: In an production environment, I am running an Apex application to read the text-file from input ...
Priyanshu Sharma's user avatar
2 votes
2 answers
175 views

I've downloaded Apache Apex 3.5.0 along with Malhar 3.5.0. I've successfully started the apex client and submitted the Yahoo Finance demo example to our YARN cluster (running CDH 5.10). The cluster ...
Tony's user avatar
  • 1,254
2 votes
3 answers
105 views

All examples of Apex say that the first operator of the DAG should be an input operator. Can this operator appear in the middle of the DAG somewhere. Consider a case in which I have data to be ...
frewper's user avatar
  • 1,453
3 votes
2 answers
176 views

Is there a way, using which we can predict the N/W latency between two different operators in Apache Apex. In a situation where the data that is going to be used in an operator, resides on a ...
frewper's user avatar
  • 1,453
1 vote
1 answer
237 views

I am following the documentation related to the Apache Apex which helps create a startup project. https://apex.apache.org/docs/apex-3.4/apex_development_setup/#creating-new-apex-project While ...
frewper's user avatar
  • 1,453

15 30 50 per page