[jira] [Created] (FLINK-22979) JobMasterExecutionDeploymentReconciliationTest error while setting up logger

2021-06-14 Thread Dawid Wysakowicz (Jira)
Dawid Wysakowicz created FLINK-22979: Summary: JobMasterExecutionDeploymentReconciliationTest error while setting up logger Key: FLINK-22979 URL: https://issues.apache.org/jira/browse/FLINK-22979

[jira] [Created] (FLINK-22980) FileExecutionGraphInfoStoreTest hangs on azure

2021-06-14 Thread Dawid Wysakowicz (Jira)
Dawid Wysakowicz created FLINK-22980: Summary: FileExecutionGraphInfoStoreTest hangs on azure Key: FLINK-22980 URL: https://issues.apache.org/jira/browse/FLINK-22980 Project: Flink Issue

[jira] [Created] (FLINK-22981) FlinkKafkaProducerMigrationTest.testRestoreProducer fail with timeout

2021-06-14 Thread Dawid Wysakowicz (Jira)
Dawid Wysakowicz created FLINK-22981: Summary: FlinkKafkaProducerMigrationTest.testRestoreProducer fail with timeout Key: FLINK-22981 URL: https://issues.apache.org/jira/browse/FLINK-22981 Projec

Re: [DISCUSS]FLIP-150: Introduce Hybrid Source

2021-06-14 Thread Arvid Heise
Hi Thomas, Thanks for bringing this up. I think this is a tough nut to crack :/. Imho 1 and 3 or 1+3 can work but it is ofc a pity if the source implementor is not aware of HybridSource. I'm also worried that we may not have a universal interface to specify start offset/time. I guess it also would

[jira] [Created] (FLINK-22982) java.lang.ClassCastException when using Python UDF

2021-06-14 Thread Jira
Maciej Bryński created FLINK-22982: -- Summary: java.lang.ClassCastException when using Python UDF Key: FLINK-22982 URL: https://issues.apache.org/jira/browse/FLINK-22982 Project: Flink Issue

[jira] [Created] (FLINK-22983) Support lazy evaluation in Flink SQL

2021-06-14 Thread Jira
Maciej Bryński created FLINK-22983: -- Summary: Support lazy evaluation in Flink SQL Key: FLINK-22983 URL: https://issues.apache.org/jira/browse/FLINK-22983 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-22984) UnsupportedOperationException when using Python UDF to generate watermark

2021-06-14 Thread Jira
Maciej Bryński created FLINK-22984: -- Summary: UnsupportedOperationException when using Python UDF to generate watermark Key: FLINK-22984 URL: https://issues.apache.org/jira/browse/FLINK-22984 Project

Got multiple issues when running the tutorial project "table-walkthrough" on IDEA

2021-06-14 Thread Lingfeng Pu
Hi, I'm currently trying to debug the tutorial project "table-walkthrough" on IDEA on a standalone Flink environment. I installed the required software (Java 8 or 11, Maven, Docker) according to the tutorial. I'll provide some key environment info about the running environment before describing th

Security Vulnerabilities with Flink OpenJDK Docker Image

2021-06-14 Thread Daniel Moore
Hello All, We have been implementing a solution using the Flink image from https://github.com/apache/flink-docker/blob/master/1.13/scala_2.12-java11-debian/Dockerfile and it got flagged by our image repository for 3 major security vulnerabilities: CVE-2017-8804 CVE-2019-25013 CVE-2021-33574 A

[jira] [Created] (FLINK-22985) sql syntax, NullPointerException

2021-06-14 Thread simenliuxing (Jira)
simenliuxing created FLINK-22985: Summary: sql syntax, NullPointerException Key: FLINK-22985 URL: https://issues.apache.org/jira/browse/FLINK-22985 Project: Flink Issue Type: Bug Co

[jira] [Created] (FLINK-22986) FileExecutionGraphInfoStoreTest.testPutSuspendedJobOnClusterShutdown hangs on azure

2021-06-14 Thread Xintong Song (Jira)
Xintong Song created FLINK-22986: Summary: FileExecutionGraphInfoStoreTest.testPutSuspendedJobOnClusterShutdown hangs on azure Key: FLINK-22986 URL: https://issues.apache.org/jira/browse/FLINK-22986

[jira] [Created] (FLINK-22987) Scala suffix check isn't working

2021-06-14 Thread Chesnay Schepler (Jira)
Chesnay Schepler created FLINK-22987: Summary: Scala suffix check isn't working Key: FLINK-22987 URL: https://issues.apache.org/jira/browse/FLINK-22987 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-22988) Port TestingUtils to Java

2021-06-14 Thread Chesnay Schepler (Jira)
Chesnay Schepler created FLINK-22988: Summary: Port TestingUtils to Java Key: FLINK-22988 URL: https://issues.apache.org/jira/browse/FLINK-22988 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-22989) Port Tasks to Java

2021-06-14 Thread Chesnay Schepler (Jira)
Chesnay Schepler created FLINK-22989: Summary: Port Tasks to Java Key: FLINK-22989 URL: https://issues.apache.org/jira/browse/FLINK-22989 Project: Flink Issue Type: Sub-task Com

[jira] [Created] (FLINK-22990) Remove unused ScalaUtils/TestingMessages

2021-06-14 Thread Chesnay Schepler (Jira)
Chesnay Schepler created FLINK-22990: Summary: Remove unused ScalaUtils/TestingMessages Key: FLINK-22990 URL: https://issues.apache.org/jira/browse/FLINK-22990 Project: Flink Issue Type:

[jira] [Created] (FLINK-22991) Use Optional in NetworkBufferPool

2021-06-14 Thread Chesnay Schepler (Jira)
Chesnay Schepler created FLINK-22991: Summary: Use Optional in NetworkBufferPool Key: FLINK-22991 URL: https://issues.apache.org/jira/browse/FLINK-22991 Project: Flink Issue Type: Sub-tas

[jira] [Created] (FLINK-22992) Move SSLUtils#is*Enabled to SecurityOptions

2021-06-14 Thread Chesnay Schepler (Jira)
Chesnay Schepler created FLINK-22992: Summary: Move SSLUtils#is*Enabled to SecurityOptions Key: FLINK-22992 URL: https://issues.apache.org/jira/browse/FLINK-22992 Project: Flink Issue Typ

[jira] [Created] (FLINK-22993) CompactFileWriter won't emit EndCheckpoint with Long.MAX_VALUE checkpointId

2021-06-14 Thread luoyuxia (Jira)
luoyuxia created FLINK-22993: Summary: CompactFileWriter won't emit EndCheckpoint with Long.MAX_VALUE checkpointId Key: FLINK-22993 URL: https://issues.apache.org/jira/browse/FLINK-22993 Project: Flink