Return-Path: X-Original-To: apmail-flink-issues-archive@minotaur.apache.org Delivered-To: apmail-flink-issues-archive@minotaur.apache.org Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by minotaur.apache.org (Postfix) with SMTP id 1CE91184E9 for ; Mon, 22 Feb 2016 09:48:56 +0000 (UTC) Received: (qmail 50751 invoked by uid 500); 22 Feb 2016 09:48:34 -0000 Delivered-To: apmail-flink-issues-archive@flink.apache.org Received: (qmail 50701 invoked by uid 500); 22 Feb 2016 09:48:34 -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 50692 invoked by uid 99); 22 Feb 2016 09:48:34 -0000 Received: from pnap-us-west-generic-nat.apache.org (HELO spamd4-us-west.apache.org) (209.188.14.142) by apache.org (qpsmtpd/0.29) with ESMTP; Mon, 22 Feb 2016 09:48:34 +0000 Received: from localhost (localhost [127.0.0.1]) by spamd4-us-west.apache.org (ASF Mail Server at spamd4-us-west.apache.org) with ESMTP id E0A29C00ED for ; Mon, 22 Feb 2016 09:48:33 +0000 (UTC) X-Virus-Scanned: Debian amavisd-new at spamd4-us-west.apache.org X-Spam-Flag: NO X-Spam-Score: -4.349 X-Spam-Level: X-Spam-Status: No, score=-4.349 tagged_above=-999 required=6.31 tests=[KAM_LAZY_DOMAIN_SECURITY=1, RCVD_IN_DNSWL_HI=-5, RCVD_IN_MSPIKE_H3=-0.01, RCVD_IN_MSPIKE_WL=-0.01, RP_MATCHES_RCVD=-0.329] autolearn=disabled Received: from mx2-lw-eu.apache.org ([10.40.0.8]) by localhost (spamd4-us-west.apache.org [10.40.0.11]) (amavisd-new, port 10024) with ESMTP id 0Wv3oS6CajeL for ; Mon, 22 Feb 2016 09:48:33 +0000 (UTC) Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by mx2-lw-eu.apache.org (ASF Mail Server at mx2-lw-eu.apache.org) with SMTP id 481555FB10 for ; Mon, 22 Feb 2016 09:48:32 +0000 (UTC) Received: (qmail 50678 invoked by uid 99); 22 Feb 2016 09:48:31 -0000 Received: from git1-us-west.apache.org (HELO git1-us-west.apache.org) (140.211.11.23) by apache.org (qpsmtpd/0.29) with ESMTP; Mon, 22 Feb 2016 09:48:31 +0000 Received: by git1-us-west.apache.org (ASF Mail Server at git1-us-west.apache.org, from userid 33) id 66064DFCB8; Mon, 22 Feb 2016 09:48:31 +0000 (UTC) From: aljoscha To: issues@flink.incubator.apache.org Reply-To: issues@flink.incubator.apache.org Message-ID: Subject: [GitHub] flink pull request: [FLINK-3450] Duplicate TypeSerializer in State... Content-Type: text/plain Date: Mon, 22 Feb 2016 09:48:31 +0000 (UTC) GitHub user aljoscha opened a pull request: https://github.com/apache/flink/pull/1686 [FLINK-3450] Duplicate TypeSerializer in StateDescriptor.writeObject The StateDescriptor can be serializer asynchronously in case of asynchronous checkpoints. In that case two threads would try to concurrently use the TypeSerializer: The normal state updating and the checkpoint serialization. If the TypeSerializer is a KryoSerializer this can lead to problems. Therefore the need to duplicate it before using in "writeObject". You can merge this pull request into a Git repository by running: $ git pull https://github.com/aljoscha/flink state-descriptor-kryo-fix Alternatively you can review and apply these changes as the patch at: https://github.com/apache/flink/pull/1686.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 #1686 ---- commit 51d8dc9fa5cdd84b6cc1c7711af96ddabf12aaf6 Author: Aljoscha Krettek Date: 2016-02-19T14:38:57Z [FLINK-3450] Duplicate TypeSerializer in StateDescriptor.writeObject The StateDescriptor can be serializer asynchronously in case of asynchronous checkpoints. In that case two threads would try to concurrently use the TypeSerializer: The normal state updating and the checkpoint serialization. If the TypeSerializer is a KryoSerializer this can lead to problems. Therefore the need to duplicate it before using in "writeObject". ---- --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is enabled but not working, please contact infrastructure at infrastructure@apache.org or file a JIRA ticket with INFRA. ---