tzolov

(⎈|N/A:N/A)➜  spring-checkpoint-restore-smoke-tests git:(spring-rabbit) ✗ docker exec -it  --privileged -u root spring-amqp-rabbit-crac jcmd /opt/app/spring-amqp-rabbit.jar JDK.checkpoint
129:
An exception during a checkpoint operation:
jdk.internal.crac.CheckpointException
	at java.base/jdk.internal.crac.Core.checkpointRestore1(Core.java:141)
	at java.base/jdk.internal.crac.Core.checkpointRestore(Core.java:246)
	at java.base/jdk.internal.crac.Core.checkpointRestoreInternal(Core.java:262)
	Suppressed: jdk.internal.crac.impl.CheckpointOpenSocketException: tcp localAddr 172.26.0.3 localPort 36964 remoteAddr 172.26.0.2 remotePort 5672
		at java.base/jdk.internal.crac.Core.translateJVMExceptions(Core.java:91)
		at java.base/jdk.internal.crac.Core.checkpointRestore1(Core.java:145)

tzolov

plugins {
    id 'org.springframework.boot' version '2.1.7.RELEASE'
    id 'io.spring.dependency-management' version '1.0.9.RELEASE'
//    id 'java'
    id 'java-library'
    id 'eclipse'
    id 'maven-publish'
}

group = 'com.example'

tzolov

{   "schemaVersion": 2,
   "mediaType": "application/vnd.docker.distribution.manifest.v2+json",
   "config": {
      "mediaType": "application/vnd.docker.container.image.v1+json",
      "digest": "sha256:4bc51a5f5f5e48a2c152c545d391f15d74a549bf7e4c1a9af32b4d1746a66a3b",
      "size": 4458 },
   "layers": [
      { "mediaType": "application/vnd.docker.image.rootfs.diff.tar.gzip",
        "size": 26689544,
        "digest": "sha256:2746a4a261c9e18bfd7ff0429c18fd7522acc14fa4c7ec8ab37ba5ebaadbc584"},

tzolov

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
		 xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd">
	<modelVersion>4.0.0</modelVersion>
	<parent>
		<groupId>org.springframework.boot</groupId>
		<artifactId>spring-boot-starter-parent</artifactId>
		<version>2.2.4.RELEASE</version>
		<relativePath/> <!-- lookup parent from repository -->
	</parent>

tzolov

import java.io.Closeable;
import java.io.IOException;
import java.nio.file.Path;
import java.util.Map;
import java.util.concurrent.Executors;

import javax.annotation.Nullable;

import com.google.cloud.tools.jib.api.Credential;
import com.google.cloud.tools.jib.api.DescriptorDigest;

tzolov

package org.springframework.cloud.dataflow.registry;

import java.util.Map;

import com.fasterxml.jackson.core.JsonProcessingException;
import com.fasterxml.jackson.databind.ObjectMapper;
import org.apache.commons.codec.binary.Base64;

import org.springframework.http.HttpEntity;
import org.springframework.http.HttpHeaders;

tzolov

package io.mindmodel.services.image.recognition;

import java.io.UnsupportedEncodingException;
import java.nio.ByteBuffer;
import java.nio.charset.Charset;
import java.util.Arrays;
import java.util.Collections;
import java.util.List;
import java.util.function.BiFunction;

tzolov

// For further information follow the instructions at: 
// https://github.com/tzolov/cdc-debezium/tree/master/spring-cloud-starter-stream-common-cdc/cdc-spring-boot-starter
@SpringBootApplication
@AutoConfigureBefore(CdcAutoConfiguration.class)
public class CdcDemoApplication {

	public static void main(String[] args) {
		SpringApplication.run(CdcDemoApplication.class, args);
	}

tzolov

mkdir /tmp/twitter-sentiment
cd /tmp/twitter-sentiment

# Download SCDF 1.5.0.RC1 server and shell
wget https://repo.spring.io/milestone/org/springframework/cloud/spring-cloud-dataflow-server-local/1.5.0.RC1/spring-cloud-dataflow-server-local-1.5.0.RC1.jar
wget https://repo.spring.io/milestone/org/springframework/cloud/spring-cloud-dataflow-shell/1.5.0.RC1/spring-cloud-dataflow-shell-1.5.0.RC1.jar

# Download the pre-build twitter-sentiment-processor-rabbit-2.0.0.BUILD-SNAPSHOT.jar and twitter-sentiment-processor-rabbit-2.0.0.BUILD-SNAPSHOT-metadata.jar
wget https://www.dropbox.com/s/0praocvbwhqk6uq/twitter-sentiment-processor-rabbit-2.0.0.BUILD-SNAPSHOT.jar
wget https://www.dropbox.com/s/qewy9zwx1743w6z/twitter-sentiment-processor-rabbit-2.0.0.BUILD-SNAPSHOT-metadata.jar

tzolov

public class MyTableScanRule3 extends RelOptRule {

	public MyTableScanRule3() {
		super(operand(JdbcTableScan.class, any()));
	}

	@Override
	public boolean matches(RelOptRuleCall call) {
		JdbcTableScan jdbcTableScan = call.rel(0);
		return super.matches(call);