[ 
https://issues.apache.org/jira/browse/BEAM-3654?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16576504#comment-16576504
 ] 

Mikhail edited comment on BEAM-3654 at 8/10/18 4:23 PM:
--------------------------------------------------------

Also I found out that
{quote}./gradlew build
{quote}
is failing for me on *KuduIOTest#testWrite*. 
 It passes with the following code but I didn't try to figure out the reason of 
failure deeply:
{code:java}
    for (int i = 1; i <= targetParallelism; i++) {
      expectedWriteLogs.verifyDebug(String.format(FakeWriter.LOG_OPEN_SESSION, 
i));
      expectedWriteLogs.verifyDebug(
          String.format(FakeWriter.LOG_WRITE, i)); // at least one per writer
      expectedWriteLogs.verifyDebug(String.format(FakeWriter.LOG_CLOSE_SESSION, 
i));
    }
    // verify all entries written
    for (int n = 0; n < numberRecords; n++) {
      expectedWriteLogs.verifyDebug(
          String.format(FakeWriter.LOG_WRITE_VALUE, n)); // at least one per 
writer
    }
{code}
I made changes in 2 fors.

[~kenn] , Have you got the same behaviour?


was (Author: sokolovms):
Also I found out that 
{quote}./gradlew build{quote}
is failing for me on *KuduIOTest#testWrite*. 
It passes with the following code but I didn't try to figure out the reason of 
failure deeply:

{code:java}
    for (int i = 1; i <= targetParallelism; i++) {
      expectedWriteLogs.verifyDebug(String.format(FakeWriter.LOG_OPEN_SESSION, 
i));
      expectedWriteLogs.verifyDebug(
          String.format(FakeWriter.LOG_WRITE, i)); // at least one per writer
      expectedWriteLogs.verifyDebug(String.format(FakeWriter.LOG_CLOSE_SESSION, 
i));
    }
    // verify all entries written
    for (int n = 0; n < numberRecords; n++) {
      expectedWriteLogs.verifyDebug(
          String.format(FakeWriter.LOG_WRITE_VALUE, n)); // at least one per 
writer
    }
{code}

I made changes in 2 fors.


> Port FilterExamplesTest off DoFnTester
> --------------------------------------
>
>                 Key: BEAM-3654
>                 URL: https://issues.apache.org/jira/browse/BEAM-3654
>             Project: Beam
>          Issue Type: Sub-task
>          Components: examples-java
>            Reporter: Kenneth Knowles
>            Priority: Major
>              Labels: beginner, newbie, starter
>          Time Spent: 10m
>  Remaining Estimate: 0h
>




--
This message was sent by Atlassian JIRA
(v7.6.3#76005)

Reply via email to