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 6D330200CD9 for ; Thu, 3 Aug 2017 16:04:23 +0200 (CEST) Received: by cust-asf.ponee.io (Postfix) id 6BB8516BA1C; Thu, 3 Aug 2017 14:04:23 +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 8B4B916BA19 for ; Thu, 3 Aug 2017 16:04:22 +0200 (CEST) Received: (qmail 82172 invoked by uid 500); 3 Aug 2017 14:04:21 -0000 Mailing-List: contact user-help@carbondata.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: user@carbondata.apache.org Delivered-To: mailing list user@carbondata.apache.org Received: (qmail 82162 invoked by uid 99); 3 Aug 2017 14:04:21 -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; Thu, 03 Aug 2017 14:04:21 +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 4AB3F1807D3 for ; Thu, 3 Aug 2017 14:04:21 +0000 (UTC) X-Virus-Scanned: Debian amavisd-new at spamd3-us-west.apache.org X-Spam-Flag: NO X-Spam-Score: -0.901 X-Spam-Level: X-Spam-Status: No, score=-0.901 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_H2=-2.8, 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 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 8T_4BCIr3n0J for ; Thu, 3 Aug 2017 14:04:19 +0000 (UTC) Received: from mail-wr0-f181.google.com (mail-wr0-f181.google.com [209.85.128.181]) by mx1-lw-eu.apache.org (ASF Mail Server at mx1-lw-eu.apache.org) with ESMTPS id 8253C5FE34 for ; Thu, 3 Aug 2017 14:04:18 +0000 (UTC) Received: by mail-wr0-f181.google.com with SMTP id v105so6189443wrb.0 for ; Thu, 03 Aug 2017 07:04:18 -0700 (PDT) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=gmail.com; s=20161025; h=mime-version:in-reply-to:references:from:date:message-id:subject:to; bh=CIBd46HGrmGQ1xTn2iov+hidMgd9arCXCXWlKdvZM8c=; b=Wpdy6Vyfn/dxy25ekkbxEk1jP17OjkrYz7Kk39Ab7oNRuX8LY5fCExBp1Ns2tCaN+q fZtoTtSxlugIgRwO0veWZr6AnxKAqkBpu9EhqmKyKqJ4f7Sb7PZiyR8HGTcQFSraPun6 w3W5ok9fcLGNKDMKw6nK1fQPrvTFMrnsm4pb6bytEWXYC6K/orXE/M/E9weHbiI++4eH vE79a4sO9c3nG9XhpC3LLufu7Q+1qKZu3dtb9AncbJgQIYT3VSMdp8lFP8wXUivZJ4CO 1t1TVseWnDx7kum9uhC8LvMAQ27urJXGTVL5R7AQm4g+rP+LulUlbJe9Mvo0+AF26PEU fbsA== X-Google-DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=1e100.net; s=20161025; h=x-gm-message-state:mime-version:in-reply-to:references:from:date :message-id:subject:to; bh=CIBd46HGrmGQ1xTn2iov+hidMgd9arCXCXWlKdvZM8c=; b=iN1rhhxR5ksOFjuWo4o993v+saJKFPOC2po8AK5HsvX+3qbULDEWSAgDjajSaVU3/n USYSEnQNyZXWdpMfIOHhxtYK/cxDFapwxIe2GeD4fiB40LQh0/Ayx5rqGt9dputnQSo2 XnWrZnLjOhpzEesT4aQ1uKrXQ5ETX9+gSuyHj4KW9aOGxEf4E4cG0HR6jAhZ091mhprD C+Rdi5phWtxpgD7mUGWjN4sB3gf064WAKPtIS/I1x7T5D2x8yeD0UTbNkuQhDV5JLe/Y +YxJ1JPPsHPuhk9bVoiMZj9vrqztt9+sSPmyCKhgX5v+41Ltza5BSV/o7rhB4e5ji/QC AaIg== X-Gm-Message-State: AIVw112BaqNrOAotx0YVKrx6wjgu6aOPYGpdanpGsHuK1zO3WwUNwa+a KJVSLG/KMO7HRqhTnJPcOvc+uWZKBA== X-Received: by 10.223.154.105 with SMTP id z96mr1337230wrb.73.1501769057921; Thu, 03 Aug 2017 07:04:17 -0700 (PDT) MIME-Version: 1.0 Received: by 10.28.208.202 with HTTP; Thu, 3 Aug 2017 07:04:17 -0700 (PDT) In-Reply-To: References: From: Ravindra Pesala Date: Thu, 3 Aug 2017 19:34:17 +0530 Message-ID: Subject: Re: spark2.2.0 support To: user@carbondata.apache.org Content-Type: multipart/alternative; boundary="f403045f50483b6db00555d9db86" archived-at: Thu, 03 Aug 2017 14:04:23 -0000 --f403045f50483b6db00555d9db86 Content-Type: text/plain; charset="UTF-8" Hi, In the ongoing version we support only spark 2.1.1 version, As spark 2.2.0 is relatively new major released version we require more time for upgrading and testing Carbondata completely. So as per the effort we plan the release of upgraded version. And about your query , yes the code should be version independent, that means same should work for 2.1.0, 2.1.1 and 2.2.0 as well. Regards, Ravindra. On 3 August 2017 at 12:57, john cheng wrote: > After dig source code about error happened(https://github.com/ > apache/carbondata/blob/master/integration/spark-common/src/ > main/scala/org/apache/spark/sql/optimizer/CarbonDecoderOptimizerHelper. > scala#L87) between spark1.6/spark2.1.x and spark2.2.0 . I notice > spark1.6's InsertIntoTable has child LogicalPlan attribute, but spark2.2.0 > change to query LogicalPlan attribute. but CarbonDecoderOptimizerHelper > is at spark-common module, which means spark1.6/spark2.1 and spark2.2 both > use this class. So I change to i.query, then build with spark2.2.0, It's OK > then. Should this code here being version compatible or version independent? > > 2017-08-03 14:52 GMT+08:00 john cheng : > >> If I build carbondata with spark2.1.x, it works. But our spark version is >> spark2.2.0. If use spark2.1.x builded jar, and execute on spark2.2.0, >> there're still errors when create CarbonSession, the errors is : >> ClassNotFoundException: o.a.s.sql.hive.HiveSessionState >> >> 2017-08-03 14:45 GMT+08:00 john cheng : >> >>> Hi carbon guys, At now carbondata seems not support spark2.2.0. I add >>> spark2.2 as a new profile, and build like this: mvn -DskipTests -Pspark-2.2 >>> -Dspark.version=2.2.0 -Dhadoop.version=2.6.0 clean package >>> >>> But there're errors on spark common module: >>> >>> [ERROR] /Users/zhengqh/Github/carbondata-parent-1.1.1/integration/sp >>> ark-common/src/main/scala/org/apache/spark/sql/optimizer/ >>> CarbonDecoderOptimizerHelper.scala:87: error: value child is not a >>> member of org.apache.spark.sql.catalyst.plans.logical.InsertIntoTable >>> [INFO] case i: InsertIntoTable => process(i.child, nodeList) >>> [INFO] ^ >>> [WARNING] 11 warnings found >>> [ERROR] one error found >>> >>> do you guys plan to support spark2.2.0. or at now I should downgrade to >>> spark2.1.x? >>> >> >> > -- Thanks & Regards, Ravi --f403045f50483b6db00555d9db86 Content-Type: text/html; charset="UTF-8" Content-Transfer-Encoding: quoted-printable
Hi,

In the ongoing version we support o= nly spark 2.1.1 version, As spark 2.2.0 is relatively new major released ve= rsion we require more time for upgrading and testing Carbondata completely.= So as per the effort we plan the release of upgraded version.
And about your query , yes the code should be version independ= ent, that means same should work for 2.1.0, 2.1.1 and 2.2.0 as well.

Regards,
Ravindra.

On 3 August 2017 at 12:57, = john cheng <zqhxuyuan@gmail.com> wrote:
After dig source code about error happened= (https://github.com/apache/carb= ondata/blob/master/integration/spark-common/src/main/scala/org/ap= ache/spark/sql/optimizer/CarbonDecoderOptimizerHelper.scala#= L87) between spark1.6/spark2.1.x and spark2.2.0 . I notice spark1.6'= ;s InsertIntoTable has child LogicalPlan attribute, but spark2.2.0 change t= o query LogicalPlan attribute. but=C2=A0CarbonDecoderOptimizerHelper i= s at spark-common module, which means spark1.6/spark2.1 and spark2.2 both u= se this class. So I change to i.query, then build with spark2.2.0, It's= OK then. Should this code here being version compatible or version indepen= dent?

2017-08-03 14:52 GMT+08:00 john cheng <zqhxuyuan@gmail.com>:
If I build carbondata with spark2.1.x, it works. But our = spark version is spark2.2.0. If use spark2.1.x builded jar, and execute on = spark2.2.0, there're still errors when create CarbonSession, the errors= is : ClassNotFoundException: o.a.s.sql.hive.HiveSessionState

2017-08= -03 14:45 GMT+08:00 john cheng <zqhxuyuan@gmail.com>:
<= blockquote class=3D"gmail_quote" style=3D"margin:0 0 0 .8ex;border-left:1px= #ccc solid;padding-left:1ex">
Hi carbon guys, At now carbo= ndata seems not support spark2.2.0. I add spark2.2 as a new profile, and bu= ild like this:=C2=A0mvn -DskipTests -Pspark-2.2 -Dspark.version=3D2.2.0 -Dh= adoop.version=3D2.6.0 clean package

But there're err= ors on spark common module:

[ERROR] /Users/zh= engqh/Github/carbondata-parent-1.1.1/integration/spark-common/src= /main/scala/org/apache/spark/sql/optimizer/CarbonDecoderOptimizer= Helper.scala:87: error: value child is not a member of org.apache.spar= k.sql.catalyst.plans.logical.InsertIntoTable
[INFO] =C2=A0 = =C2=A0 =C2=A0 case i: InsertIntoTable =3D> process(i.child, nodeList)
[INFO] =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2= =A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 = =C2=A0 =C2=A0 =C2=A0^
[WARNING] 11 warnings found
[ERRO= R] one error found

do you guys plan to suppo= rt spark2.2.0. or at now I should downgrade to spark2.1.x?





--
=
Thanks &a= mp; Regards,
Ravi
--f403045f50483b6db00555d9db86--