mberchon

+1 Please provide SSO support for AWS-ECS-CLI so DEVs & OPs can have an homogeneous authentication experience across CLIs

### Unit test ``` def `byte buffer wrapping`(): Unit = { val payload = s"My test payload ${UUID.randomUUID().toString}".padTo(1024*1000,'X').getBytes(StandardCharsets.UTF_8) val partition = UUID.randomUUID().toString val req = PutRecordsRequestEntry .builder() .partitionKey(partition) .data(SdkBytes.fromByteArray(payload)) .build()...

My work around: add throughput throttle flow on the upstream with the following weight function ``` def weightFunction(request:PutRecordsRequestEntry):Int = request.partitionKey().length+request.data().asByteArray().length .throttle(nbShard*1024*1024,1 second, nbShard*1024*1024, { case (req,_) => weightFunction(req)},1 second,ThrottleMode.Shaping) .via(KinesisFlow.withContext[Ctx](streamName,...

Hi @dennyglee Is there an ETA for this so powerful feature ? :-)

Hello +1 `[error] scalafix.internal.v1.FileException: unexpected error processing file /Users/math/MYCOM-WS/aiops-bda-spe-sandbox/bda-spe-spark/src/test/scala/com/mycomosi/bda/spe/spark/anomaly/objects/AnomalyObjectsSerDeTest.scala [error] Caused by: scala.meta.internal.classpath.MissingSymbolException: missing symbol: org.scalameter [error] at scala.meta.internal.scalacp.SymbolOps$XtensionSymbolSSpec.descriptor(SymbolOps.scala:121) [error] at scala.meta.internal.scalacp.SymbolOps$XtensionSymbolSSymbol.uncached$1(SymbolOps.scala:19) [error] at scala.meta.internal.scalacp.SymbolOps$XtensionSymbolSSymbol.toSemantic(SymbolOps.scala:26) [error] at scala.meta.internal.scalacp.SymbolOps$XtensionSymbol.ssym(SymbolOps.scala:187) [error] at...

> Hello > > +1 > > `[error] scalafix.internal.v1.FileException: unexpected error processing file /Users/math/MYCOM-WS/aiops-bda-spe-sandbox/bda-spe-spark/src/test/scala/com/mycomosi/bda/spe/spark/anomaly/objects/AnomalyObjectsSerDeTest.scala [error] Caused by: scala.meta.internal.classpath.MissingSymbolException: missing symbol: org.scalameter [error] at scala.meta.internal.scalacp.SymbolOps$XtensionSymbolSSpec.descriptor(SymbolOps.scala:121) [error] at scala.meta.internal.scalacp.SymbolOps$XtensionSymbolSSymbol.uncached$1(SymbolOps.scala:19) [error] at scala.meta.internal.scalacp.SymbolOps$XtensionSymbolSSymbol.toSemantic(SymbolOps.scala:26)...

FYI, our team is troubleshooting a similar weird behavior between scala-java8-compat and AWS SDK V2 Context: - scala 2.12, - AWS SDK 2.17.138 involving cloudwatch, cloudwatchlogs & aws-crt-client & async...