You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/09/25 16:56:20 UTC

[jira] [Commented] (FLINK-4552) Refactor WindowOperator/Trigger Tests

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

ASF GitHub Bot commented on FLINK-4552:
---------------------------------------

GitHub user aljoscha opened a pull request:

    https://github.com/apache/flink/pull/2547

    [FLINK-4552] Refactor WindowOperator/Trigger Tests

    Before `WindowOperatorTest` was more like an integration test. We would throw elements at `WindowOperator` and observe whether we got the correct output.
    
    The new `WindowOperatorTest` verifies the implicit contract between the windowing components. I also added explicit tests for `WindowAssigners` and `Triggers`. For triggers I added a new `TriggerTestHarness`. Also, I modified `HeapKeyedStateBackend` to allow querying how many entries there are for a given namespace, this allows testing whether trigger correctly clean up their state. I also added the new interfaces `TimerService` and `InternalTimerService` that should be used for all stuff concerning time and timers. For now, these are only used in the tests but they should be used in more components. 
    
    R: @StefanRRichter and @kl0u for review.
    
    P.S. : I wanted to get this in before we get in the work on triggers/trigger DSL to ensure that we don't break things and to modularize the tests.

You can merge this pull request into a Git repository by running:

    $ git pull https://github.com/aljoscha/flink window-test-refactor

Alternatively you can review and apply these changes as the patch at:

    https://github.com/apache/flink/pull/2547.patch

To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:

    This closes #2547
    
----
commit 90f6785d1038ebef8cd92965cd29a2d1da6e0370
Author: Aljoscha Krettek <al...@gmail.com>
Date:   2016-09-05T10:01:11Z

    [FLINK-4552] Refactor WindowOperator/Trigger Tests

commit 140d85ffff3364f98e70539861a1c1bb51f39a1b
Author: Aljoscha Krettek <al...@gmail.com>
Date:   2016-09-24T13:41:10Z

    Add WindowAssignerTests

commit 56f33789e22f0bdc056be34e92c523d7965bbad4
Author: Aljoscha Krettek <al...@gmail.com>
Date:   2016-09-25T16:39:47Z

    Add TriggerTests/TimerService

----


> Refactor WindowOperator/Trigger Tests
> -------------------------------------
>
>                 Key: FLINK-4552
>                 URL: https://issues.apache.org/jira/browse/FLINK-4552
>             Project: Flink
>          Issue Type: Improvement
>          Components: Windowing Operators
>            Reporter: Aljoscha Krettek
>            Assignee: Aljoscha Krettek
>
> Right now, tests for {{WindowOperator}}, {{WindowAssigner}}, {{Trigger}} and {{WindowFunction}} are all conflated in {{WindowOperatorTest}}. All of these test that a certain combination of a {{Trigger}}, {{WindowAssigner}} and {{WindowFunction}} produce the expected output.
> We should modularize these tests and spread them out across multiple files, possibly one per trigger, for the triggers. Also, we should extend/change the tests in some key ways:
>  - {{WindowOperatorTest}} test should just verify that the interaction between {{WindowOperator}} and the various other parts works as expected, that the correct methods on {{Trigger}} and {{WindowFunction}} are called at the expected time and that snapshotting, timers, cleanup etc. work correctly. These tests should also verify that the different state types and {{WindowFunctions}} work correctly.
>  - {{Trigger}} tests should present elements to triggers and verify that they fire at the correct times. The actual output of the {{WindowFunction}} is not important for these tests. We should also test that triggers correctly clean up state and timers.
>  - {{WindowAssigner}} tests should test each window assigner and also verify that, for example, the offset parameter of time-based windows works correctly.
> There is already {{WindowingTestHarness}} but it is not used by tests, I think we can expand on that and provide more thorough test coverage while also making the tests more maintainable ({{WindowOperatorTest.java}} is nearing 3000 lines of code).



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)