Return-Path: X-Original-To: archive-asf-public-internal@cust-asf2.ponee.io Delivered-To: archive-asf-public-internal@cust-asf2.ponee.io Received: from cust-asf.ponee.io (cust-asf.ponee.io [163.172.22.183]) by cust-asf2.ponee.io (Postfix) with ESMTP id 7F3F2200C02 for ; Fri, 20 Jan 2017 12:58:33 +0100 (CET) Received: by cust-asf.ponee.io (Postfix) id 766E0160B48; Fri, 20 Jan 2017 11:58:33 +0000 (UTC) Delivered-To: archive-asf-public@cust-asf.ponee.io Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by cust-asf.ponee.io (Postfix) with SMTP id C81DE160B39 for ; Fri, 20 Jan 2017 12:58:32 +0100 (CET) Received: (qmail 90883 invoked by uid 500); 20 Jan 2017 11:58:31 -0000 Mailing-List: contact issues-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 issues@flink.apache.org Received: (qmail 90869 invoked by uid 99); 20 Jan 2017 11:58:31 -0000 Received: from pnap-us-west-generic-nat.apache.org (HELO spamd3-us-west.apache.org) (209.188.14.142) by apache.org (qpsmtpd/0.29) with ESMTP; Fri, 20 Jan 2017 11:58:31 +0000 Received: from localhost (localhost [127.0.0.1]) by spamd3-us-west.apache.org (ASF Mail Server at spamd3-us-west.apache.org) with ESMTP id 4704C18C36E for ; Fri, 20 Jan 2017 11:58:31 +0000 (UTC) X-Virus-Scanned: Debian amavisd-new at spamd3-us-west.apache.org X-Spam-Flag: NO X-Spam-Score: -1.199 X-Spam-Level: X-Spam-Status: No, score=-1.199 tagged_above=-999 required=6.31 tests=[KAM_ASCII_DIVIDERS=0.8, KAM_LAZY_DOMAIN_SECURITY=1, RP_MATCHES_RCVD=-2.999] autolearn=disabled Received: from mx1-lw-eu.apache.org ([10.40.0.8]) by localhost (spamd3-us-west.apache.org [10.40.0.10]) (amavisd-new, port 10024) with ESMTP id jwa6xZAbYaFX for ; Fri, 20 Jan 2017 11:58:30 +0000 (UTC) Received: from mailrelay1-us-west.apache.org (mailrelay1-us-west.apache.org [209.188.14.139]) by mx1-lw-eu.apache.org (ASF Mail Server at mx1-lw-eu.apache.org) with ESMTP id C67565FC80 for ; Fri, 20 Jan 2017 11:58:29 +0000 (UTC) Received: from jira-lw-us.apache.org (unknown [207.244.88.139]) by mailrelay1-us-west.apache.org (ASF Mail Server at mailrelay1-us-west.apache.org) with ESMTP id 0029AE0284 for ; Fri, 20 Jan 2017 11:58:28 +0000 (UTC) Received: from jira-lw-us.apache.org (localhost [127.0.0.1]) by jira-lw-us.apache.org (ASF Mail Server at jira-lw-us.apache.org) with ESMTP id 8FCD62528F for ; Fri, 20 Jan 2017 11:58:26 +0000 (UTC) Date: Fri, 20 Jan 2017 11:58:26 +0000 (UTC) From: "ASF GitHub Bot (JIRA)" To: issues@flink.apache.org Message-ID: In-Reply-To: References: Subject: [jira] [Commented] (FLINK-5527) QueryableState: requesting a non-existing key in MemoryStateBackend or FsStateBackend does not return the default value MIME-Version: 1.0 Content-Type: text/plain; charset=utf-8 Content-Transfer-Encoding: 7bit X-JIRA-FingerPrint: 30527f35849b9dde25b450d4833f0394 archived-at: Fri, 20 Jan 2017 11:58:33 -0000 [ https://issues.apache.org/jira/browse/FLINK-5527?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15831608#comment-15831608 ] ASF GitHub Bot commented on FLINK-5527: --------------------------------------- Github user uce commented on the issue: https://github.com/apache/flink/pull/3142 I agree with both of your points, but I'm slightly leaning towards the side of consistent behaviour since this behaviour is not special for queryable state per se. It's just implementing the current contract of the state interfaces, which still allow for a default value. Once we remove that from the state interfaces, queryable state should also not expose it anymore, since queryable state is registered within the program. In the end I'm fine with both approaches and it's up to you both to decide. :wink: PS Note that `null` is not returned in case of a query to a non-existent value for a key/namespace, but the `UnknownKeyOrNamespace` exception fails the queries `Future` instance. > QueryableState: requesting a non-existing key in MemoryStateBackend or FsStateBackend does not return the default value > ----------------------------------------------------------------------------------------------------------------------- > > Key: FLINK-5527 > URL: https://issues.apache.org/jira/browse/FLINK-5527 > Project: Flink > Issue Type: Improvement > Components: Queryable State > Affects Versions: 1.2.0 > Reporter: Nico Kruber > Assignee: Nico Kruber > > Querying for a non-existing key for a state that has a default value set currently results in an UnknownKeyOrNamespace exception when the MemoryStateBackend or FsStateBackend is used. It should return the default value instead just like the RocksDBStateBackend. -- This message was sent by Atlassian JIRA (v6.3.4#6332)