Received: from malur.postgresql.org ([217.196.149.56]) by arkaria.postgresql.org with esmtps (TLS1.3) tls TLS_ECDHE_RSA_WITH_AES_256_GCM_SHA384 (Exim 4.94.2) (envelope-from ) id 1sqPK7-009UFR-EF for pgsql-general@arkaria.postgresql.org; Tue, 17 Sep 2024 03:56:20 +0000 Received: from localhost ([127.0.0.1] helo=malur.postgresql.org) by malur.postgresql.org with esmtp (Exim 4.94.2) (envelope-from ) id 1sqPK4-003oRf-Ql for pgsql-general@arkaria.postgresql.org; Tue, 17 Sep 2024 03:56:16 +0000 Received: from magus.postgresql.org ([2a02:c0:301:0:ffff::29]) by malur.postgresql.org with esmtps (TLS1.3) tls TLS_ECDHE_RSA_WITH_AES_256_GCM_SHA384 (Exim 4.94.2) (envelope-from ) id 1sqPK4-003oR3-Ez for pgsql-general@lists.postgresql.org; Tue, 17 Sep 2024 03:56:16 +0000 Received: from mail-ej1-x630.google.com ([2a00:1450:4864:20::630]) by magus.postgresql.org with esmtps (TLS1.3) tls TLS_ECDHE_RSA_WITH_AES_128_GCM_SHA256 (Exim 4.94.2) (envelope-from ) id 1sqPK0-001aQP-Ia for pgsql-general@lists.postgresql.org; Tue, 17 Sep 2024 03:56:15 +0000 Received: by mail-ej1-x630.google.com with SMTP id a640c23a62f3a-a8a7903cb7dso331725366b.3 for ; Mon, 16 Sep 2024 20:56:13 -0700 (PDT) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=gmail.com; s=20230601; t=1726545372; x=1727150172; darn=lists.postgresql.org; h=cc:to:subject:message-id:date:from:in-reply-to:references :mime-version:from:to:cc:subject:date:message-id:reply-to; bh=HeA1SQsNqysTdVFX5vMm8bHdfHe4pHXRmYNIhobFdeg=; b=G8FtvmH/tXS9BuiKOO6FeEfbK5YgcTUfU9jjc4QpDfmLCeqgRK1pqUcnL87+6PlVZb AKPMvVO9UKL9ai+p6QCOWBONEhFCBlNHWtLu/YKDY0xTq99n2vu70tkQ+uHRaLDqd+G7 XPeetxgwwmHx3wBzlM+Z7EgtiNaHcAHE/Jo2JscxIjrng6Fq/dSK1BRiDAxOHMhx3u4T vDHTiJx1TxCB/nOXnIIezveMareDMrt2hSPiwATez0Sk/yzKV91SeAtjSSaQkFWoNcLH npmjyhXpsNZB2usUg03knB6BwDN7ahril7RoI4DdCY9G0AOuUA4y/mZ8GWi6/GvKXxjJ osoA== X-Google-DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=1e100.net; s=20230601; t=1726545372; x=1727150172; h=cc:to:subject:message-id:date:from:in-reply-to:references :mime-version:x-gm-message-state:from:to:cc:subject:date:message-id :reply-to; bh=HeA1SQsNqysTdVFX5vMm8bHdfHe4pHXRmYNIhobFdeg=; b=K2H9+fNTmqKwaRrIYEE0IsIqdMUYrjS+DW1SY/knB6GiTUHIiESmdWi+9BLDZUM7dZ kBcdgyF+bC3SSSjo8fhrnMtlw61Ug0bKgKi+h521NQfotENsb5uGIC6WIEopMaFVRuGb 1pRhUTozSgwsivXsfWHsrDXsqEAtPd5kJMQ2Jt6MA83QG2JrWGeBDpIAtYqHehy4w2cE sV7ypfFRhr0vTXvJ7OEs2WGMJ6GYKHMH+X8oWMfndNaYETQcS60vghEXddJ2WuYZ/kFW 3xs6DEMtVsIOZC5BS6tw3IXm8wkmuEN6d4iderhVJek7oNvaAnavGQ/bfoyPVq/VlfF9 0zww== X-Gm-Message-State: AOJu0YwMItGifuzflD6zuEeNfS/bsW1znc3DoLVTyX+RpMMqibk7wdzh MozcTQ32LP7N7I82s/xiyjyOX9rUr9LzgdPpl+ZqFPYQER2EjckqtneikADet2WcuqVUHiVEL7L Y4fA8+w6ZmOLdWsThU/sQNKZplCqa2blf X-Google-Smtp-Source: AGHT+IEcoY16A+tqy2P4VIDphNW7vkEVKTbFqZKs9bzXQyzGeczlbgxWNPi1TIPkrVp1bxYn2NB/CRKDCK7o9Y8gFBo= X-Received: by 2002:a05:6402:901:b0:5c2:5f43:3e8 with SMTP id 4fb4d7f45d1cf-5c41e0968f3mr19191701a12.9.1726545371357; Mon, 16 Sep 2024 20:56:11 -0700 (PDT) MIME-Version: 1.0 References: <3dddea5e-52ab-4075-970d-a87b0c921ae7@aklaver.com> In-Reply-To: <3dddea5e-52ab-4075-970d-a87b0c921ae7@aklaver.com> From: veem v Date: Tue, 17 Sep 2024 09:25:59 +0530 Message-ID: Subject: Re: IO related waits To: Adrian Klaver , Christophe Pettus Cc: pgsql-general Content-Type: multipart/alternative; boundary="0000000000008c6633062248ab76" List-Id: List-Help: List-Subscribe: List-Post: List-Owner: List-Archive: Archived-At: Precedence: bulk --0000000000008c6633062248ab76 Content-Type: text/plain; charset="UTF-8" On Tue, 17 Sept 2024 at 03:41, Adrian Klaver wrote: > > Are you referring to this?: > > > https://nightlies.apache.org/flink/flink-docs-release-1.20/docs/dev/datastream/operators/asyncio/ > > If not then you will need to be more specific. > > Yes, I was referring to this one. So what can be the caveats in this approach, considering transactions meant to be ACID compliant as financial transactions.Additionally I was not aware of the parameter "synchronous_commit" in DB side which will mimic the synchronous commit. Would both of these mimic the same asynchronous behaviour and achieves the same, which means the client data load throughput will increase because the DB will not wait for those data to be written to the WAL and give a confirmation back to the client and also the client will not wait for the DB to give a confirmation back on the data to be persisted in the DB or not?. Also, as in the backend the flushing of the WAL to the disk has to happen anyway(just that it will be delayed now), so can this method cause contention in the database storage side if the speed in which the data gets ingested from the client is not getting written to the disk , and if it can someway impact the data consistency for the read queries? --0000000000008c6633062248ab76 Content-Type: text/html; charset="UTF-8" Content-Transfer-Encoding: quoted-printable


=
On Tue, 17 Sept 2024 at 03:41, Adrian= Klaver <adrian.klaver@akla= ver.com> wrote:

Are you referring to this?:

htt= ps://nightlies.apache.org/flink/flink-docs-release-1.20/docs/dev/datastream= /operators/asyncio/

If not then you will need to be more specific.

Yes, I was referring to this one. So what can be the caveats in= this approach, considering transactions meant to be ACID compliant as fina= ncial transactions.Additionally I was not aware of the parameter "sync= hronous_commit" in DB side which will mimic the synchronous commit.

Would both of these mimic the same asynchronous beha= viour and achieves the same, which means the client data load throughput=C2= =A0will increase because the DB will not wait for those data to be written = to the WAL and give a confirmation back to the client and also the client w= ill not wait for the DB to give a confirmation back on the data to be persi= sted in the DB or not?. Also,=C2=A0as in the backend the flushing of the WA= L to the disk has to happen anyway(just that it will be delayed now), so ca= n this method cause contention in the database=C2=A0storage side if the spe= ed in which=C2=A0the data gets ingested from the client is not getting writ= ten to the=C2=A0disk , and if it can someway impact the data consistency fo= r the read queries?
--0000000000008c6633062248ab76--