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 A3389200B4F for ; Tue, 26 Jul 2016 19:35:58 +0200 (CEST) Received: by cust-asf.ponee.io (Postfix) id A1CCA160A75; Tue, 26 Jul 2016 17:35:58 +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 C387E160A69 for ; Tue, 26 Jul 2016 19:35:57 +0200 (CEST) Received: (qmail 96930 invoked by uid 500); 26 Jul 2016 17:35:57 -0000 Mailing-List: contact user-help@ignite.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: user@ignite.apache.org Delivered-To: mailing list user@ignite.apache.org Received: (qmail 96919 invoked by uid 99); 26 Jul 2016 17:35:56 -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; Tue, 26 Jul 2016 17:35:56 +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 82218187A00 for ; Tue, 26 Jul 2016 17:35:56 +0000 (UTC) X-Virus-Scanned: Debian amavisd-new at spamd3-us-west.apache.org X-Spam-Flag: NO X-Spam-Score: 1.879 X-Spam-Level: * X-Spam-Status: No, score=1.879 tagged_above=-999 required=6.31 tests=[DKIM_SIGNED=0.1, DKIM_VALID=-0.1, DKIM_VALID_AU=-0.1, HTML_MESSAGE=2, RCVD_IN_DNSWL_NONE=-0.0001, RCVD_IN_MSPIKE_H3=-0.01, RCVD_IN_MSPIKE_WL=-0.01, SPF_PASS=-0.001] autolearn=disabled Authentication-Results: spamd3-us-west.apache.org (amavisd-new); dkim=pass (2048-bit key) header.d=gmail.com Received: from mx2-lw-us.apache.org ([10.40.0.8]) by localhost (spamd3-us-west.apache.org [10.40.0.10]) (amavisd-new, port 10024) with ESMTP id YbIH7xpWPWb8 for ; Tue, 26 Jul 2016 17:35:52 +0000 (UTC) Received: from mail-yw0-f172.google.com (mail-yw0-f172.google.com [209.85.161.172]) by mx2-lw-us.apache.org (ASF Mail Server at mx2-lw-us.apache.org) with ESMTPS id 9550760D53 for ; Tue, 26 Jul 2016 17:35:52 +0000 (UTC) Received: by mail-yw0-f172.google.com with SMTP id r9so23869955ywg.0 for ; Tue, 26 Jul 2016 10:35:52 -0700 (PDT) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=gmail.com; s=20120113; h=mime-version:in-reply-to:references:from:date:message-id:subject:to; bh=vep2rwO5NolbK8TBiEyERnoiZZ6e4SDs3pyKj2gG7ic=; b=MWpEgN5YRK40/3ga2BI0wmVZGQFAAjXFPF3RK8akAXkbEVWsVl55sWQSFW3I89xZsq +aHeLoW6xljDauxhdp1W7mnRhUoFcm9tOdvQmz7KuM+knH4KFYcNMYNuuALo4mg8Kv65 qFd2WulWkaNwWt4IJWuENivgl3VoVYLzWaq6sj5U2JfOnp/adXyJWGMA7kE47wKGnb7v J1KZgoBd68/eQt9fFAijMWOvyYy/M50x4mNC7tggA3go7EracWVI4v8xEbEvKr7xALNc r73WtCRr83JnFU6Bdi8IG2x5aT1IIFmHNJwnOPFlAKst0317Jf2h/pfZTYNGMb5ZyzxB yasw== X-Google-DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=1e100.net; s=20130820; h=x-gm-message-state:mime-version:in-reply-to:references:from:date :message-id:subject:to; bh=vep2rwO5NolbK8TBiEyERnoiZZ6e4SDs3pyKj2gG7ic=; b=RzDR2TPqUJGek+wJ2c/kx5vfOJYv4ilr+RigzgG6lqhVcQUq6RZN1BS70nnwcmzi4A mE2EwBuymtaZRpeBhRUted+M/whoK3L7Atq2Fn6f65Zzsyt3r9hfY6kGsBvSy37Xo/RA VBi86amHB5bLyQtpaEYNPuJ5jOVnZy/AndqC9bHhHwM+6VDwDVTPUBUN/PvE+Gu6v7VV gDqCkEOIIN/4CEY4XNBh53V4BrAJXThGz8//iG6rZu8PRePGiE4UKhmmmsdFqa4wIppf VjH2zMCnLPvv/uOYMXWyu1zzlDKdo5GIDaXb9ljKIDv4eq6kRGZq+4ahm3SGCQroGk9m eNbg== X-Gm-Message-State: AEkoouvrFUGGMB7lqsoeqwKGH2tQwo3j0vnoAxaUQEM+Cht6SHDljdPzdtcwQiOYDIe4fYLzFDUv9SmQBZCyUQ== X-Received: by 10.31.11.195 with SMTP id 186mr10544605vkl.111.1469554551514; Tue, 26 Jul 2016 10:35:51 -0700 (PDT) MIME-Version: 1.0 Received: by 10.176.65.103 with HTTP; Tue, 26 Jul 2016 10:35:51 -0700 (PDT) In-Reply-To: <1469416169525-6499.post@n6.nabble.com> References: <1469097836448-6442.post@n6.nabble.com> <1469160612029-6461.post@n6.nabble.com> <1469214191329-6477.post@n6.nabble.com> <1469290360028-6491.post@n6.nabble.com> <1469416169525-6499.post@n6.nabble.com> From: Alexey Goncharuk Date: Tue, 26 Jul 2016 20:35:51 +0300 Message-ID: Subject: Re: How to use the logger in the BackupFilter? To: user@ignite.apache.org Content-Type: multipart/alternative; boundary=001a11440bde056d4e05388d55cf archived-at: Tue, 26 Jul 2016 17:35:58 -0000 --001a11440bde056d4e05388d55cf Content-Type: text/plain; charset=UTF-8 Jason, As far as I understood your use case, machine-to group assignment (the digit in your example) is constant and cannot change over time. In this case user attributes should work perfectly like Val suggested. If, for some reason, this does not meet your requirements, my suggestion would be to implement an IgnitePlugin and create a component which maintains this mapping. Ignite has an internal mechanism to exchange arbitrary node information for it's components at the time of node discovery. Take a look at org.apache.ignite.internal.GridComponent#collectDiscoveryData and org.apache.ignite.internal.GridComponent#onDiscoveryDataReceived. This should be enough for you to implement virtually any strategy for affinity assignment. Let us know if you need help with plugin development. Thanks, AG 2016-07-25 6:09 GMT+03:00 Jason : > hi Val, > > Another question about point 3: > Event with user attributes, but when do the deployment of adding new > machines to the node, it will roll out one machine group by one, so this > means during the period of deployment, all the nodes cannot get the same > user attributes (machines group info) and if the Rendezvous hashing return > a > new machine list for one partition with a new machine in the top N (N is > the > backup # + 1), the backup filter in different nodes may made different > decision. > > E.g. for partition p of cache c, its node list after Rendezvous hashing is > A1, X1, B2, C3, D2, ..., where letter is machine and digit is group; and X > is a new added machine and for rolled machine, its group is 1 but for > others, it's unknown; and suppose the backup = 2. Say, we've rolled out > group 1 and are rolling out group 2 now, so in machine A, it selects (A1, > B2, C3), but in machine C, it may select (A1, X, B2), because it doesn't > know which group X belongs to now. This will cause inconsistency. > > And we must ensure no data loss in the memory only. > > BTW, do you have any successful case for this usage scenario? how do you > resolve this problem? > > Thanks, > -Jason > > > > > -- > View this message in context: > http://apache-ignite-users.70518.x6.nabble.com/How-to-use-the-logger-in-the-BackupFilter-tp6442p6499.html > Sent from the Apache Ignite Users mailing list archive at Nabble.com. > --001a11440bde056d4e05388d55cf Content-Type: text/html; charset=UTF-8 Content-Transfer-Encoding: quoted-printable
Jason,

