[CASSANDRA-8292] From Pig: org.apache.cassandra.exceptions.ConfigurationException: Expecting URI in variable: [cassandra.config]. Please prefix the file with file:/// for local files or file://<server>/ for remote files.

• Type: Bug
• Status: Resolved
• Priority: Normal
• Resolution: Fixed
• Fix Version/s: 2.1.3
• Severity: Normal
• Since Version: 2.1.2
• Assignee: Joshua McKenzie
• Reporter: Brandon Kearby

Authors

Joshua McKenzie

Reviewers

Brandon Williams

• Tester: Brandon Kearby
• Created: 11/Nov/14 18:19
• Updated: 16/Apr/19 09:31
• Resolved: 14/Jan/15 17:49

Description

Getting this error from Pig:
Looks like the client side hadoop code is trying to locate the cassandra.yaml.

ERROR org.apache.cassandra.config.DatabaseDescriptor - Fatal configuration error
org.apache.cassandra.exceptions.ConfigurationException: Expecting URI in variable: [cassandra.config].  Please prefix the file with file:/// for local files or file://<server>/ for remote files.  Aborting.
	at org.apache.cassandra.config.YamlConfigurationLoader.getStorageConfigURL(YamlConfigurationLoader.java:73)
	at org.apache.cassandra.config.YamlConfigurationLoader.loadConfig(YamlConfigurationLoader.java:84)
	at org.apache.cassandra.config.DatabaseDescriptor.loadConfig(DatabaseDescriptor.java:158)
	at org.apache.cassandra.config.DatabaseDescriptor.<clinit>(DatabaseDescriptor.java:133)
	at org.apache.cassandra.utils.JVMStabilityInspector.inspectThrowable(JVMStabilityInspector.java:54)
	at org.apache.cassandra.hadoop.HadoopCompat.<clinit>(HadoopCompat.java:135)
	at org.apache.cassandra.hadoop.AbstractColumnFamilyInputFormat.getSplits(AbstractColumnFamilyInputFormat.java:120)
	at org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.PigInputFormat.getSplits(PigInputFormat.java:273)
	at org.apache.hadoop.mapred.JobClient.writeNewSplits(JobClient.java:1014)
	at org.apache.hadoop.mapred.JobClient.writeSplits(JobClient.java:1031)
	at org.apache.hadoop.mapred.JobClient.access$600(JobClient.java:172)
	at org.apache.hadoop.mapred.JobClient$2.run(JobClient.java:943)
	at org.apache.hadoop.mapred.JobClient$2.run(JobClient.java:896)
	at java.security.AccessController.doPrivileged(Native Method)
	at javax.security.auth.Subject.doAs(Subject.java:422)
	at org.apache.hadoop.security.UserGroupInformation.doAs(UserGroupInformation.java:1332)
	at org.apache.hadoop.mapred.JobClient.submitJobInternal(JobClient.java:896)
	at org.apache.hadoop.mapreduce.Job.submit(Job.java:531)
	at org.apache.hadoop.mapreduce.lib.jobcontrol.ControlledJob.submit(ControlledJob.java:318)
	at org.apache.hadoop.mapreduce.lib.jobcontrol.JobControl.startReadyJobs(JobControl.java:238)
	at org.apache.hadoop.mapreduce.lib.jobcontrol.JobControl.run(JobControl.java:269)
	at java.lang.Thread.run(Thread.java:745)
	at org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.MapReduceLauncher$1.run(MapReduceLauncher.java:260)
Expecting URI in variable: [cassandra.config].  Please prefix the file with file:/// for local files or file://<server>/ for remote files.  Aborting.
Fatal configuration error; unable to start. See log for stacktrace.

Sample Pig Script:

grunt> sigs = load 'cql://socialdata/signal' using org.apache.cassandra.hadoop.pig.CqlNativeStorage();
grunt> a = limit sigs 5;                                                                              
grunt> dump a;