RetryTemplate 질문 드립니다.

여기 소스에서 new DefaultRetryState(item, rollbackClassifier)를 추가했을 경우 입니다. Retry(3) 강의 27:40에서 실행 하셨을때의 경우 입니다. public class RetryItemProcessor2 implements org.springframework.batch.item.ItemProcessor, Customer> { @Autowired private RetryTemplate retryTemplate; private int cnt = 0; @Override public Customer process(String item) throws Exception { System.out.println("ItemProcessor : " + item); Classifier, Boolean> rollbackClassifier = new BinaryExceptionClassifier(true); Customer customer = retryTemplate.execute( new RetryCallback, RuntimeException>() { @Override public Customer doWithRetry(RetryContext retryContext) throws RuntimeException { System.out.println("item = " + item); if (item.equals("1") || item.equals("2")) { cnt++; throw new RetryableException("Retry Exception!! cnt : " + cnt); } return new Customer(item); } }, new RecoveryCallback() { @Override public Customer recover(RetryContext retryContext) throws Exception { return new Customer(item); } }, new DefaultRetryState(item, rollbackClassifier) ); return customer; }} @Configuration@RequiredArgsConstructorpublic class RetryTemplateConfiguration { private final JobBuilderFactory jobBuilderFactory; private final StepBuilderFactory stepBuilderFactory; private int chunkSize = 5; @Bean public Job job() { return jobBuilderFactory.get("batchjob") .incrementer(new RunIdIncrementer()) .start(step1()) .build(); } @Bean public Step step1() { return stepBuilderFactory.get("step1") ., Customer>chunk(chunkSize) .reader(new ItemReader() { int i = 0; @Override public String read() throws Exception, UnexpectedInputException, ParseException, NonTransientResourceException { i++; System.out.println("ItemReader :" + i); return i > 10 ? null : String.valueOf(i); } }) .processor(retryItemProcessor()) .writer(System.out::println) .faultTolerant()// .skip(RetryableException.class)// .skipLimit(2)// .retry(RetryableException.class)// .retryLimit(2) .build(); } @Bean public ItemProcessorsuper String, Customer> retryItemProcessor() { return new RetryItemProcessor2(); } @Bean public RetryTemplate retryTemplate() { Mapextends Throwable>, Boolean> exceptionClasses = new HashMap(); exceptionClasses.put(RetryableException.class, true); FixedBackOffPolicy backOffPolicy = new FixedBackOffPolicy(); backOffPolicy.setBackOffPeriod(2000); SimpleRetryPolicy simpleRetryPolicy = new SimpleRetryPolicy(2, exceptionClasses); RetryTemplate retryTemplate = new RetryTemplate(); retryTemplate.setRetryPolicy(simpleRetryPolicy);// retryTemplate.setBackOffPolicy(backOffPolicy); return retryTemplate; }

Dashboard 실행 중 에러가 납니다.

curl podIP:8080/hostname 해도 결과는 똑같이 time out 에러가 납니다.. kubectl logs -n kube-system calico-node-1-.. 하면 아래와 같은 로그가 나옵니다. 2020-04-19 05:05:18.630 [INFO][52] int_dataplane.go 964: Applying dataplane updates 2020-04-19 05:05:18.630 [INFO][52] ipsets.go 223: Asked to resync with the dataplane on next update. family="inet" 2020-04-19 05:05:18.630 [INFO][52] ipsets.go 306: Resyncing ipsets with dataplane. family="inet" 2020-04-19 05:05:18.632 [INFO][52] ipsets.go 356: Finished resync family="inet" numInconsistenciesFound=0 resyncDuration=1.92041ms 2020-04-19 05:05:18.632 [INFO][52] int_dataplane.go 978: Finished applying updates to dataplane. msecToApply=2.161511 kubectl logs -n kube-system kube-proxy-...를 하면 아래와 같은 로그가 나옵니다. W0417 07:05:41.437308 1 proxier.go:513] Failed to load kernel module ip_vs with modprobe. You can ignore this message when kube-proxy is running inside container without mounting /lib/modules W0417 07:05:41.438401 1 proxier.go:513] Failed to load kernel module ip_vs_rr with modprobe. You can ignore this message when kube-proxy is running inside container without mounting /lib/modules W0417 07:05:41.439420 1 proxier.go:513] Failed to load kernel module ip_vs_wrr with modprobe. You can ignore this message when kube-proxy is running inside container without mounting /lib/modules W0417 07:05:41.440400 1 proxier.go:513] Failed to load kernel module ip_vs_sh with modprobe. You can ignore this message when kube-proxy is running inside container without mounting /lib/modules W0417 07:05:41.449164 1 server_others.go:249] Flag proxy-mode="" unknown, assuming iptables proxy I0417 07:05:41.461394 1 server_others.go:143] Using iptables Proxier. I0417 07:05:41.462037 1 server.go:534] Version: v1.15.11 I0417 07:05:41.471451 1 conntrack.go:52] Setting nf_conntrack_max to 131072 I0417 07:05:41.471604 1 config.go:96] Starting endpoints config controller I0417 07:05:41.471633 1 controller_utils.go:1029] Waiting for caches to sync for endpoints config controller I0417 07:05:41.471690 1 config.go:187] Starting service config controller I0417 07:05:41.471702 1 controller_utils.go:1029] Waiting for caches to sync for service config controller I0417 07:05:41.571817 1 controller_utils.go:1036] Caches are synced for service config controller I0417 07:05:41.571885 1 controller_utils.go:1036] Caches are synced for endpoints config controller kubectl logs -n kube-system calico-kube-controller-... 하면 아래와 같은 로그가 나옵니다. 2020-04-17 07:06:24.224 [INFO][1] main.go 87: Loaded configuration from environment config=&config.Config{LogLevel:"info", ReconcilerPeriod:"5m", CompactionPeriod:"10m", EnabledControllers:"node", WorkloadEndpointWorkers:1, ProfileWorkers:1, PolicyWorkers:1, NodeWorkers:1, Kubeconfig:"", HealthEnabled:true, SyncNodeLabels:true, DatastoreType:"kubernetes"} 2020-04-17 07:06:24.226 [INFO][1] k8s.go 228: Using Calico IPAM W0417 07:06:24.226804 1 client_config.go:541] Neither --kubeconfig nor --master was specified. Using the inClusterConfig. This might not work. 2020-04-17 07:06:24.227 [INFO][1] main.go 108: Ensuring Calico datastore is initialized 2020-04-17 07:06:24.235 [INFO][1] main.go 182: Starting status report routine 2020-04-17 07:06:24.235 [INFO][1] main.go 364: Starting controller ControllerType="Node" 2020-04-17 07:06:24.235 [INFO][1] node_controller.go 133: Starting Node controller 2020-04-17 07:06:24.336 [INFO][1] node_controller.go 146: Node controller is now running 2020-04-17 07:06:24.352 [INFO][1] kdd.go 154: Cleaning up IPAM resources for deleted node node="est2" 2020-04-17 07:06:24.364 [INFO][1] kdd.go 154: Cleaning up IPAM resources for deleted node node="est1" 2020-04-17 07:06:24.368 [INFO][1] kdd.go 167: Node and IPAM data is in sync 네트워크 관련 방화벽은 관련 포트들 전부 오픈하고 설치나 실행도 서버 ip나 hostname 제외하고 가이드와 똑같이 했습니다.. ㅠㅠ 혹시 괜찮으시다면 서버 관련 정보를 알려드릴테니 한번 봐주 실 수 있으신가요?? 메일 주소 알려주시면 보내드리겠습니다..

