airbytehq · zzstoatzz · Aug 4, 2021 · Aug 4, 2021 · Aug 4, 2021 · Aug 4, 2021
diff --git a/airbyte-api/bin/main/config.yaml b/airbyte-api/bin/main/config.yaml
diff --git a/airbyte-api/bin/main/io/airbyte/api/client/AirbyteApiClient.class b/airbyte-api/bin/main/io/airbyte/api/client/AirbyteApiClient.class
diff --git a/airbyte-api/bin/main/io/airbyte/api/client/PatchedLogsApi.class b/airbyte-api/bin/main/io/airbyte/api/client/PatchedLogsApi.class
diff --git a/airbyte-commons-cli/bin/main/io/airbyte/commons/cli/Clis$RelaxedParser.class b/airbyte-commons-cli/bin/main/io/airbyte/commons/cli/Clis$RelaxedParser.class
diff --git a/airbyte-commons-cli/bin/main/io/airbyte/commons/cli/Clis.class b/airbyte-commons-cli/bin/main/io/airbyte/commons/cli/Clis.class
diff --git a/airbyte-commons-cli/bin/test/io/airbyte/commons/cli/ClisTest.class b/airbyte-commons-cli/bin/test/io/airbyte/commons/cli/ClisTest.class
diff --git a/airbyte-commons-docker/bin/main/io/airbyte/commons/docker/DockerUtils.class b/airbyte-commons-docker/bin/main/io/airbyte/commons/docker/DockerUtils.class
diff --git a/airbyte-commons-docker/bin/test/io/airbyte/commons/docker/DockerUtilsTest.class b/airbyte-commons-docker/bin/test/io/airbyte/commons/docker/DockerUtilsTest.class
diff --git a/airbyte-commons/bin/main/io/airbyte/commons/concurrency/GracefulShutdownHandler.class b/airbyte-commons/bin/main/io/airbyte/commons/concurrency/GracefulShutdownHandler.class
diff --git a/airbyte-commons/bin/main/io/airbyte/commons/concurrency/LifecycledCallable$Builder.class b/airbyte-commons/bin/main/io/airbyte/commons/concurrency/LifecycledCallable$Builder.class
diff --git a/airbyte-commons/bin/main/io/airbyte/commons/concurrency/LifecycledCallable.class b/airbyte-commons/bin/main/io/airbyte/commons/concurrency/LifecycledCallable.class
diff --git a/airbyte-commons/bin/main/io/airbyte/commons/concurrency/VoidCallable.class b/airbyte-commons/bin/main/io/airbyte/commons/concurrency/VoidCallable.class
diff --git a/airbyte-commons/bin/main/io/airbyte/commons/concurrency/WaitingUtils.class b/airbyte-commons/bin/main/io/airbyte/commons/concurrency/WaitingUtils.class
diff --git a/airbyte-commons/bin/main/io/airbyte/commons/enums/Enums.class b/airbyte-commons/bin/main/io/airbyte/commons/enums/Enums.class
diff --git a/airbyte-commons/bin/main/io/airbyte/commons/features/EnvVariableFeatureFlags.class b/airbyte-commons/bin/main/io/airbyte/commons/features/EnvVariableFeatureFlags.class
diff --git a/airbyte-commons/bin/main/io/airbyte/commons/features/FeatureFlags.class b/airbyte-commons/bin/main/io/airbyte/commons/features/FeatureFlags.class
diff --git a/airbyte-commons/bin/main/io/airbyte/commons/functional/CheckedBiConsumer.class b/airbyte-commons/bin/main/io/airbyte/commons/functional/CheckedBiConsumer.class
diff --git a/airbyte-commons/bin/main/io/airbyte/commons/functional/CheckedBiFunction.class b/airbyte-commons/bin/main/io/airbyte/commons/functional/CheckedBiFunction.class
diff --git a/airbyte-commons/bin/main/io/airbyte/commons/functional/CheckedConsumer.class b/airbyte-commons/bin/main/io/airbyte/commons/functional/CheckedConsumer.class
diff --git a/airbyte-commons/bin/main/io/airbyte/commons/functional/CheckedFunction.class b/airbyte-commons/bin/main/io/airbyte/commons/functional/CheckedFunction.class
diff --git a/airbyte-commons/bin/main/io/airbyte/commons/functional/CheckedSupplier.class b/airbyte-commons/bin/main/io/airbyte/commons/functional/CheckedSupplier.class
diff --git a/airbyte-commons/bin/main/io/airbyte/commons/functional/Consumers.class b/airbyte-commons/bin/main/io/airbyte/commons/functional/Consumers.class
diff --git a/airbyte-commons/bin/main/io/airbyte/commons/functional/ListConsumer.class b/airbyte-commons/bin/main/io/airbyte/commons/functional/ListConsumer.class
diff --git a/airbyte-commons/bin/main/io/airbyte/commons/io/Archives.class b/airbyte-commons/bin/main/io/airbyte/commons/io/Archives.class
diff --git a/airbyte-commons/bin/main/io/airbyte/commons/io/FileTtlManager.class b/airbyte-commons/bin/main/io/airbyte/commons/io/FileTtlManager.class
diff --git a/airbyte-commons/bin/main/io/airbyte/commons/io/IOs.class b/airbyte-commons/bin/main/io/airbyte/commons/io/IOs.class
diff --git a/airbyte-commons/bin/main/io/airbyte/commons/io/LineGobbler.class b/airbyte-commons/bin/main/io/airbyte/commons/io/LineGobbler.class
diff --git a/airbyte-commons/bin/main/io/airbyte/commons/jackson/MoreMappers.class b/airbyte-commons/bin/main/io/airbyte/commons/jackson/MoreMappers.class
diff --git a/airbyte-commons/bin/main/io/airbyte/commons/json/JsonSchemas.class b/airbyte-commons/bin/main/io/airbyte/commons/json/JsonSchemas.class
diff --git a/airbyte-commons/bin/main/io/airbyte/commons/json/Jsons$1.class b/airbyte-commons/bin/main/io/airbyte/commons/json/Jsons$1.class
diff --git a/airbyte-commons/bin/main/io/airbyte/commons/json/Jsons$JsonPrettyPrinter.class b/airbyte-commons/bin/main/io/airbyte/commons/json/Jsons$JsonPrettyPrinter.class
diff --git a/airbyte-commons/bin/main/io/airbyte/commons/json/Jsons.class b/airbyte-commons/bin/main/io/airbyte/commons/json/Jsons.class
diff --git a/airbyte-commons/bin/main/io/airbyte/commons/lang/CloseableConsumer.class b/airbyte-commons/bin/main/io/airbyte/commons/lang/CloseableConsumer.class
diff --git a/airbyte-commons/bin/main/io/airbyte/commons/lang/CloseableQueue.class b/airbyte-commons/bin/main/io/airbyte/commons/lang/CloseableQueue.class
diff --git a/airbyte-commons/bin/main/io/airbyte/commons/lang/Exceptions$Procedure.class b/airbyte-commons/bin/main/io/airbyte/commons/lang/Exceptions$Procedure.class
diff --git a/airbyte-commons/bin/main/io/airbyte/commons/lang/Exceptions.class b/airbyte-commons/bin/main/io/airbyte/commons/lang/Exceptions.class
diff --git a/airbyte-commons/bin/main/io/airbyte/commons/lang/MoreBooleans.class b/airbyte-commons/bin/main/io/airbyte/commons/lang/MoreBooleans.class
diff --git a/airbyte-commons/bin/main/io/airbyte/commons/lang/Queues$1.class b/airbyte-commons/bin/main/io/airbyte/commons/lang/Queues$1.class
diff --git a/airbyte-commons/bin/main/io/airbyte/commons/lang/Queues.class b/airbyte-commons/bin/main/io/airbyte/commons/lang/Queues.class
diff --git a/airbyte-commons/bin/main/io/airbyte/commons/logging/LoggingHelper$Color.class b/airbyte-commons/bin/main/io/airbyte/commons/logging/LoggingHelper$Color.class
diff --git a/airbyte-commons/bin/main/io/airbyte/commons/logging/LoggingHelper.class b/airbyte-commons/bin/main/io/airbyte/commons/logging/LoggingHelper.class
diff --git a/airbyte-commons/bin/main/io/airbyte/commons/logging/MdcScope$Builder.class b/airbyte-commons/bin/main/io/airbyte/commons/logging/MdcScope$Builder.class
diff --git a/airbyte-commons/bin/main/io/airbyte/commons/logging/MdcScope.class b/airbyte-commons/bin/main/io/airbyte/commons/logging/MdcScope.class
diff --git a/airbyte-commons/bin/main/io/airbyte/commons/map/MoreMaps.class b/airbyte-commons/bin/main/io/airbyte/commons/map/MoreMaps.class
diff --git a/airbyte-commons/bin/main/io/airbyte/commons/resources/MoreResources.class b/airbyte-commons/bin/main/io/airbyte/commons/resources/MoreResources.class
diff --git a/airbyte-commons/bin/main/io/airbyte/commons/set/MoreSets.class b/airbyte-commons/bin/main/io/airbyte/commons/set/MoreSets.class
diff --git a/airbyte-commons/bin/main/io/airbyte/commons/stream/MoreStreams.class b/airbyte-commons/bin/main/io/airbyte/commons/stream/MoreStreams.class
diff --git a/airbyte-commons/bin/main/io/airbyte/commons/string/Strings.class b/airbyte-commons/bin/main/io/airbyte/commons/string/Strings.class
diff --git a/airbyte-commons/bin/main/io/airbyte/commons/text/Names.class b/airbyte-commons/bin/main/io/airbyte/commons/text/Names.class
diff --git a/airbyte-commons/bin/main/io/airbyte/commons/text/Sqls.class b/airbyte-commons/bin/main/io/airbyte/commons/text/Sqls.class
diff --git a/airbyte-commons/bin/main/io/airbyte/commons/time/Instants.class b/airbyte-commons/bin/main/io/airbyte/commons/time/Instants.class
diff --git a/airbyte-commons/bin/main/io/airbyte/commons/type/Types.class b/airbyte-commons/bin/main/io/airbyte/commons/type/Types.class
diff --git a/airbyte-commons/bin/main/io/airbyte/commons/util/AutoCloseableIterator.class b/airbyte-commons/bin/main/io/airbyte/commons/util/AutoCloseableIterator.class
diff --git a/airbyte-commons/bin/main/io/airbyte/commons/util/AutoCloseableIterators.class b/airbyte-commons/bin/main/io/airbyte/commons/util/AutoCloseableIterators.class
diff --git a/airbyte-commons/bin/main/io/airbyte/commons/util/CompositeIterator.class b/airbyte-commons/bin/main/io/airbyte/commons/util/CompositeIterator.class
diff --git a/airbyte-commons/bin/main/io/airbyte/commons/util/DefaultAutoCloseableIterator.class b/airbyte-commons/bin/main/io/airbyte/commons/util/DefaultAutoCloseableIterator.class
diff --git a/airbyte-commons/bin/main/io/airbyte/commons/util/LazyAutoCloseableIterator.class b/airbyte-commons/bin/main/io/airbyte/commons/util/LazyAutoCloseableIterator.class
diff --git a/airbyte-commons/bin/main/io/airbyte/commons/util/MoreIterators$1.class b/airbyte-commons/bin/main/io/airbyte/commons/util/MoreIterators$1.class
diff --git a/airbyte-commons/bin/main/io/airbyte/commons/util/MoreIterators.class b/airbyte-commons/bin/main/io/airbyte/commons/util/MoreIterators.class
diff --git a/airbyte-commons/bin/main/io/airbyte/commons/util/MoreLists.class b/airbyte-commons/bin/main/io/airbyte/commons/util/MoreLists.class
diff --git a/airbyte-commons/bin/main/io/airbyte/commons/util/MoreProperties.class b/airbyte-commons/bin/main/io/airbyte/commons/util/MoreProperties.class
diff --git a/airbyte-commons/bin/main/io/airbyte/commons/version/AirbyteVersion.class b/airbyte-commons/bin/main/io/airbyte/commons/version/AirbyteVersion.class
diff --git a/airbyte-commons/bin/main/io/airbyte/commons/yaml/Yamls$1.class b/airbyte-commons/bin/main/io/airbyte/commons/yaml/Yamls$1.class
diff --git a/airbyte-commons/bin/main/io/airbyte/commons/yaml/Yamls$YamlConsumer.class b/airbyte-commons/bin/main/io/airbyte/commons/yaml/Yamls$YamlConsumer.class
diff --git a/airbyte-commons/bin/main/io/airbyte/commons/yaml/Yamls.class b/airbyte-commons/bin/main/io/airbyte/commons/yaml/Yamls.class
diff --git a/airbyte-commons/bin/main/log4j2.xml b/airbyte-commons/bin/main/log4j2.xml
@@ -0,0 +1,206 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<Configuration status="INFO">
+    <Properties>
+
+        <!-- Mask the string apikey=<string> to apikey=***** to prevent secrets leaking. -->
+        <Property name="default-pattern">%d{yyyy-MM-dd HH:mm:ss}{GMT+0} %highlight{%p} %C{1.}(%M):%L - %replace{%m}{apikey=[\w\-]*}{apikey=*****}%n</Property>
+        <!--Logs the timestamp and log_source/application name in the beginning of the line if it exists with a > separator, and then always the rest of the line.-->
+        <Property name="simple-pattern">%d{yyyy-MM-dd HH:mm:ss}{GMT+0}%replace{ %X{log_source}}{^ -}{} > %replace{%m}{apikey=[\w\-]*}{apikey=*****}%n</Property>
+
+        <!-- Always log INFO by default. -->
+        <Property name="log-level">${sys:LOG_LEVEL:-${env:LOG_LEVEL:-INFO}}</Property>
+
+        <Property name="s3-bucket">${sys:S3_LOG_BUCKET:-${env:S3_LOG_BUCKET}}</Property>
+        <Property name="s3-region">${sys:S3_LOG_BUCKET_REGION:-${env:S3_LOG_BUCKET_REGION}}</Property>
+        <Property name="s3-aws-key">${sys:AWS_ACCESS_KEY_ID:-${env:AWS_ACCESS_KEY_ID}}</Property>
+        <Property name="s3-aws-secret">${sys:AWS_SECRET_ACCESS_KEY:-${env:AWS_SECRET_ACCESS_KEY}}</Property>
+        <Property name="s3-minio-endpoint">${sys:S3_MINIO_ENDPOINT:-${env:S3_MINIO_ENDPOINT}}</Property>
+        <Property name="s3-path-style-access">${sys:S3_PATH_STYLE_ACCESS:-${env:S3_PATH_STYLE_ACCESS}}</Property>
+
+        <Property name="gcs-log-bucket">${sys:GCS_LOG_BUCKET:-${env:GCS_LOG_BUCKET}}</Property>
+    </Properties>
+
+    <Appenders>
+        <Console name="Default" target="SYSTEM_OUT">
+            <ContextMapFilter onMatch="DENY" onMismatch="ACCEPT">
+                <KeyValuePair key="simple" value="true"/>
+            </ContextMapFilter>
+            <PatternLayout pattern="${default-pattern}"/>
+        </Console>
+
+        <Console name="SimpleDefault" target="SYSTEM_OUT">
+            <ContextMapFilter onMatch="ACCEPT" onMismatch="DENY">
+                <KeyValuePair key="simple" value="true"/>
+            </ContextMapFilter>
+            <PatternLayout pattern="${simple-pattern}"/>
+        </Console>
+
+        <Routing name="LogSplit">
+            <ContextMapFilter onMatch="DENY" onMismatch="ACCEPT">
+                <KeyValuePair key="simple" value="true"/>
+            </ContextMapFilter>
+            <Routes pattern="$${ctx:job_log_path}">
+                <!-- Don't split logs if job_root isn't defined -->
+                <Route key="$${ctx:job_log_path}">
+                    <Null name="/dev/null"/>
+                </Route>
+                <Route>
+                    <File name="${ctx:job_log_path}-local" fileName="${ctx:job_log_path}">
+                        <PatternLayout pattern="${default-pattern}"/>
+                    </File>
+                </Route>
+            </Routes>
+            <IdlePurgePolicy timeToLive="15" timeUnit="minutes"/>
+        </Routing>
+
+        <Routing name="SimpleLogSplit">
+            <ContextMapFilter onMatch="ACCEPT" onMismatch="DENY">
+                <KeyValuePair key="simple" value="true"/>
+            </ContextMapFilter>
+            <Routes pattern="$${ctx:job_log_path}">
+                <!-- Don't split logs if job_root isn't defined -->
+                <Route key="$${ctx:job_log_path}">
+                    <Null name="/dev/null"/>
+                </Route>
+                <Route>
+                    <File name="${ctx:job_log_path}-local" fileName="${ctx:job_log_path}">
+                        <PatternLayout pattern="${simple-pattern}"/>
+                    </File>
+                </Route>
+            </Routes>
+            <IdlePurgePolicy timeToLive="15" timeUnit="minutes"/>
+        </Routing>
+
+        <!--
+            Separate routers are created for each cloud logger as
+            1) a Route only accepts 1 appender
+            2) Routes don't support routing log output to more than Route
+        -->
+        <Routing name="LogSplitCloud">
+            <ContextMapFilter onMatch="DENY" onMismatch="ACCEPT">
+                <KeyValuePair key="simple" value="true"/>
+            </ContextMapFilter>
+            <Routes pattern="$${ctx:cloud_job_log_path}">
+                <!-- Don't split logs if job_root isn't defined -->
+                <Route key="$${ctx:cloud_job_log_path}">
+                    <Null name="/dev/null"/>
+                </Route>
+                <Route>
+                    <Log4j2Appender name="${ctx:cloud_job_log_path}"
+                      verbose="true"
+                      stagingBufferAge="1"
+                      s3Bucket="${s3-bucket}" s3Path="job-logging${ctx:cloud_job_log_path}" s3Region="${s3-region}"
+                      s3AwsKey="${s3-aws-key}" s3AwsSecret="${s3-aws-secret}"
+                      s3ServiceEndpoint="${s3-minio-endpoint}" s3PathStyleAccess="${s3-path-style-access}"
+                      gcpStorageBucket="${gcs-log-bucket}" gcpStorageBlobNamePrefix="job-logging${ctx:cloud_job_log_path}">
+                        <PatternLayout pattern="${default-pattern}"/>
+                    </Log4j2Appender>
+                </Route>
+            </Routes>
+            <IdlePurgePolicy timeToLive="15" timeUnit="minutes"/>
+        </Routing>
+
+        <Routing name="SimpleLogSplitCloud">
+            <ContextMapFilter onMatch="ACCEPT" onMismatch="DENY">
+                <KeyValuePair key="simple" value="true"/>
+            </ContextMapFilter>
+            <Routes pattern="$${ctx:cloud_job_log_path}">
+                <!-- Don't split logs if job_root isn't defined -->
+                <Route key="$${ctx:cloud_job_log_path}">
+                    <Null name="/dev/null"/>
+                </Route>
+                <Route>
+                    <Log4j2Appender name="${ctx:cloud_job_log_path}"
+                                    verbose="true"
+                                    stagingBufferAge="1"
+                                    s3Bucket="${s3-bucket}" s3Path="job-logging${ctx:cloud_job_log_path}" s3Region="${s3-region}"
+                                    s3AwsKey="${s3-aws-key}" s3AwsSecret="${s3-aws-secret}"
+                                    s3ServiceEndpoint="${s3-minio-endpoint}" s3PathStyleAccess="${s3-path-style-access}"
+                                    gcpStorageBucket="${gcs-log-bucket}" gcpStorageBlobNamePrefix="job-logging${ctx:cloud_job_log_path}">
+                        <PatternLayout pattern="${simple-pattern}"/>
+                    </Log4j2Appender>
+                </Route>
+            </Routes>
+            <IdlePurgePolicy timeToLive="15" timeUnit="minutes"/>
+        </Routing>
+
+        <Routing name="AppLogSplit">
+            <Routes pattern="$${ctx:workspace_app_root}">
+                <!-- Don't split logs if workspace_app_log_root isn't defined -->
+                <Route key="$${ctx:workspace_app_root}">
+                    <Null name="/dev/null"/>
+                </Route>
+                <Route>
+                    <RollingFile
+                            name="${ctx:workspace_app_root}-local"
+                            fileName="${ctx:workspace_app_root}/logs.log"
+                            filePattern="${ctx:workspace_app_root}/logs.%i.log.gz"
+                            ignoreExceptions="false">
+                        <PatternLayout pattern="${default-pattern}"/>
+                        <Policies>
+                            <SizeBasedTriggeringPolicy size="100MB" />
+                        </Policies>
+                        <DefaultRolloverStrategy max="3" />
+                    </RollingFile>
+                </Route>
+            </Routes>
+            <IdlePurgePolicy timeToLive="15" timeUnit="minutes"/>
+        </Routing>
+        <Routing name="AppLogSplitCloud">
+            <Routes pattern="$${ctx:cloud_workspace_app_root}">
+                <!-- Don't split logs if workspace_app_log_root isn't defined -->
+                <Route key="$${ctx:cloud_workspace_app_root}">
+                    <Null name="/dev/null"/>
+                </Route>
+                <Route>
+                    <Log4j2Appender name="app-logging/${ctx:cloud_workspace_app_root}/"
+                      stagingBufferAge="1"
+                      s3Bucket="${s3-bucket}" s3Path="app-logging${ctx:cloud_workspace_app_root}" s3Region="${s3-region}"
+                      s3AwsKey="${s3-aws-key}" s3AwsSecret="${s3-aws-secret}"
+                      s3ServiceEndpoint="${s3-minio-endpoint}" s3PathStyleAccess="${s3-path-style-access}"
+                      gcpStorageBucket="${gcs-log-bucket}" gcpStorageBlobNamePrefix="app-logging${ctx:cloud_workspace_app_root}">
+                        <PatternLayout pattern="${default-pattern}"/>
+                    </Log4j2Appender>
+                </Route>
+            </Routes>
+            <IdlePurgePolicy timeToLive="15" timeUnit="minutes"/>
+        </Routing>
+    </Appenders>
+
+    <Loggers>
+        <Root level="${log-level}">
+            <AppenderRef ref="Default"/>
+            <AppenderRef ref="SimpleDefault"/>
+            <AppenderRef ref="LogSplit"/>
+            <AppenderRef ref="SimpleLogSplit"/>
+            <AppenderRef ref="LogSplitCloud"/>
+            <AppenderRef ref="SimpleLogSplitCloud"/>
+            <AppenderRef ref="AppLogSplit"/>
+            <AppenderRef ref="AppLogSplitCloud"/>
+        </Root>
+
+        <Logger name="org.eclipse.jetty" level="INFO" />
+        <Logger name="com.github.dockerjava" level="INFO" />
+        <Logger name="org.apache.hc" level="INFO" />
+        <Logger name="org.jooq" level="INFO" />
+        <logger name="org.jooq.Constants" level="OFF" />
+        <Logger name="com.networknt.schema" level="INFO" />
+        <Logger name="me.andrz.jackson" level="INFO" />
+        <Logger name="com.leansoft.bigqueue" level="INFO" />
+        <Logger name="io.netty" level="INFO" />
+        <Logger name="io.grpc" level="INFO" />
+        <Logger name="io.temporal" level="INFO" />
+        <Logger name="org.apache" level="WARN" />
+        <Logger name="httpclient" level="WARN" />
+        <Logger name="com.amazonaws" level="WARN" />
+        <!--MySQL Debezium connector generates a log whenever it converts an invalid value to empty value.
+        Ex: Invalid value '0000-00-00 00:00:00' stored in column 'column_name' of table 'table_name' converted to empty value
+        If a database has tons of such values, the logs would be filled with such messages-->
+        <Logger name="io.debezium.connector.mysql.MySqlValueConverters" level="OFF" />
+        <!--MySQL Debezium connector generates a log whenever it comes across a DDL query to mention that it skipped it.
+        If a database has tons of DDL queries, the logs would be filled with such messages-->
+        <Logger name="io.debezium.relational.history" level="OFF" />
+
+    </Loggers>
+
+</Configuration>
diff --git a/airbyte-commons/bin/test/io/airbyte/commons/concurrency/GracefulShutdownHandlerTest.class b/airbyte-commons/bin/test/io/airbyte/commons/concurrency/GracefulShutdownHandlerTest.class
diff --git a/airbyte-commons/bin/test/io/airbyte/commons/concurrency/LifecycledCallableTest.class b/airbyte-commons/bin/test/io/airbyte/commons/concurrency/LifecycledCallableTest.class
diff --git a/airbyte-commons/bin/test/io/airbyte/commons/concurrency/WaitingUtilsTest.class b/airbyte-commons/bin/test/io/airbyte/commons/concurrency/WaitingUtilsTest.class
diff --git a/airbyte-commons/bin/test/io/airbyte/commons/enums/EnumsTest$E1.class b/airbyte-commons/bin/test/io/airbyte/commons/enums/EnumsTest$E1.class
diff --git a/airbyte-commons/bin/test/io/airbyte/commons/enums/EnumsTest$E2.class b/airbyte-commons/bin/test/io/airbyte/commons/enums/EnumsTest$E2.class
diff --git a/airbyte-commons/bin/test/io/airbyte/commons/enums/EnumsTest$E3.class b/airbyte-commons/bin/test/io/airbyte/commons/enums/EnumsTest$E3.class
diff --git a/airbyte-commons/bin/test/io/airbyte/commons/enums/EnumsTest$E4.class b/airbyte-commons/bin/test/io/airbyte/commons/enums/EnumsTest$E4.class
diff --git a/airbyte-commons/bin/test/io/airbyte/commons/enums/EnumsTest$E5.class b/airbyte-commons/bin/test/io/airbyte/commons/enums/EnumsTest$E5.class
diff --git a/airbyte-commons/bin/test/io/airbyte/commons/enums/EnumsTest.class b/airbyte-commons/bin/test/io/airbyte/commons/enums/EnumsTest.class
diff --git a/airbyte-commons/bin/test/io/airbyte/commons/io/FileTtlManagerTest.class b/airbyte-commons/bin/test/io/airbyte/commons/io/FileTtlManagerTest.class
diff --git a/airbyte-commons/bin/test/io/airbyte/commons/io/IOsTest.class b/airbyte-commons/bin/test/io/airbyte/commons/io/IOsTest.class
diff --git a/airbyte-commons/bin/test/io/airbyte/commons/io/LineGobblerTest.class b/airbyte-commons/bin/test/io/airbyte/commons/io/LineGobblerTest.class
diff --git a/airbyte-commons/bin/test/io/airbyte/commons/json/JsonsTest$1.class b/airbyte-commons/bin/test/io/airbyte/commons/json/JsonsTest$1.class
diff --git a/airbyte-commons/bin/test/io/airbyte/commons/json/JsonsTest$2.class b/airbyte-commons/bin/test/io/airbyte/commons/json/JsonsTest$2.class
diff --git a/airbyte-commons/bin/test/io/airbyte/commons/json/JsonsTest$3.class b/airbyte-commons/bin/test/io/airbyte/commons/json/JsonsTest$3.class
diff --git a/airbyte-commons/bin/test/io/airbyte/commons/json/JsonsTest$ToClass.class b/airbyte-commons/bin/test/io/airbyte/commons/json/JsonsTest$ToClass.class
diff --git a/airbyte-commons/bin/test/io/airbyte/commons/json/JsonsTest.class b/airbyte-commons/bin/test/io/airbyte/commons/json/JsonsTest.class
diff --git a/airbyte-commons/bin/test/io/airbyte/commons/lang/ExceptionsTest.class b/airbyte-commons/bin/test/io/airbyte/commons/lang/ExceptionsTest.class
diff --git a/airbyte-commons/bin/test/io/airbyte/commons/lang/MoreBooleansTest.class b/airbyte-commons/bin/test/io/airbyte/commons/lang/MoreBooleansTest.class
diff --git a/airbyte-commons/bin/test/io/airbyte/commons/logging/Log4j2ConfigTest.class b/airbyte-commons/bin/test/io/airbyte/commons/logging/Log4j2ConfigTest.class
diff --git a/airbyte-commons/bin/test/io/airbyte/commons/logging/MdcScopeTest$1.class b/airbyte-commons/bin/test/io/airbyte/commons/logging/MdcScopeTest$1.class
diff --git a/airbyte-commons/bin/test/io/airbyte/commons/logging/MdcScopeTest$2.class b/airbyte-commons/bin/test/io/airbyte/commons/logging/MdcScopeTest$2.class
diff --git a/airbyte-commons/bin/test/io/airbyte/commons/logging/MdcScopeTest$3.class b/airbyte-commons/bin/test/io/airbyte/commons/logging/MdcScopeTest$3.class
diff --git a/airbyte-commons/bin/test/io/airbyte/commons/logging/MdcScopeTest.class b/airbyte-commons/bin/test/io/airbyte/commons/logging/MdcScopeTest.class
diff --git a/airbyte-commons/bin/test/io/airbyte/commons/map/MoreMapsTest.class b/airbyte-commons/bin/test/io/airbyte/commons/map/MoreMapsTest.class
diff --git a/airbyte-commons/bin/test/io/airbyte/commons/resources/MoreResourcesTest.class b/airbyte-commons/bin/test/io/airbyte/commons/resources/MoreResourcesTest.class
diff --git a/airbyte-commons/bin/test/io/airbyte/commons/set/MoreSetsTest.class b/airbyte-commons/bin/test/io/airbyte/commons/set/MoreSetsTest.class
diff --git a/airbyte-commons/bin/test/io/airbyte/commons/string/StringsTest$JoinClass.class b/airbyte-commons/bin/test/io/airbyte/commons/string/StringsTest$JoinClass.class
diff --git a/airbyte-commons/bin/test/io/airbyte/commons/string/StringsTest.class b/airbyte-commons/bin/test/io/airbyte/commons/string/StringsTest.class
diff --git a/airbyte-commons/bin/test/io/airbyte/commons/text/NamesTest.class b/airbyte-commons/bin/test/io/airbyte/commons/text/NamesTest.class
diff --git a/airbyte-commons/bin/test/io/airbyte/commons/text/SqlsTest$E1.class b/airbyte-commons/bin/test/io/airbyte/commons/text/SqlsTest$E1.class
diff --git a/airbyte-commons/bin/test/io/airbyte/commons/text/SqlsTest.class b/airbyte-commons/bin/test/io/airbyte/commons/text/SqlsTest.class
diff --git a/airbyte-commons/bin/test/io/airbyte/commons/time/InstantsTest.class b/airbyte-commons/bin/test/io/airbyte/commons/time/InstantsTest.class
diff --git a/airbyte-commons/bin/test/io/airbyte/commons/util/AutoCloseableIteratorsTest.class b/airbyte-commons/bin/test/io/airbyte/commons/util/AutoCloseableIteratorsTest.class
diff --git a/airbyte-commons/bin/test/io/airbyte/commons/util/CompositeIteratorTest.class b/airbyte-commons/bin/test/io/airbyte/commons/util/CompositeIteratorTest.class
diff --git a/airbyte-commons/bin/test/io/airbyte/commons/util/DefaultAutoCloseableIteratorTest.class b/airbyte-commons/bin/test/io/airbyte/commons/util/DefaultAutoCloseableIteratorTest.class
diff --git a/airbyte-commons/bin/test/io/airbyte/commons/util/LazyAutoCloseableIteratorTest.class b/airbyte-commons/bin/test/io/airbyte/commons/util/LazyAutoCloseableIteratorTest.class
diff --git a/airbyte-commons/bin/test/io/airbyte/commons/util/MoreListsTest.class b/airbyte-commons/bin/test/io/airbyte/commons/util/MoreListsTest.class
diff --git a/airbyte-commons/bin/test/io/airbyte/commons/util/MorePropertiesTest.class b/airbyte-commons/bin/test/io/airbyte/commons/util/MorePropertiesTest.class
diff --git a/airbyte-commons/bin/test/io/airbyte/commons/version/AirbyteVersionTest.class b/airbyte-commons/bin/test/io/airbyte/commons/version/AirbyteVersionTest.class
diff --git a/airbyte-commons/bin/test/io/airbyte/commons/yaml/YamlsTest$ToClass.class b/airbyte-commons/bin/test/io/airbyte/commons/yaml/YamlsTest$ToClass.class
diff --git a/airbyte-commons/bin/test/io/airbyte/commons/yaml/YamlsTest.class b/airbyte-commons/bin/test/io/airbyte/commons/yaml/YamlsTest.class
diff --git a/airbyte-commons/bin/test/mockito-extensions/org.mockito.plugins.MockMaker b/airbyte-commons/bin/test/mockito-extensions/org.mockito.plugins.MockMaker
@@ -0,0 +1 @@
+mock-maker-inline
diff --git a/airbyte-commons/bin/test/resource_test b/airbyte-commons/bin/test/resource_test
@@ -0,0 +1 @@
+content1
diff --git a/airbyte-commons/bin/test/resource_test_a b/airbyte-commons/bin/test/resource_test_a
@@ -0,0 +1 @@
+content1
diff --git a/airbyte-commons/bin/test/subdir/resource_test_a b/airbyte-commons/bin/test/subdir/resource_test_a
@@ -0,0 +1 @@
+content2
diff --git a/airbyte-commons/bin/test/subdir/resource_test_sub b/airbyte-commons/bin/test/subdir/resource_test_sub
@@ -0,0 +1 @@
+content2
diff --git a/airbyte-commons/bin/test/subdir/resource_test_sub_2 b/airbyte-commons/bin/test/subdir/resource_test_sub_2
@@ -0,0 +1 @@
+content3
diff --git a/airbyte-config/models/bin/main/io/airbyte/config/AirbyteConfig.class b/airbyte-config/models/bin/main/io/airbyte/config/AirbyteConfig.class
diff --git a/airbyte-config/models/bin/main/io/airbyte/config/AirbyteConfigValidator.class b/airbyte-config/models/bin/main/io/airbyte/config/AirbyteConfigValidator.class
diff --git a/airbyte-config/models/bin/main/io/airbyte/config/ConfigSchema.class b/airbyte-config/models/bin/main/io/airbyte/config/ConfigSchema.class
diff --git a/airbyte-config/models/bin/main/io/airbyte/config/ConfigSchemaMigrationSupport.class b/airbyte-config/models/bin/main/io/airbyte/config/ConfigSchemaMigrationSupport.class
diff --git a/airbyte-config/models/bin/main/io/airbyte/config/ConfigWithMetadata.class b/airbyte-config/models/bin/main/io/airbyte/config/ConfigWithMetadata.class
diff --git a/airbyte-config/models/bin/main/io/airbyte/config/Configs$DeploymentMode.class b/airbyte-config/models/bin/main/io/airbyte/config/Configs$DeploymentMode.class
diff --git a/airbyte-config/models/bin/main/io/airbyte/config/Configs$SecretPersistenceType.class b/airbyte-config/models/bin/main/io/airbyte/config/Configs$SecretPersistenceType.class
diff --git a/airbyte-config/models/bin/main/io/airbyte/config/Configs$TrackingStrategy.class b/airbyte-config/models/bin/main/io/airbyte/config/Configs$TrackingStrategy.class
diff --git a/airbyte-config/models/bin/main/io/airbyte/config/Configs$WorkerEnvironment.class b/airbyte-config/models/bin/main/io/airbyte/config/Configs$WorkerEnvironment.class
diff --git a/airbyte-config/models/bin/main/io/airbyte/config/Configs.class b/airbyte-config/models/bin/main/io/airbyte/config/Configs.class
diff --git a/airbyte-config/models/bin/main/io/airbyte/config/EnvConfigs.class b/airbyte-config/models/bin/main/io/airbyte/config/EnvConfigs.class
diff --git a/airbyte-config/models/bin/main/io/airbyte/config/MaxWorkersConfig.class b/airbyte-config/models/bin/main/io/airbyte/config/MaxWorkersConfig.class
diff --git a/airbyte-config/models/bin/main/io/airbyte/config/TolerationPOJO.class b/airbyte-config/models/bin/main/io/airbyte/config/TolerationPOJO.class
diff --git a/airbyte-config/models/bin/main/io/airbyte/config/WorkerEnvConstants.class b/airbyte-config/models/bin/main/io/airbyte/config/WorkerEnvConstants.class
diff --git a/airbyte-config/models/bin/main/io/airbyte/config/WorkspaceRetentionConfig.class b/airbyte-config/models/bin/main/io/airbyte/config/WorkspaceRetentionConfig.class
diff --git a/airbyte-config/models/bin/main/io/airbyte/config/helpers/CloudLogs.class b/airbyte-config/models/bin/main/io/airbyte/config/helpers/CloudLogs.class
diff --git a/airbyte-config/models/bin/main/io/airbyte/config/helpers/GcsLogs.class b/airbyte-config/models/bin/main/io/airbyte/config/helpers/GcsLogs.class
diff --git a/airbyte-config/models/bin/main/io/airbyte/config/helpers/LogClientSingleton.class b/airbyte-config/models/bin/main/io/airbyte/config/helpers/LogClientSingleton.class
diff --git a/airbyte-config/models/bin/main/io/airbyte/config/helpers/LogConfigs.class b/airbyte-config/models/bin/main/io/airbyte/config/helpers/LogConfigs.class
diff --git a/airbyte-config/models/bin/main/io/airbyte/config/helpers/S3Logs.class b/airbyte-config/models/bin/main/io/airbyte/config/helpers/S3Logs.class
diff --git a/airbyte-config/models/bin/main/io/airbyte/config/helpers/ScheduleHelpers.class b/airbyte-config/models/bin/main/io/airbyte/config/helpers/ScheduleHelpers.class
diff --git a/airbyte-config/models/bin/main/io/airbyte/config/helpers/YamlListToStandardDefinitions.class b/airbyte-config/models/bin/main/io/airbyte/config/helpers/YamlListToStandardDefinitions.class
diff --git a/airbyte-config/models/bin/main/io/airbyte/config/storage/CloudStorageConfigs$GcsConfig.class b/airbyte-config/models/bin/main/io/airbyte/config/storage/CloudStorageConfigs$GcsConfig.class
diff --git a/...te-config/models/bin/main/io/airbyte/config/storage/CloudStorageConfigs$MinioConfig.class b/...te-config/models/bin/main/io/airbyte/config/storage/CloudStorageConfigs$MinioConfig.class
diff --git a/...els/bin/main/io/airbyte/config/storage/CloudStorageConfigs$S3ApiWorkerStorageConfig.class b/...els/bin/main/io/airbyte/config/storage/CloudStorageConfigs$S3ApiWorkerStorageConfig.class
diff --git a/airbyte-config/models/bin/main/io/airbyte/config/storage/CloudStorageConfigs$S3Config.class b/airbyte-config/models/bin/main/io/airbyte/config/storage/CloudStorageConfigs$S3Config.class
diff --git a/...fig/models/bin/main/io/airbyte/config/storage/CloudStorageConfigs$WorkerStorageType.class b/...fig/models/bin/main/io/airbyte/config/storage/CloudStorageConfigs$WorkerStorageType.class
diff --git a/airbyte-config/models/bin/main/io/airbyte/config/storage/CloudStorageConfigs.class b/airbyte-config/models/bin/main/io/airbyte/config/storage/CloudStorageConfigs.class
diff --git a/airbyte-config/models/bin/main/io/airbyte/config/storage/DefaultGcsClientFactory.class b/airbyte-config/models/bin/main/io/airbyte/config/storage/DefaultGcsClientFactory.class
diff --git a/airbyte-config/models/bin/main/io/airbyte/config/storage/DefaultS3ClientFactory.class b/airbyte-config/models/bin/main/io/airbyte/config/storage/DefaultS3ClientFactory.class
diff --git a/airbyte-config/models/bin/main/io/airbyte/config/storage/MinioS3ClientFactory.class b/airbyte-config/models/bin/main/io/airbyte/config/storage/MinioS3ClientFactory.class
diff --git a/airbyte-config/models/bin/main/types/ActorCatalog.yaml b/airbyte-config/models/bin/main/types/ActorCatalog.yaml
@@ -0,0 +1,20 @@
+---
+"$schema": http://json-schema.org/draft-07/schema#
+"$id": https://github.com/airbytehq/airbyte/blob/master/airbyte-config/models/src/main/resources/types/AttemptFailureSummary.yaml
+title: ActorCatalog
+description: Catalog of an actor.
+type: object
+additionalProperties: false
+required:
+  - id
+  - catalog
+  - catalogHash
+properties:
+  id:
+    type: string
+    format: uuid
+  catalog:
+    type: object
+    existingJavaType: com.fasterxml.jackson.databind.JsonNode
+  catalogHash:
+    type: string
diff --git a/airbyte-config/models/bin/main/types/ActorCatalogFetchEvent.yaml b/airbyte-config/models/bin/main/types/ActorCatalogFetchEvent.yaml
@@ -0,0 +1,27 @@
+---
+"$schema": http://json-schema.org/draft-07/schema#
+"$id": https://github.com/airbytehq/airbyte/blob/master/airbyte-config/models/src/main/resources/types/AttemptFailureSummary.yaml
+title: ActorCatalogFetchEvent
+description: Link actor to their actual catalog
+type: object
+additionalProperties: false
+required:
+  - id
+  - actorCatalogId
+  - actorId
+  - configHash
+  - connectorVersion
+properties:
+  id:
+    type: string
+    format: uuid
+  actorId:
+    type: string
+    format: uuid
+  actorCatalogId:
+    type: string
+    format: uuid
+  configHash:
+    type: string
+  connectorVersion:
+    type: string
diff --git a/airbyte-config/models/bin/main/types/ActorDefinitionResourceRequirements.yaml b/airbyte-config/models/bin/main/types/ActorDefinitionResourceRequirements.yaml
@@ -0,0 +1,30 @@
+---
+"$schema": http://json-schema.org/draft-07/schema#
+"$id": https://github.com/airbytehq/airbyte/blob/master/airbyte-config/models/src/main/resources/types/ActorDefinitionResourceRequirements.yaml
+title: ActorDefinitionResourceRequirements
+description: actor definition specific resource requirements
+type: object
+# set to false because we need the validations on seeds to be strict. otherwise, we will just add whatever is in the seed file into the db.
+additionalProperties: false
+properties:
+  default:
+    description: if set, these are the requirements that should be set for ALL jobs run for this actor definition.
+    "$ref": ResourceRequirements.yaml
+  jobSpecific:
+    type: array
+    items:
+      "$ref": "#/definitions/JobTypeResourceLimit"
+definitions:
+  JobTypeResourceLimit:
+    description: sets resource requirements for a specific job type for an actor definition. these values override the default, if both are set.
+    type: object
+    # set to false because we need the validations on seeds to be strict. otherwise, we will just add whatever is in the seed file into the db.
+    additionalProperties: false
+    required:
+      - jobType
+      - resourceRequirements
+    properties:
+      jobType:
+        "$ref": JobType.yaml
+      resourceRequirements:
+        "$ref": ResourceRequirements.yaml
diff --git a/airbyte-config/models/bin/main/types/ActorType.yaml b/airbyte-config/models/bin/main/types/ActorType.yaml
@@ -0,0 +1,9 @@
+---
+"$schema": http://json-schema.org/draft-07/schema#
+"$id": https://github.com/airbytehq/airbyte/blob/master/airbyte-config/models/src/main/resources/types/ActorType.yaml
+title: ActorType
+description: enum that describes different types of actors
+type: string
+enum:
+  - source
+  - destination
diff --git a/airbyte-config/models/bin/main/types/AttemptFailureSummary.yaml b/airbyte-config/models/bin/main/types/AttemptFailureSummary.yaml
@@ -0,0 +1,18 @@
+---
+"$schema": http://json-schema.org/draft-07/schema#
+"$id": https://github.com/airbytehq/airbyte/blob/master/airbyte-config/models/src/main/resources/types/AttemptFailureSummary.yaml
+title: AttemptFailureSummary
+description: Attempt-level summarization of failures that occurred during a sync workflow.
+type: object
+additionalProperties: false
+required:
+  - failures
+properties:
+  failures:
+    description: Ordered list of failures that occurred during the attempt.
+    type: array
+    items:
+      "$ref": FailureReason.yaml
+  partialSuccess:
+    description: True if the number of committed records for this attempt was greater than 0. False if 0 records were committed. Blank if number of committed records is unknown.
+    type: boolean
diff --git a/airbyte-config/models/bin/main/types/DataType.yaml b/airbyte-config/models/bin/main/types/DataType.yaml
@@ -0,0 +1,12 @@
+---
+"$schema": http://json-schema.org/draft-07/schema#
+"$id": https://github.com/airbytehq/airbyte/blob/master/airbyte-config/models/src/main/resources/types/DataType.yaml
+title: DataType
+description: standard data types.
+type: string
+enum:
+  - string
+  - number
+  - boolean
+  - object
+  - array
diff --git a/airbyte-config/models/bin/main/types/DestinationConnection.yaml b/airbyte-config/models/bin/main/types/DestinationConnection.yaml
@@ -0,0 +1,35 @@
+---
+"$schema": http://json-schema.org/draft-07/schema#
+"$id": https://github.com/airbytehq/airbyte/blob/master/airbyte-config/models/src/main/resources/types/DestinationConnection.yaml
+title: DestinationConnection
+description: information required for connection to a destination.
+type: object
+required:
+  - name
+  - destinationDefinitionId
+  - workspaceId
+  - destinationId
+  - configuration
+  - tombstone
+additionalProperties: false
+properties:
+  name:
+    type: string
+  destinationDefinitionId:
+    type: string
+    format: uuid
+  workspaceId:
+    type: string
+    format: uuid
+  destinationId:
+    type: string
+    format: uuid
+  configuration:
+    description: Integration specific blob. Must be a valid JSON string.
+    type: object
+    existingJavaType: com.fasterxml.jackson.databind.JsonNode
+  tombstone:
+    description:
+      if not set or false, the configuration is active. if true, then this
+      configuration is permanently off.
+    type: boolean