As far as I understood your use = case, machine-to group assignment (the digit in your example) is constant a= nd cannot change over time. In this case user attributes should work perfec= tly like Val suggested.

If, for some reason, this = does not meet your requirements, my suggestion would be to implement an Ign= itePlugin and create a component which maintains this mapping. Ignite has a= n internal mechanism to exchange arbitrary node information for it's co= mponents at the time of node discovery. Take a look at=C2=A0org.apache.igni= te.internal.GridComponent#collectDiscoveryData and=C2=A0org.apache.ignite.i= nternal.GridComponent#onDiscoveryDataReceived. This should be enough for yo= u to implement virtually any strategy for affinity assignment. Let us know = if you need help with plugin development.=C2=A0

Th= anks,
AG

2016-07-25 6:09 GMT+03:00 Jason <fqyang@outlook.com>= :
hi Val,

Another question about point 3:
Event with user attributes, but when do the deployment of adding new
machines to the node, it will roll out one machine group by one, so this means during the period of deployment, all the nodes cannot get the same user attributes (machines group info) and if the Rendezvous hashing return = a
new machine list for one partition with a new machine in the top N (N is th= e
backup # + 1), the backup filter in different nodes may made different
decision.

E.g. for partition p of cache c, its node list after Rendezvous hashing is<= br> A1, X1, B2, C3, D2, ..., where letter is machine and digit is group; and X<= br> is a new added machine and for rolled machine, its group is 1 but for
others, it's unknown; and suppose the backup =3D 2. Say, we've roll= ed out
group 1 and are rolling out group 2 now, so in machine A, it selects (A1, B2, C3), but in machine C, it may select (A1, X, B2), because it doesn'= t
know which group X belongs to now. This will cause inconsistency.

And we must ensure no data loss in the memory only.

BTW, do you have any successful case for this usage scenario? how do you resolve this problem?

Thanks,
-Jason




--
View this message in context: http://apache-ignite-users.70518.x6.nabb= le.com/How-to-use-the-logger-in-the-BackupFilter-tp6442p6499.html
Sent from the Apache Ignite Users m= ailing list archive at Nabble.com.

--001a11440bde056d4e05388d55cf--