baybatu

If you got following error when you try to run your Flink job on local.

Caused by: java.lang.ClassNotFoundException: org.apache.flink.api.scala.typeutils.CaseClassTypeInfo

Then change your provided scoped Flink dependencies to compile scope.

On IntelliJ it can be done using Project Structure window:

baybatu

/*
* Splits array into subarrays.
* count parameter indicates that how many item per subarray contains.
* Example usage: splitIntoSubArray([1,2,3,4,5], 2) -> [[1, 2], [3, 4], [5]]
*/
function splitIntoSubArray(arr, count) {
  var newArray = [];
  while (arr.length > 0) {
    newArray.push(arr.splice(0, count)); 
  }

baybatu

Assuming SPARK_HOME=/spark246

• Put logback.xml into $SPARK_HOME/conf
• Create additionaljars directory under $SPARK_HOME
• Download required logback and logback-gelf related jars into additionaljars directory
  • log4j-over-slf4j-1.7.30.jar
  • logback-core-1.2.3.jar
  • logback-classic-1.2.3.jar
  • logback-gelf-2.2.0.jar
• Tell Spark to use custom jar folder additionaljars as primarily classpath folder using following spark-submit parameters:

baybatu

git tag VERSION
git push origin tag VERSION
pod trunk push

baybatu

 #!/bin/bash
sudo kill -9 `ps ax|grep 'coreaudio[a-z]' | awk '{print $1}'

baybatu

Required jars:

• log4j2 (comes with flink)
• log4j2-logstash-layout (https://github.com/vy/log4j2-logstash-layout)
• jackson-core (my version is 2.12.0)
• jackson-databind (my version is 2.12.0)
• jackson-annotations (my version is 2.12.0)

Note: It seems that since Log4j 2.14.0, we do not need to add jackson dependencies according to log4j documentation. However I need to stick with log4j2 version comes with Flink for now, so I have not tested it yet.

baybatu

MJML responsive email templateler için bir markup dili.

İşin güzel yanı outlook, gmail gibi client bazlı css vs yazmamız gereken yerler için de kullanılabilir.

https://mjml.io/

Kaynak: https://twitter.com/simtoalev/status/1272912198193614849

baybatu

• Kowl: https://github.com/cloudhut/kowl
• Conduktor: https://www.conduktor.io

baybatu

import com.twitter.finagle.http2.param.FrameLoggerNamePrefix
val service =
        Http
          .client
          .withLabel("service-label")
          .configured(FrameLoggerNamePrefix(this.getClass.getName))
          .withHttp2
          .newService("localhost:8080")

baybatu

Run shell in a container without running entrypoint script set by the image build

docker run -it --entrypoint sh IMAGE_NAME

Sources

• https://stackoverflow.com/a/44769468
• https://docs.docker.com/engine/reference/run/#entrypoint-default-command-to-execute-at-runtime