You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@oozie.apache.org by vi...@apache.org on 2013/02/19 04:54:16 UTC
svn commit: r1447582 - in /oozie/branches/hcat-intre:
core/src/main/java/org/apache/oozie/service/ core/src/main/resources/
core/src/test/java/org/apache/oozie/service/ core/src/test/resources/
docs/src/site/twiki/ examples/src/main/apps/hcatalog/
Author: virag
Date: Tue Feb 19 03:54:16 2013
New Revision: 1447582
URL: http://svn.apache.org/r1447582
Log:
Removing trailing spaces and tabs
Modified:
oozie/branches/hcat-intre/core/src/main/java/org/apache/oozie/service/HadoopAccessorService.java
oozie/branches/hcat-intre/core/src/main/java/org/apache/oozie/service/JMSAccessorService.java
oozie/branches/hcat-intre/core/src/main/resources/ehcache-default.xml
oozie/branches/hcat-intre/core/src/main/resources/oozie-default.xml
oozie/branches/hcat-intre/core/src/test/java/org/apache/oozie/service/TestHCatAccessorService.java
oozie/branches/hcat-intre/core/src/test/java/org/apache/oozie/service/TestJMSAccessorService.java
oozie/branches/hcat-intre/core/src/test/resources/coord-job-for-matd-hcat.xml
oozie/branches/hcat-intre/core/src/test/resources/coord-job-for-matd-neg-hcat.xml
oozie/branches/hcat-intre/core/src/test/resources/ehcache.xml
oozie/branches/hcat-intre/docs/src/site/twiki/CoordinatorFunctionalSpec.twiki
oozie/branches/hcat-intre/docs/src/site/twiki/WorkflowFunctionalSpec.twiki
oozie/branches/hcat-intre/examples/src/main/apps/hcatalog/coordinator.xml
oozie/branches/hcat-intre/examples/src/main/apps/hcatalog/id.pig
oozie/branches/hcat-intre/examples/src/main/apps/hcatalog/workflow.xml
Modified: oozie/branches/hcat-intre/core/src/main/java/org/apache/oozie/service/HadoopAccessorService.java
URL: http://svn.apache.org/viewvc/oozie/branches/hcat-intre/core/src/main/java/org/apache/oozie/service/HadoopAccessorService.java?rev=1447582&r1=1447581&r2=1447582&view=diff
==============================================================================
--- oozie/branches/hcat-intre/core/src/main/java/org/apache/oozie/service/HadoopAccessorService.java (original)
+++ oozie/branches/hcat-intre/core/src/main/java/org/apache/oozie/service/HadoopAccessorService.java Tue Feb 19 03:54:16 2013
@@ -535,7 +535,7 @@ public class HadoopAccessorService imple
throw new HadoopAccessorException(ErrorCode.E0904, uriScheme, uri.toString());
}
}
- }
+ }
}
public Set<String> getSupportedSchemes() {
Modified: oozie/branches/hcat-intre/core/src/main/java/org/apache/oozie/service/JMSAccessorService.java
URL: http://svn.apache.org/viewvc/oozie/branches/hcat-intre/core/src/main/java/org/apache/oozie/service/JMSAccessorService.java?rev=1447582&r1=1447581&r2=1447582&view=diff
==============================================================================
--- oozie/branches/hcat-intre/core/src/main/java/org/apache/oozie/service/JMSAccessorService.java (original)
+++ oozie/branches/hcat-intre/core/src/main/java/org/apache/oozie/service/JMSAccessorService.java Tue Feb 19 03:54:16 2013
@@ -65,12 +65,12 @@ public class JMSAccessorService implemen
/**
* Map of JMS connection info to established JMS Connection
*/
- private ConcurrentMap<JMSConnectionInfo, ConnectionContext> connectionMap =
+ private ConcurrentMap<JMSConnectionInfo, ConnectionContext> connectionMap =
new ConcurrentHashMap<JMSConnectionInfo, ConnectionContext>();
/**
* Map of JMS connection info to topic names to MessageReceiver
*/
- private ConcurrentMap<JMSConnectionInfo, Map<String, MessageReceiver>> receiversMap =
+ private ConcurrentMap<JMSConnectionInfo, Map<String, MessageReceiver>> receiversMap =
new ConcurrentHashMap<JMSConnectionInfo, Map<String, MessageReceiver>>();
/**
Modified: oozie/branches/hcat-intre/core/src/main/resources/ehcache-default.xml
URL: http://svn.apache.org/viewvc/oozie/branches/hcat-intre/core/src/main/resources/ehcache-default.xml?rev=1447582&r1=1447581&r2=1447582&view=diff
==============================================================================
--- oozie/branches/hcat-intre/core/src/main/resources/ehcache-default.xml (original)
+++ oozie/branches/hcat-intre/core/src/main/resources/ehcache-default.xml Tue Feb 19 03:54:16 2013
@@ -1,3 +1,20 @@
+<!--
+ Licensed to the Apache Software Foundation (ASF) under one
+ or more contributor license agreements. See the NOTICE file
+ distributed with this work for additional information
+ regarding copyright ownership. The ASF licenses this file
+ to you under the Apache License, Version 2.0 (the
+ "License"); you may not use this file except in compliance
+ with the License. You may obtain a copy of the License at
+
+ http://www.apache.org/licenses/LICENSE-2.0
+
+ Unless required by applicable law or agreed to in writing, software
+ distributed under the License is distributed on an "AS IS" BASIS,
+ WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ See the License for the specific language governing permissions and
+ limitations under the License.
+-->
<ehcache>
<!-- http://svn.codehaus.org/sonar/tags/1.1/sonar-commons/src/main/resources/ehcache.xml -->
<diskStore path="java.io.tmpdir"/>
Modified: oozie/branches/hcat-intre/core/src/main/resources/oozie-default.xml
URL: http://svn.apache.org/viewvc/oozie/branches/hcat-intre/core/src/main/resources/oozie-default.xml?rev=1447582&r1=1447581&r2=1447582&view=diff
==============================================================================
--- oozie/branches/hcat-intre/core/src/main/resources/oozie-default.xml (original)
+++ oozie/branches/hcat-intre/core/src/main/resources/oozie-default.xml Tue Feb 19 03:54:16 2013
@@ -138,9 +138,9 @@
default=java.naming.factory.initial#org.apache.activemq.jndi.ActiveMQInitialContextFactory;java.naming.provider.url#tcp://localhost:61616;connectionFactoryNames#ConnectionFactory
</value>
<description>
- Specify the map of endpoints to JMS configuration properties. In general, endpoint
- identifies the HCatalog server URL. "default" is used if no endpoint is mentioned
- in the query. If some JMS property is not defined, the system will use the property
+ Specify the map of endpoints to JMS configuration properties. In general, endpoint
+ identifies the HCatalog server URL. "default" is used if no endpoint is mentioned
+ in the query. If some JMS property is not defined, the system will use the property
defined jndi.properties. jndi.properties files is retrieved from the application classpath.
Mapping rules can also be provided for mapping Hcatalog server names to JMS server.
hcat://${1}.${2}.server.com:8020=java.naming.factory.initial#Dummy.Factory;java.naming.provider.url#tcp://broker.${2}:61616
Modified: oozie/branches/hcat-intre/core/src/test/java/org/apache/oozie/service/TestHCatAccessorService.java
URL: http://svn.apache.org/viewvc/oozie/branches/hcat-intre/core/src/test/java/org/apache/oozie/service/TestHCatAccessorService.java?rev=1447582&r1=1447581&r2=1447582&view=diff
==============================================================================
--- oozie/branches/hcat-intre/core/src/test/java/org/apache/oozie/service/TestHCatAccessorService.java (original)
+++ oozie/branches/hcat-intre/core/src/test/java/org/apache/oozie/service/TestHCatAccessorService.java Tue Feb 19 03:54:16 2013
@@ -46,9 +46,9 @@ public class TestHCatAccessorService ext
services = super.setupServicesForHCatalog();
Configuration conf = services.getConf();
String server2 = "hcat://${1}.${2}.server.com:8020=java.naming.factory.initial#Dummy.Factory;" +
- "java.naming.provider.url#tcp://broker.${2}:61616";
+ "java.naming.provider.url#tcp://broker.${2}:61616";
String server3 = "hcat://xyz.corp.dummy.com=java.naming.factory.initial#Dummy.Factory;" +
- "java.naming.provider.url#tcp:localhost:61616";
+ "java.naming.provider.url#tcp:localhost:61616";
String jmsConnectionURL = server2 + "," + server3;
conf.set(HCatAccessorService.JMS_CONNECTIONS_PROPERTIES, jmsConnectionURL);
@@ -72,11 +72,11 @@ public class TestHCatAccessorService ext
services = super.setupServicesForHCatalog();
Configuration conf = services.getConf();
String server1 = "default=java.naming.factory.initial#org.apache.activemq.jndi.ActiveMQInitialContextFactory;" +
- "java.naming.provider.url#vm://localhost?broker.persistent=false";
+ "java.naming.provider.url#vm://localhost?broker.persistent=false";
String server2 = "hcat://${1}.${2}.server.com:8020=java.naming.factory.initial#Dummy.Factory;" +
- "java.naming.provider.url#tcp://broker.${2}:61616";
+ "java.naming.provider.url#tcp://broker.${2}:61616";
String server3 = "hcat://xyz.corp.dummy.com=java.naming.factory.initial#Dummy.Factory;" +
- "java.naming.provider.url#tcp:localhost:61616";
+ "java.naming.provider.url#tcp:localhost:61616";
String jmsConnectionURL = server1 + "," + server2 + "," + server3;
conf.set(HCatAccessorService.JMS_CONNECTIONS_PROPERTIES, jmsConnectionURL);
Modified: oozie/branches/hcat-intre/core/src/test/java/org/apache/oozie/service/TestJMSAccessorService.java
URL: http://svn.apache.org/viewvc/oozie/branches/hcat-intre/core/src/test/java/org/apache/oozie/service/TestJMSAccessorService.java?rev=1447582&r1=1447581&r2=1447582&view=diff
==============================================================================
--- oozie/branches/hcat-intre/core/src/test/java/org/apache/oozie/service/TestJMSAccessorService.java (original)
+++ oozie/branches/hcat-intre/core/src/test/java/org/apache/oozie/service/TestJMSAccessorService.java Tue Feb 19 03:54:16 2013
@@ -125,7 +125,7 @@ public class TestJMSAccessorService exte
Configuration conf = services.getConf();
// set the connection factory name
String jmsURL = "hcat://${1}.${2}.server.com:8020=java.naming.factory.initial#org.apache.activemq.jndi.ActiveMQInitialContextFactory" +
- ";java.naming.provider.url#vm://localhost?broker.persistent=false;connectionFactoryNames#dynamicFactories/hcat.prod.${1}";
+ ";java.naming.provider.url#vm://localhost?broker.persistent=false;connectionFactoryNames#dynamicFactories/hcat.prod.${1}";
conf.set(HCatAccessorService.JMS_CONNECTIONS_PROPERTIES, jmsURL);
services.init();
HCatAccessorService hcatService = services.get(HCatAccessorService.class);
Modified: oozie/branches/hcat-intre/core/src/test/resources/coord-job-for-matd-hcat.xml
URL: http://svn.apache.org/viewvc/oozie/branches/hcat-intre/core/src/test/resources/coord-job-for-matd-hcat.xml?rev=1447582&r1=1447581&r2=1447582&view=diff
==============================================================================
--- oozie/branches/hcat-intre/core/src/test/resources/coord-job-for-matd-hcat.xml (original)
+++ oozie/branches/hcat-intre/core/src/test/resources/coord-job-for-matd-hcat.xml Tue Feb 19 03:54:16 2013
@@ -6,9 +6,9 @@
to you under the Apache License, Version 2.0 (the
"License"); you may not use this file except in compliance
with the License. You may obtain a copy of the License at
-
+
http://www.apache.org/licenses/LICENSE-2.0
-
+
Unless required by applicable law or agreed to in writing, software
distributed under the License is distributed on an "AS IS" BASIS,
WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
@@ -16,58 +16,61 @@
limitations under the License.
-->
<coordinator-app xmlns='uri:oozie:coordinator:0.2' name='NAME'
- frequency="1" start='2009-02-01T01:00Z' end='2009-02-03T23:59Z'
- timezone='UTC' freq_timeunit='DAY' end_of_duration='NONE'>
- <controls>
- <timeout>10</timeout>
- <concurrency>2</concurrency>
- <execution>LIFO</execution>
- </controls>
- <input-events>
- <data-in name='A' dataset='a'>
- <dataset name='a' frequency='7' initial-instance='2009-01-01T01:00Z'
- timezone='UTC' freq_timeunit='DAY' end_of_duration='NONE'>
- <uri-template>hcat://dummyhcat:1000/db1/table1/ds=${YEAR}-${DAY}
- </uri-template>
- </dataset>
- <instance>${coord:current(-3)}</instance>
- </data-in>
- <data-in name='B' dataset='b'>
- <dataset name='b' frequency='7' initial-instance='2009-01-01T01:00Z'
- timezone='UTC' freq_timeunit='DAY' end_of_duration='NONE'>
- <uri-template>hcat://dummyhcat:1000/db2/table2/ds=${YEAR}-${DAY}
- </uri-template>
- </dataset>
- <start-instance>${coord:latest(-1)}</start-instance>
- <end-instance>${coord:latest(0)}</end-instance>
- </data-in>
+frequency="1" start='2009-02-01T01:00Z' end='2009-02-03T23:59Z'
+timezone='UTC' freq_timeunit='DAY' end_of_duration='NONE'>
+ <controls>
+ <timeout>10</timeout>
+ <concurrency>2</concurrency>
+ <execution>LIFO</execution>
+ </controls>
+ <input-events>
+ <data-in name='A' dataset='a'>
+ <dataset name='a' frequency='7' initial-instance='2009-01-01T01:00Z'
+ timezone='UTC' freq_timeunit='DAY' end_of_duration='NONE'>
+ <uri-template>hcat://dummyhcat:1000/db1/table1/ds=${YEAR}-${DAY}
+ </uri-template>
+ </dataset>
+ <instance>${coord:current(-3)}</instance>
+ </data-in>
+
+ <data-in name='B' dataset='b'>
+ <dataset name='b' frequency='7' initial-instance='2009-01-01T01:00Z'
+ timezone='UTC' freq_timeunit='DAY' end_of_duration='NONE'>
+ <uri-template>hcat://dummyhcat:1000/db2/table2/ds=${YEAR}-${DAY}
+ </uri-template>
+ </dataset>
+ <start-instance>${coord:latest(-1)}</start-instance>
+ <end-instance>${coord:latest(0)}</end-instance>
+ </data-in>
<data-in name='C' dataset='c'>
- <dataset name='c' frequency='7' initial-instance='2009-01-01T01:00Z'
- timezone='UTC' freq_timeunit='DAY' end_of_duration='NONE'>
- <uri-template>hcat://dummyhcat:1000/db3/table3/ds=${YEAR}-${DAY}
- </uri-template>
- </dataset>
- <start-instance>${coord:current(-1)}</start-instance>
- <end-instance>${coord:current(0)}</end-instance>
+ <dataset name='c' frequency='7' initial-instance='2009-01-01T01:00Z'
+ timezone='UTC' freq_timeunit='DAY' end_of_duration='NONE'>
+ <uri-template>hcat://dummyhcat:1000/db3/table3/ds=${YEAR}-${DAY}
+ </uri-template>
+ </dataset>
+ <start-instance>${coord:current(-1)}</start-instance>
+ <end-instance>${coord:current(0)}</end-instance>
+ </data-in>
+
+ <data-in name='D' dataset='d'>
+ <dataset name='d' frequency='7' initial-instance='2009-01-01T01:00Z'
+ timezone='UTC' freq_timeunit='DAY' end_of_duration='NONE'>
+ <uri-template>file://dummyhdfs/${YEAR}/${DAY}
+ </uri-template>
+ </dataset>
+ <instance>${coord:current(0)}</instance>
</data-in>
- <data-in name='D' dataset='d'>
- <dataset name='d' frequency='7' initial-instance='2009-01-01T01:00Z'
- timezone='UTC' freq_timeunit='DAY' end_of_duration='NONE'>
- <uri-template>file://dummyhdfs/${YEAR}/${DAY}
- </uri-template>
- </dataset>
- <instance>${coord:current(0)}</instance>
- </data-in>
- </input-events>
- <action>
- <workflow>
- <app-path>hdfs:///tmp/workflows/</app-path>
- <configuration>
- <property>
- <name>inputA</name>
- <value>${coord:dataIn('A')}</value>
- </property>
- </configuration>
- </workflow>
- </action>
+ </input-events>
+
+ <action>
+ <workflow>
+ <app-path>hdfs:///tmp/workflows/</app-path>
+ <configuration>
+ <property>
+ <name>inputA</name>
+ <value>${coord:dataIn('A')}</value>
+ </property>
+ </configuration>
+ </workflow>
+ </action>
</coordinator-app>
Modified: oozie/branches/hcat-intre/core/src/test/resources/coord-job-for-matd-neg-hcat.xml
URL: http://svn.apache.org/viewvc/oozie/branches/hcat-intre/core/src/test/resources/coord-job-for-matd-neg-hcat.xml?rev=1447582&r1=1447581&r2=1447582&view=diff
==============================================================================
--- oozie/branches/hcat-intre/core/src/test/resources/coord-job-for-matd-neg-hcat.xml (original)
+++ oozie/branches/hcat-intre/core/src/test/resources/coord-job-for-matd-neg-hcat.xml Tue Feb 19 03:54:16 2013
@@ -16,32 +16,32 @@
limitations under the License.
-->
<coordinator-app xmlns='uri:oozie:coordinator:0.2' name='NAME'
- frequency="1" start='2009-02-01T01:00Z' end='2009-02-03T23:59Z'
- timezone='UTC' freq_timeunit='DAY' end_of_duration='NONE'>
- <controls>
- <timeout>10</timeout>
- <concurrency>2</concurrency>
- <execution>LIFO</execution>
- </controls>
- <input-events>
- <data-in name='A' dataset='a'>
- <dataset name='a' frequency='7' initial-instance='2009-01-01T01:00Z'
- timezone='UTC' freq_timeunit='DAY' end_of_duration='NONE'>
- <uri-template>hcat://dummyhcat:1000/table/ds=${YEAR}/${DAY};region=us
- </uri-template>
- </dataset>
- <instance>${coord:current(-3)}</instance>
- </data-in>
- </input-events>
- <action>
- <workflow>
- <app-path>hdfs:///tmp/workflows/</app-path>
- <configuration>
- <property>
- <name>inputA</name>
- <value>${coord:dataIn('A')}</value>
- </property>
- </configuration>
- </workflow>
- </action>
+ frequency="1" start='2009-02-01T01:00Z' end='2009-02-03T23:59Z'
+ timezone='UTC' freq_timeunit='DAY' end_of_duration='NONE'>
+ <controls>
+ <timeout>10</timeout>
+ <concurrency>2</concurrency>
+ <execution>LIFO</execution>
+ </controls>
+ <input-events>
+ <data-in name='A' dataset='a'>
+ <dataset name='a' frequency='7' initial-instance='2009-01-01T01:00Z'
+ timezone='UTC' freq_timeunit='DAY' end_of_duration='NONE'>
+ <uri-template>hcat://dummyhcat:1000/table/ds=${YEAR}/${DAY};region=us
+ </uri-template>
+ </dataset>
+ <instance>${coord:current(-3)}</instance>
+ </data-in>
+ </input-events>
+ <action>
+ <workflow>
+ <app-path>hdfs:///tmp/workflows/</app-path>
+ <configuration>
+ <property>
+ <name>inputA</name>
+ <value>${coord:dataIn('A')}</value>
+ </property>
+ </configuration>
+ </workflow>
+ </action>
</coordinator-app>
Modified: oozie/branches/hcat-intre/core/src/test/resources/ehcache.xml
URL: http://svn.apache.org/viewvc/oozie/branches/hcat-intre/core/src/test/resources/ehcache.xml?rev=1447582&r1=1447581&r2=1447582&view=diff
==============================================================================
--- oozie/branches/hcat-intre/core/src/test/resources/ehcache.xml (original)
+++ oozie/branches/hcat-intre/core/src/test/resources/ehcache.xml Tue Feb 19 03:54:16 2013
@@ -1,3 +1,20 @@
+<!--
+ Licensed to the Apache Software Foundation (ASF) under one
+ or more contributor license agreements. See the NOTICE file
+ distributed with this work for additional information
+ regarding copyright ownership. The ASF licenses this file
+ to you under the Apache License, Version 2.0 (the
+ "License"); you may not use this file except in compliance
+ with the License. You may obtain a copy of the License at
+
+ http://www.apache.org/licenses/LICENSE-2.0
+
+ Unless required by applicable law or agreed to in writing, software
+ distributed under the License is distributed on an "AS IS" BASIS,
+ WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ See the License for the specific language governing permissions and
+ limitations under the License.
+-->
<ehcache>
<!-- http://svn.codehaus.org/sonar/tags/1.1/sonar-commons/src/main/resources/ehcache.xml -->
<diskStore path="target"/>
Modified: oozie/branches/hcat-intre/docs/src/site/twiki/CoordinatorFunctionalSpec.twiki
URL: http://svn.apache.org/viewvc/oozie/branches/hcat-intre/docs/src/site/twiki/CoordinatorFunctionalSpec.twiki?rev=1447582&r1=1447581&r2=1447582&view=diff
==============================================================================
--- oozie/branches/hcat-intre/docs/src/site/twiki/CoordinatorFunctionalSpec.twiki (original)
+++ oozie/branches/hcat-intre/docs/src/site/twiki/CoordinatorFunctionalSpec.twiki Tue Feb 19 03:54:16 2013
@@ -2416,13 +2416,13 @@ coordinator action.
</prepare>
...
<script>id.pig</script>
- <param>HCAT_IN_DB=${IN_DB}</param>
+ <param>HCAT_IN_DB=${IN_DB}</param>
<param>HCAT_IN_TABLE=${IN_TABLE}</param>
<param>HCAT_OUT_DB=${OUT_DB}</param>
<param>HCAT_OUT_TABLE=${OUT_TABLE}</param>
<param>PARTITION_FILTER=${FILTER}</param>
<param>OUTPUT_PARTITIONS=${OUT_PARTITIONS}</param>
- <file>lib/hive-site.xml</file>
+ <file>lib/hive-site.xml</file>
</pig>
<ok to="end"/>
<error to="fail"/>
Modified: oozie/branches/hcat-intre/docs/src/site/twiki/WorkflowFunctionalSpec.twiki
URL: http://svn.apache.org/viewvc/oozie/branches/hcat-intre/docs/src/site/twiki/WorkflowFunctionalSpec.twiki?rev=1447582&r1=1447581&r2=1447582&view=diff
==============================================================================
--- oozie/branches/hcat-intre/docs/src/site/twiki/WorkflowFunctionalSpec.twiki (original)
+++ oozie/branches/hcat-intre/docs/src/site/twiki/WorkflowFunctionalSpec.twiki Tue Feb 19 03:54:16 2013
@@ -823,7 +823,7 @@ The =pig= action has to be configured wi
configuration to run the Pig job.
A =pig= action can be configured to perform HDFS files/directories cleanup or HCatalog partitions cleanup before
-starting the Pig job. This capability enables Oozie to retry a Pig job in the situation of a transient failure (Pig
+starting the Pig job. This capability enables Oozie to retry a Pig job in the situation of a transient failure (Pig
creates temporary directories for intermediate data, thus a retry without cleanup would fail).
Hadoop JobConf properties can be specified in a JobConf XML file bundled with the workflow application or they can be
Modified: oozie/branches/hcat-intre/examples/src/main/apps/hcatalog/coordinator.xml
URL: http://svn.apache.org/viewvc/oozie/branches/hcat-intre/examples/src/main/apps/hcatalog/coordinator.xml?rev=1447582&r1=1447581&r2=1447582&view=diff
==============================================================================
--- oozie/branches/hcat-intre/examples/src/main/apps/hcatalog/coordinator.xml (original)
+++ oozie/branches/hcat-intre/examples/src/main/apps/hcatalog/coordinator.xml Tue Feb 19 03:54:16 2013
@@ -20,11 +20,11 @@
<datasets>
<dataset name="raw-logs" frequency="${coord:minutes(20)}" initial-instance="2010-01-01T00:00Z" timezone="UTC">
<uri-template>${hcatNode}/${db}/${table}/ds=${YEAR}-${MONTH}-${DAY};region=${region}</uri-template>
- <done-flag></done-flag>
+ <done-flag></done-flag>
</dataset>
<dataset name="processed-logs" frequency="${coord:minutes(20)}" initial-instance="2010-01-01T00:00Z" timezone="UTC">
<uri-template>${hcatNode}/${db}/${outputtable}/ds=${dataOut};region=${region}</uri-template>
- <done-flag></done-flag>
+ <done-flag></done-flag>
</dataset>
</datasets>
Modified: oozie/branches/hcat-intre/examples/src/main/apps/hcatalog/id.pig
URL: http://svn.apache.org/viewvc/oozie/branches/hcat-intre/examples/src/main/apps/hcatalog/id.pig?rev=1447582&r1=1447581&r2=1447582&view=diff
==============================================================================
--- oozie/branches/hcat-intre/examples/src/main/apps/hcatalog/id.pig (original)
+++ oozie/branches/hcat-intre/examples/src/main/apps/hcatalog/id.pig Tue Feb 19 03:54:16 2013
@@ -1,4 +1,4 @@
---
+--
-- Licensed to the Apache Software Foundation (ASF) under one
-- or more contributor license agreements. See the NOTICE file
-- distributed with this work for additional information
@@ -6,9 +6,9 @@
-- to you under the Apache License, Version 2.0 (the
-- "License"); you may not use this file except in compliance
-- with the License. You may obtain a copy of the License at
---
+--
-- http://www.apache.org/licenses/LICENSE-2.0
---
+--
-- Unless required by applicable law or agreed to in writing, software
-- distributed under the License is distributed on an "AS IS" BASIS,
-- WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
Modified: oozie/branches/hcat-intre/examples/src/main/apps/hcatalog/workflow.xml
URL: http://svn.apache.org/viewvc/oozie/branches/hcat-intre/examples/src/main/apps/hcatalog/workflow.xml?rev=1447582&r1=1447581&r2=1447582&view=diff
==============================================================================
--- oozie/branches/hcat-intre/examples/src/main/apps/hcatalog/workflow.xml (original)
+++ oozie/branches/hcat-intre/examples/src/main/apps/hcatalog/workflow.xml Tue Feb 19 03:54:16 2013
@@ -32,13 +32,13 @@
</property>
</configuration>
<script>id.pig</script>
- <param>DB=${DB}</param>
- <param>TABLE=${TABLE}</param>
- <param>FILTER=${FILTER}</param>
+ <param>DB=${DB}</param>
+ <param>TABLE=${TABLE}</param>
+ <param>FILTER=${FILTER}</param>
<param>OUTPUT_DB=${OUTPUT_DB}</param>
<param>OUTPUT_TABLE=${OUTPUT_TABLE}</param>
<param>OUTPUT_PARTITION=${OUTPUT_PARTITION}</param>
- <file>lib/hive-site.xml</file>
+ <file>lib/hive-site.xml</file>
</pig>
<ok to="end"/>
<error to="fail"/>