Dashboard 실행 중 에러가 납니다.

말씀하신 curl clusterIP:9000/hostname 하면 Connection timed out이 나네요.. 위에 dashboard 외부 접근도 Error: 'dial tcp 20.108.215.3:8443: i/o timeout' 나는거 보면 말씀하신 podNetwork가 제대로 동작 안하는 것 같은데 맞나요?? 클러스터 구성 안하고 마스터 노드만 생성 하고 dashboard 접근하면 접속이 됩니다. 이전에도 클러스터 구성없이 마스터만 했을때 됐는데 똑같나 보네요. 클러스터 구성간의 문제일까요? kubectl get nodes나 calico 노드들 보면 정상으로 조회 되긴 합니다.

Dashboard 실행 중 에러가 납니다.

서버 다 지우고 처음부터 진행해서 calico는 정상적으로 동작 됐습니다. 그런데 proxy는 여전히 안되네요.. 말씀하신대로 nohup kubectl proxy --address='0.0.0.0' --port=8001 --accept-hosts='.*' 해서 netstat으로 확인하면 process는 잘 띄워진 것 같습니다. 그런데 접속을 하면 Error: 'dial tcp 20.108.215.3:8443: i/o timeout' Trying to reach: 'https://20.108.215.3:8443/' 라고 나오네요. nohup log를 보니 http: proxy error: context canceled 에러가 나옵니다. 혹시 서비스 대역 ip가 겹쳐서 안되나 해서 kubeadm init --pod-network-cidr=20.96.0.0/12 –service-cidr=30.96.0.0/12 도 해봤는데 이건 netstat으로 8001 포트 검색이 안되더라고요.. 제 서버 private IP 대역이 10.0.0.0/24 인데 IP대역 문제인가요..? 몇일째 붙잡고 있는데 안되니 너무 답답하네요..ㅠㅠ

Dashboard 실행 중 에러가 납니다.

버전은 확인해보니 1.18.0인데 버전을 바꿔서 진행해야 할까요?

Dashboard 실행 중 에러가 납니다.

calico 지우고 다시 진행하면서 logs -n 으로 조회 했는데 아래와 같이 나오네요. 10.0.0.18은 worker 노드 private IP 입니다. calico에서 따로 오픈해야 할 포트가 있나요?? 인터넷 검색 결과 179 포트 오픈해야 한다 해서 179는 오픈 했습니다. (사진)

Dashboard 실행 중 에러가 납니다.

다른 worker 노드들을 제거하고 master만 남겨뒀을때는 calico-node 1개가 정상적으로 돌아가고 dash보드 또한 접속이 가능하네요. cluster 구성 에서 문제가 있는걸까요?? 그리고 dashboard 들어갔을때 아래와 같은 화면으로 에러가 나는데 왜 그런걸까요? (사진)

Dashboard 실행 중 에러가 납니다.

kubectl logs -n kube-system calico-node-169qn 명령어 해보니 아래와 같이 나옵니다. Error from server (NotFound): pods "calico-node-169qn" not found kubectl get pods 하면 No resources found in default namespace. 라고 뜨고 kubectl get service 하면 CLUSTER-IP 뜨는데(10.96.0.1) host ip와 겹치진 않는것 같습니다. pod ip 설정은 calico.yaml의 - name: CALICO_IPV4POOL_CIDR value: "20.96.0.0/12" 이 부분인가요? 그리고 host ip는 외부 ip를 말씀하시는건가요? 아니면 프라이빗 ip를 말씀하시는건가요??