[jira] [Created] (FLINK-29546) UDF：Failed to compile split code, falling back to original code

2022-10-08 Thread Hui Wang (Jira) 
Hui Wang created FLINK-29546:


 Summary: UDF：Failed to compile split code, falling back to 
original code
 Key: FLINK-29546
 URL: https://issues.apache.org/jira/browse/FLINK-29546
 Project: Flink
  Issue Type: Bug
  Components: API / DataStream
Affects Versions: 1.15.0
 Environment: my pom:


    org.apache.flink
    flink-table-api-java-uber


    org.apache.flink
    flink-table-runtime


    org.apache.flink
    flink-table-planner-loader


jdk 1.8
Reporter: Hui Wang


2022-10-08 19:05:23 [GroupWindowAggregate[11] (1/1)#0] WARN  
org.apache.flink.table.runtime.generated.GeneratedClass -Failed to compile 
split code, falling back to original code
org.apache.flink.util.FlinkRuntimeException: 
org.apache.flink.api.common.InvalidProgramException: Table program cannot be 
compiled. This is a bug. Please file an issue.
    at 
org.apache.flink.table.runtime.generated.CompileUtils.compile(CompileUtils.java:94)
    at 
org.apache.flink.table.runtime.generated.GeneratedClass.compile(GeneratedClass.java:97)
    at 
org.apache.flink.table.runtime.generated.GeneratedClass.newInstance(GeneratedClass.java:68)
    at 
org.apache.flink.table.runtime.operators.window.AggregateWindowOperator.compileGeneratedCode(AggregateWindowOperator.java:148)
    at 
org.apache.flink.table.runtime.operators.window.WindowOperator.open(WindowOperator.java:274)
    at 
org.apache.flink.table.runtime.operators.window.AggregateWindowOperator.open(AggregateWindowOperator.java:139)
    at 
org.apache.flink.streaming.runtime.tasks.RegularOperatorChain.initializeStateAndOpenOperators(RegularOperatorChain.java:107)
    at 
org.apache.flink.streaming.runtime.tasks.StreamTask.restoreGates(StreamTask.java:700)
    at 
org.apache.flink.streaming.runtime.tasks.StreamTaskActionExecutor$1.call(StreamTaskActionExecutor.java:55)
    at 
org.apache.flink.streaming.runtime.tasks.StreamTask.restoreInternal(StreamTask.java:676)
    at 
org.apache.flink.streaming.runtime.tasks.StreamTask.restore(StreamTask.java:643)
    at 
org.apache.flink.runtime.taskmanager.Task.runWithSystemExitMonitoring(Task.java:948)
    at org.apache.flink.runtime.taskmanager.Task.restoreAndInvoke(Task.java:917)
    at org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:741)
    at org.apache.flink.runtime.taskmanager.Task.run(Task.java:563)
    at java.lang.Thread.run(Thread.java:748)
Caused by: 
org.apache.flink.shaded.guava30.com.google.common.util.concurrent.UncheckedExecutionException:
 org.apache.flink.api.common.InvalidProgramException: Table program cannot be 
compiled. This is a bug. Please file an issue.
    at 
org.apache.flink.shaded.guava30.com.google.common.cache.LocalCache$Segment.get(LocalCache.java:2051)
    at 
org.apache.flink.shaded.guava30.com.google.common.cache.LocalCache.get(LocalCache.java:3962)
    at 
org.apache.flink.shaded.guava30.com.google.common.cache.LocalCache$LocalManualCache.get(LocalCache.java:4859)
    at 
org.apache.flink.table.runtime.generated.CompileUtils.compile(CompileUtils.java:92)
    ... 15 common frames omitted
Caused by: org.apache.flink.api.common.InvalidProgramException: Table program 
cannot be compiled. This is a bug. Please file an issue.
    at 
org.apache.flink.table.runtime.generated.CompileUtils.doCompile(CompileUtils.java:107)
    at 
