[
https://issues.apache.org/jira/browse/CAMEL-7068?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xavier Fournet updated CAMEL-7068:
----------------------------------
Description:
When using a route with a streamed split of a Flatpack result, only halve of
the rows are processed
Using the repro case we get
{noformat}
2013-12-13 19:51:17,438 [main] INFO route1 - Number of rows 6
2013-12-13 19:51:17,442 [main] INFO test - Exchange[ExchangePattern: InOnly,
BodyType: java.util.HashMap, Body: {Col1=1, Col2=A}]
2013-12-13 19:51:17,443 [main] INFO test - Exchange[ExchangePattern: InOnly,
BodyType: java.util.HashMap, Body: {Col1=3, Col2=C}]
2013-12-13 19:51:17,443 [main] INFO test - Exchange[ExchangePattern: InOnly,
BodyType: java.util.HashMap, Body: {Col1=5, Col2=E}]
{noformat}
if streaming() is removed, all the lines are processed
{noformat}
2013-12-13 19:52:37,471 [main] INFO route1 - Number of rows 6
2013-12-13 19:52:37,475 [main] INFO test - Exchange[ExchangePattern: InOnly,
BodyType: java.util.HashMap, Body: {Col1=1, Col2=A}]
2013-12-13 19:52:37,476 [main] INFO test - Exchange[ExchangePattern: InOnly,
BodyType: java.util.HashMap, Body: {Col1=2, Col2=B}]
2013-12-13 19:52:37,476 [main] INFO test - Exchange[ExchangePattern: InOnly,
BodyType: java.util.HashMap, Body: {Col1=3, Col2=C}]
2013-12-13 19:52:37,476 [main] INFO test - Exchange[ExchangePattern: InOnly,
BodyType: java.util.HashMap, Body: {Col1=4, Col2=D}]
2013-12-13 19:52:37,479 [main] INFO test - Exchange[ExchangePattern: InOnly,
BodyType: java.util.HashMap, Body: {Col1=5, Col2=E}]
2013-12-13 19:52:37,479 [main] INFO test - Exchange[ExchangePattern: InOnly,
BodyType: java.util.HashMap, Body: {Col1=6, Col2=F}]
{noformat}
was:When using a route with a streamed split of a Flatpack result, only halve
of the rows are processed
> Flatpack skips 1 row every 2 rows when using split with streaming=true
> ----------------------------------------------------------------------
>
> Key: CAMEL-7068
> URL: https://issues.apache.org/jira/browse/CAMEL-7068
> Project: Camel
> Issue Type: Bug
> Components: camel-flatpack
> Reporter: Xavier Fournet
> Attachments: Camel7068Test.java
>
>
> When using a route with a streamed split of a Flatpack result, only halve of
> the rows are processed
> Using the repro case we get
> {noformat}
> 2013-12-13 19:51:17,438 [main] INFO route1 - Number of rows 6
> 2013-12-13 19:51:17,442 [main] INFO test - Exchange[ExchangePattern: InOnly,
> BodyType: java.util.HashMap, Body: {Col1=1, Col2=A}]
> 2013-12-13 19:51:17,443 [main] INFO test - Exchange[ExchangePattern: InOnly,
> BodyType: java.util.HashMap, Body: {Col1=3, Col2=C}]
> 2013-12-13 19:51:17,443 [main] INFO test - Exchange[ExchangePattern: InOnly,
> BodyType: java.util.HashMap, Body: {Col1=5, Col2=E}]
> {noformat}
> if streaming() is removed, all the lines are processed
> {noformat}
> 2013-12-13 19:52:37,471 [main] INFO route1 - Number of rows 6
> 2013-12-13 19:52:37,475 [main] INFO test - Exchange[ExchangePattern: InOnly,
> BodyType: java.util.HashMap, Body: {Col1=1, Col2=A}]
> 2013-12-13 19:52:37,476 [main] INFO test - Exchange[ExchangePattern: InOnly,
> BodyType: java.util.HashMap, Body: {Col1=2, Col2=B}]
> 2013-12-13 19:52:37,476 [main] INFO test - Exchange[ExchangePattern: InOnly,
> BodyType: java.util.HashMap, Body: {Col1=3, Col2=C}]
> 2013-12-13 19:52:37,476 [main] INFO test - Exchange[ExchangePattern: InOnly,
> BodyType: java.util.HashMap, Body: {Col1=4, Col2=D}]
> 2013-12-13 19:52:37,479 [main] INFO test - Exchange[ExchangePattern: InOnly,
> BodyType: java.util.HashMap, Body: {Col1=5, Col2=E}]
> 2013-12-13 19:52:37,479 [main] INFO test - Exchange[ExchangePattern: InOnly,
> BodyType: java.util.HashMap, Body: {Col1=6, Col2=F}]
> {noformat}
--
This message was sent by Atlassian JIRA
(v6.1.4#6159)
