java - Accesing JobContext from a partitioned step in JSR 352 -


i'm trying pass object between batchlets, i've encountered problem when trying access jobcontext partitioned step (batchlet).

according jsr 352 specification

9.4.1.1 batch context lifecycle , scope: batch context has thread affinity , visible batch artifacts executing on particular thread. batch context injected field may null when out of scope. each context type has distinct scope , lifecycle follows: 1. jobcontext there 1 jobcontext per job execution. exists life of job. there distinct jobcontext each sub-thread of parallel execution (e.g. partitioned step). 2. stepcontext there 1 stepcontext per step execution. exists life of step. partitioned step, there 1 stepcontext parent step/thread; there distinct stepcontext each sub-thread.

my (failed) solution use jobcontext.settransientuserdata, because partitioned step uses distinct jobcontext can't transientuserdata.

is there alternative i'm trying do? using partitionmapper properties it's not possible because need pass object, not string every partition.

to clear, need this:

  1. normalbatchlet -> save object used in next step.
  2. partitionedbatchlet -> obtain saved object in previous step. object isn't simple string using partitionmapper properties not solution.

update

i'm using simple singleton ejb hashmap store objects between steps , when job finished clear map avoid resources leak.

this workaround because want use javax.batch package , not depend on ejb's, i'm not putting answer.

you try should conform current spec programming model.

store object first step using persistent step data in normalbatchlet:

stepctx.setpersistentuserdata(myserializabledata);

retrieve data first step in partitions, looking previous step:

long execid = jobctx.getexecutionid();  list<stepexecution> stepexecs = joboperator.getstepexecutions(execid);  mypersistentuserdata mydata;  (stepexecution step : stepexecs) {     if (step.getstepname().equals("somepreviousstepx") {         mydata = (mypersistentuserdata)step.getpersistentuserdata();     } }  //use mydata

Comments

Post a Comment

Popular posts from this blog

Android layout hidden on keyboard show -

i have strange problem layout. when tap on edittext , keyboard shown edittext stay on bottom , when tap on to hide keyboard , keyboard hides , edittext go should when want input text. when tap again, keyboard shown , edittext goes down behind keyboard... <relativelayout android:layout_width="match_parent" android:layout_height="match_parent" > <scrollview android:layout_width="match_parent" android:layout_height="fill_parent" android:above="@+id/rl_commands"> <textview android:layout_width="match_parent" android:layout_height="wrap_content"/> </scrollview> <relativelayout android:layout_width="match_parent android:layout_height="24dp" android:id="@+id/rl_commands" android:alignparentbottom="true">
Read more

google app engine - 403 Forbidden POST - Flask WTForms -

i have flask application running on google app engine. trying submit form built using wtform , keep getting following error. 403 forbidden: don't have permission access requested resource. either read-protected or not readable server. location.html (part of code) <form method=post action="/home/location"> .... <button type="submit" class="btn btn-primary" value="submit"> directions </button> </form> main.py @app.route('/home/location', methods=['post', 'get']) def location(): form = cfcdirections.direction(request.form) print(request.method) if request.method == 'post' , form.validate(): print("after if") directions = cfcdirections() street_no = directions.no street = directions.street suburb = directions.suburb postcode = directions.postcode
Read more

c - Why would PK11_GenerateRandom() return an error -8023? -

i looking through internet trying find source of pk11_generaterandom() function see why function fail. have program uses function when moved new flavor of linux, fails after forking ( fork() ) since not believe there problem nss, suspect doing incorrectly disregarded in older versions of linux new 1 there issue. the openssl package same on 'good' , 'bad' server: openssl 0.9.8e-fips-rhel5 01 jul nss rpm differs though. 'good' has nss-3.12.2.0-2.el5 and bas has version nss-3.15.3-4.el5_10 the 'good' server uses quite obsolete linux: linux 2.6.18-128.el5 #1 smp wed jan 21 08:45:05 est 2009 x86_64 x86_64 x86_64 gnu/linux enterprise linux enterprise linux server release 5.3 (carthage) red hat enterprise linux server release 5.3 (tikanga) the 'bad' server newer: linux bad 2.6.18-371.4.1.el5 #1 smp wed jan 29 11:05:49 pst 2014 x86_64 x86_64 x86_64 gnu/linux oracle linux server release 5.10 red hat enterprise linux server release
Read more