org.apache.flink.table.runtime.generated.CompileUtils.lambda$compile$0(CompileUtils.java:92)
    at 
org.apache.flink.shaded.guava30.com.google.common.cache.LocalCache$LocalManualCache$1.load(LocalCache.java:4864)
    at 
org.apache.flink.shaded.guava30.com.google.common.cache.LocalCache$LoadingValueReference.loadFuture(LocalCache.java:3529)
    at 
org.apache.flink.shaded.guava30.com.google.common.cache.LocalCache$Segment.loadSync(LocalCache.java:2278)
    at 
org.apache.flink.shaded.guava30.com.google.common.cache.LocalCache$Segment.lockedGetOrLoad(LocalCache.java:2155)
    at 
org.apache.flink.shaded.guava30.com.google.common.cache.LocalCache$Segment.get(LocalCache.java:2045)
    ... 18 common frames omitted
Caused by: org.codehaus.commons.compiler.CompileException: Line 17, Column 28: 
Cannot determine simple type name "org"
    at org.codehaus.janino.UnitCompiler.compileError(UnitCompiler.java:12211)
    at org.codehaus.janino.UnitCompiler.getReferenceType(UnitCompiler.java:6833)
    at org.codehaus.janino.UnitCompiler.getReferenceType(UnitCompiler.java:6594)
    at org.codehaus.janino.UnitCompiler.getReferenceType(UnitCompiler.java:6607)
    at org.codehaus.janino.UnitCompiler.getReferenceType(UnitCompiler.java:6607)
    at org.codehaus.janino.UnitCompiler.getReferenceType(UnitCompiler.java:6607)
    at org.codehaus.janino.UnitCompiler.getReferenceType(UnitCompiler.java:6607)
    at org.codehaus.janino.UnitCompiler.getReferenceType(UnitCompiler.java:6607)
    at org.codehaus.janino.UnitCompiler.getReferenceType(UnitCompiler.java:6607)
    at

[jira] [Created] (FLINK-23568) Plaintext Java Keystore Password Risks in the flink-conf.yaml File

2021-07-30 Thread Hui Wang (Jira) 
Hui Wang created FLINK-23568:


 Summary: Plaintext Java Keystore Password Risks in the 
flink-conf.yaml File
 Key: FLINK-23568
 URL: https://issues.apache.org/jira/browse/FLINK-23568
 Project: Flink
  Issue Type: Improvement
  Components: Client / Job Submission, Runtime / REST
Affects Versions: 1.11.3
Reporter: Hui Wang


When REST SSL is enabled, the plaintext password of the Java keystore needs to 
be configured in the flink-conf.yaml configuration of Flink, which poses great 
security risks. It is hoped that the community can provide the capability of 
encrypting and storing passwords in the flink-conf.yaml file.

{{}}
{code:java}
security.ssl.internal.keystore-password: keystore_password
security.ssl.internal.key-password: key_password
security.ssl.internal.truststore-password: truststore_password{code}
{{}}



--
This message was sent by Atlassian Jira
(v8.3.4#803005)

[jira] [Created] (FLINK-23444) Slf4j 1.7.15 has the high-risk vulnerability CVE-2018-8088

2021-07-20 Thread Hui Wang (Jira) 
Hui Wang created FLINK-23444:


 Summary: Slf4j 1.7.15 has the high-risk vulnerability CVE-2018-8088
 Key: FLINK-23444
 URL: https://issues.apache.org/jira/browse/FLINK-23444
 Project: Flink
  Issue Type: Improvement
  Components: API / Core
Affects Versions: 1.13.1, 1.12.3, 1.13.0, 1.11.3
Reporter: Hui Wang


Slf4j 1.7.15 has the high-risk vulnerability CVE-2018-8088 [1] . When can Flink 
be upgraded to a more secure version?

[1] https://nvd.nist.gov/vuln/detail/CVE-2018-8088



--
This message was sent by Atlassian Jira
(v8.3.4#803005)