Ես գրանցեցի իմ առաջադրանքի հավելվածը Spring Cloud Data Flow-ում, ստեղծեցի դրա սահմանումը և կարգավիճակը ցույց է տալիս «անհայտ»: Ես ստեղծեցի հոսքը և փորձում եմ առաջադրանքը գործարկել task-sink-ի միջոցով, և ես սխալ եմ ստանում.
java.lang.IllegalStateException: failed to resolve MavenResource:
Ինչպե՞ս գործարկել առաջադրանքը task-sink-ից: Ինչ-որ բան կարոտում եմ? Ցանկացած օգնություն գնահատելի է: Մեկ այլ հարց է, թե ինչպես կարող եմ մուտք գործել TaskLaunchRequest-ի միջոցով ուղարկված ծանրաբեռնվածություն իմ առաջադրանքում: S1 http | քայլ 1. տրանսֆորմատոր-նապաստակ | log S2 :S1.step1 > filter --expression=payload.contains('CUSTADDRMODRQ_V15') | առաջադրանք-մշակող | առաջադրանք-լվացարան
task-sink-ը գործարկում է uri-ի կողմից տրամադրված առաջադրանքը TaskLaunchRequest-ում: Այն փնտրում է ռեսուրսը, ինչպես ցույց է տրված log OUT-ում, օգտագործելով EnhancedLocalRepositoryManager-ի մենեջեր՝ առաջնահերթություն 10.0-ով /home/vcap/.m2/repository OUT-ի համար Օգտագործելով HttpTransporter 5.0 առաջնահերթություն ունեցող փոխադրողը https://repo.spring.io-իհամար:/libs-snapshot և վերջապես ձախողվեց:
Առաջադրանքը տեղադրված է մեր պահոցում, և ինչպես նշվեց, ես գրանցեցի և ստեղծեցի դրա սահմանումը նույնպես:
Սա cf միջավայրում է, և ես օգտագործում եմ SCDF սերվեր 1.0.0.M4: Հատկություններ առաջադրանքի համար նախատեսված հավելվածում ես տրամադրում եմ maven.remote.repositories.snapshots.url=**
առաջադրանք ստեղծել fis-ifx-event-task --սահմանում «fis-event-task»
Իմ նպատակն է առաջադրանքը գործարկել հոսքից:
Շնորհակալություն տեղեկատվության համար: Ես իրականում օգտագործում եմ BUILD-SNAPSHOT-ը, քանի որ չեմ կարողանում միացնել 1.0.0M4 տարբերակով նկարները: Ահա այն մեկը, որը ես օգտագործում եմ spring-cloud-dataflow-server-cloudfoundry-1.0.0.BUILD-20160808.144306-116: Ես կարողանում եմ գրանցվել և ստեղծել առաջադրանքների սահմանումներ: Առաջադրանքի սահմանման կարգավիճակը ցուցադրվում է որպես «անհայտ» նույնիսկ այն ժամանակ, երբ ես օգտագործում եմ ձեր թիմի կողմից տրամադրված առաջադրանքի նմուշ մոդուլը: Բայց երբ ես սկսում եմ հոսքի հոսքը, և երբ task-sink-ը փորձում է գործարկել առաջադրանքը, այն չի կարողանում գտնել maven ռեսուրսը: Երբ ես ստեղծում եմ առաջադրանքի սահմանումը, արդյո՞ք առաջադրանքի մոդուլը տեղակայվում է: Ես որևէ հավելված չեմ տեսնում Pivotal Apps Manager-ում: Ինչպես նշվեց ավելի վաղ, ես maven.remote.repositories.snapshot.url-ը ներկայացրել եմ application.properties ֆայլում՝ task-sink հավելվածի համար: Մեկ այլ բան, որ ես նկատեցի այն է, որ երբ ես առաջադրանքը ձեռքով գործարկում եմ տվյալների հոսքի վահանակից, այն տալիս է սխալ CF-UnprocessableEntity(10008). հարցումը իմաստային առումով անվավեր է. Անհայտ դաշտ(ներ)՝ «staging_disk_in_mb», «staging_memory_in_mb» և նաև հաղորդագրություն՝ ասելով « Աղբյուրը դատարկ է։ Ներկայումս առաջադրանքը պետք է տպի ժամանակի դրոշմը և կախված չէ որևէ մուտքագրումից:
TaskProcessor code:
@EnableBinding(Processor.class)
@EnableConfigurationProperties(TaskProcessorProperties.class)
public class TaskProcessor {
@Autowired
private TaskProcessorProperties processorProperties;
public TaskProcessor() {
}
@Transformer(inputChannel = Processor.INPUT, outputChannel = Processor.OUTPUT)
@ELI(level = "info", eventType = ELIEventType.INBOUND)
public Object setupRequest(String message) {
Map<String, String> properties = new HashMap<String, String>();
properties.put("payload", message);
TaskLaunchRequest request = new TaskLaunchRequest(processorProperties.getUri(), null, properties, null);
return new GenericMessage<>(request);
}
}
TaskSink code:
@SpringBootApplication
@EnableTaskLauncher
@EnableBinding(Sink.class)
@EnableConfigurationProperties(TaskSinkProperties.class)
public class FisIfxEventTaskSinkApplication {
public static void main(String[] args) {
SpringApplication.run(FisIfxEventTaskSinkApplication.class, args);
}
}
Ես ավելի վաղ տրամադրել եմ այն հոսքը, որն օգտագործում եմ գրառման մեջ: Sink-ը ստանում է TaskLaunchRequest-ը uri-ով և ծանրաբեռնվածությամբ, ինչպես կարող եք տեսնել այստեղ և չի կարողանում գործարկել առաջադրանքը:
OUT registering [40, java.io.File] with serializer org.springframework.integration.codec.kryo.FileSerializer
2016-08-10T16:08:55.02-0600 [APP/0]
OUT Launching Task for the following resource TaskLaunchRequest{uri='maven://com.xxx:fis.ifx.event-task:jar:1.0-SNAPSHOT', commandlineArguments=[], environmentProperties={payload={"statusCode":0,"fisT
opic":"CustomerDataUpdated","payloadId":"CUSTADDRMODR``Q_V15","customerIds":[1597304]}}, deploymentProperties={}}
