You are viewing a plain text version of this content. The canonical link for it is here.
Posted to user@oozie.apache.org by "Felix.徐" <yg...@gmail.com> on 2013/03/04 08:33:02 UTC
How to conditionally initialize parameters?
Hi,
I'm new to oozie and I'm wandering if there is any way to initialize
Action's parameters according to the output of previous Action?
The scenario is that I have a few hive scripts(A,B,C)
If the output of A is null then I would initialize B's parameter with some
other value.
Another question is that does oozie support loop action that can invoke
other actions?
Re: How to conditionally initialize parameters?
Posted by "Felix.徐" <yg...@gmail.com>.
Sorry , it works now , I did not ran the ooziedb.sh first.
2013/3/6 Felix.徐 <yg...@gmail.com>
> Well, I got the following exception in catalina.out:
>
> Mar 6, 2013 1:41:25 PM org.apache.catalina.core.AprLifecycleListener init
> INFO: The APR based Apache Tomcat Native library which allows optimal
> performance in production environments was not found on the
> java.library.path:
> /usr/local/jdk1.6.0_30/jre/lib/amd64/server:/usr/local/jdk1.6.0_30/jre/lib/amd64:/usr/local/jdk1.6.0_30/jre/../lib/amd64:/usr/java/packages/lib/amd64:/usr/lib64:/lib64:/lib:/usr/lib
> Mar 6, 2013 1:41:25 PM org.apache.coyote.http11.Http11Protocol init
> INFO: Initializing Coyote HTTP/1.1 on http-11000
> Mar 6, 2013 1:41:25 PM org.apache.catalina.startup.Catalina load
> INFO: Initialization processed in 807 ms
> Mar 6, 2013 1:41:25 PM org.apache.catalina.core.StandardService start
> INFO: Starting service Catalina
> Mar 6, 2013 1:41:25 PM org.apache.catalina.core.StandardEngine start
> INFO: Starting Servlet Engine: Apache Tomcat/6.0.36
> Mar 6, 2013 1:41:25 PM org.apache.catalina.startup.HostConfig
> deployDescriptor
> INFO: Deploying configuration descriptor oozie.xml
>
> ERROR: Oozie could not be started
>
> REASON: org.apache.oozie.service.ServiceException: E0103: Could not load
> service classes, Schema 'SA' does not exist {SELECT t0.bean_type, t0.conf,
> t0.console_url, t0.cred, t0.data, t0.error_code, t0.error_message,
> t0.external_child_ids, t0.external_id, t0.external_status, t0.name,
> t0.retries, t0.stats, t0.tracker_uri, t0.transition, t0.type,
> t0.user_retry_count, t0.user_retry_interval, t0.user_retry_max,
> t0.end_time, t0.execution_path, t0.last_check_time, t0.log_token,
> t0.pending, t0.pending_age, t0.signal_value, t0.sla_xml, t0.start_time,
> t0.status, t0.wf_id FROM WF_ACTIONS t0 WHERE t0.bean_type = ? AND t0.id =
> ?} [code=30000, state=42Y07]
>
> Stacktrace:
> -----------------------------------------------------------------
> org.apache.oozie.service.ServiceException: E0103: Could not load service
> classes, Schema 'SA' does not exist {SELECT t0.bean_type, t0.conf,
> t0.console_url, t0.cred, t0.data, t0.error_code, t0.error_message,
> t0.external_child_ids, t0.external_id, t0.external_status, t0.name,
> t0.retries, t0.stats, t0.tracker_uri, t0.transition, t0.type,
> t0.user_retry_count, t0.user_retry_interval, t0.user_retry_max,
> t0.end_time, t0.execution_path, t0.last_check_time, t0.log_token,
> t0.pending, t0.pending_age, t0.signal_value, t0.sla_xml, t0.start_time,
> t0.status, t0.wf_id FROM WF_ACTIONS t0 WHERE t0.bean_type = ? AND t0.id =
> ?} [code=30000, state=42Y07]
> at org.apache.oozie.service.Services.loadServices(Services.java:291)
> at org.apache.oozie.service.Services.init(Services.java:208)
> at
> org.apache.oozie.servlet.ServicesLoader.contextInitialized(ServicesLoader.java:39)
> at
> org.apache.catalina.core.StandardContext.listenerStart(StandardContext.java:4206)
> at
> org.apache.catalina.core.StandardContext.start(StandardContext.java:4705)
> at
> org.apache.catalina.core.ContainerBase.addChildInternal(ContainerBase.java:799)
> at
> org.apache.catalina.core.ContainerBase.addChild(ContainerBase.java:779)
> at org.apache.catalina.core.StandardHost.addChild(StandardHost.java:601)
> at
> org.apache.catalina.startup.HostConfig.deployDescriptor(HostConfig.java:675)
> at
> org.apache.catalina.startup.HostConfig.deployDescriptors(HostConfig.java:601)
> at org.apache.catalina.startup.HostConfig.deployApps(HostConfig.java:502)
> at org.apache.catalina.startup.HostConfig.start(HostConfig.java:1317)
> at
> org.apache.catalina.startup.HostConfig.lifecycleEvent(HostConfig.java:324)
> at
> org.apache.catalina.util.LifecycleSupport.fireLifecycleEvent(LifecycleSupport.java:142)
> at org.apache.catalina.core.ContainerBase.start(ContainerBase.java:1065)
> at org.apache.catalina.core.StandardHost.start(StandardHost.java:840)
> at org.apache.catalina.core.ContainerBase.start(ContainerBase.java:1057)
> at org.apache.catalina.core.StandardEngine.start(StandardEngine.java:463)
> at
> org.apache.catalina.core.StandardService.start(StandardService.java:525)
> at org.apache.catalina.core.StandardServer.start(StandardServer.java:754)
> at org.apache.catalina.startup.Catalina.start(Catalina.java:595)
> at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
> at
> sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:39)
> at
> sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25)
> at java.lang.reflect.Method.invoke(Method.java:597)
> at org.apache.catalina.startup.Bootstrap.start(Bootstrap.java:289)
> at org.apache.catalina.startup.Bootstrap.main(Bootstrap.java:414)
> Caused by: <openjpa-2.1.0-r422266:1071316 fatal general error>
> org.apache.openjpa.persistence.PersistenceException: Schema 'SA' does not
> exist {SELECT t0.bean_type, t0.conf, t0.console_url, t0.cred, t0.data,
> t0.error_code, t0.error_message, t0.external_child_ids, t0.external_id,
> t0.external_status, t0.name, t0.retries, t0.stats, t0.tracker_uri,
> t0.transition, t0.type, t0.user_retry_count, t0.user_retry_interval,
> t0.user_retry_max, t0.end_time, t0.execution_path, t0.last_check_time,
> t0.log_token, t0.pending, t0.pending_age, t0.signal_value, t0.sla_xml,
> t0.start_time, t0.status, t0.wf_id FROM WF_ACTIONS t0 WHERE t0.bean_type =
> ? AND t0.id = ?} [code=30000, state=42Y07]
> FailedObject: 1 [org.apache.openjpa.util.StringId] [java.lang.String]
> at org.apache.openjpa.jdbc.sql.DBDictionary.narrow(DBDictionary.java:4869)
> at
> org.apache.openjpa.jdbc.sql.DBDictionary.newStoreException(DBDictionary.java:4829)
> at
> org.apache.openjpa.jdbc.sql.SQLExceptions.getStore(SQLExceptions.java:136)
> at
> org.apache.openjpa.jdbc.sql.SQLExceptions.getStore(SQLExceptions.java:86)
> at
> org.apache.openjpa.jdbc.kernel.JDBCStoreManager.initialize(JDBCStoreManager.java:338)
> at
> org.apache.openjpa.kernel.DelegatingStoreManager.initialize(DelegatingStoreManager.java:112)
> at
> org.apache.openjpa.kernel.ROPStoreManager.initialize(ROPStoreManager.java:57)
> at org.apache.openjpa.kernel.BrokerImpl.initialize(BrokerImpl.java:1022)
> at org.apache.openjpa.kernel.BrokerImpl.find(BrokerImpl.java:980)
> at org.apache.openjpa.kernel.BrokerImpl.find(BrokerImpl.java:897)
> at
> org.apache.openjpa.kernel.DelegatingBroker.find(DelegatingBroker.java:223)
> at
> org.apache.openjpa.persistence.EntityManagerImpl.find(EntityManagerImpl.java:478)
> at org.apache.oozie.service.JPAService.init(JPAService.java:159)
> at org.apache.oozie.service.Services.setServiceInternal(Services.java:368)
> at org.apache.oozie.service.Services.setService(Services.java:354)
> at org.apache.oozie.service.Services.loadServices(Services.java:287)
> ... 26 more
> Caused by: org.apache.openjpa.lib.jdbc.ReportingSQLException: Schema 'SA'
> does not exist {SELECT t0.bean_type, t0.conf, t0.console_url, t0.cred,
> t0.data, t0.error_code, t0.error_message, t0.external_child_ids,
> t0.external_id, t0.external_status, t0.name, t0.retries, t0.stats,
> t0.tracker_uri, t0.transition, t0.type, t0.user_retry_count,
> t0.user_retry_interval, t0.user_retry_max, t0.end_time, t0.execution_path,
> t0.last_check_time, t0.log_token, t0.pending, t0.pending_age,
> t0.signal_value, t0.sla_xml, t0.start_time, t0.status, t0.wf_id FROM
> WF_ACTIONS t0 WHERE t0.bean_type = ? AND t0.id = ?} [code=30000,
> state=42Y07]
> at
> org.apache.openjpa.lib.jdbc.LoggingConnectionDecorator.wrap(LoggingConnectionDecorator.java:281)
> at
> org.apache.openjpa.lib.jdbc.LoggingConnectionDecorator.wrap(LoggingConnectionDecorator.java:261)
> at
> org.apache.openjpa.lib.jdbc.LoggingConnectionDecorator.access$000(LoggingConnectionDecorator.java:72)
> at
> org.apache.openjpa.lib.jdbc.LoggingConnectionDecorator$LoggingConnection.prepareStatement(LoggingConnectionDecorator.java:313)
> at
> org.apache.openjpa.lib.jdbc.DelegatingConnection.prepareStatement(DelegatingConnection.java:155)
> at
> org.apache.openjpa.lib.jdbc.ConfiguringConnectionDecorator$ConfiguringConnection.prepareStatement(ConfiguringConnectionDecorator.java:158)
> at
> org.apache.openjpa.lib.jdbc.DelegatingConnection.prepareStatement(DelegatingConnection.java:155)
> at
> org.apache.openjpa.jdbc.kernel.JDBCStoreManager$RefCountConnection.prepareStatement(JDBCStoreManager.java:1655)
> at
> org.apache.openjpa.lib.jdbc.DelegatingConnection.prepareStatement(DelegatingConnection.java:144)
> at
> org.apache.openjpa.jdbc.sql.SQLBuffer.prepareStatement(SQLBuffer.java:561)
> at
> org.apache.openjpa.jdbc.sql.SQLBuffer.prepareStatement(SQLBuffer.java:541)
> at
> org.apache.openjpa.jdbc.sql.SelectImpl.prepareStatement(SelectImpl.java:479)
> at org.apache.openjpa.jdbc.sql.SelectImpl.execute(SelectImpl.java:420)
> at org.apache.openjpa.jdbc.sql.SelectImpl.execute(SelectImpl.java:382)
> at
> org.apache.openjpa.jdbc.kernel.JDBCStoreManager.getInitializeStateResult(JDBCStoreManager.java:576)
> at
> org.apache.openjpa.jdbc.kernel.JDBCStoreManager.initializeState(JDBCStoreManager.java:378)
> at
> org.apache.openjpa.jdbc.kernel.JDBCStoreManager.initialize(JDBCStoreManager.java:333)
> ... 37 more
> -----------------------------------------------------------------
>
>
>
> 2013/3/6 Mona Chitnis <ch...@yahoo-inc.com>
>
>> Can you tell us what problems you faced with the build?
>>
>> --
>> Mona
>>
>> On 3/5/13 2:07 AM, "Felix.徐" <yg...@gmail.com> wrote:
>>
>> >I see , BTW , where can I download a binary distribution of Oozie 3.3.1.
>> I
>> >got some problems using my own build while starting up.
>> >
>> >
>> >2013/3/5 Mohammad Islam <mi...@yahoo.com>
>> >
>> >> Hi Felix,
>> >> Oozie has if-like statement, called decision-switch-case.
>> >>
>> >> More at:
>> >>
>> >>
>> http://oozie.apache.org/docs/3.3.1/WorkflowFunctionalSpec.html#a3.1.4_Dec
>> >>ision_Control_Node
>> >>
>> >> Regards,
>> >> Mohammad
>> >>
>> >>
>> >> ________________________________
>> >> From: Felix.徐 <yg...@gmail.com>
>> >> To: user@oozie.apache.org
>> >> Sent: Monday, March 4, 2013 5:58 PM
>> >> Subject: Re: How to conditionally initialize parameters?
>> >>
>> >> Thanks Rebert.
>> >>
>> >> Is flow control such as if/while supported by EL expression?
>> >>
>> >>
>> >> 2013/3/5 Robert Kanter <rk...@cloudera.com>
>> >>
>> >> > Hi Felix,
>> >> >
>> >> > If you specify the <capture-output> element, you can have Oozie get
>> >>the
>> >> > output of an action; the output has to be in java properties format
>> >>and
>> >> > there's a few other restrictions. Try searching
>> >> > http://oozie.apache.org/docs/3.3.1/WorkflowFunctionalSpec.html for
>> >> > <capture-output>; it should be similar to the Java action. You can
>> >>then
>> >> > use an EL function to pass that output to any of your actions.
>> >> >
>> >> > Oozie workflows must be DAGs (
>> >> > http://en.wikipedia.org/wiki/Directed_acyclic_graph) so no
>> >>loops/cycles
>> >> > are
>> >> > allowed.
>> >> >
>> >> > - Robert
>> >> >
>> >> >
>> >> >
>> >> > On Sun, Mar 3, 2013 at 11:33 PM, Felix.徐 <yg...@gmail.com> wrote:
>> >> >
>> >> > > Hi,
>> >> > >
>> >> > > I'm new to oozie and I'm wandering if there is any way to
>> initialize
>> >> > > Action's parameters according to the output of previous Action?
>> >> > >
>> >> > > The scenario is that I have a few hive scripts(A,B,C)
>> >> > > If the output of A is null then I would initialize B's parameter
>> >>with
>> >> > some
>> >> > > other value.
>> >> > >
>> >> > > Another question is that does oozie support loop action that can
>> >>invoke
>> >> > > other actions?
>> >> > >
>> >> >
>> >>
>>
>>
>
Re: How to conditionally initialize parameters?
Posted by "Felix.徐" <yg...@gmail.com>.
Well, I got the following exception in catalina.out:
Mar 6, 2013 1:41:25 PM org.apache.catalina.core.AprLifecycleListener init
INFO: The APR based Apache Tomcat Native library which allows optimal
performance in production environments was not found on the
java.library.path:
/usr/local/jdk1.6.0_30/jre/lib/amd64/server:/usr/local/jdk1.6.0_30/jre/lib/amd64:/usr/local/jdk1.6.0_30/jre/../lib/amd64:/usr/java/packages/lib/amd64:/usr/lib64:/lib64:/lib:/usr/lib
Mar 6, 2013 1:41:25 PM org.apache.coyote.http11.Http11Protocol init
INFO: Initializing Coyote HTTP/1.1 on http-11000
Mar 6, 2013 1:41:25 PM org.apache.catalina.startup.Catalina load
INFO: Initialization processed in 807 ms
Mar 6, 2013 1:41:25 PM org.apache.catalina.core.StandardService start
INFO: Starting service Catalina
Mar 6, 2013 1:41:25 PM org.apache.catalina.core.StandardEngine start
INFO: Starting Servlet Engine: Apache Tomcat/6.0.36
Mar 6, 2013 1:41:25 PM org.apache.catalina.startup.HostConfig
deployDescriptor
INFO: Deploying configuration descriptor oozie.xml
ERROR: Oozie could not be started
REASON: org.apache.oozie.service.ServiceException: E0103: Could not load
service classes, Schema 'SA' does not exist {SELECT t0.bean_type, t0.conf,
t0.console_url, t0.cred, t0.data, t0.error_code, t0.error_message,
t0.external_child_ids, t0.external_id, t0.external_status, t0.name,
t0.retries, t0.stats, t0.tracker_uri, t0.transition, t0.type,
t0.user_retry_count, t0.user_retry_interval, t0.user_retry_max,
t0.end_time, t0.execution_path, t0.last_check_time, t0.log_token,
t0.pending, t0.pending_age, t0.signal_value, t0.sla_xml, t0.start_time,
t0.status, t0.wf_id FROM WF_ACTIONS t0 WHERE t0.bean_type = ? AND t0.id =
?} [code=30000, state=42Y07]
Stacktrace:
-----------------------------------------------------------------
org.apache.oozie.service.ServiceException: E0103: Could not load service
classes, Schema 'SA' does not exist {SELECT t0.bean_type, t0.conf,
t0.console_url, t0.cred, t0.data, t0.error_code, t0.error_message,
t0.external_child_ids, t0.external_id, t0.external_status, t0.name,
t0.retries, t0.stats, t0.tracker_uri, t0.transition, t0.type,
t0.user_retry_count, t0.user_retry_interval, t0.user_retry_max,
t0.end_time, t0.execution_path, t0.last_check_time, t0.log_token,
t0.pending, t0.pending_age, t0.signal_value, t0.sla_xml, t0.start_time,
t0.status, t0.wf_id FROM WF_ACTIONS t0 WHERE t0.bean_type = ? AND t0.id =
?} [code=30000, state=42Y07]
at org.apache.oozie.service.Services.loadServices(Services.java:291)
at org.apache.oozie.service.Services.init(Services.java:208)
at
org.apache.oozie.servlet.ServicesLoader.contextInitialized(ServicesLoader.java:39)
at
org.apache.catalina.core.StandardContext.listenerStart(StandardContext.java:4206)
at org.apache.catalina.core.StandardContext.start(StandardContext.java:4705)
at
org.apache.catalina.core.ContainerBase.addChildInternal(ContainerBase.java:799)
at org.apache.catalina.core.ContainerBase.addChild(ContainerBase.java:779)
at org.apache.catalina.core.StandardHost.addChild(StandardHost.java:601)
at
org.apache.catalina.startup.HostConfig.deployDescriptor(HostConfig.java:675)
at
org.apache.catalina.startup.HostConfig.deployDescriptors(HostConfig.java:601)
at org.apache.catalina.startup.HostConfig.deployApps(HostConfig.java:502)
at org.apache.catalina.startup.HostConfig.start(HostConfig.java:1317)
at
org.apache.catalina.startup.HostConfig.lifecycleEvent(HostConfig.java:324)
at
org.apache.catalina.util.LifecycleSupport.fireLifecycleEvent(LifecycleSupport.java:142)
at org.apache.catalina.core.ContainerBase.start(ContainerBase.java:1065)
at org.apache.catalina.core.StandardHost.start(StandardHost.java:840)
at org.apache.catalina.core.ContainerBase.start(ContainerBase.java:1057)
at org.apache.catalina.core.StandardEngine.start(StandardEngine.java:463)
at org.apache.catalina.core.StandardService.start(StandardService.java:525)
at org.apache.catalina.core.StandardServer.start(StandardServer.java:754)
at org.apache.catalina.startup.Catalina.start(Catalina.java:595)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:39)
at
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25)
at java.lang.reflect.Method.invoke(Method.java:597)
at org.apache.catalina.startup.Bootstrap.start(Bootstrap.java:289)
at org.apache.catalina.startup.Bootstrap.main(Bootstrap.java:414)
Caused by: <openjpa-2.1.0-r422266:1071316 fatal general error>
org.apache.openjpa.persistence.PersistenceException: Schema 'SA' does not
exist {SELECT t0.bean_type, t0.conf, t0.console_url, t0.cred, t0.data,
t0.error_code, t0.error_message, t0.external_child_ids, t0.external_id,
t0.external_status, t0.name, t0.retries, t0.stats, t0.tracker_uri,
t0.transition, t0.type, t0.user_retry_count, t0.user_retry_interval,
t0.user_retry_max, t0.end_time, t0.execution_path, t0.last_check_time,
t0.log_token, t0.pending, t0.pending_age, t0.signal_value, t0.sla_xml,
t0.start_time, t0.status, t0.wf_id FROM WF_ACTIONS t0 WHERE t0.bean_type =
? AND t0.id = ?} [code=30000, state=42Y07]
FailedObject: 1 [org.apache.openjpa.util.StringId] [java.lang.String]
at org.apache.openjpa.jdbc.sql.DBDictionary.narrow(DBDictionary.java:4869)
at
org.apache.openjpa.jdbc.sql.DBDictionary.newStoreException(DBDictionary.java:4829)
at
org.apache.openjpa.jdbc.sql.SQLExceptions.getStore(SQLExceptions.java:136)
at org.apache.openjpa.jdbc.sql.SQLExceptions.getStore(SQLExceptions.java:86)
at
org.apache.openjpa.jdbc.kernel.JDBCStoreManager.initialize(JDBCStoreManager.java:338)
at
org.apache.openjpa.kernel.DelegatingStoreManager.initialize(DelegatingStoreManager.java:112)
at
org.apache.openjpa.kernel.ROPStoreManager.initialize(ROPStoreManager.java:57)
at org.apache.openjpa.kernel.BrokerImpl.initialize(BrokerImpl.java:1022)
at org.apache.openjpa.kernel.BrokerImpl.find(BrokerImpl.java:980)
at org.apache.openjpa.kernel.BrokerImpl.find(BrokerImpl.java:897)
at
org.apache.openjpa.kernel.DelegatingBroker.find(DelegatingBroker.java:223)
at
org.apache.openjpa.persistence.EntityManagerImpl.find(EntityManagerImpl.java:478)
at org.apache.oozie.service.JPAService.init(JPAService.java:159)
at org.apache.oozie.service.Services.setServiceInternal(Services.java:368)
at org.apache.oozie.service.Services.setService(Services.java:354)
at org.apache.oozie.service.Services.loadServices(Services.java:287)
... 26 more
Caused by: org.apache.openjpa.lib.jdbc.ReportingSQLException: Schema 'SA'
does not exist {SELECT t0.bean_type, t0.conf, t0.console_url, t0.cred,
t0.data, t0.error_code, t0.error_message, t0.external_child_ids,
t0.external_id, t0.external_status, t0.name, t0.retries, t0.stats,
t0.tracker_uri, t0.transition, t0.type, t0.user_retry_count,
t0.user_retry_interval, t0.user_retry_max, t0.end_time, t0.execution_path,
t0.last_check_time, t0.log_token, t0.pending, t0.pending_age,
t0.signal_value, t0.sla_xml, t0.start_time, t0.status, t0.wf_id FROM
WF_ACTIONS t0 WHERE t0.bean_type = ? AND t0.id = ?} [code=30000,
state=42Y07]
at
org.apache.openjpa.lib.jdbc.LoggingConnectionDecorator.wrap(LoggingConnectionDecorator.java:281)
at
org.apache.openjpa.lib.jdbc.LoggingConnectionDecorator.wrap(LoggingConnectionDecorator.java:261)
at
org.apache.openjpa.lib.jdbc.LoggingConnectionDecorator.access$000(LoggingConnectionDecorator.java:72)
at
org.apache.openjpa.lib.jdbc.LoggingConnectionDecorator$LoggingConnection.prepareStatement(LoggingConnectionDecorator.java:313)
at
org.apache.openjpa.lib.jdbc.DelegatingConnection.prepareStatement(DelegatingConnection.java:155)
at
org.apache.openjpa.lib.jdbc.ConfiguringConnectionDecorator$ConfiguringConnection.prepareStatement(ConfiguringConnectionDecorator.java:158)
at
org.apache.openjpa.lib.jdbc.DelegatingConnection.prepareStatement(DelegatingConnection.java:155)
at
org.apache.openjpa.jdbc.kernel.JDBCStoreManager$RefCountConnection.prepareStatement(JDBCStoreManager.java:1655)
at
org.apache.openjpa.lib.jdbc.DelegatingConnection.prepareStatement(DelegatingConnection.java:144)
at
org.apache.openjpa.jdbc.sql.SQLBuffer.prepareStatement(SQLBuffer.java:561)
at
org.apache.openjpa.jdbc.sql.SQLBuffer.prepareStatement(SQLBuffer.java:541)
at
org.apache.openjpa.jdbc.sql.SelectImpl.prepareStatement(SelectImpl.java:479)
at org.apache.openjpa.jdbc.sql.SelectImpl.execute(SelectImpl.java:420)
at org.apache.openjpa.jdbc.sql.SelectImpl.execute(SelectImpl.java:382)
at
org.apache.openjpa.jdbc.kernel.JDBCStoreManager.getInitializeStateResult(JDBCStoreManager.java:576)
at
org.apache.openjpa.jdbc.kernel.JDBCStoreManager.initializeState(JDBCStoreManager.java:378)
at
org.apache.openjpa.jdbc.kernel.JDBCStoreManager.initialize(JDBCStoreManager.java:333)
... 37 more
-----------------------------------------------------------------
2013/3/6 Mona Chitnis <ch...@yahoo-inc.com>
> Can you tell us what problems you faced with the build?
>
> --
> Mona
>
> On 3/5/13 2:07 AM, "Felix.徐" <yg...@gmail.com> wrote:
>
> >I see , BTW , where can I download a binary distribution of Oozie 3.3.1. I
> >got some problems using my own build while starting up.
> >
> >
> >2013/3/5 Mohammad Islam <mi...@yahoo.com>
> >
> >> Hi Felix,
> >> Oozie has if-like statement, called decision-switch-case.
> >>
> >> More at:
> >>
> >>
> http://oozie.apache.org/docs/3.3.1/WorkflowFunctionalSpec.html#a3.1.4_Dec
> >>ision_Control_Node
> >>
> >> Regards,
> >> Mohammad
> >>
> >>
> >> ________________________________
> >> From: Felix.徐 <yg...@gmail.com>
> >> To: user@oozie.apache.org
> >> Sent: Monday, March 4, 2013 5:58 PM
> >> Subject: Re: How to conditionally initialize parameters?
> >>
> >> Thanks Rebert.
> >>
> >> Is flow control such as if/while supported by EL expression?
> >>
> >>
> >> 2013/3/5 Robert Kanter <rk...@cloudera.com>
> >>
> >> > Hi Felix,
> >> >
> >> > If you specify the <capture-output> element, you can have Oozie get
> >>the
> >> > output of an action; the output has to be in java properties format
> >>and
> >> > there's a few other restrictions. Try searching
> >> > http://oozie.apache.org/docs/3.3.1/WorkflowFunctionalSpec.html for
> >> > <capture-output>; it should be similar to the Java action. You can
> >>then
> >> > use an EL function to pass that output to any of your actions.
> >> >
> >> > Oozie workflows must be DAGs (
> >> > http://en.wikipedia.org/wiki/Directed_acyclic_graph) so no
> >>loops/cycles
> >> > are
> >> > allowed.
> >> >
> >> > - Robert
> >> >
> >> >
> >> >
> >> > On Sun, Mar 3, 2013 at 11:33 PM, Felix.徐 <yg...@gmail.com> wrote:
> >> >
> >> > > Hi,
> >> > >
> >> > > I'm new to oozie and I'm wandering if there is any way to initialize
> >> > > Action's parameters according to the output of previous Action?
> >> > >
> >> > > The scenario is that I have a few hive scripts(A,B,C)
> >> > > If the output of A is null then I would initialize B's parameter
> >>with
> >> > some
> >> > > other value.
> >> > >
> >> > > Another question is that does oozie support loop action that can
> >>invoke
> >> > > other actions?
> >> > >
> >> >
> >>
>
>
Re: How to conditionally initialize parameters?
Posted by Mona Chitnis <ch...@yahoo-inc.com>.
Can you tell us what problems you faced with the build?
--
Mona
On 3/5/13 2:07 AM, "Felix.徐" <yg...@gmail.com> wrote:
>I see , BTW , where can I download a binary distribution of Oozie 3.3.1. I
>got some problems using my own build while starting up.
>
>
>2013/3/5 Mohammad Islam <mi...@yahoo.com>
>
>> Hi Felix,
>> Oozie has if-like statement, called decision-switch-case.
>>
>> More at:
>>
>>http://oozie.apache.org/docs/3.3.1/WorkflowFunctionalSpec.html#a3.1.4_Dec
>>ision_Control_Node
>>
>> Regards,
>> Mohammad
>>
>>
>> ________________________________
>> From: Felix.徐 <yg...@gmail.com>
>> To: user@oozie.apache.org
>> Sent: Monday, March 4, 2013 5:58 PM
>> Subject: Re: How to conditionally initialize parameters?
>>
>> Thanks Rebert.
>>
>> Is flow control such as if/while supported by EL expression?
>>
>>
>> 2013/3/5 Robert Kanter <rk...@cloudera.com>
>>
>> > Hi Felix,
>> >
>> > If you specify the <capture-output> element, you can have Oozie get
>>the
>> > output of an action; the output has to be in java properties format
>>and
>> > there's a few other restrictions. Try searching
>> > http://oozie.apache.org/docs/3.3.1/WorkflowFunctionalSpec.html for
>> > <capture-output>; it should be similar to the Java action. You can
>>then
>> > use an EL function to pass that output to any of your actions.
>> >
>> > Oozie workflows must be DAGs (
>> > http://en.wikipedia.org/wiki/Directed_acyclic_graph) so no
>>loops/cycles
>> > are
>> > allowed.
>> >
>> > - Robert
>> >
>> >
>> >
>> > On Sun, Mar 3, 2013 at 11:33 PM, Felix.徐 <yg...@gmail.com> wrote:
>> >
>> > > Hi,
>> > >
>> > > I'm new to oozie and I'm wandering if there is any way to initialize
>> > > Action's parameters according to the output of previous Action?
>> > >
>> > > The scenario is that I have a few hive scripts(A,B,C)
>> > > If the output of A is null then I would initialize B's parameter
>>with
>> > some
>> > > other value.
>> > >
>> > > Another question is that does oozie support loop action that can
>>invoke
>> > > other actions?
>> > >
>> >
>>
Re: How to conditionally initialize parameters?
Posted by "Felix.徐" <yg...@gmail.com>.
I see , BTW , where can I download a binary distribution of Oozie 3.3.1. I
got some problems using my own build while starting up.
2013/3/5 Mohammad Islam <mi...@yahoo.com>
> Hi Felix,
> Oozie has if-like statement, called decision-switch-case.
>
> More at:
> http://oozie.apache.org/docs/3.3.1/WorkflowFunctionalSpec.html#a3.1.4_Decision_Control_Node
>
> Regards,
> Mohammad
>
>
> ________________________________
> From: Felix.徐 <yg...@gmail.com>
> To: user@oozie.apache.org
> Sent: Monday, March 4, 2013 5:58 PM
> Subject: Re: How to conditionally initialize parameters?
>
> Thanks Rebert.
>
> Is flow control such as if/while supported by EL expression?
>
>
> 2013/3/5 Robert Kanter <rk...@cloudera.com>
>
> > Hi Felix,
> >
> > If you specify the <capture-output> element, you can have Oozie get the
> > output of an action; the output has to be in java properties format and
> > there's a few other restrictions. Try searching
> > http://oozie.apache.org/docs/3.3.1/WorkflowFunctionalSpec.html for
> > <capture-output>; it should be similar to the Java action. You can then
> > use an EL function to pass that output to any of your actions.
> >
> > Oozie workflows must be DAGs (
> > http://en.wikipedia.org/wiki/Directed_acyclic_graph) so no loops/cycles
> > are
> > allowed.
> >
> > - Robert
> >
> >
> >
> > On Sun, Mar 3, 2013 at 11:33 PM, Felix.徐 <yg...@gmail.com> wrote:
> >
> > > Hi,
> > >
> > > I'm new to oozie and I'm wandering if there is any way to initialize
> > > Action's parameters according to the output of previous Action?
> > >
> > > The scenario is that I have a few hive scripts(A,B,C)
> > > If the output of A is null then I would initialize B's parameter with
> > some
> > > other value.
> > >
> > > Another question is that does oozie support loop action that can invoke
> > > other actions?
> > >
> >
>
Re: How to conditionally initialize parameters?
Posted by Mohammad Islam <mi...@yahoo.com>.
Hi Felix,
Oozie has if-like statement, called decision-switch-case.
More at: http://oozie.apache.org/docs/3.3.1/WorkflowFunctionalSpec.html#a3.1.4_Decision_Control_Node
Regards,
Mohammad
________________________________
From: Felix.徐 <yg...@gmail.com>
To: user@oozie.apache.org
Sent: Monday, March 4, 2013 5:58 PM
Subject: Re: How to conditionally initialize parameters?
Thanks Rebert.
Is flow control such as if/while supported by EL expression?
2013/3/5 Robert Kanter <rk...@cloudera.com>
> Hi Felix,
>
> If you specify the <capture-output> element, you can have Oozie get the
> output of an action; the output has to be in java properties format and
> there's a few other restrictions. Try searching
> http://oozie.apache.org/docs/3.3.1/WorkflowFunctionalSpec.html for
> <capture-output>; it should be similar to the Java action. You can then
> use an EL function to pass that output to any of your actions.
>
> Oozie workflows must be DAGs (
> http://en.wikipedia.org/wiki/Directed_acyclic_graph) so no loops/cycles
> are
> allowed.
>
> - Robert
>
>
>
> On Sun, Mar 3, 2013 at 11:33 PM, Felix.徐 <yg...@gmail.com> wrote:
>
> > Hi,
> >
> > I'm new to oozie and I'm wandering if there is any way to initialize
> > Action's parameters according to the output of previous Action?
> >
> > The scenario is that I have a few hive scripts(A,B,C)
> > If the output of A is null then I would initialize B's parameter with
> some
> > other value.
> >
> > Another question is that does oozie support loop action that can invoke
> > other actions?
> >
>
Re: How to conditionally initialize parameters?
Posted by "Felix.徐" <yg...@gmail.com>.
Thanks Rebert.
Is flow control such as if/while supported by EL expression?
2013/3/5 Robert Kanter <rk...@cloudera.com>
> Hi Felix,
>
> If you specify the <capture-output> element, you can have Oozie get the
> output of an action; the output has to be in java properties format and
> there's a few other restrictions. Try searching
> http://oozie.apache.org/docs/3.3.1/WorkflowFunctionalSpec.html for
> <capture-output>; it should be similar to the Java action. You can then
> use an EL function to pass that output to any of your actions.
>
> Oozie workflows must be DAGs (
> http://en.wikipedia.org/wiki/Directed_acyclic_graph) so no loops/cycles
> are
> allowed.
>
> - Robert
>
>
>
> On Sun, Mar 3, 2013 at 11:33 PM, Felix.徐 <yg...@gmail.com> wrote:
>
> > Hi,
> >
> > I'm new to oozie and I'm wandering if there is any way to initialize
> > Action's parameters according to the output of previous Action?
> >
> > The scenario is that I have a few hive scripts(A,B,C)
> > If the output of A is null then I would initialize B's parameter with
> some
> > other value.
> >
> > Another question is that does oozie support loop action that can invoke
> > other actions?
> >
>
Re: How to conditionally initialize parameters?
Posted by Robert Kanter <rk...@cloudera.com>.
Hi Felix,
If you specify the <capture-output> element, you can have Oozie get the
output of an action; the output has to be in java properties format and
there's a few other restrictions. Try searching
http://oozie.apache.org/docs/3.3.1/WorkflowFunctionalSpec.html for
<capture-output>; it should be similar to the Java action. You can then
use an EL function to pass that output to any of your actions.
Oozie workflows must be DAGs (
http://en.wikipedia.org/wiki/Directed_acyclic_graph) so no loops/cycles are
allowed.
- Robert
On Sun, Mar 3, 2013 at 11:33 PM, Felix.徐 <yg...@gmail.com> wrote:
> Hi,
>
> I'm new to oozie and I'm wandering if there is any way to initialize
> Action's parameters according to the output of previous Action?
>
> The scenario is that I have a few hive scripts(A,B,C)
> If the output of A is null then I would initialize B's parameter with some
> other value.
>
> Another question is that does oozie support loop action that can invoke
> other actions?
>