Comments (13)
evantahler
commented on June 30, 2024
3
This issue has been solved by #34613 - Update to destination-redshift v2.5.0!
from airbyte.
marcosmarxm
commented on June 30, 2024
2
Hello all 👋 the team is investigating the issue with Destination Redshift. Thanks for all inputs here, any news I'll update the issue here.
from airbyte.
gisripa
commented on June 30, 2024
2
Please try with the latest connector version 2.5.0
from airbyte.
JamesWhyley
commented on June 30, 2024
1
Have tried all three additional drivers using the standard/insert method for the destination to no effect. Same issue as via S3 staging.
from airbyte.
marcosmarxm
commented on June 30, 2024
Can you share the complete sync log? The one you shared doesn't inform anything about the issue.
from airbyte.
fkody1
commented on June 30, 2024
Hi, I am also having this same issue. Ive attached logs from a recent run attempt where the timeout error given by redshift was eventually reached while Airbyte was performing its BaseDestinationV1V2Migrator checks. As mentioned, this patch was added on May 1st/ 2nd (https://docs.aws.amazon.com/redshift/latest/mgmt/cluster-versions.html#cluster-version-181). This sync has around 60+ tables involved, but I do have another Redshift destination sync which has only 1 table, and it still works fine. Potentially it has to do with slow query performance while performing concurrent reading of the PG_* tables or SVV_TABLE_INFO table for many airbyte streams?
airbyte_redshift_jobfailure.txt
from airbyte.
JamesWhyley
commented on June 30, 2024
Just chiming in to say that we've also seen this behaviour since the Redshift patch rollout with the following version and patch level.
- Workgroup version 1.0.67308
- Patch version 181
- Redshift destination connector 2.4.3
Our logs show effectively the same patterns as previously described. We have however seen intermittently successful syncs for small data sets and occasionally some of the larger ones. Typically these take several attempts to succeeed however.
We've tried a few approaches with some test data. Each tried separately and in various combinations.
- Removed staging data.
- Reset stream.
- Sync a single table.
- New source.
- New destination.
- Destination connectors 2.4.2, 2.4.1, 2.4.0
We intermittently see a success with a completely fresh set of data, tables, connection, etc, but it is very intermiitent and typically takes exponentially more time than previous benchmarks. Curiously the destination test works every time.
Addendum: Logs imply redshift-jdbc42-2.1.0.23 is currently in use in our environment while redshift-jdbc42-2.1.0.24, redshift-jdbc42-2.1.0.25, and redshift-jdbc42-2.1.0.26 are available so we're going to have a tinker and see what we can see.
from airbyte.
bryanasdev000
commented on June 30, 2024
Same here with 1.0.67305.
Not sure if it helps, but I have attached jstack output and strace snippet of a docker container running the reset process.
bash-5.2# ps aux
USER PID %CPU %MEM VSZ RSS TTY STAT START TIME COMMAND
root 1 0.1 0.0 944 4 ? Ss 18:04 0:00 /sbin/docker-init -- /airbyte/base.sh write --config destination_config.json --catalog destination_catalog.json
root 7 0.0 0.0 4620 3096 ? S 18:04 0:00 bash /airbyte/base.sh write --config destination_config.json --catalog destination_catalog.json
root 8 0.0 0.0 4620 3288 ? S 18:04 0:00 bash /airbyte/javabase.sh --write --config destination_config.json --catalog destination_catalog.json
root 9 3.9 1.1 16062196 192284 ? Sl 18:04 0:09 /usr/lib/jvm/java-21-amazon-corretto/bin/java -XX:+ExitOnOutOfMemoryError -XX:MaxRAMPercentage=75.0 -XX:NativeMemoryTracking=detail -XX:+UnlockDiagnosticVMOptions -XX:GCLockerRetryAllocationCount=100 -Dlog4j.encoder.byt
root 58 0.2 0.0 4884 3864 pts/0 Ss 18:04 0:00 bash
root 82 0.0 0.0 5100 2784 pts/0 R+ 18:07 0:00 ps aux
bash-5.2# jstack 9
2024-05-06 18:07:56
Full thread dump OpenJDK 64-Bit Server VM (21.0.2+14-LTS mixed mode, sharing):
Threads class SMR info:
_java_thread_list=0x00007f4c2c002640, length=20, elements={
0x00007f4ccc0271f0, 0x00007f4ccc1026c0, 0x00007f4ccc104ac0, 0x00007f4ccc106ce0,
0x00007f4ccc109090, 0x00007f4ccc10b0e0, 0x00007f4ccc10dd50, 0x00007f4ccc10ff30,
0x00007f4ccc125d00, 0x00007f4ccc12d470, 0x00007f4ccd238420, 0x00007f4ccd2eb6b0,
0x00007f4ccd2fc070, 0x00007f4ccd2fd580, 0x00007f4bf815b4c0, 0x00007f4ccda9f070,
0x00007f4ccda9fd70, 0x00007f4ccdaa0f60, 0x00007f4ccdaa2320, 0x00007f4c2c001180
}
"main" #1 [25] prio=5 os_prio=0 cpu=2624.70ms elapsed=230.56s tid=0x00007f4ccc0271f0 nid=25 waiting on condition [0x00007f4cd0c2f000]
java.lang.Thread.State: WAITING (parking)
at jdk.internal.misc.Unsafe.park([email protected]/Native Method)
- parking to wait for <0x00000007ff926f60> (a java.util.concurrent.CompletableFuture$Signaller)
at java.util.concurrent.locks.LockSupport.park([email protected]/LockSupport.java:221)
at java.util.concurrent.CompletableFuture$Signaller.block([email protected]/CompletableFuture.java:1864)
at java.util.concurrent.ForkJoinPool.unmanagedBlock([email protected]/ForkJoinPool.java:3780)
at java.util.concurrent.ForkJoinPool.managedBlock([email protected]/ForkJoinPool.java:3725)
at java.util.concurrent.CompletableFuture.waitingGet([email protected]/CompletableFuture.java:1898)
at java.util.concurrent.CompletableFuture.join([email protected]/CompletableFuture.java:2117)
at io.airbyte.integrations.base.destination.typing_deduping.TyperDeduperUtil$Companion.executeWeirdMigrations(TyperDeduperUtil.kt:149)
at io.airbyte.integrations.base.destination.typing_deduping.DefaultTyperDeduper.prepareSchemasAndRunMigrations(DefaultTyperDeduper.kt:120)
at io.airbyte.cdk.integrations.destination.jdbc.JdbcBufferedConsumerFactory.onStartFunction$lambda$1(JdbcBufferedConsumerFactory.kt:198)
at io.airbyte.cdk.integrations.destination.jdbc.JdbcBufferedConsumerFactory$$Lambda/0x00007f4c48285290.voidCall(Unknown Source)
at io.airbyte.commons.concurrency.VoidCallable.call(VoidCallable.kt:12)
at io.airbyte.cdk.integrations.destination.async.AsyncStreamConsumer.start(AsyncStreamConsumer.kt:181)
at io.airbyte.cdk.integrations.base.SerializedAirbyteMessageConsumer$Companion$appendOnClose$1.start(SerializedAirbyteMessageConsumer.kt:60)
at io.airbyte.cdk.integrations.base.IntegrationRunner$Companion.consumeWriteStream$io_airbyte_airbyte_cdk_java_airbyte_cdk_airbyte_cdk_core(IntegrationRunner.kt:382)
at io.airbyte.cdk.integrations.base.IntegrationRunner$Companion.consumeWriteStream$io_airbyte_airbyte_cdk_java_airbyte_cdk_airbyte_cdk_core$default(IntegrationRunner.kt:377)
at io.airbyte.cdk.integrations.base.IntegrationRunner.runInternal(IntegrationRunner.kt:209)
at io.airbyte.cdk.integrations.base.IntegrationRunner.run(IntegrationRunner.kt:115)
at io.airbyte.integrations.destination.redshift.RedshiftDestination.main(RedshiftDestination.java:80)
"Reference Handler" #9 [33] daemon prio=10 os_prio=0 cpu=3.24ms elapsed=230.54s tid=0x00007f4ccc1026c0 nid=33 waiting on condition [0x00007f4c97977000]
java.lang.Thread.State: RUNNABLE
at java.lang.ref.Reference.waitForReferencePendingList([email protected]/Native Method)
at java.lang.ref.Reference.processPendingReferences([email protected]/Reference.java:246)
at java.lang.ref.Reference$ReferenceHandler.run([email protected]/Reference.java:208)
"Finalizer" #10 [34] daemon prio=8 os_prio=0 cpu=0.51ms elapsed=230.53s tid=0x00007f4ccc104ac0 nid=34 in Object.wait() [0x00007f4c97877000]
java.lang.Thread.State: WAITING (on object monitor)
at java.lang.Object.wait0([email protected]/Native Method)
- waiting on <0x00000005190000f0> (a java.lang.ref.NativeReferenceQueue$Lock)
at java.lang.Object.wait([email protected]/Object.java:366)
at java.lang.Object.wait([email protected]/Object.java:339)
at java.lang.ref.NativeReferenceQueue.await([email protected]/NativeReferenceQueue.java:48)
at java.lang.ref.ReferenceQueue.remove0([email protected]/ReferenceQueue.java:158)
at java.lang.ref.NativeReferenceQueue.remove([email protected]/NativeReferenceQueue.java:89)
- locked <0x00000005190000f0> (a java.lang.ref.NativeReferenceQueue$Lock)
at java.lang.ref.Finalizer$FinalizerThread.run([email protected]/Finalizer.java:173)
"Signal Dispatcher" #11 [35] daemon prio=9 os_prio=0 cpu=0.61ms elapsed=230.53s tid=0x00007f4ccc106ce0 nid=35 waiting on condition [0x0000000000000000]
java.lang.Thread.State: RUNNABLE
"Service Thread" #12 [36] daemon prio=9 os_prio=0 cpu=1.44ms elapsed=230.53s tid=0x00007f4ccc109090 nid=36 runnable [0x0000000000000000]
java.lang.Thread.State: RUNNABLE
"Monitor Deflation Thread" #13 [37] daemon prio=9 os_prio=0 cpu=37.40ms elapsed=230.53s tid=0x00007f4ccc10b0e0 nid=37 runnable [0x0000000000000000]
java.lang.Thread.State: RUNNABLE
"C2 CompilerThread0" #14 [38] daemon prio=9 os_prio=0 cpu=1977.81ms elapsed=230.53s tid=0x00007f4ccc10dd50 nid=38 waiting on condition [0x0000000000000000]
java.lang.Thread.State: RUNNABLE
No compile task
"C1 CompilerThread0" #16 [39] daemon prio=9 os_prio=0 cpu=1333.34ms elapsed=230.53s tid=0x00007f4ccc10ff30 nid=39 waiting on condition [0x0000000000000000]
java.lang.Thread.State: RUNNABLE
No compile task
"Notification Thread" #17 [40] daemon prio=9 os_prio=0 cpu=0.21ms elapsed=230.51s tid=0x00007f4ccc125d00 nid=40 runnable [0x0000000000000000]
java.lang.Thread.State: RUNNABLE
"Common-Cleaner" #18 [41] daemon prio=8 os_prio=0 cpu=6.66ms elapsed=230.50s tid=0x00007f4ccc12d470 nid=41 waiting on condition [0x00007f4c970a6000]
java.lang.Thread.State: TIMED_WAITING (parking)
at jdk.internal.misc.Unsafe.park([email protected]/Native Method)
- parking to wait for <0x0000000519000218> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject)
at java.util.concurrent.locks.LockSupport.parkNanos([email protected]/LockSupport.java:269)
at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await([email protected]/AbstractQueuedSynchronizer.java:1847)
at java.lang.ref.ReferenceQueue.await([email protected]/ReferenceQueue.java:71)
at java.lang.ref.ReferenceQueue.remove0([email protected]/ReferenceQueue.java:143)
at java.lang.ref.ReferenceQueue.remove([email protected]/ReferenceQueue.java:218)
at jdk.internal.ref.CleanerImpl.run([email protected]/CleanerImpl.java:140)
at java.lang.Thread.runWith([email protected]/Thread.java:1596)
at java.lang.Thread.run([email protected]/Thread.java:1583)
at jdk.internal.misc.InnocuousThread.run([email protected]/InnocuousThread.java:186)
"HikariPool-1 housekeeper" #23 [46] daemon prio=5 os_prio=0 cpu=2.88ms elapsed=228.31s tid=0x00007f4ccd238420 nid=46 waiting on condition [0x00007f4c96b7f000]
java.lang.Thread.State: TIMED_WAITING (parking)
at jdk.internal.misc.Unsafe.park([email protected]/Native Method)
- parking to wait for <0x000000052805c568> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject)
at java.util.concurrent.locks.LockSupport.parkNanos([email protected]/LockSupport.java:269)
at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos([email protected]/AbstractQueuedSynchronizer.java:1758)
at java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take([email protected]/ScheduledThreadPoolExecutor.java:1182)
at java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take([email protected]/ScheduledThreadPoolExecutor.java:899)
at java.util.concurrent.ThreadPoolExecutor.getTask([email protected]/ThreadPoolExecutor.java:1070)
at java.util.concurrent.ThreadPoolExecutor.runWorker([email protected]/ThreadPoolExecutor.java:1130)
at java.util.concurrent.ThreadPoolExecutor$Worker.run([email protected]/ThreadPoolExecutor.java:642)
at java.lang.Thread.runWith([email protected]/Thread.java:1596)
at java.lang.Thread.run([email protected]/Thread.java:1583)
"pool-3-thread-1" #24 [47] prio=5 os_prio=0 cpu=13.04ms elapsed=228.22s tid=0x00007f4ccd2eb6b0 nid=47 waiting on condition [0x00007f4c96a7f000]
java.lang.Thread.State: TIMED_WAITING (parking)
at jdk.internal.misc.Unsafe.park([email protected]/Native Method)
- parking to wait for <0x000000052805c850> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject)
at java.util.concurrent.locks.LockSupport.parkNanos([email protected]/LockSupport.java:269)
at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos([email protected]/AbstractQueuedSynchronizer.java:1758)
at java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take([email protected]/ScheduledThreadPoolExecutor.java:1182)
at java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take([email protected]/ScheduledThreadPoolExecutor.java:899)
at java.util.concurrent.ThreadPoolExecutor.getTask([email protected]/ThreadPoolExecutor.java:1070)
at java.util.concurrent.ThreadPoolExecutor.runWorker([email protected]/ThreadPoolExecutor.java:1130)
at java.util.concurrent.ThreadPoolExecutor$Worker.run([email protected]/ThreadPoolExecutor.java:642)
at java.lang.Thread.runWith([email protected]/Thread.java:1596)
at java.lang.Thread.run([email protected]/Thread.java:1583)
"pool-5-thread-1" #25 [48] prio=5 os_prio=0 cpu=85.14ms elapsed=228.21s tid=0x00007f4ccd2fc070 nid=48 waiting on condition [0x00007f4c9697f000]
java.lang.Thread.State: TIMED_WAITING (parking)
at jdk.internal.misc.Unsafe.park([email protected]/Native Method)
- parking to wait for <0x000000052805c9b0> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject)
at java.util.concurrent.locks.LockSupport.parkNanos([email protected]/LockSupport.java:269)
at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos([email protected]/AbstractQueuedSynchronizer.java:1758)
at java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take([email protected]/ScheduledThreadPoolExecutor.java:1182)
at java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take([email protected]/ScheduledThreadPoolExecutor.java:899)
at java.util.concurrent.ThreadPoolExecutor.getTask([email protected]/ThreadPoolExecutor.java:1070)
at java.util.concurrent.ThreadPoolExecutor.runWorker([email protected]/ThreadPoolExecutor.java:1130)
at java.util.concurrent.ThreadPoolExecutor$Worker.run([email protected]/ThreadPoolExecutor.java:642)
at java.lang.Thread.runWith([email protected]/Thread.java:1596)
at java.lang.Thread.run([email protected]/Thread.java:1583)
"pool-6-thread-1" #26 [49] prio=5 os_prio=0 cpu=7.28ms elapsed=228.21s tid=0x00007f4ccd2fd580 nid=49 waiting on condition [0x00007f4c9687f000]
java.lang.Thread.State: TIMED_WAITING (parking)
at jdk.internal.misc.Unsafe.park([email protected]/Native Method)
- parking to wait for <0x000000052805cb10> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject)
at java.util.concurrent.locks.LockSupport.parkNanos([email protected]/LockSupport.java:269)
at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos([email protected]/AbstractQueuedSynchronizer.java:1758)
at java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take([email protected]/ScheduledThreadPoolExecutor.java:1182)
at java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take([email protected]/ScheduledThreadPoolExecutor.java:899)
at java.util.concurrent.ThreadPoolExecutor.getTask([email protected]/ThreadPoolExecutor.java:1070)
at java.util.concurrent.ThreadPoolExecutor.runWorker([email protected]/ThreadPoolExecutor.java:1130)
at java.util.concurrent.ThreadPoolExecutor$Worker.run([email protected]/ThreadPoolExecutor.java:642)
at java.lang.Thread.runWith([email protected]/Thread.java:1596)
at java.lang.Thread.run([email protected]/Thread.java:1583)
"Redshift-JDBC-SharedTimer-1" #28 [52] daemon prio=5 os_prio=0 cpu=0.18ms elapsed=226.81s tid=0x00007f4bf815b4c0 nid=52 in Object.wait() [0x00007f4c9667a000]
java.lang.Thread.State: WAITING (on object monitor)
at java.lang.Object.wait0([email protected]/Native Method)
- waiting on <0x00000005280ec950> (a java.util.TaskQueue)
at java.lang.Object.wait([email protected]/Object.java:366)
at java.lang.Object.wait([email protected]/Object.java:339)
at java.util.TimerThread.mainLoop([email protected]/Timer.java:537)
- locked <0x00000005280ec950> (a java.util.TaskQueue)
at java.util.TimerThread.run([email protected]/Timer.java:516)
"type-and-dedupe" #29 [53] prio=5 os_prio=0 cpu=30.38ms elapsed=226.54s tid=0x00007f4ccda9f070 nid=53 runnable [0x00007f4c96f9b000]
java.lang.Thread.State: RUNNABLE
at sun.nio.ch.Net.poll([email protected]/Native Method)
at sun.nio.ch.NioSocketImpl.park([email protected]/NioSocketImpl.java:191)
at sun.nio.ch.NioSocketImpl.park([email protected]/NioSocketImpl.java:201)
at sun.nio.ch.NioSocketImpl.implRead([email protected]/NioSocketImpl.java:309)
at sun.nio.ch.NioSocketImpl.read([email protected]/NioSocketImpl.java:346)
at sun.nio.ch.NioSocketImpl$1.read([email protected]/NioSocketImpl.java:796)
at java.net.Socket$SocketInputStream.read([email protected]/Socket.java:1099)
at sun.security.ssl.SSLSocketInputRecord.read([email protected]/SSLSocketInputRecord.java:489)
at sun.security.ssl.SSLSocketInputRecord.readHeader([email protected]/SSLSocketInputRecord.java:483)
at sun.security.ssl.SSLSocketInputRecord.bytesInCompletePacket([email protected]/SSLSocketInputRecord.java:70)
at sun.security.ssl.SSLSocketImpl.readApplicationRecord([email protected]/SSLSocketImpl.java:1461)
at sun.security.ssl.SSLSocketImpl$AppInputStream.read([email protected]/SSLSocketImpl.java:1066)
at com.amazon.redshift.core.CompressedInputStream.readFromNetwork(CompressedInputStream.java:336)
at com.amazon.redshift.core.CompressedInputStream.tryReadMessage(CompressedInputStream.java:166)
at com.amazon.redshift.core.CompressedInputStream.read(CompressedInputStream.java:387)
at com.amazon.redshift.core.VisibleBufferedInputStream.readMore(VisibleBufferedInputStream.java:167)
at com.amazon.redshift.core.VisibleBufferedInputStream.ensureBytes(VisibleBufferedInputStream.java:134)
at com.amazon.redshift.core.VisibleBufferedInputStream.ensureBytes(VisibleBufferedInputStream.java:119)
at com.amazon.redshift.core.VisibleBufferedInputStream.read(VisibleBufferedInputStream.java:79)
at com.amazon.redshift.core.RedshiftStream.receiveChar(RedshiftStream.java:440)
at com.amazon.redshift.core.v3.QueryExecutorImpl.processResultsOnThread(QueryExecutorImpl.java:1914)
at com.amazon.redshift.core.v3.QueryExecutorImpl.processResults(QueryExecutorImpl.java:1886)
at com.amazon.redshift.core.v3.QueryExecutorImpl.processResults(QueryExecutorImpl.java:1878)
at com.amazon.redshift.core.v3.QueryExecutorImpl.execute(QueryExecutorImpl.java:375)
- locked <0x00000007ffe03a80> (a com.amazon.redshift.core.v3.QueryExecutorImpl)
at com.amazon.redshift.jdbc.RedshiftStatementImpl.executeInternal(RedshiftStatementImpl.java:515)
at com.amazon.redshift.jdbc.RedshiftStatementImpl.execute(RedshiftStatementImpl.java:436)
at com.amazon.redshift.jdbc.RedshiftStatementImpl.executeWithFlags(RedshiftStatementImpl.java:377)
at com.amazon.redshift.jdbc.RedshiftStatementImpl.executeCachedSql(RedshiftStatementImpl.java:363)
at com.amazon.redshift.jdbc.RedshiftStatementImpl.executeWithFlags(RedshiftStatementImpl.java:340)
at com.amazon.redshift.jdbc.RedshiftStatementImpl.executeQuery(RedshiftStatementImpl.java:268)
at com.amazon.redshift.jdbc.RedshiftDatabaseMetaData.getColumns(RedshiftDatabaseMetaData.java:2095)
at com.zaxxer.hikari.pool.ProxyDatabaseMetaData.getColumns(ProxyDatabaseMetaData.java:107)
at com.zaxxer.hikari.pool.HikariProxyDatabaseMetaData.getColumns(HikariProxyDatabaseMetaData.java)
at io.airbyte.cdk.integrations.destination.jdbc.typing_deduping.JdbcDestinationHandler$Companion.findExistingTable$lambda$1(JdbcDestinationHandler.kt:511)
at io.airbyte.cdk.integrations.destination.jdbc.typing_deduping.JdbcDestinationHandler$Companion$$Lambda/0x00007f4c483df9f0.apply(Unknown Source)
at io.airbyte.cdk.db.jdbc.DefaultJdbcDatabase.executeMetadataQuery(DefaultJdbcDatabase.kt:87)
at io.airbyte.cdk.integrations.destination.jdbc.typing_deduping.JdbcDestinationHandler$Companion.findExistingTable(JdbcDestinationHandler.kt:498)
at io.airbyte.cdk.integrations.destination.jdbc.typing_deduping.JdbcV1V2Migrator.getTableIfExists(JdbcV1V2Migrator.kt:63)
at io.airbyte.integrations.base.destination.typing_deduping.BaseDestinationV1V2Migrator.doesValidV1RawTableExist(BaseDestinationV1V2Migrator.kt:176)
at io.airbyte.integrations.base.destination.typing_deduping.BaseDestinationV1V2Migrator.shouldMigrate(BaseDestinationV1V2Migrator.kt:53)
at io.airbyte.integrations.base.destination.typing_deduping.BaseDestinationV1V2Migrator.migrateIfNecessary(BaseDestinationV1V2Migrator.kt:23)
at io.airbyte.integrations.base.destination.typing_deduping.TyperDeduperUtil$Companion.executeWeirdMigrations$lambda$9$lambda$8(TyperDeduperUtil.kt:141)
at io.airbyte.integrations.base.destination.typing_deduping.TyperDeduperUtil$Companion$$Lambda/0x00007f4c483d0218.get(Unknown Source)
at java.util.concurrent.CompletableFuture$AsyncSupply.run([email protected]/CompletableFuture.java:1768)
at java.util.concurrent.ThreadPoolExecutor.runWorker([email protected]/ThreadPoolExecutor.java:1144)
at java.util.concurrent.ThreadPoolExecutor$Worker.run([email protected]/ThreadPoolExecutor.java:642)
at java.lang.Thread.runWith([email protected]/Thread.java:1596)
at java.lang.Thread.run([email protected]/Thread.java:1583)
"type-and-dedupe" #30 [54] prio=5 os_prio=0 cpu=26.82ms elapsed=226.54s tid=0x00007f4ccda9fd70 nid=54 waiting on condition [0x00007f4c9657a000]
java.lang.Thread.State: WAITING (parking)
at jdk.internal.misc.Unsafe.park([email protected]/Native Method)
- parking to wait for <0x000000052801a8d8> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject)
at java.util.concurrent.locks.LockSupport.park([email protected]/LockSupport.java:371)
at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionNode.block([email protected]/AbstractQueuedSynchronizer.java:519)
at java.util.concurrent.ForkJoinPool.unmanagedBlock([email protected]/ForkJoinPool.java:3780)
at java.util.concurrent.ForkJoinPool.managedBlock([email protected]/ForkJoinPool.java:3725)
at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await([email protected]/AbstractQueuedSynchronizer.java:1707)
at java.util.concurrent.LinkedBlockingQueue.take([email protected]/LinkedBlockingQueue.java:435)
at java.util.concurrent.ThreadPoolExecutor.getTask([email protected]/ThreadPoolExecutor.java:1070)
at java.util.concurrent.ThreadPoolExecutor.runWorker([email protected]/ThreadPoolExecutor.java:1130)
at java.util.concurrent.ThreadPoolExecutor$Worker.run([email protected]/ThreadPoolExecutor.java:642)
at java.lang.Thread.runWith([email protected]/Thread.java:1596)
at java.lang.Thread.run([email protected]/Thread.java:1583)
"type-and-dedupe" #31 [55] prio=5 os_prio=0 cpu=36.94ms elapsed=226.53s tid=0x00007f4ccdaa0f60 nid=55 runnable [0x00007f4c96479000]
java.lang.Thread.State: RUNNABLE
at sun.nio.ch.Net.poll([email protected]/Native Method)
at sun.nio.ch.NioSocketImpl.park([email protected]/NioSocketImpl.java:191)
at sun.nio.ch.NioSocketImpl.park([email protected]/NioSocketImpl.java:201)
at sun.nio.ch.NioSocketImpl.implRead([email protected]/NioSocketImpl.java:309)
at sun.nio.ch.NioSocketImpl.read([email protected]/NioSocketImpl.java:346)
at sun.nio.ch.NioSocketImpl$1.read([email protected]/NioSocketImpl.java:796)
at java.net.Socket$SocketInputStream.read([email protected]/Socket.java:1099)
at sun.security.ssl.SSLSocketInputRecord.read([email protected]/SSLSocketInputRecord.java:489)
at sun.security.ssl.SSLSocketInputRecord.readHeader([email protected]/SSLSocketInputRecord.java:483)
at sun.security.ssl.SSLSocketInputRecord.bytesInCompletePacket([email protected]/SSLSocketInputRecord.java:70)
at sun.security.ssl.SSLSocketImpl.readApplicationRecord([email protected]/SSLSocketImpl.java:1461)
at sun.security.ssl.SSLSocketImpl$AppInputStream.read([email protected]/SSLSocketImpl.java:1066)
at com.amazon.redshift.core.CompressedInputStream.readFromNetwork(CompressedInputStream.java:336)
at com.amazon.redshift.core.CompressedInputStream.tryReadMessage(CompressedInputStream.java:166)
at com.amazon.redshift.core.CompressedInputStream.read(CompressedInputStream.java:387)
at com.amazon.redshift.core.VisibleBufferedInputStream.readMore(VisibleBufferedInputStream.java:167)
at com.amazon.redshift.core.VisibleBufferedInputStream.ensureBytes(VisibleBufferedInputStream.java:134)
at com.amazon.redshift.core.VisibleBufferedInputStream.ensureBytes(VisibleBufferedInputStream.java:119)
at com.amazon.redshift.core.VisibleBufferedInputStream.read(VisibleBufferedInputStream.java:79)
at com.amazon.redshift.core.RedshiftStream.receiveChar(RedshiftStream.java:440)
at com.amazon.redshift.core.v3.QueryExecutorImpl.processResultsOnThread(QueryExecutorImpl.java:1914)
at com.amazon.redshift.core.v3.QueryExecutorImpl.processResults(QueryExecutorImpl.java:1886)
at com.amazon.redshift.core.v3.QueryExecutorImpl.processResults(QueryExecutorImpl.java:1878)
at com.amazon.redshift.core.v3.QueryExecutorImpl.execute(QueryExecutorImpl.java:375)
- locked <0x00000007ff86d420> (a com.amazon.redshift.core.v3.QueryExecutorImpl)
at com.amazon.redshift.jdbc.RedshiftStatementImpl.executeInternal(RedshiftStatementImpl.java:515)
at com.amazon.redshift.jdbc.RedshiftStatementImpl.execute(RedshiftStatementImpl.java:436)
at com.amazon.redshift.jdbc.RedshiftStatementImpl.executeWithFlags(RedshiftStatementImpl.java:377)
at com.amazon.redshift.jdbc.RedshiftStatementImpl.executeCachedSql(RedshiftStatementImpl.java:363)
at com.amazon.redshift.jdbc.RedshiftStatementImpl.executeWithFlags(RedshiftStatementImpl.java:340)
at com.amazon.redshift.jdbc.RedshiftStatementImpl.executeQuery(RedshiftStatementImpl.java:268)
at com.amazon.redshift.jdbc.RedshiftDatabaseMetaData.getColumns(RedshiftDatabaseMetaData.java:2095)
at com.zaxxer.hikari.pool.ProxyDatabaseMetaData.getColumns(ProxyDatabaseMetaData.java:107)
at com.zaxxer.hikari.pool.HikariProxyDatabaseMetaData.getColumns(HikariProxyDatabaseMetaData.java)
at io.airbyte.cdk.integrations.destination.jdbc.typing_deduping.JdbcDestinationHandler$Companion.findExistingTable$lambda$1(JdbcDestinationHandler.kt:511)
at io.airbyte.cdk.integrations.destination.jdbc.typing_deduping.JdbcDestinationHandler$Companion$$Lambda/0x00007f4c483df9f0.apply(Unknown Source)
at io.airbyte.cdk.db.jdbc.DefaultJdbcDatabase.executeMetadataQuery(DefaultJdbcDatabase.kt:87)
at io.airbyte.cdk.integrations.destination.jdbc.typing_deduping.JdbcDestinationHandler$Companion.findExistingTable(JdbcDestinationHandler.kt:498)
at io.airbyte.cdk.integrations.destination.jdbc.typing_deduping.JdbcV1V2Migrator.getTableIfExists(JdbcV1V2Migrator.kt:63)
at io.airbyte.integrations.base.destination.typing_deduping.BaseDestinationV1V2Migrator.doesValidV2RawTableAlreadyExist(BaseDestinationV1V2Migrator.kt:156)
at io.airbyte.integrations.base.destination.typing_deduping.BaseDestinationV1V2Migrator.shouldMigrate(BaseDestinationV1V2Migrator.kt:51)
at io.airbyte.integrations.base.destination.typing_deduping.BaseDestinationV1V2Migrator.migrateIfNecessary(BaseDestinationV1V2Migrator.kt:23)
at io.airbyte.integrations.base.destination.typing_deduping.TyperDeduperUtil$Companion.executeWeirdMigrations$lambda$9$lambda$8(TyperDeduperUtil.kt:141)
at io.airbyte.integrations.base.destination.typing_deduping.TyperDeduperUtil$Companion$$Lambda/0x00007f4c483d0218.get(Unknown Source)
at java.util.concurrent.CompletableFuture$AsyncSupply.run([email protected]/CompletableFuture.java:1768)
at java.util.concurrent.ThreadPoolExecutor.runWorker([email protected]/ThreadPoolExecutor.java:1144)
at java.util.concurrent.ThreadPoolExecutor$Worker.run([email protected]/ThreadPoolExecutor.java:642)
at java.lang.Thread.runWith([email protected]/Thread.java:1596)
at java.lang.Thread.run([email protected]/Thread.java:1583)
"type-and-dedupe" #32 [56] prio=5 os_prio=0 cpu=25.93ms elapsed=226.53s tid=0x00007f4ccdaa2320 nid=56 runnable [0x00007f4c96379000]
java.lang.Thread.State: RUNNABLE
at sun.nio.ch.Net.poll([email protected]/Native Method)
at sun.nio.ch.NioSocketImpl.park([email protected]/NioSocketImpl.java:191)
at sun.nio.ch.NioSocketImpl.park([email protected]/NioSocketImpl.java:201)
at sun.nio.ch.NioSocketImpl.implRead([email protected]/NioSocketImpl.java:309)
at sun.nio.ch.NioSocketImpl.read([email protected]/NioSocketImpl.java:346)
at sun.nio.ch.NioSocketImpl$1.read([email protected]/NioSocketImpl.java:796)
at java.net.Socket$SocketInputStream.read([email protected]/Socket.java:1099)
at sun.security.ssl.SSLSocketInputRecord.read([email protected]/SSLSocketInputRecord.java:489)
at sun.security.ssl.SSLSocketInputRecord.readHeader([email protected]/SSLSocketInputRecord.java:483)
at sun.security.ssl.SSLSocketInputRecord.bytesInCompletePacket([email protected]/SSLSocketInputRecord.java:70)
at sun.security.ssl.SSLSocketImpl.readApplicationRecord([email protected]/SSLSocketImpl.java:1461)
at sun.security.ssl.SSLSocketImpl$AppInputStream.read([email protected]/SSLSocketImpl.java:1066)
at com.amazon.redshift.core.CompressedInputStream.readFromNetwork(CompressedInputStream.java:336)
at com.amazon.redshift.core.CompressedInputStream.tryReadMessage(CompressedInputStream.java:166)
at com.amazon.redshift.core.CompressedInputStream.read(CompressedInputStream.java:387)
at com.amazon.redshift.core.VisibleBufferedInputStream.readMore(VisibleBufferedInputStream.java:167)
at com.amazon.redshift.core.VisibleBufferedInputStream.ensureBytes(VisibleBufferedInputStream.java:134)
at com.amazon.redshift.core.VisibleBufferedInputStream.ensureBytes(VisibleBufferedInputStream.java:119)
at com.amazon.redshift.core.VisibleBufferedInputStream.read(VisibleBufferedInputStream.java:79)
at com.amazon.redshift.core.RedshiftStream.receiveChar(RedshiftStream.java:440)
at com.amazon.redshift.core.v3.QueryExecutorImpl.processResultsOnThread(QueryExecutorImpl.java:1914)
at com.amazon.redshift.core.v3.QueryExecutorImpl.processResults(QueryExecutorImpl.java:1886)
at com.amazon.redshift.core.v3.QueryExecutorImpl.processResults(QueryExecutorImpl.java:1878)
at com.amazon.redshift.core.v3.QueryExecutorImpl.execute(QueryExecutorImpl.java:375)
- locked <0x00000007ffd88448> (a com.amazon.redshift.core.v3.QueryExecutorImpl)
at com.amazon.redshift.jdbc.RedshiftStatementImpl.executeInternal(RedshiftStatementImpl.java:515)
at com.amazon.redshift.jdbc.RedshiftStatementImpl.execute(RedshiftStatementImpl.java:436)
at com.amazon.redshift.jdbc.RedshiftStatementImpl.executeWithFlags(RedshiftStatementImpl.java:377)
at com.amazon.redshift.jdbc.RedshiftStatementImpl.executeCachedSql(RedshiftStatementImpl.java:363)
at com.amazon.redshift.jdbc.RedshiftStatementImpl.executeWithFlags(RedshiftStatementImpl.java:340)
at com.amazon.redshift.jdbc.RedshiftStatementImpl.executeQuery(RedshiftStatementImpl.java:268)
at com.amazon.redshift.jdbc.RedshiftDatabaseMetaData.getColumns(RedshiftDatabaseMetaData.java:2095)
at com.zaxxer.hikari.pool.ProxyDatabaseMetaData.getColumns(ProxyDatabaseMetaData.java:107)
at com.zaxxer.hikari.pool.HikariProxyDatabaseMetaData.getColumns(HikariProxyDatabaseMetaData.java)
at io.airbyte.cdk.integrations.destination.jdbc.typing_deduping.JdbcDestinationHandler$Companion.findExistingTable$lambda$1(JdbcDestinationHandler.kt:511)
at io.airbyte.cdk.integrations.destination.jdbc.typing_deduping.JdbcDestinationHandler$Companion$$Lambda/0x00007f4c483df9f0.apply(Unknown Source)
at io.airbyte.cdk.db.jdbc.DefaultJdbcDatabase.executeMetadataQuery(DefaultJdbcDatabase.kt:87)
at io.airbyte.cdk.integrations.destination.jdbc.typing_deduping.JdbcDestinationHandler$Companion.findExistingTable(JdbcDestinationHandler.kt:498)
at io.airbyte.cdk.integrations.destination.jdbc.typing_deduping.JdbcV1V2Migrator.getTableIfExists(JdbcV1V2Migrator.kt:63)
at io.airbyte.integrations.base.destination.typing_deduping.BaseDestinationV1V2Migrator.doesValidV1RawTableExist(BaseDestinationV1V2Migrator.kt:176)
at io.airbyte.integrations.base.destination.typing_deduping.BaseDestinationV1V2Migrator.shouldMigrate(BaseDestinationV1V2Migrator.kt:53)
at io.airbyte.integrations.base.destination.typing_deduping.BaseDestinationV1V2Migrator.migrateIfNecessary(BaseDestinationV1V2Migrator.kt:23)
at io.airbyte.integrations.base.destination.typing_deduping.TyperDeduperUtil$Companion.executeWeirdMigrations$lambda$9$lambda$8(TyperDeduperUtil.kt:141)
at io.airbyte.integrations.base.destination.typing_deduping.TyperDeduperUtil$Companion$$Lambda/0x00007f4c483d0218.get(Unknown Source)
at java.util.concurrent.CompletableFuture$AsyncSupply.run([email protected]/CompletableFuture.java:1768)
at java.util.concurrent.ThreadPoolExecutor.runWorker([email protected]/ThreadPoolExecutor.java:1144)
at java.util.concurrent.ThreadPoolExecutor$Worker.run([email protected]/ThreadPoolExecutor.java:642)
at java.lang.Thread.runWith([email protected]/Thread.java:1596)
at java.lang.Thread.run([email protected]/Thread.java:1583)
"Attach Listener" #33 [102] daemon prio=9 os_prio=0 cpu=0.54ms elapsed=0.10s tid=0x00007f4c2c001180 nid=102 waiting on condition [0x0000000000000000]
java.lang.Thread.State: RUNNABLE
"VM Thread" os_prio=0 cpu=30.56ms elapsed=230.55s tid=0x00007f4ccc0ed0d0 nid=32 runnable
"GC Thread#0" os_prio=0 cpu=54.25ms elapsed=230.56s tid=0x00007f4ccc05e4c0 nid=26 runnable
"GC Thread#1" os_prio=0 cpu=37.18ms elapsed=230.35s tid=0x00007f4c3c00c270 nid=43 runnable
"GC Thread#2" os_prio=0 cpu=42.81ms elapsed=230.35s tid=0x00007f4c3c00d4c0 nid=44 runnable
"GC Thread#3" os_prio=0 cpu=53.34ms elapsed=230.35s tid=0x00007f4c3c00e160 nid=45 runnable
"G1 Main Marker" os_prio=0 cpu=1.58ms elapsed=230.56s tid=0x00007f4ccc06c450 nid=27 runnable
"G1 Conc#0" os_prio=0 cpu=29.92ms elapsed=230.56s tid=0x00007f4ccc06d9d0 nid=28 runnable
"G1 Refine#0" os_prio=0 cpu=0.13ms elapsed=230.56s tid=0x00007f4ccc09c200 nid=29 runnable
"G1 Service" os_prio=0 cpu=15.24ms elapsed=230.56s tid=0x00007f4ccc09da90 nid=30 runnable
"VM Periodic Task Thread" os_prio=0 cpu=193.60ms elapsed=230.55s tid=0x00007f4ccc0c5fa0 nid=31 waiting on condition
JNI global refs: 15, weak refs: 0
Strace:
bash-5.2# strace -fp 9
[pid 32] futex(0x7f4cd2425ad8, FUTEX_WAIT_BITSET_PRIVATE, 0, {tv_sec=17033, tv_nsec=254841635}, FUTEX_BITSET_MATCH_ANY <unfinished ...>
[pid 31] futex(0x7f4cd2426cdc, FUTEX_WAIT_BITSET_PRIVATE, 0, {tv_sec=17032, tv_nsec=305000249}, FUTEX_BITSET_MATCH_ANY) = -1 ETIMEDOUT (Connection timed out)
[pid 31] futex(0x7f4cd2426c88, FUTEX_WAKE_PRIVATE, 1) = 0
[pid 31] futex(0x7f4cd2426cdc, FUTEX_WAIT_BITSET_PRIVATE, 0, {tv_sec=17032, tv_nsec=355605018}, FUTEX_BITSET_MATCH_ANY) = -1 ETIMEDOUT (Connection timed out)
[pid 31] futex(0x7f4cd2426c88, FUTEX_WAKE_PRIVATE, 1) = 0
[pid 31] futex(0x7f4cd2426cdc, FUTEX_WAIT_BITSET_PRIVATE, 0, {tv_sec=17032, tv_nsec=406142935}, FUTEX_BITSET_MATCH_ANY <unfinished ...>
[pid 37] <... futex resumed>) = -1 ETIMEDOUT (Connection timed out)
[pid 37] futex(0x7f4cd2427c88, FUTEX_WAKE_PRIVATE, 1) = 0
[pid 37] futex(0x7f4cd2427cd8, FUTEX_WAIT_BITSET_PRIVATE, 0, {tv_sec=17032, tv_nsec=619962394}, FUTEX_BITSET_MATCH_ANY <unfinished ...>
[pid 31] <... futex resumed>) = -1 ETIMEDOUT (Connection timed out)
[pid 31] futex(0x7f4cd2426c88, FUTEX_WAKE_PRIVATE, 1) = 0
[pid 31] futex(0x7f4cd2426cdc, FUTEX_WAIT_BITSET_PRIVATE, 0, {tv_sec=17032, tv_nsec=456673273}, FUTEX_BITSET_MATCH_ANY) = -1 ETIMEDOUT (Connection timed out)
[pid 31] futex(0x7f4cd2426c88, FUTEX_WAKE_PRIVATE, 1) = 0
[pid 31] futex(0x7f4cd2426cdc, FUTEX_WAIT_BITSET_PRIVATE, 0, {tv_sec=17032, tv_nsec=507287712}, FUTEX_BITSET_MATCH_ANY) = -1 ETIMEDOUT (Connection timed out)
[pid 31] futex(0x7f4cd2426c88, FUTEX_WAKE_PRIVATE, 1) = 0
[pid 31] futex(0x7f4cd2426cdc, FUTEX_WAIT_BITSET_PRIVATE, 0, {tv_sec=17032, tv_nsec=557827169}, FUTEX_BITSET_MATCH_ANY) = -1 ETIMEDOUT (Connection timed out)
[pid 31] futex(0x7f4cd2426c88, FUTEX_WAKE_PRIVATE, 1) = 0
[pid 31] futex(0x7f4cd2426cdc, FUTEX_WAIT_BITSET_PRIVATE, 0, {tv_sec=17032, tv_nsec=608526382}, FUTEX_BITSET_MATCH_ANY) = -1 ETIMEDOUT (Connection timed out)
[pid 31] futex(0x7f4cd2426c88, FUTEX_WAKE_PRIVATE, 1) = 0
[pid 31] futex(0x7f4cd2426cdc, FUTEX_WAIT_BITSET_PRIVATE, 0, {tv_sec=17032, tv_nsec=659015618}, FUTEX_BITSET_MATCH_ANY <unfinished ...>
[pid 37] <... futex resumed>) = -1 ETIMEDOUT (Connection timed out)
[pid 37] futex(0x7f4cd2427c88, FUTEX_WAKE_PRIVATE, 1) = 0
[pid 37] futex(0x7f4cd2427cd8, FUTEX_WAIT_BITSET_PRIVATE, 0, {tv_sec=17032, tv_nsec=870233657}, FUTEX_BITSET_MATCH_ANY <unfinished ...>
[pid 31] <... futex resumed>) = -1 ETIMEDOUT (Connection timed out)
[pid 31] futex(0x7f4cd2426c88, FUTEX_WAKE_PRIVATE, 1) = 0
[pid 31] futex(0x7f4cd2426cdc, FUTEX_WAIT_BITSET_PRIVATE, 0, {tv_sec=17032, tv_nsec=709760411}, FUTEX_BITSET_MATCH_ANY) = -1 ETIMEDOUT (Connection timed out)
[pid 31] futex(0x7f4cd2426c88, FUTEX_WAKE_PRIVATE, 1) = 0
[pid 31] futex(0x7f4cd2426cdc, FUTEX_WAIT_BITSET_PRIVATE, 0, {tv_sec=17032, tv_nsec=760380461}, FUTEX_BITSET_MATCH_ANY) = -1 ETIMEDOUT (Connection timed out)
[pid 31] futex(0x7f4cd2426c88, FUTEX_WAKE_PRIVATE, 1) = 0
[pid 31] futex(0x7f4cd2426cdc, FUTEX_WAIT_BITSET_PRIVATE, 0, {tv_sec=17032, tv_nsec=810985590}, FUTEX_BITSET_MATCH_ANY <unfinished ...>
[pid 30] <... futex resumed>) = -1 ETIMEDOUT (Connection timed out)
[pid 30] futex(0x7f4ccc09de28, FUTEX_WAKE_PRIVATE, 1) = 0
[pid 30] getrusage(RUSAGE_THREAD, {ru_utime={tv_sec=0, tv_usec=2928}, ru_stime={tv_sec=0, tv_usec=15602}, ...}) = 0
[pid 30] futex(0x7f4ccc09de78, FUTEX_WAIT_BITSET_PRIVATE, 0, {tv_sec=17033, tv_nsec=765115595}, FUTEX_BITSET_MATCH_ANY <unfinished ...>
[pid 31] <... futex resumed>) = -1 ETIMEDOUT (Connection timed out)
[pid 31] futex(0x7f4cd2426c88, FUTEX_WAKE_PRIVATE, 1) = 0
[pid 31] futex(0x7f4cd2426cdc, FUTEX_WAIT_BITSET_PRIVATE, 0, {tv_sec=17032, tv_nsec=861411364}, FUTEX_BITSET_MATCH_ANY) = -1 ETIMEDOUT (Connection timed out)
[pid 31] futex(0x7f4cd2426c88, FUTEX_WAKE_PRIVATE, 1) = 0
[pid 31] futex(0x7f4cd2426cdc, FUTEX_WAIT_BITSET_PRIVATE, 0, {tv_sec=17032, tv_nsec=911953691}, FUTEX_BITSET_MATCH_ANY <unfinished ...>
[pid 37] <... futex resumed>) = -1 ETIMEDOUT (Connection timed out)
[pid 37] futex(0x7f4cd2427c88, FUTEX_WAKE_PRIVATE, 1) = 0
[pid 37] futex(0x7f4cd2427cd8, FUTEX_WAIT_BITSET_PRIVATE, 0, {tv_sec=17033, tv_nsec=120483679}, FUTEX_BITSET_MATCH_ANY <unfinished ...>
[pid 31] <... futex resumed>) = -1 ETIMEDOUT (Connection timed out)
[pid 31] futex(0x7f4cd2426c88, FUTEX_WAKE_PRIVATE, 1) = 0
[pid 31] futex(0x7f4cd2426cdc, FUTEX_WAIT_BITSET_PRIVATE, 0, {tv_sec=17032, tv_nsec=962609213}, FUTEX_BITSET_MATCH_ANY) = -1 ETIMEDOUT (Connection timed out)
[pid 31] futex(0x7f4cd2426c88, FUTEX_WAKE_PRIVATE, 1) = 0
[pid 31] futex(0x7f4cd2426cdc, FUTEX_WAIT_BITSET_PRIVATE, 0, {tv_sec=17033, tv_nsec=13072597}, FUTEX_BITSET_MATCH_ANY) = -1 ETIMEDOUT (Connection timed out)
[pid 31] futex(0x7f4cd2426c88, FUTEX_WAKE_PRIVATE, 1) = 0
[pid 31] futex(0x7f4cd2426cdc, FUTEX_WAIT_BITSET_PRIVATE, 0, {tv_sec=17033, tv_nsec=63543283}, FUTEX_BITSET_MATCH_ANY <unfinished ...>
[pid 48] <... futex resumed>) = -1 ETIMEDOUT (Connection timed out)
[pid 48] futex(0x7f4ccd2fc690, FUTEX_WAKE_PRIVATE, 1) = 0
[pid 48] futex(0x7f4ccd2fc6e0, FUTEX_WAIT_BITSET_PRIVATE, 0, {tv_sec=17034, tv_nsec=30607381}, FUTEX_BITSET_MATCH_ANY <unfinished ...>
[pid 31] <... futex resumed>) = -1 ETIMEDOUT (Connection timed out)
[pid 31] futex(0x7f4cd2426c88, FUTEX_WAKE_PRIVATE, 1) = 0
[pid 31] futex(0x7f4cd2426cdc, FUTEX_WAIT_BITSET_PRIVATE, 0, {tv_sec=17033, tv_nsec=114184303}, FUTEX_BITSET_MATCH_ANY) = -1 ETIMEDOUT (Connection timed out)
[pid 31] futex(0x7f4cd2426c88, FUTEX_WAKE_PRIVATE, 1) = 0
[pid 31] futex(0x7f4cd2426cdc, FUTEX_WAIT_BITSET_PRIVATE, 0, {tv_sec=17033, tv_nsec=164815144}, FUTEX_BITSET_MATCH_ANY <unfinished ...>
[pid 37] <... futex resumed>) = -1 ETIMEDOUT (Connection timed out)
[pid 37] futex(0x7f4cd2427c88, FUTEX_WAKE_PRIVATE, 1) = 0
[pid 37] futex(0x7f4cd2427cd8, FUTEX_WAIT_BITSET_PRIVATE, 0, {tv_sec=17033, tv_nsec=370708002}, FUTEX_BITSET_MATCH_ANY <unfinished ...>
[pid 31] <... futex resumed>) = -1 ETIMEDOUT (Connection timed out)
[pid 31] futex(0x7f4cd2426c88, FUTEX_WAKE_PRIVATE, 1) = 0
[pid 31] futex(0x7f4cd2426cdc, FUTEX_WAIT_BITSET_PRIVATE, 0, {tv_sec=17033, tv_nsec=215498806}, FUTEX_BITSET_MATCH_ANY) = -1 ETIMEDOUT (Connection timed out)
[pid 31] futex(0x7f4cd2426c88, FUTEX_WAKE_PRIVATE, 1) = 0
[pid 31] futex(0x7f4cd2426cdc, FUTEX_WAIT_BITSET_PRIVATE, 0, {tv_sec=17033, tv_nsec=266015682}, FUTEX_BITSET_MATCH_ANY <unfinished ...>
[pid 32] <... futex resumed>) = -1 ETIMEDOUT (Connection timed out)
[pid 32] futex(0x7f4cd2425a88, FUTEX_WAKE_PRIVATE, 1) = 0
[pid 32] futex(0x7f4cd2425ad8, FUTEX_WAIT_BITSET_PRIVATE, 0, {tv_sec=17034, tv_nsec=255233708}, FUTEX_BITSET_MATCH_ANY <unfinished ...>
[pid 31] <... futex resumed>) = -1 ETIMEDOUT (Connection timed out)
[pid 31] futex(0x7f4cd2426c88, FUTEX_WAKE_PRIVATE, 1) = 0
[pid 31] futex(0x7f4cd2426cdc, FUTEX_WAIT_BITSET_PRIVATE, 0, {tv_sec=17033, tv_nsec=316541219}, FUTEX_BITSET_MATCH_ANY) = -1 ETIMEDOUT (Connection timed out)
[pid 31] futex(0x7f4cd2426c88, FUTEX_WAKE_PRIVATE, 1) = 0
[pid 31] futex(0x7f4cd2426cdc, FUTEX_WAIT_BITSET_PRIVATE, 0, {tv_sec=17033, tv_nsec=366940523}, FUTEX_BITSET_MATCH_ANY) = -1 ETIMEDOUT (Connection timed out)
[pid 31] futex(0x7f4cd2426c88, FUTEX_WAKE_PRIVATE, 1) = 0
[pid 31] futex(0x7f4cd2426cdc, FUTEX_WAIT_BITSET_PRIVATE, 0, {tv_sec=17033, tv_nsec=417610654}, FUTEX_BITSET_MATCH_ANY <unfinished ...>
[pid 37] <... futex resumed>) = -1 ETIMEDOUT (Connection timed out)
[pid 37] futex(0x7f4cd2427c88, FUTEX_WAKE_PRIVATE, 1) = 0
[pid 37] futex(0x7f4cd2427cd8, FUTEX_WAIT_BITSET_PRIVATE, 0, {tv_sec=17033, tv_nsec=621072739}, FUTEX_BITSET_MATCH_ANY <unfinished ...>
[pid 31] <... futex resumed>) = -1 ETIMEDOUT (Connection timed out)
[pid 31] futex(0x7f4cd2426c88, FUTEX_WAKE_PRIVATE, 1) = 0
[pid 31] futex(0x7f4cd2426cdc, FUTEX_WAIT_BITSET_PRIVATE, 0, {tv_sec=17033, tv_nsec=468105760}, FUTEX_BITSET_MATCH_ANY) = -1 ETIMEDOUT (Connection timed out)
[pid 31] futex(0x7f4cd2426c88, FUTEX_WAKE_PRIVATE, 1) = 0
[pid 31] futex(0x7f4cd2426cdc, FUTEX_WAIT_BITSET_PRIVATE, 0, {tv_sec=17033, tv_nsec=518928116}, FUTEX_BITSET_MATCH_ANY) = -1 ETIMEDOUT (Connection timed out)
[pid 31] futex(0x7f4cd2426c88, FUTEX_WAKE_PRIVATE, 1) = 0
[pid 31] futex(0x7f4cd2426cdc, FUTEX_WAIT_BITSET_PRIVATE, 0, {tv_sec=17033, tv_nsec=569451143}, FUTEX_BITSET_MATCH_ANY) = -1 ETIMEDOUT (Connection timed out)
[pid 31] futex(0x7f4cd2426c88, FUTEX_WAKE_PRIVATE, 1) = 0
[pid 31] futex(0x7f4cd2426cdc, FUTEX_WAIT_BITSET_PRIVATE, 0, {tv_sec=17033, tv_nsec=596980390}, FUTEX_BITSET_MATCH_ANY) = -1 ETIMEDOUT (Connection timed out)
[pid 31] futex(0x7f4cd2426c88, FUTEX_WAKE_PRIVATE, 1) = 0
[pid 31] futex(0x7f4cd2426cdc, FUTEX_WAIT_BITSET_PRIVATE, 0, {tv_sec=17033, tv_nsec=620546484}, FUTEX_BITSET_MATCH_ANY) = -1 ETIMEDOUT (Connection timed out)
[pid 31] futex(0x7f4cd2426c88, FUTEX_WAKE_PRIVATE, 1 <unfinished ...>
[pid 37] <... futex resumed>) = -1 ETIMEDOUT (Connection timed out)
[pid 31] <... futex resumed>) = 0
[pid 37] futex(0x7f4cd2427c88, FUTEX_WAKE_PRIVATE, 1 <unfinished ...>
[pid 31] futex(0x7f4cd2426cdc, FUTEX_WAIT_BITSET_PRIVATE, 0, {tv_sec=17033, tv_nsec=671394105}, FUTEX_BITSET_MATCH_ANY <unfinished ...>
[pid 37] <... futex resumed>) = 0
[pid 37] futex(0x7f4cd2427cd8, FUTEX_WAIT_BITSET_PRIVATE, 0, {tv_sec=17033, tv_nsec=871387334}, FUTEX_BITSET_MATCH_ANY <unfinished ...>
[pid 31] <... futex resumed>) = -1 ETIMEDOUT (Connection timed out)
[pid 31] futex(0x7f4cd2426c88, FUTEX_WAKE_PRIVATE, 1) = 0
[pid 31] futex(0x7f4cd2426cdc, FUTEX_WAIT_BITSET_PRIVATE, 0, {tv_sec=17033, tv_nsec=721932412}, FUTEX_BITSET_MATCH_ANY) = -1 ETIMEDOUT (Connection timed out)
[pid 31] futex(0x7f4cd2426c88, FUTEX_WAKE_PRIVATE, 1) = 0
[pid 31] futex(0x7f4cd2426cdc, FUTEX_WAIT_BITSET_PRIVATE, 0, {tv_sec=17033, tv_nsec=772278433}, FUTEX_BITSET_MATCH_ANY <unfinished ...>
[pid 30] <... futex resumed>) = -1 ETIMEDOUT (Connection timed out)
[pid 30] futex(0x7f4ccc09de28, FUTEX_WAKE_PRIVATE, 1) = 0
[pid 30] getrusage(RUSAGE_THREAD, {ru_utime={tv_sec=0, tv_usec=2928}, ru_stime={tv_sec=0, tv_usec=15925}, ...}) = 0
[pid 30] futex(0x7f4ccc09de78, FUTEX_WAIT_BITSET_PRIVATE, 0, {tv_sec=17034, tv_nsec=765917262}, FUTEX_BITSET_MATCH_ANY <unfinished ...>
[pid 31] <... futex resumed>) = -1 ETIMEDOUT (Connection timed out)
[pid 31] futex(0x7f4cd2426c88, FUTEX_WAKE_PRIVATE, 1) = 0
[pid 31] futex(0x7f4cd2426cdc, FUTEX_WAIT_BITSET_PRIVATE, 0, {tv_sec=17033, tv_nsec=822795470}, FUTEX_BITSET_MATCH_ANY) = -1 ETIMEDOUT (Connection timed out)
[pid 31] futex(0x7f4cd2426c88, FUTEX_WAKE_PRIVATE, 1) = 0
[pid 31] futex(0x7f4cd2426cdc, FUTEX_WAIT_BITSET_PRIVATE, 0, {tv_sec=17033, tv_nsec=873456141}, FUTEX_BITSET_MATCH_ANY <unfinished ...>
[pid 37] <... futex resumed>) = -1 ETIMEDOUT (Connection timed out)
[pid 37] futex(0x7f4cd2427c88, FUTEX_WAKE_PRIVATE, 1) = 0
[pid 37] futex(0x7f4cd2427cd8, FUTEX_WAIT_BITSET_PRIVATE, 0, {tv_sec=17034, tv_nsec=121700129}, FUTEX_BITSET_MATCH_ANY <unfinished ...>
[pid 31] <... futex resumed>) = -1 ETIMEDOUT (Connection timed out)
[pid 31] futex(0x7f4cd2426c88, FUTEX_WAKE_PRIVATE, 1) = 0
[pid 31] futex(0x7f4cd2426cdc, FUTEX_WAIT_BITSET_PRIVATE, 0, {tv_sec=17033, tv_nsec=923911196}, FUTEX_BITSET_MATCH_ANY) = -1 ETIMEDOUT (Connection timed out)
[pid 31] futex(0x7f4cd2426c88, FUTEX_WAKE_PRIVATE, 1) = 0
[pid 31] futex(0x7f4cd2426cdc, FUTEX_WAIT_BITSET_PRIVATE, 0, {tv_sec=17033, tv_nsec=974513436}, FUTEX_BITSET_MATCH_ANY) = -1 ETIMEDOUT (Connection timed out)
[pid 31] futex(0x7f4cd2426c88, FUTEX_WAKE_PRIVATE, 1) = 0
[pid 31] futex(0x7f4cd2426cdc, FUTEX_WAIT_BITSET_PRIVATE, 0, {tv_sec=17034, tv_nsec=25023592}, FUTEX_BITSET_MATCH_ANY) = -1 ETIMEDOUT (Connection timed out)
[pid 31] futex(0x7f4cd2426c88, FUTEX_WAKE_PRIVATE, 1) = 0
[pid 31] futex(0x7f4cd2426cdc, FUTEX_WAIT_BITSET_PRIVATE, 0, {tv_sec=17034, tv_nsec=75968882}, FUTEX_BITSET_MATCH_ANY <unfinished ...>
[pid 48] <... futex resumed>) = -1 ETIMEDOUT (Connection timed out)
[pid 48] futex(0x7f4ccd2fc690, FUTEX_WAKE_PRIVATE, 1) = 0
[pid 48] futex(0x7f4ccd2fc6e0, FUTEX_WAIT_BITSET_PRIVATE, 0, {tv_sec=17035, tv_nsec=30605830}, FUTEX_BITSET_MATCH_ANY <unfinished ...>
[pid 39] <... futex resumed>) = -1 ETIMEDOUT (Connection timed out)
[pid 39] futex(0x7f4cd2427208, FUTEX_WAKE_PRIVATE, 1) = 0
[pid 39] futex(0x7f4cd242725c, FUTEX_WAIT_BITSET_PRIVATE, 0, {tv_sec=17039, tv_nsec=32120008}, FUTEX_BITSET_MATCH_ANY <unfinished ...>
[pid 38] <... futex resumed>) = -1 ETIMEDOUT (Connection timed out)
[pid 38] futex(0x7f4cd2427208, FUTEX_WAKE_PRIVATE, 1) = 0
[pid 38] futex(0x7f4cd242725c, FUTEX_WAIT_BITSET_PRIVATE, 0, {tv_sec=17039, tv_nsec=35258663}, FUTEX_BITSET_MATCH_ANY <unfinished ...>
[pid 31] <... futex resumed>) = -1 ETIMEDOUT (Connection timed out)
[pid 31] futex(0x7f4cd2426c88, FUTEX_WAKE_PRIVATE, 1) = 0
[pid 31] futex(0x7f4cd2426cdc, FUTEX_WAIT_BITSET_PRIVATE, 0, {tv_sec=17034, tv_nsec=126973013}, FUTEX_BITSET_MATCH_ANY <unfinished ...>
[pid 37] <... futex resumed>) = -1 ETIMEDOUT (Connection timed out)
[pid 37] futex(0x7f4cd2427c88, FUTEX_WAKE_PRIVATE, 1) = 0
[pid 37] futex(0x7f4cd2427cd8, FUTEX_WAIT_BITSET_PRIVATE, 0, {tv_sec=17034, tv_nsec=372059656}, FUTEX_BITSET_MATCH_ANY <unfinished ...>
[pid 31] <... futex resumed>) = -1 ETIMEDOUT (Connection timed out)
[pid 31] futex(0x7f4cd2426c88, FUTEX_WAKE_PRIVATE, 1) = 0
[pid 31] futex(0x7f4cd2426cdc, FUTEX_WAIT_BITSET_PRIVATE, 0, {tv_sec=17034, tv_nsec=177479540}, FUTEX_BITSET_MATCH_ANY) = -1 ETIMEDOUT (Connection timed out)
[pid 31] futex(0x7f4cd2426c88, FUTEX_WAKE_PRIVATE, 1) = 0
[pid 31] futex(0x7f4cd2426cdc, FUTEX_WAIT_BITSET_PRIVATE, 0, {tv_sec=17034, tv_nsec=228106600}, FUTEX_BITSET_MATCH_ANY) = -1 ETIMEDOUT (Connection timed out)
[pid 31] futex(0x7f4cd2426c88, FUTEX_WAKE_PRIVATE, 1) = 0
[pid 31] futex(0x7f4cd2426cdc, FUTEX_WAIT_BITSET_PRIVATE, 0, {tv_sec=17034, tv_nsec=278662598}, FUTEX_BITSET_MATCH_ANY <unfinished ...>
[pid 32] <... futex resumed>) = -1 ETIMEDOUT (Connection timed out)
[pid 32] futex(0x7f4cd2425a88, FUTEX_WAKE_PRIVATE, 1) = 0
[pid 32] futex(0x7f4cd2425ad8, FUTEX_WAIT_BITSET_PRIVATE, 0, {tv_sec=17035, tv_nsec=255596972}, FUTEX_BITSET_MATCH_ANY <unfinished ...>
[pid 31] <... futex resumed>) = -1 ETIMEDOUT (Connection timed out)
[pid 31] futex(0x7f4cd2426c88, FUTEX_WAKE_PRIVATE, 1) = 0
[pid 31] futex(0x7f4cd2426cdc, FUTEX_WAIT_BITSET_PRIVATE, 0, {tv_sec=17034, tv_nsec=329304439}, FUTEX_BITSET_MATCH_ANY) = -1 ETIMEDOUT (Connection timed out)
[pid 31] futex(0x7f4cd2426c88, FUTEX_WAKE_PRIVATE, 1) = 0
[pid 31] futex(0x7f4cd2426cdc, FUTEX_WAIT_BITSET_PRIVATE, 0, {tv_sec=17034, tv_nsec=380033052}, FUTEX_BITSET_MATCH_ANY <unfinished ...>
[pid 37] <... futex resumed>) = -1 ETIMEDOUT (Connection timed out)
[pid 37] futex(0x7f4cd2427c88, FUTEX_WAKE_PRIVATE, 1) = 0
[pid 37] futex(0x7f4cd2427cd8, FUTEX_WAIT_BITSET_PRIVATE, 0, {tv_sec=17034, tv_nsec=622339900}, FUTEX_BITSET_MATCH_ANY <unfinished ...>
[pid 31] <... futex resumed>) = -1 ETIMEDOUT (Connection timed out)
[pid 31] futex(0x7f4cd2426c88, FUTEX_WAKE_PRIVATE, 1) = 0
[pid 31] futex(0x7f4cd2426cdc, FUTEX_WAIT_BITSET_PRIVATE, 0, {tv_sec=17034, tv_nsec=430562019}, FUTEX_BITSET_MATCH_ANY) = -1 ETIMEDOUT (Connection timed out)
[pid 31] futex(0x7f4cd2426c88, FUTEX_WAKE_PRIVATE, 1) = 0
[pid 31] futex(0x7f4cd2426cdc, FUTEX_WAIT_BITSET_PRIVATE, 0, {tv_sec=17034, tv_nsec=481167979}, FUTEX_BITSET_MATCH_ANY) = -1 ETIMEDOUT (Connection timed out)
[pid 31] futex(0x7f4cd2426c88, FUTEX_WAKE_PRIVATE, 1) = 0
[pid 31] futex(0x7f4cd2426cdc, FUTEX_WAIT_BITSET_PRIVATE, 0, {tv_sec=17034, tv_nsec=531815260}, FUTEX_BITSET_MATCH_ANY) = -1 ETIMEDOUT (Connection timed out)
[pid 31] futex(0x7f4cd2426c88, FUTEX_WAKE_PRIVATE, 1) = 0
[pid 31] futex(0x7f4cd2426cdc, FUTEX_WAIT_BITSET_PRIVATE, 0, {tv_sec=17034, tv_nsec=582535263}, FUTEX_BITSET_MATCH_ANY) = -1 ETIMEDOUT (Connection timed out)
[pid 31] futex(0x7f4cd2426c88, FUTEX_WAKE_PRIVATE, 1) = 0
[pid 31] futex(0x7f4cd2426cdc, FUTEX_WAIT_BITSET_PRIVATE, 0, {tv_sec=17034, tv_nsec=633461302}, FUTEX_BITSET_MATCH_ANY <unfinished ...>
[pid 37] <... futex resumed>) = -1 ETIMEDOUT (Connection timed out)
[pid 37] futex(0x7f4cd2427c88, FUTEX_WAKE_PRIVATE, 1) = 0
[pid 37] futex(0x7f4cd2427cd8, FUTEX_WAIT_BITSET_PRIVATE, 0, {tv_sec=17034, tv_nsec=872592294}, FUTEX_BITSET_MATCH_ANY <unfinished ...>
[pid 31] <... futex resumed>) = -1 ETIMEDOUT (Connection timed out)
[pid 31] futex(0x7f4cd2426c88, FUTEX_WAKE_PRIVATE, 1) = 0
[pid 31] futex(0x7f4cd2426cdc, FUTEX_WAIT_BITSET_PRIVATE, 0, {tv_sec=17034, tv_nsec=683966798}, FUTEX_BITSET_MATCH_ANY) = -1 ETIMEDOUT (Connection timed out)
[pid 31] futex(0x7f4cd2426c88, FUTEX_WAKE_PRIVATE, 1) = 0
[pid 31] futex(0x7f4cd2426cdc, FUTEX_WAIT_BITSET_PRIVATE, 0, {tv_sec=17034, tv_nsec=734532596}, FUTEX_BITSET_MATCH_ANY) = -1 ETIMEDOUT (Connection timed out)
[pid 31] futex(0x7f4cd2426c88, FUTEX_WAKE_PRIVATE, 1) = 0
[pid 31] futex(0x7f4cd2426cdc, FUTEX_WAIT_BITSET_PRIVATE, 0, {tv_sec=17034, tv_nsec=785097095}, FUTEX_BITSET_MATCH_ANY <unfinished ...>
[pid 30] <... futex resumed>) = -1 ETIMEDOUT (Connection timed out)
[pid 30] futex(0x7f4ccc09de28, FUTEX_WAKE_PRIVATE, 1) = 0
[pid 30] getrusage(RUSAGE_THREAD, {ru_utime={tv_sec=0, tv_usec=2928}, ru_stime={tv_sec=0, tv_usec=16148}, ...}) = 0
[pid 30] futex(0x7f4ccc09de78, FUTEX_WAIT_BITSET_PRIVATE, 0, {tv_sec=17035, tv_nsec=766518955}, FUTEX_BITSET_MATCH_ANY <unfinished ...>
[pid 31] <... futex resumed>) = -1 ETIMEDOUT (Connection timed out)
[pid 31] futex(0x7f4cd2426c88, FUTEX_WAKE_PRIVATE, 1) = 0
[pid 31] futex(0x7f4cd2426cdc, FUTEX_WAIT_BITSET_PRIVATE, 0, {tv_sec=17034, tv_nsec=835793657}, FUTEX_BITSET_MATCH_ANY) = -1 ETIMEDOUT (Connection timed out)
[pid 31] futex(0x7f4cd2426c88, FUTEX_WAKE_PRIVATE, 1) = 0
[pid 31] futex(0x7f4cd2426cdc, FUTEX_WAIT_BITSET_PRIVATE, 0, {tv_sec=17034, tv_nsec=886403757}, FUTEX_BITSET_MATCH_ANY <unfinished ...>
[pid 37] <... futex resumed>) = -1 ETIMEDOUT (Connection timed out)
[pid 37] futex(0x7f4cd2427c88, FUTEX_WAKE_PRIVATE, 1) = 0
[pid 37] futex(0x7f4cd2427cd8, FUTEX_WAIT_BITSET_PRIVATE, 0, {tv_sec=17035, tv_nsec=122891040}, FUTEX_BITSET_MATCH_ANY <unfinished ...>
[pid 31] <... futex resumed>) = -1 ETIMEDOUT (Connection timed out)
[pid 31] futex(0x7f4cd2426c88, FUTEX_WAKE_PRIVATE, 1) = 0
[pid 31] futex(0x7f4cd2426cdc, FUTEX_WAIT_BITSET_PRIVATE, 0, {tv_sec=17034, tv_nsec=937124759}, FUTEX_BITSET_MATCH_ANY) = -1 ETIMEDOUT (Connection timed out)
[pid 31] futex(0x7f4cd2426c88, FUTEX_WAKE_PRIVATE, 1) = 0
[pid 31] futex(0x7f4cd2426cdc, FUTEX_WAIT_BITSET_PRIVATE, 0, {tv_sec=17034, tv_nsec=987934566}, FUTEX_BITSET_MATCH_ANY) = -1 ETIMEDOUT (Connection timed out)
[pid 31] futex(0x7f4cd2426c88, FUTEX_WAKE_PRIVATE, 1) = 0
[pid 31] futex(0x7f4cd2426cdc, FUTEX_WAIT_BITSET_PRIVATE, 0, {tv_sec=17035, tv_nsec=38929376}, FUTEX_BITSET_MATCH_ANY <unfinished ...>
[pid 48] <... futex resumed>) = -1 ETIMEDOUT (Connection timed out)
[pid 48] futex(0x7f4ccd2fc690, FUTEX_WAKE_PRIVATE, 1) = 0
[pid 48] futex(0x7f4ccd2fc6e0, FUTEX_WAIT_BITSET_PRIVATE, 0, {tv_sec=17036, tv_nsec=30608560}, FUTEX_BITSET_MATCH_ANY <unfinished ...>
[pid 31] <... futex resumed>) = -1 ETIMEDOUT (Connection timed out)
[pid 31] futex(0x7f4cd2426c88, FUTEX_WAKE_PRIVATE, 1) = 0
[pid 31] futex(0x7f4cd2426cdc, FUTEX_WAIT_BITSET_PRIVATE, 0, {tv_sec=17035, tv_nsec=89418083}, FUTEX_BITSET_MATCH_ANY) = -1 ETIMEDOUT (Connection timed out)
[pid 31] futex(0x7f4cd2426c88, FUTEX_WAKE_PRIVATE, 1) = 0
[pid 31] futex(0x7f4cd2426cdc, FUTEX_WAIT_BITSET_PRIVATE, 0, {tv_sec=17035, tv_nsec=140025732}, FUTEX_BITSET_MATCH_ANY <unfinished ...>
[pid 37] <... futex resumed>) = -1 ETIMEDOUT (Connection timed out)
[pid 37] futex(0x7f4cd2427c88, FUTEX_WAKE_PRIVATE, 1) = 0
[pid 37] futex(0x7f4cd2427cd8, FUTEX_WAIT_BITSET_PRIVATE, 0, {tv_sec=17035, tv_nsec=373228335}, FUTEX_BITSET_MATCH_ANY <unfinished ...>
[pid 31] <... futex resumed>) = -1 ETIMEDOUT (Connection timed out)
[pid 31] futex(0x7f4cd2426c88, FUTEX_WAKE_PRIVATE, 1) = 0
[pid 31] futex(0x7f4cd2426cdc, FUTEX_WAIT_BITSET_PRIVATE, 0, {tv_sec=17035, tv_nsec=190672842}, FUTEX_BITSET_MATCH_ANY) = -1 ETIMEDOUT (Connection timed out)
[pid 31] futex(0x7f4cd2426c88, FUTEX_WAKE_PRIVATE, 1) = 0
[pid 31] futex(0x7f4cd2426cdc, FUTEX_WAIT_BITSET_PRIVATE, 0, {tv_sec=17035, tv_nsec=241125397}, FUTEX_BITSET_MATCH_ANY) = -1 ETIMEDOUT (Connection timed out)
[pid 31] futex(0x7f4cd2426c88, FUTEX_WAKE_PRIVATE, 1) = 0
[pid 31] futex(0x7f4cd2426cdc, FUTEX_WAIT_BITSET_PRIVATE, 0, {tv_sec=17035, tv_nsec=291704826}, FUTEX_BITSET_MATCH_ANY <unfinished ...>
[pid 32] <... futex resumed>) = -1 ETIMEDOUT (Connection timed out)
[pid 32] futex(0x7f4cd2425a88, FUTEX_WAKE_PRIVATE, 1) = 0
[pid 32] futex(0x7f4cd2425ad8, FUTEX_WAIT_BITSET_PRIVATE, 0, {tv_sec=17036, tv_nsec=255872754}, FUTEX_BITSET_MATCH_ANY <unfinished ...>
[pid 31] <... futex resumed>) = -1 ETIMEDOUT (Connection timed out)
[pid 31] futex(0x7f4cd2426c88, FUTEX_WAKE_PRIVATE, 1) = 0
[pid 31] futex(0x7f4cd2426cdc, FUTEX_WAIT_BITSET_PRIVATE, 0, {tv_sec=17035, tv_nsec=342507032}, FUTEX_BITSET_MATCH_ANY) = -1 ETIMEDOUT (Connection timed out)
[pid 31] futex(0x7f4cd2426c88, FUTEX_WAKE_PRIVATE, 1) = 0
[pid 31] futex(0x7f4cd2426cdc, FUTEX_WAIT_BITSET_PRIVATE, 0, {tv_sec=17035, tv_nsec=393103840}, FUTEX_BITSET_MATCH_ANY <unfinished ...>
[pid 37] <... futex resumed>) = -1 ETIMEDOUT (Connection timed out)
[pid 37] futex(0x7f4cd2427c88, FUTEX_WAKE_PRIVATE, 1) = 0
[pid 37] futex(0x7f4cd2427cd8, FUTEX_WAIT_BITSET_PRIVATE, 0, {tv_sec=17035, tv_nsec=623553631}, FUTEX_BITSET_MATCH_ANY <unfinished ...>
[pid 31] <... futex resumed>) = -1 ETIMEDOUT (Connection timed out)
[pid 31] futex(0x7f4cd2426c88, FUTEX_WAKE_PRIVATE, 1) = 0
[pid 31] futex(0x7f4cd2426cdc, FUTEX_WAIT_BITSET_PRIVATE, 0, {tv_sec=17035, tv_nsec=443714710}, FUTEX_BITSET_MATCH_ANY) = -1 ETIMEDOUT (Connection timed out)
[pid 31] futex(0x7f4cd2426c88, FUTEX_WAKE_PRIVATE, 1) = 0
[pid 31] futex(0x7f4cd2426cdc, FUTEX_WAIT_BITSET_PRIVATE, 0, {tv_sec=17035, tv_nsec=494310039}, FUTEX_BITSET_MATCH_ANY) = -1 ETIMEDOUT (Connection timed out)
[pid 31] futex(0x7f4cd2426c88, FUTEX_WAKE_PRIVATE, 1) = 0
[pid 31] futex(0x7f4cd2426cdc, FUTEX_WAIT_BITSET_PRIVATE, 0, {tv_sec=17035, tv_nsec=545164116}, FUTEX_BITSET_MATCH_ANY) = -1 ETIMEDOUT (Connection timed out)
[pid 31] futex(0x7f4cd2426c88, FUTEX_WAKE_PRIVATE, 1) = 0
[pid 31] futex(0x7f4cd2426cdc, FUTEX_WAIT_BITSET_PRIVATE, 0, {tv_sec=17035, tv_nsec=595918139}, FUTEX_BITSET_MATCH_ANY) = -1 ETIMEDOUT (Connection timed out)
[pid 31] futex(0x7f4cd2426c88, FUTEX_WAKE_PRIVATE, 1) = 0
[pid 31] futex(0x7f4cd2426cdc, FUTEX_WAIT_BITSET_PRIVATE, 0, {tv_sec=17035, tv_nsec=646633133}, FUTEX_BITSET_MATCH_ANY <unfinished ...>
[pid 37] <... futex resumed>) = -1 ETIMEDOUT (Connection timed out)
[pid 37] futex(0x7f4cd2427c88, FUTEX_WAKE_PRIVATE, 1) = 0
[pid 37] futex(0x7f4cd2427cd8, FUTEX_WAIT_BITSET_PRIVATE, 0, {tv_sec=17035, tv_nsec=873937177}, FUTEX_BITSET_MATCH_ANY <unfinished ...>
[pid 31] <... futex resumed>) = -1 ETIMEDOUT (Connection timed out)
[pid 31] futex(0x7f4cd2426c88, FUTEX_WAKE_PRIVATE, 1) = 0
[pid 31] futex(0x7f4cd2426cdc, FUTEX_WAIT_BITSET_PRIVATE, 0, {tv_sec=17035, tv_nsec=697080947}, FUTEX_BITSET_MATCH_ANY) = -1 ETIMEDOUT (Connection timed out)
[pid 31] futex(0x7f4cd2426c88, FUTEX_WAKE_PRIVATE, 1) = 0
[pid 31] futex(0x7f4cd2426cdc, FUTEX_WAIT_BITSET_PRIVATE, 0, {tv_sec=17035, tv_nsec=747559553}, FUTEX_BITSET_MATCH_ANY) = -1 ETIMEDOUT (Connection timed out)
[pid 31] futex(0x7f4cd2426c88, FUTEX_WAKE_PRIVATE, 1) = 0
[pid 31] futex(0x7f4cd2426cdc, FUTEX_WAIT_BITSET_PRIVATE, 0, {tv_sec=17035, tv_nsec=798138522}, FUTEX_BITSET_MATCH_ANY <unfinished ...>
[pid 30] <... futex resumed>) = -1 ETIMEDOUT (Connection timed out)
[pid 30] futex(0x7f4ccc09de28, FUTEX_WAKE_PRIVATE, 1) = 0
[pid 30] getrusage(RUSAGE_THREAD, {ru_utime={tv_sec=0, tv_usec=2928}, ru_stime={tv_sec=0, tv_usec=16366}, ...}) = 0
[pid 30] futex(0x7f4ccc09de78, FUTEX_WAIT_BITSET_PRIVATE, 0, {tv_sec=17036, tv_nsec=767207348}, FUTEX_BITSET_MATCH_ANY <unfinished ...>
[pid 31] <... futex resumed>) = -1 ETIMEDOUT (Connection timed out)
[pid 31] futex(0x7f4cd2426c88, FUTEX_WAKE_PRIVATE, 1) = 0
[pid 31] futex(0x7f4cd2426cdc, FUTEX_WAIT_BITSET_PRIVATE, 0, {tv_sec=17035, tv_nsec=848674299}, FUTEX_BITSET_MATCH_ANY) = -1 ETIMEDOUT (Connection timed out)
[pid 31] futex(0x7f4cd2426c88, FUTEX_WAKE_PRIVATE, 1) = 0
[pid 31] futex(0x7f4cd2426cdc, FUTEX_WAIT_BITSET_PRIVATE, 0, {tv_sec=17035, tv_nsec=899242628}, FUTEX_BITSET_MATCH_ANY <unfinished ...>
[pid 37] <... futex resumed>) = -1 ETIMEDOUT (Connection timed out)
[pid 37] futex(0x7f4cd2427c88, FUTEX_WAKE_PRIVATE, 1) = 0
[pid 37] futex(0x7f4cd2427cd8, FUTEX_WAIT_BITSET_PRIVATE, 0, {tv_sec=17036, tv_nsec=127306906}, FUTEX_BITSET_MATCH_ANY <unfinished ...>
[pid 31] <... futex resumed>) = -1 ETIMEDOUT (Connection timed out)
[pid 31] futex(0x7f4cd2426c88, FUTEX_WAKE_PRIVATE, 1) = 0
[pid 31] futex(0x7f4cd2426cdc, FUTEX_WAIT_BITSET_PRIVATE, 0, {tv_sec=17035, tv_nsec=950137416}, FUTEX_BITSET_MATCH_ANY) = -1 ETIMEDOUT (Connection timed out)
[pid 31] futex(0x7f4cd2426c88, FUTEX_WAKE_PRIVATE, 1) = 0
[pid 31] futex(0x7f4cd2426cdc, FUTEX_WAIT_BITSET_PRIVATE, 0, {tv_sec=17036, tv_nsec=725384}, FUTEX_BITSET_MATCH_ANY) = -1 ETIMEDOUT (Connection timed out)
[pid 31] futex(0x7f4cd2426c88, FUTEX_WAKE_PRIVATE, 1) = 0
[pid 31] futex(0x7f4cd2426cdc, FUTEX_WAIT_BITSET_PRIVATE, 0, {tv_sec=17036, tv_nsec=51241691}, FUTEX_BITSET_MATCH_ANY <unfinished ...>
[pid 48] <... futex resumed>) = -1 ETIMEDOUT (Connection timed out)
[pid 48] futex(0x7f4ccd2fc690, FUTEX_WAKE_PRIVATE, 1) = 0
[pid 48] futex(0x7f4ccd2fc6e0, FUTEX_WAIT_BITSET_PRIVATE, 0, {tv_sec=17037, tv_nsec=30607240}, FUTEX_BITSET_MATCH_ANY <unfinished ...>
[pid 31] <... futex resumed>) = -1 ETIMEDOUT (Connection timed out)
[pid 31] futex(0x7f4cd2426c88, FUTEX_WAKE_PRIVATE, 1) = 0
[pid 31] futex(0x7f4cd2426cdc, FUTEX_WAIT_BITSET_PRIVATE, 0, {tv_sec=17036, tv_nsec=101721927}, FUTEX_BITSET_MATCH_ANY^Cstrace: Process 9 detached
strace: Process 25 detached
strace: Process 26 detached
strace: Process 27 detached
strace: Process 28 detached
strace: Process 29 detached
strace: Process 30 detached
strace: Process 31 detached
<detached ...>
strace: Process 32 detached
strace: Process 33 detached
strace: Process 34 detached
strace: Process 35 detached
strace: Process 36 detached
strace: Process 37 detached
strace: Process 38 detached
strace: Process 39 detached
strace: Process 40 detached
strace: Process 41 detached
strace: Process 43 detached
strace: Process 44 detached
strace: Process 45 detached
strace: Process 46 detached
strace: Process 47 detached
strace: Process 48 detached
strace: Process 49 detached
strace: Process 52 detached
strace: Process 53 detached
strace: Process 54 detached
strace: Process 55 detached
strace: Process 56 detached
strace: Process 102 detached
from airbyte.
bryanasdev000
commented on June 30, 2024
CC: @herbertstos
from airbyte.
bryanasdev000
commented on June 30, 2024
Also running with connector 2.4.3.
from airbyte.
mkrawc
commented on June 30, 2024
@gisripa Would it be possible to apply the patch to Redshift destination prior the 2.0 version for those who for some reason don't want to or can't migrate to Destinations V2?
from airbyte.
evantahler
commented on June 30, 2024
@mkrawc - sorry, no. We've removed normalization from Airbyte and changed the format of the tables we produce. We only support the latest version of the connector. Keeping up-to-date is important for things like driver updates from Redshift, which was the root cause of this issue
from airbyte.
fkody1
commented on June 30, 2024
@gisripa , would it be possible to share a few examples of the slow queries run by the tests you commented out in AbstractRedshiftTypingDedupingTest.java ? I'd like to send them to AWS
from airbyte.
Related Issues (20)
- [EPIC] Support Platform<-->Connector Metadata Rollout
- Stripe: Duplicate records in a full rewrite stream HOT 2
- Source Facebook Marketing: argument of type 'NoneType' is not iterable
- [destination-weaviate] 'Default Vectorizer' none failure
- [destination-weaviate] PGVector embeddings interpreted as String? HOT 3
- [destination-weaviate] From Field - support multiple embeddings per schema? HOT 1
- [source-prestashop] API Error 500 on cart_rules Endpoint Due to Method Signature Mismatch in CartRule.php
- Error: couldn't find key DATABASE_USER in Secret airbyte-airbyte-secrets HOT 3
- [source-file] Error reading zipped CSV file with latin-1 encoding HOT 1
- Depoly Failed HOT 1
- airbyte-temporal failed to connect to RDS when rds.force_ssl enabled in RDS HOT 2
- Airbyte CDK: add logic for checkpointing state in the end of sync to Checkpoint Reader if records are not ordered by cursor field
- [source-posthog] attributes `properties` and `uuid` not extracted from API HOT 2
- Scheduler with Cron don't trigger when needed HOT 2
- [destination-bigquery] You must upgrade your platform version to use this connector version (latest version already) HOT 3
- Helm Chart AppVersion Update HOT 1
- Deploy Airbyte on Kubernetes using Helm Failed HOT 1
- [source-mongo] data loading only first time HOT 1
- Live tests: wire through a connector certification & connector type check to control which tests to run HOT 1
- [EPIC] Live tests Automation
Recommend Projects
-
React
A declarative, efficient, and flexible JavaScript library for building user interfaces.
-
Vue.js
🖖 Vue.js is a progressive, incrementally-adoptable JavaScript framework for building UI on the web.
-
Typescript
TypeScript is a superset of JavaScript that compiles to clean JavaScript output.
-
TensorFlow
An Open Source Machine Learning Framework for Everyone
-
Django
The Web framework for perfectionists with deadlines.
-
Laravel
A PHP framework for web artisans
-
D3
Bring data to life with SVG, Canvas and HTML. 📊📈🎉
-
Recommend Topics
-
javascript
JavaScript (JS) is a lightweight interpreted programming language with first-class functions.
-
web
Some thing interesting about web. New door for the world.
-
server
A server is a program made to process requests and deliver data to clients.
-
Machine learning
Machine learning is a way of modeling and interpreting data that allows a piece of software to respond intelligently.
-
Visualization
Some thing interesting about visualization, use data art
-
Game
Some thing interesting about game, make everyone happy.
Recommend Org
-
Facebook
We are working to build community through open source technology. NB: members must have two-factor auth.
-
Microsoft
Open source projects and samples from Microsoft.
-
Google
Google ❤️ Open Source for everyone.
-
Alibaba
Alibaba Open Source for everyone
-
D3
Data-Driven Documents codes.
-
Tencent
China tencent open source team.
from airbyte.