You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by "Mikhail (JIRA)" <ji...@apache.org> on 2018/08/10 16:24:00 UTC
[jira] [Comment Edited] (BEAM-3654) Port FilterExamplesTest off DoFnTester

    [ 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)