Caio César P. Ricciuti
05/16/2022, 6:36 AM0.37.0-alpha
since this update I'm getting an error with my Google Search Console connectors... Does anyone experiencing this problem as well? Any fix/advices?
Error :
Exception('Error while refreshing access token: 400 Client Error: Bad Request for url: <https://oauth2.googleapis.com/token>')
Logs are emtpy!
Eric Gill
05/16/2022, 7:28 AMSUB_BUILD=PLATFORM ./gradlew build
The error I am getting is:
Deprecated Gradle features were used in this build, making it incompatible with Gradle 8.0.
has anyone had any similar issues?
Thanks in advance, EricHarvey Marshall
05/16/2022, 12:33 PMCould not connect with provided configuration. Error: com.google.gson.stream.MalformedJsonException: Use JsonReader.setLenient(true) to accept malformed JSON at line 1 column 1 path $
I got it after testing the bigQuery source is it to do with my service account?Maëlise Castel
05/16/2022, 1:12 PMBhaumik Shah
05/16/2022, 2:29 PMMohit Reddy
05/16/2022, 10:51 PM2022-05-16 22:37:08 INFO i.a.w.t.TemporalAttemptExecution(get):108 - Docker volume job log path: /tmp/workspace/52acf6ef-3402-42c6-94c2-d8a05ff1e092/0/logs.log
2022-05-16 22:37:08 INFO i.a.w.t.TemporalAttemptExecution(get):113 - Executing worker wrapper. Airbyte version: dev
2022-05-16 22:37:08 INFO i.a.c.i.LineGobbler(voidCall):82 - Checking if airbyte/destination-kafka:0.1.8 exists...
2022-05-16 22:37:08 INFO i.a.c.i.LineGobbler(voidCall):82 - airbyte/destination-kafka:0.1.8 not found locally. Attempting to pull the image...
2022-05-16 22:37:11 INFO i.a.c.i.LineGobbler(voidCall):82 - Image does not exist.
2022-05-16 22:37:11 INFO i.a.w.t.TemporalAttemptExecution(lambda$getWorkerThread$2):161 - Completing future exceptionally...
io.airbyte.workers.WorkerException: Error while getting checking connection.
....
I had to bump the version
I had to bump the version of destination-kafka from 0.1.7 -> 0.1.8 given the change. I thought, that just changing the *`_definitions.yaml` file and running ./gradlew :airbyte-config:init:processResources
would update the _specs.yaml
file - this failed, so I had to manually update the _specs.yaml file as well.
Please do let me know if I am missing on any information. Any leads here highly appreciated 😄Maëlise Castel
05/17/2022, 1:26 PMrepositories {
mavenCentral()
maven {
url '<https://airbyte.mycloudrepo.io/public/repositories/airbyte-public-jars/>'
}
}
Alec Dou
05/17/2022, 2:25 PMAyush
05/18/2022, 7:05 AMYash Makwana
05/18/2022, 2:24 PMJared Zhao (Polyture)
05/18/2022, 6:22 PMAndras N.
05/18/2022, 8:06 PMRodrigo Capuzzi
05/18/2022, 8:33 PMCraig Condie
05/18/2022, 11:17 PM이진규
05/19/2022, 12:45 AMErez Zohar
05/19/2022, 9:42 AMÍñigo
05/19/2022, 10:41 AMPetro Tiurin
05/19/2022, 11:12 AMSlackbot
05/19/2022, 1:31 PMMikhail
05/19/2022, 1:47 PMSergi van den Berg
05/19/2022, 1:58 PMLavanya Siliveri
05/20/2022, 4:27 AMSlackbot
05/20/2022, 3:53 PMAnton Podviaznikov
05/20/2022, 5:11 PMUser-Defined Cursor
I don't see input to change that in the UI. And I don't see anything like the screenshot in the docs https://docs.airbyte.com/understanding-airbyte/connections/incremental-append#user-defined-cursorDimitris Bachtsevanis
05/20/2022, 8:57 PMDimitris Bachtsevanis
05/20/2022, 8:57 PMAnton Podviaznikov
05/21/2022, 8:47 AM49.25 GB | 32,773,497 emitted records | 32,773,497 committed records | 2h 32m 18s | Sync
So the speed is around 5MB/s.
How would I make it faster?
I increased
SUBMITTER_NUM_THREADS=40
MAX_SYNC_WORKERS=20
as was described here https://discuss.airbyte.io/t/scaling-airbyte-on-k8s-increased-job-parallelism/826
But I wasn't sure how to increase number of workers.
Also what else can I tune to make jobs go faster?CM
05/22/2022, 2:05 PMIs this your first time deploying Airbyte?: Yes
OS Version / Instance: Windows
Memory / Disk: 16 gb / 1 tb
Deployment: Docker
Airbyte Version: Latest
Source name/version: Facebook Marketing 0.2.48
Destination name/version: MS SQL Server 0.1.17
Step: The issue happens at the end of the sync
Description: Everything seems to go well, then I get this error and sync fails to complete:
(‘42000’, ‘[42000] [Microsoft][ODBC Driver 17 for SQL Server][SQL Server]Error converting data type nvarchar to float. (8114) (SQLMoreResults)
ASulaiman
05/22/2022, 3:09 PM"Cannot end publish with com.van.logging.gcp.CloudStoragePublishHelper@13049a9a due to error: Cannot end publishing: Invalid bucket name: '${env:GCS_LOG_BUCKET}'"
i'm not using GCS bucket and config pointing to GCS is off. this happens only on "pods airbyte-worker"
apiVersion: apps/v1
kind: Deployment
metadata:
name: airbyte-worker
spec:
replicas: 1
selector:
matchLabels:
airbyte: worker
template:
metadata:
labels:
airbyte: worker
spec:
serviceAccountName: airbyte-admin
automountServiceAccountToken: true
containers:
- name: airbyte-worker-container
image: airbyte/worker
env:
- name: AIRBYTE_VERSION
valueFrom:
configMapKeyRef:
name: airbyte-env
key: AIRBYTE_VERSION
# - name: CONFIG_ROOT
# valueFrom:
# configMapKeyRef:
# name: airbyte-env
# key: CONFIG_ROOT
- name: DATABASE_HOST
valueFrom:
configMapKeyRef:
name: airbyte-env
key: DATABASE_HOST
- name: DATABASE_PORT
valueFrom:
configMapKeyRef:
name: airbyte-env
key: DATABASE_PORT
- name: DATABASE_PASSWORD
valueFrom:
secretKeyRef:
name: airbyte-secrets
key: DATABASE_PASSWORD
- name: DATABASE_URL
valueFrom:
configMapKeyRef:
name: airbyte-env
key: DATABASE_URL
- name: DATABASE_USER
valueFrom:
secretKeyRef:
name: airbyte-secrets
key: DATABASE_USER
- name: TRACKING_STRATEGY
valueFrom:
configMapKeyRef:
name: airbyte-env
key: TRACKING_STRATEGY
- name: WORKSPACE_DOCKER_MOUNT
value: workspace
- name: WORKSPACE_ROOT
valueFrom:
configMapKeyRef:
name: airbyte-env
key: WORKSPACE_ROOT
- name: WORKER_ENVIRONMENT
valueFrom:
configMapKeyRef:
name: airbyte-env
key: WORKER_ENVIRONMENT
- name: LOCAL_ROOT
valueFrom:
configMapKeyRef:
name: airbyte-env
key: LOCAL_ROOT
- name: WEBAPP_URL
valueFrom:
configMapKeyRef:
name: airbyte-env
key: WEBAPP_URL
- name: TEMPORAL_HOST
valueFrom:
configMapKeyRef:
name: airbyte-env
key: TEMPORAL_HOST
- name: TEMPORAL_WORKER_PORTS
valueFrom:
configMapKeyRef:
name: airbyte-env
key: TEMPORAL_WORKER_PORTS
- name: LOG_LEVEL
valueFrom:
configMapKeyRef:
name: airbyte-env
key: LOG_LEVEL
- name: JOB_KUBE_NAMESPACE
valueFrom:
fieldRef:
fieldPath: metadata.namespace
- name: SUBMITTER_NUM_THREADS
valueFrom:
configMapKeyRef:
name: airbyte-env
key: SUBMITTER_NUM_THREADS
- name: JOB_MAIN_CONTAINER_CPU_REQUEST
valueFrom:
configMapKeyRef:
name: airbyte-env
key: JOB_MAIN_CONTAINER_CPU_REQUEST
- name: JOB_MAIN_CONTAINER_CPU_LIMIT
valueFrom:
configMapKeyRef:
name: airbyte-env
key: JOB_MAIN_CONTAINER_CPU_LIMIT
- name: JOB_MAIN_CONTAINER_MEMORY_REQUEST
valueFrom:
configMapKeyRef:
name: airbyte-env
key: JOB_MAIN_CONTAINER_MEMORY_REQUEST
- name: JOB_MAIN_CONTAINER_MEMORY_LIMIT
valueFrom:
configMapKeyRef:
name: airbyte-env
key: JOB_MAIN_CONTAINER_MEMORY_LIMIT
- name: S3_LOG_BUCKET
valueFrom:
configMapKeyRef:
name: airbyte-env
key: S3_LOG_BUCKET
- name: S3_LOG_BUCKET_REGION
valueFrom:
configMapKeyRef:
name: airbyte-env
key: S3_LOG_BUCKET_REGION
- name: AWS_ACCESS_KEY_ID
valueFrom:
secretKeyRef:
name: airbyte-secrets
key: AWS_ACCESS_KEY_ID
- name: AWS_SECRET_ACCESS_KEY
valueFrom:
secretKeyRef:
name: airbyte-secrets
key: AWS_SECRET_ACCESS_KEY
- name: S3_MINIO_ENDPOINT
valueFrom:
configMapKeyRef:
name: airbyte-env
key: S3_MINIO_ENDPOINT
- name: S3_PATH_STYLE_ACCESS
valueFrom:
configMapKeyRef:
name: airbyte-env
key: S3_PATH_STYLE_ACCESS
# - name: GOOGLE_APPLICATION_CREDENTIALS
# valueFrom:
# secretKeyRef:
# name: airbyte-secrets
# key: GOOGLE_APPLICATION_CREDENTIALS
# - name: GCS_LOG_BUCKET
# valueFrom:
# configMapKeyRef:
# name: airbyte-env
# key: GCS_LOG_BUCKET
- name: INTERNAL_API_HOST
valueFrom:
configMapKeyRef:
name: airbyte-env
key: INTERNAL_API_HOST
- name: JOB_KUBE_TOLERATIONS
valueFrom:
configMapKeyRef:
name: airbyte-env
key: JOB_KUBE_TOLERATIONS
- name: JOB_KUBE_ANNOTATIONS
valueFrom:
configMapKeyRef:
name: airbyte-env
key: JOB_KUBE_ANNOTATIONS
- name: JOB_KUBE_NODE_SELECTORS
valueFrom:
configMapKeyRef:
name: airbyte-env
key: JOB_KUBE_NODE_SELECTORS
- name: JOB_KUBE_MAIN_CONTAINER_IMAGE_PULL_POLICY
valueFrom:
configMapKeyRef:
name: airbyte-env
key: JOB_KUBE_MAIN_CONTAINER_IMAGE_PULL_POLICY
# todo: add other state storage keys
- name: STATE_STORAGE_MINIO_BUCKET_NAME
valueFrom:
configMapKeyRef:
name: airbyte-env
key: STATE_STORAGE_MINIO_BUCKET_NAME
- name: STATE_STORAGE_MINIO_ENDPOINT
valueFrom:
configMapKeyRef:
name: airbyte-env
key: STATE_STORAGE_MINIO_ENDPOINT
# - name: STATE_STORAGE_MINIO_ACCESS_KEY
# valueFrom:
# secretKeyRef:
# name: airbyte-secrets
# key: STATE_STORAGE_MINIO_ACCESS_KEY
# - name: STATE_STORAGE_MINIO_SECRET_ACCESS_KEY
# valueFrom:
# secretKeyRef:
# name: airbyte-secrets
# key: STATE_STORAGE_MINIO_SECRET_ACCESS_KEY
- name: CONTAINER_ORCHESTRATOR_ENABLED
valueFrom:
configMapKeyRef:
name: airbyte-env
key: CONTAINER_ORCHESTRATOR_ENABLED
ports:
- containerPort: 9000 # for heartbeat server
- containerPort: 9001 # start temporal worker port pool
- containerPort: 9002
- containerPort: 9003
- containerPort: 9004
- containerPort: 9005
- containerPort: 9006
- containerPort: 9007
- containerPort: 9008
- containerPort: 9009
- containerPort: 9010
- containerPort: 9011
- containerPort: 9012
- containerPort: 9013
- containerPort: 9014
- containerPort: 9015
- containerPort: 9016
- containerPort: 9017
- containerPort: 9018
- containerPort: 9019
- containerPort: 9020
- containerPort: 9021
- containerPort: 9022
- containerPort: 9023
- containerPort: 9024
- containerPort: 9025
- containerPort: 9026
- containerPort: 9027
- containerPort: 9028
- containerPort: 9029
- containerPort: 9030 # end temporal worker port pool
# volumeMounts:
# - name: gcs-log-creds-volume
# mountPath: /secrets/gcs-log-creds
# readOnly: true
# volumes:
# - name: gcs-log-creds-volume
# secret:
# secretName: gcs-log-creds
Shubhransh Bhargava
05/23/2022, 5:03 AMdestination
should be fixed/ or we can have a default destination. Is the use case possible, or they have to add destination everytime?