[jira] [Created] (FLINK-33213) Flink SQL MinMax aggregations without retract messages when `where` condition exist

2023-10-09 Thread Sergey Paryshev (Jira) 
Sergey Paryshev created FLINK-33213:
---

 Summary: Flink SQL MinMax aggregations without retract messages 
when `where` condition exist
 Key: FLINK-33213
 URL: https://issues.apache.org/jira/browse/FLINK-33213
 Project: Flink
  Issue Type: Bug
  Components: Table SQL / Planner
Affects Versions: 1.17.1, 1.16.2, 1.15.4, 1.14.6, 1.13.6, 1.12.7
Reporter: Sergey Paryshev
 Fix For: 1.19.0


Currently Flink didn't take account `where` condition when calculate 
SqlMonotonicity for Calc/FlinkLogicalCalc/StreamPhysicalCalc.

 

To reproduce bug:



--
This message was sent by Atlassian Jira
(v8.20.10#820010)

[jira] [Created] (FLINK-35902) WebUI Metrics RangeError on huge parallelism

2024-07-25 Thread Sergey Paryshev (Jira) 
Sergey Paryshev created FLINK-35902:
---

 Summary: WebUI Metrics RangeError on huge parallelism
 Key: FLINK-35902
 URL: https://issues.apache.org/jira/browse/FLINK-35902
 Project: Flink
  Issue Type: Bug
  Components: Runtime / Web Frontend
Affects Versions: 1.19.1, 1.18.1, 1.17.2, 1.20.0
Reporter: Sergey Paryshev
 Attachments: flink-high-parallelism-webui.png

Displaying metrics with high parallelism results in a RangeError (similar to 
StackOverflow in JS). To reproduce the error locally it is enough to launch 
locally any job with parallelism of one of the operators 1600 or higher and go 
to the metrics menu.



--
This message was sent by Atlassian Jira
(v8.20.10#820010)

[jira] [Created] (FLINK-34109) FileSystem sink connector restore job from historical checkpoint failure

2024-01-16 Thread Sergey Paryshev (Jira) 
Sergey Paryshev created FLINK-34109:
---

 Summary: FileSystem sink connector restore job from historical 
checkpoint failure
 Key: FLINK-34109
 URL: https://issues.apache.org/jira/browse/FLINK-34109
 Project: Flink
  Issue Type: Bug
  Components: Connectors / FileSystem
Affects Versions: 1.17.2, 1.16.3, 1.18.0, 1.15.4, 1.14.6, 1.13.6, 1.12.7
Reporter: Sergey Paryshev


FileSystem connector sink can't restore job from historical checkpoint (when 
MAX_RETAINED_CHECKPOINTS > 1 and restroing checkpoint is not last)
{code:java}
java.io.UncheckedIOException: java.io.FileNotFoundException: File 
file:/tmp/parquet-test/output/.uncompacted-part-81340e1d-9004-4ce2-a45c-628d17919bbf-0-1
 does not exist or the user running Flink ('user') has insufficient permissions 
to access it.
    at 
org.apache.flink.connector.file.table.stream.compact.CompactCoordinator.lambda$coordinate$1(CompactCoordinator.java:165)
 ~[classes/:?]
    at 
org.apache.flink.connector.file.table.BinPacking.pack(BinPacking.java:40) 
~[classes/:?]
    at 
org.apache.flink.connector.file.table.stream.compact.CompactCoordinator.lambda$coordinate$2(CompactCoordinator.java:175)
 ~[classes/:?]
    at java.util.HashMap.forEach(HashMap.java:1290) ~[?:1.8.0_312]
    at 
org.apache.flink.connector.file.table.stream.compact.CompactCoordinator.coordinate(CompactCoordinator.java:171)
 ~[classes/:?]
    at 
org.apache.flink.connector.file.table.stream.compact.CompactCoordinator.commitUpToCheckpoint(CompactCoordinator.java:153)
 ~[classes/:?]
    at 
org.apache.flink.connector.file.table.stream.compact.CompactCoordinator.processElement(CompactCoordinator.java:143)
 ~[classes/:?]
    at 
org.apache.flink.streaming.runtime.tasks.OneInputStreamTask$StreamTaskNetworkOutput.emitRecord(OneInputStreamTask.java:262)
 ~[classes/:?]
    at 
org.apache.flink.streaming.runtime.io.AbstractStreamTaskNetworkInput.processElement(AbstractStreamTaskNetworkInput.java:155)
 ~[classes/:?]
    at 
org.apache.flink.streaming.runtime.io.AbstractStreamTaskNetworkInput.emitNext(AbstractStreamTaskNetworkInput.java:114)
 ~[classes/:?]
    at 
org.apache.flink.streaming.runtime.io.StreamOneInputProcessor.processInput(StreamOneInputProcessor.java:65)
 ~[classes/:?]
    at 
org.apache.flink.streaming.runtime.tasks.StreamTask.processInput(StreamTask.java:554)
 ~[classes/:?]
    at 
org.apache.flink.streaming.runtime.tasks.mailbox.MailboxProcessor.runMailboxLoop(MailboxProcessor.java:245)
 ~[classes/:?]
    at 
org.apache.flink.streaming.runtime.tasks.StreamTask.runMailboxLoop(StreamTask.java:848)
 ~[classes/:?]
    at 
org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:797) 
~[classes/:?]
    at 
org.apache.flink.runtime.taskmanager.Task.runWithSystemExitMonitoring(Task.java:954)
 ~[classes/:?]
    at 
org.apache.flink.runtime.taskmanager.Task.restoreAndInvoke(Task.java:933) 
~[classes/:?]
    at org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:747) 
~[classes/:?]
    at org.apache.flink.runtime.taskmanager.Task.run(Task.java:563) 
~[classes/:?]
    at java.lang.Thread.run(Thread.java:748) ~[?:1.8.0_312]
Caused by: java.io.FileNotFoundException: File 
file:/tmp/parquet-test/output/.uncompacted-part-81340e1d-9004-4ce2-a45c-628d17919bbf-0-1
 does not exist or the user running Flink ('user') has insufficient permissions 
to access it.
    at 
org.apache.flink.core.fs.local.LocalFileSystem.getFileStatus(LocalFileSystem.java:113)
 ~[classes/:?]
    at 
org.apache.flink.core.fs.SafetyNetWrapperFileSystem.getFileStatus(SafetyNetWrapperFileSystem.java:65)
 ~[classes/:?]
    at 
org.apache.flink.connector.file.table.stream.compact.CompactCoordinator.lambda$coordinate$1(CompactCoordinator.java:163)
 ~[classes/:?]
    ... 19 more {code}



--
This message was sent by Atlassian Jira
(v8.20.10#820010)