Member since
06-09-2016
185
Posts
22
Kudos Received
5
Solutions
My Accepted Solutions
Title | Views | Posted |
---|---|---|
2181 | 04-21-2017 07:57 AM | |
1357 | 04-18-2017 07:07 AM | |
3234 | 02-27-2017 05:41 AM | |
905 | 12-09-2016 11:05 AM | |
1270 | 11-24-2016 11:20 AM |
11-24-2016
04:27 AM
@Ned Shawa please suggest if HIVE needs to be started with ACID and compactor on? or any other property. Thanks. While creating the table got this error, on HDP2.5 java.sql.SQLException: Error while processing statement: FAILED: Execution Error, return code 1 from org.apache.hadoop.hive.ql.exec.DDLTask. MetaException(message:default.OLYMPICS cannot be declared transactional because it's an external table) Also got errors with the inferred AVRO schema How does Infer schema works in the flow, does it keep inferring for every 10 records, is that a good approach? shoudn't we use convertCSVToAVRO by providing a avsc file created by Kite. Thanks.
... View more
11-23-2016
11:11 AM
1 Kudo
Hi, I was trying to use PutHiveStreaming processor in nifi - getting some errors. however when another process try to write from spark streaming, It works hivesc.sql("insert into defaulttweetinfo select * from tweetstemp").write.mode(SaveMode.Append).saveAsTable("default.tweetinfo") We have not enabled ACID/ Transactions etc. on HIVE Please suggest whats the least common denominator to use HIVE Streaming Also using INSERT command means HIVE Streaming..correct? Thanks, Avijeet
... View more
Labels:
- Labels:
-
Apache Hive
11-16-2016
09:55 AM
1 Kudo
Hi, I want to create a streaming source for weather data something like the Flume source using TwitterStream api the weather api is available at https://openweathermap.org/price Can someone please suggest what's the best way. Thanks, Avijeet
... View more
Labels:
- Labels:
-
Apache Flume
11-09-2016
11:33 AM
Hi All, I was able to resolve this - by adding this line in in docker.service in /lib/systemd/system ExecStart=/usr/bin/dockerd --graph="/datadrive/docker-data" --storage-opt=dm.basesize=50G [root@docker datadrive]# docker load < HDP_2.5_docker.tar
b1b065555b8a: Loading layer [==================================================>] 202.2 MB/202.2 MB
0b547722f59f: Loading layer [==================================================>] 13.84 GB/13.84 GB
99d7327952e0: Loading layer [==================================================>] 234.8 MB/234.8 MB
294b1c0e07bd: Loading layer [==================================================>] 207.5 MB/207.5 MB
fd5c10f2f1a1: Loading layer [==================================================>] 387.6 kB/387.6 kB
6852ef70321d: Loading layer [==================================================>] 163 MB/163 MB
517f170bbf7f: Loading layer [==================================================>] 20.98 MB/20.98 MB
665edb80fc91: Loading layer [==================================================>] 337.4 kB/337.4 kB
Loaded image: sandbox:latest Thanks, Avijeet
... View more
11-08-2016
10:06 AM
Hi, @Laurence Da Luz SparkR works using livy interpreter and sparkR shell. However is there a way to launch a sparkR job from command prompt something like spark-submit. Thanks, Avijeet
... View more
10-26-2016
05:12 AM
Hi @Michael Young I don't have any other images, this is the only image i was trying to load I have a azure centos vm, which root directory / has only 30GB I have another directory with has 500Gb but wondering how to tell docker to use that directory thanks, Avijeet
... View more
10-25-2016
01:23 PM
@Michael Young Hi Michel, while doing docker load, it ran out of space Is it possible to tell it load and use a specific location? Also how can I clean the half loaded image. Thanks Avijeet b1b065555b8a: Loading layer 202.2 MB/202.2 MB 0b547722f59f: Loading layer 10.36 GB/13.84 GB ApplyLayer exit status 1 stdout: stderr: write /usr/lib/jvm/java-1.8.0-openjdk-1.8.0.101-3.b13.el6_8.x86_64/jre/lib/rt.jar: no space left on device
... View more
10-24-2016
06:31 AM
thanks @pankaj singh, how did you add the repository to zeppelin?
... View more
10-24-2016
05:22 AM
hi @pankaj singh I am trying to use the local repo @ /usr/hdp/current/zeppelin-server/local-repo/2BXQ86S9Q Which has the jar files Also isn't StreamContext part of Spark core libraries? Why does it complain StremContext cont found. Thanks, Avijeet
... View more
10-23-2016
08:03 AM
Hi All, while trying the twitter-streaming zeppelin notebook example in hdp 25., I keep getting this error <console>:44: error: not found: type StreamingContext Please help. import org.apache.spark.streaming._ import org.apache.spark.streaming.twitter._ import org.apache.spark.storage.StorageLevel import scala.io.Source
import scala.collection.mutable.HashMap
import java.io.File
import org.apache.log4j.Logger import org.apache.log4j.Level
<console>:44: error: not found: type StreamingContext val ssc = new StreamingContext(sc, Seconds(2))
^
<console>:45: error: not found: value TwitterUtils
val tweets = TwitterUtils.createStream(ssc, None) Thanks, Avijeet
... View more
Labels: