Return-Path: X-Original-To: apmail-flink-dev-archive@www.apache.org Delivered-To: apmail-flink-dev-archive@www.apache.org Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by minotaur.apache.org (Postfix) with SMTP id 34AE418C86 for ; Fri, 15 Jan 2016 15:30:41 +0000 (UTC) Received: (qmail 11097 invoked by uid 500); 15 Jan 2016 15:30:40 -0000 Delivered-To: apmail-flink-dev-archive@flink.apache.org Received: (qmail 10976 invoked by uid 500); 15 Jan 2016 15:30:40 -0000 Mailing-List: contact dev-help@flink.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@flink.apache.org Delivered-To: mailing list dev@flink.apache.org Received: (qmail 10831 invoked by uid 99); 15 Jan 2016 15:30:40 -0000 Received: from arcas.apache.org (HELO arcas) (140.211.11.28) by apache.org (qpsmtpd/0.29) with ESMTP; Fri, 15 Jan 2016 15:30:40 +0000 Received: from arcas.apache.org (localhost [127.0.0.1]) by arcas (Postfix) with ESMTP id 0543C2C1F58 for ; Fri, 15 Jan 2016 15:30:40 +0000 (UTC) Date: Fri, 15 Jan 2016 15:30:40 +0000 (UTC) From: "Aljoscha Krettek (JIRA)" To: dev@flink.apache.org Message-ID: In-Reply-To: References: Subject: [jira] [Created] (FLINK-3243) Fix Interplay of TimeCharacteristic and Time Windows MIME-Version: 1.0 Content-Type: text/plain; charset=utf-8 Content-Transfer-Encoding: 7bit X-JIRA-FingerPrint: 30527f35849b9dde25b450d4833f0394 Aljoscha Krettek created FLINK-3243: --------------------------------------- Summary: Fix Interplay of TimeCharacteristic and Time Windows Key: FLINK-3243 URL: https://issues.apache.org/jira/browse/FLINK-3243 Project: Flink Issue Type: Bug Components: Streaming Affects Versions: 1.0.0 Reporter: Aljoscha Krettek Assignee: Aljoscha Krettek Priority: Blocker As per the discussion on the Dev ML: http://apache-flink-mailing-list-archive.1008284.n3.nabble.com/DISCUSS-Time-Behavior-in-Streaming-Jobs-Event-time-processing-time-td9616.html. The discussion seems to have converged on option 2): - Add dedicated WindowAssigners for processing time and event time - {{timeWindow()}} and {{timeWindowAll()}} respect the set {{TimeCharacteristic}}. This will make the easy stuff easy, i.e. using time windows and quickly switching the time characteristic. Users will then have the flexibility to mix different kinds of window assigners in their job. -- This message was sent by Atlassian JIRA (v6.3.4#6332)