Hi all,
We would like to write and run integration tests for our own Samza Tasks/Jobs,
but without using external tools like Zoopkio, but rather as a part of the
build process. What we would like to do is start Yarn/Zookeeper/Kafka locally
(or in a docker container) and then submit jobs program
/store/TestMetricDocumentStore.java
PRE-CREATION
settings.gradle 4c1aa10
Diff: https://reviews.apache.org/r/36767/diff/
Testing
---
Thanks,
Robert Zuljevic
Hello all,
I've added a design document to task SAMZA-423. If anyone is interested please
take a look : )
I have some outstanding questions that I would like to resolve so I could
continue working on this as soon as possible:
1. Should the API support bulk indexing/removing/matching? (n
ld be greatly appreaciated! I tested the change
with the unit/integration tests already available.
Thanks,
Robert Zuljevic
nters would be greatly appreaciated! I tested the change
with the unit/integration tests already available.
Thanks,
Robert Zuljevic
h the unit/integration tests already available.
Thanks,
Robert Zuljevic
-
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/36163/#review93093
-------
On July 9, 2015, 2:39 p.m., Robert Zuljevic wrote:
>
> ---
n
JobCoordinator, right after cration?
- Robert
---
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/36163/#review93019
---
rt
---
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/36163/#review93019
---
On July 9, 2015, 2:39 p.m., Robert Zuljevi
temStream.getStream,
changeLogPartitions)
}
This is the only way I could thought of for simplifing this. I don't think
what you posted would work, because you're using String's map function, but it
did steer me in the right direction. Do you agree?
- Robert Zuljevic
19bff971ad221084dac10d3f7f3facfa42b829a7
Diff: https://reviews.apache.org/r/36767/diff/
Testing
---
Thanks,
Robert Zuljevic
here, so any pointers would be greatly appreaciated! I tested the change
with the unit/integration tests already available.
Thanks,
Robert Zuljevic
test / integration test) I should
make here, so any pointers would be greatly appreaciated! I tested the change
with the unit/integration tests already available.
Thanks,
Robert Zuljevic
samza-yarn/src/test/scala/org/apache/samza/job/yarn/TestSamzaAppMasterTaskManager.scala
1e936b42a5b9a4bfb43766c17847b2947ebdb21d
Diff: https://reviews.apache.org/r/36163/diff/
Testing
---
Thanks,
Robert Zuljevic
:40 AM, Robert Zuljevic
wrote:
> 1. Is checkpoint topic referred to in the description coordinator
> stream/topic?
>
In the master branch, checkpoint topic is deprecated (except for migration
purpose). The checkpoints will be sent to coordinator stream. Hence, there is
no need
Hello all,
Description of SAMZA-690 (https://issues.apache.org/jira/browse/SAMZA-690)
ticket says that creation of changelog and checkpoint topics should be moved
from SamzaContainer class to JobRunner/JobCoordinator class. I investigated for
a while, but seem to have hit a wall and require som
95f76b61f70058bb567fe4eff3a3bb2298a0e197
samza-test/src/test/scala/org/apache/samza/test/integration/TestStatefulTask.scala
82006960adc45a92a79e28f078ebd5eb01d3205e
Diff: https://reviews.apache.org/r/35067/diff/
Testing
---
Thanks,
Robert Zuljevic
82006960adc45a92a79e28f078ebd5eb01d3205e
Diff: https://reviews.apache.org/r/35067/diff/
Testing
---
Thanks,
Robert Zuljevic
throw an NumberFormatException. Is this ok?
- Robert
---
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/35067/#review86980
---
On June 4, 2015, 1:50 p.m., Robert Zuljevic wrote:
>
>
19 matches
Mail list logo
