flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "ASF GitHub Bot (JIRA)" <j...@apache.org>
Subject [jira] [Commented] (FLINK-4953) Allow access to "time" in ProcessWindowFunction.Context
Date Sun, 02 Apr 2017 12:52:41 GMT

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

ASF GitHub Bot commented on FLINK-4953:

Github user manuzhang commented on the issue:

    Not sure what happened here although tests passed in most cases. Looks unrelated to this
    [ERROR] Failed to execute goal org.apache.maven.plugins:maven-surefire-plugin:2.18.1:test
(default-test) on project flink-runtime-web_2.10: There are test failures.
    [ERROR] Please refer to /home/travis/build/apache/flink/flink-runtime-web/target/surefire-reports
for the individual test results.
    [ERROR] -> [Help 1]
    [ERROR] To see the full stack trace of the errors, re-run Maven with the -e switch.
    [ERROR] Re-run Maven using the -X switch to enable full debug logging.
    [ERROR] For more information about the errors and possible solutions, please read the
following articles:
    [ERROR] [Help 1] http://cwiki.apache.org/confluence/display/MAVEN/MojoFailureException
    [ERROR] After correcting the problems, you can resume the build with the command
    [ERROR]   mvn <goals> -rf :flink-runtime-web_2.10
    Trying to KILL watchdog (1513).
    ./tools/travis_mvn_watchdog.sh: line 210:  1513 Terminated              watchdog
    MVN exited with EXIT CODE: 1.
    java.io.FileNotFoundException: build-target/lib/flink-dist-*.jar (No such file or directory)
    	at java.util.zip.ZipFile.open(Native Method)
    	at java.util.zip.ZipFile.<init>(ZipFile.java:215)
    	at java.util.zip.ZipFile.<init>(ZipFile.java:145)
    	at java.util.zip.ZipFile.<init>(ZipFile.java:116)
    	at sun.tools.jar.Main.list(Main.java:1004)
    	at sun.tools.jar.Main.run(Main.java:245)
    	at sun.tools.jar.Main.main(Main.java:1177)
    find: `./flink-yarn-tests/target/flink-yarn-tests*': No such file or directory
    PRODUCED build artifacts.
    1.log  2.log  build_info  mvn.out
    COMPRESSING build artifacts.
    Uploading to transfer.sh
    The command "./tools/travis_mvn_watchdog.sh 300" exited with 1.
    Done. Your build exited with 1.

> Allow access to "time" in ProcessWindowFunction.Context
> -------------------------------------------------------
>                 Key: FLINK-4953
>                 URL: https://issues.apache.org/jira/browse/FLINK-4953
>             Project: Flink
>          Issue Type: Improvement
>          Components: DataStream API
>            Reporter: Manu Zhang
>            Assignee: Manu Zhang
> The recently added {{ProcessWindowFunction}} has a {{Context}} object that allows querying
some additional information about the window firing that we are processing. Right now, this
is only the window for which the firing is happening. We should extends this with methods
that allow querying the current processing time and the current watermark.
> Original text by issue creator: This is similar to FLINK-3674 but exposing time information
in window functions. Currently when a timer is fired, all states in a window will be returned
to users, including those after the timer. This change will allow users to filter out states
after the timer based on time info.

This message was sent by Atlassian JIRA

View raw message