Prabhu Joseph created FLINK-34262:
-
Summary: Support to set user specified labels for Rest Service
Object
Key: FLINK-34262
URL: https://issues.apache.org/jira/browse/FLINK-34262
Project: Flink
Prabhu Joseph created FLINK-34142:
-
Summary: TaskManager WorkingDirectory is not removed during
shutdown
Key: FLINK-34142
URL: https://issues.apache.org/jira/browse/FLINK-34142
Project: Flink
Prabhu Joseph created FLINK-34132:
-
Summary: Batch WordCount job fails when run with AdaptiveBatch
scheduler
Key: FLINK-34132
URL: https://issues.apache.org/jira/browse/FLINK-34132
Project: Flink
Prabhu Joseph created FLINK-33957:
-
Summary: Generic Log-Based Incremental Checkpoint fails when Task
Local Recovery is enabled
Key: FLINK-33957
URL: https://issues.apache.org/jira/browse/FLINK-33957
Prabhu Joseph created FLINK-33862:
-
Summary: Flink Unit Test Failures on 1.18.0
Key: FLINK-33862
URL: https://issues.apache.org/jira/browse/FLINK-33862
Project: Flink
Issue Type: Bug
idence do you have that this operator is causing the timeout?
> Typically this operator should handle the checkpoint barrier quickly and
> proceed with reading (ignoring alignment). In my early days I suspected a
> similar issue but it was other checkpoint alignment issues.
>
> Darin
>
> On We
g-java/src/main/java/org/apache/flink/streaming/api/functions/source/ContinuousFileReaderOperator.java#L407
> >,
> > the operator supports checkpointable input splits, meaning it'll save
> it's
> > place within a file split. This would only be possible if the reader can
> be
&
check the mailbox executor after every record read?
>
> On Tue, Dec 5, 2023 at 6:48 AM Prabhu Joseph (Jira)
> wrote:
>
> > Prabhu Joseph created FLINK-33753:
> > -
> >
> > Summary: Continuous
Prabhu Joseph created FLINK-33753:
-
Summary: ContinuousFileReaderOperator consume records as mini batch
Key: FLINK-33753
URL: https://issues.apache.org/jira/browse/FLINK-33753
Project: Flink
Prabhu Joseph created FLINK-33536:
-
Summary: Flink Table API CSV streaming sink throws "IOException:
Stream closed"
Key: FLINK-33536
URL: https://issues.apache.org/jira/browse/FLINK-33536
Prabhu Joseph created FLINK-33529:
-
Summary: PyFlink fails with "No module named 'cloudpickle"
Key: FLINK-33529
URL: https://issues.apache.org/jira/browse/FLINK-33529
Project: Flink
Prabhu Joseph created FLINK-33523:
-
Summary: DataType ARRAY fails to cast into Object[]
Key: FLINK-33523
URL: https://issues.apache.org/jira/browse/FLINK-33523
Project: Flink
Issue Type: Bug
Prabhu Joseph created FLINK-33473:
-
Summary: Update Flink client to 1.18.0
Key: FLINK-33473
URL: https://issues.apache.org/jira/browse/FLINK-33473
Project: Flink
Issue Type: Improvement
Prabhu Joseph created FLINK-33358:
-
Summary: Flink SQL Client fails to start in Flink on YARN
Key: FLINK-33358
URL: https://issues.apache.org/jira/browse/FLINK-33358
Project: Flink
Issue
*+1 (non-binding)*
Thanks for working on this. We have seen good improvement during the cool
down period with this feature.
Below are details on the test results from one of our clusters:
On a scale-out operation, 8 new nodes were added one by one with a gap of
~30 seconds. There were 8 restarts
Prabhu Joseph created FLINK-32484:
-
Summary: AdaptiveScheduler combined restart during scaling out
Key: FLINK-32484
URL: https://issues.apache.org/jira/browse/FLINK-32484
Project: Flink
Prabhu Joseph created FLINK-32253:
-
Summary: Blocklist unblockResources does not update for pending
containers
Key: FLINK-32253
URL: https://issues.apache.org/jira/browse/FLINK-32253
Project: Flink
Prabhu Joseph created FLINK-32173:
-
Summary: Flink Job Metrics returns stale values in the first
request after an update in the values
Key: FLINK-32173
URL: https://issues.apache.org/jira/browse/FLINK-32173
Prabhu Joseph created FLINK-31196:
-
Summary: Flink on YARN honors env.java.home
Key: FLINK-31196
URL: https://issues.apache.org/jira/browse/FLINK-31196
Project: Flink
Issue Type: Improvement
@Gyula
>> It is easier to make the operator work with jobs running in different
types of clusters than to take the
autoscaler module itself and plug that in somewhere else.
Our (part of Samrat's team) main problem is to leverage the AutoScaler
Recommendation Engine part of
Prabhu Joseph created FLINK-31080:
-
Summary: Idle slots are not released due to a mismatch in time
between DeclarativeSlotPoolService and SlotSharingSlotAllocator
Key: FLINK-31080
URL: https://issues.apache.org
Prabhu Joseph created FLINK-30377:
-
Summary: CommonExecSink does not use ClientWrapperClassLoader
while extracting Type from KeyedStream
Key: FLINK-30377
URL: https://issues.apache.org/jira/browse/FLINK-30377
Prabhu Joseph created FLINK-30375:
-
Summary: SqlClient leaks flink-table-planner jar under /tmp
Key: FLINK-30375
URL: https://issues.apache.org/jira/browse/FLINK-30375
Project: Flink
Issue
Prabhu Joseph created FLINK-30277:
-
Summary: Allow PYTHONPATH of Python Worker to be configurable
Key: FLINK-30277
URL: https://issues.apache.org/jira/browse/FLINK-30277
Project: Flink
Issue
Prabhu Joseph created FLINK-30111:
-
Summary: CacheRead fails with Intermediate data set with ID not
found
Key: FLINK-30111
URL: https://issues.apache.org/jira/browse/FLINK-30111
Project: Flink
Prabhu Joseph created FLINK-30097:
-
Summary: CachedDataStream java example in the document is not
correct
Key: FLINK-30097
URL: https://issues.apache.org/jira/browse/FLINK-30097
Project: Flink
Prabhu Joseph created FLINK-29680:
-
Summary: Create/Use Database with DatabaseName "default" fails
Key: FLINK-29680
URL: https://issues.apache.org/jira/browse/FLINK-29680
Proj
Prabhu Joseph created FLINK-29432:
-
Summary: Replace GenericUDFNvl with GenericUDFCoalesce
Key: FLINK-29432
URL: https://issues.apache.org/jira/browse/FLINK-29432
Project: Flink
Issue Type
Prabhu Joseph created FLINK-28406:
-
Summary: Build fails on retrieving
org.pentaho:pentaho-aggdesigner-algorithm
Key: FLINK-28406
URL: https://issues.apache.org/jira/browse/FLINK-28406
Project: Flink
Prabhu Joseph created FLINK-28216:
-
Summary: Hadoop S3FileSystemFactory does not honor fs.s3.impl
Key: FLINK-28216
URL: https://issues.apache.org/jira/browse/FLINK-28216
Project: Flink
Issue
Prabhu Joseph created FLINK-28112:
-
Summary: Misleading error message when Hadoop S3FileSystem is used
and not at classpath
Key: FLINK-28112
URL: https://issues.apache.org/jira/browse/FLINK-28112
Prabhu Joseph created FLINK-28102:
-
Summary: Flink AkkaRpcSystemLoader fails when temporary directory
is a symlink
Key: FLINK-28102
URL: https://issues.apache.org/jira/browse/FLINK-28102
Project
Great, thanks for the details.
On Tue, May 24, 2022 at 8:07 AM Sriram Ganesh wrote:
> Hi Prabhu,
>
> For detail understanding check it out this link:
>
> https://www.alibabacloud.com/blog/in-depth-analysis-of-flink-job-execution-flink-advanced-tutorials_596633
>
> Thanks,
> Sriram G
>
> On Tue,
Hi, Could someone give an idea of what these graphs - StreamGraph, JobGraph
and ExecutionGraph are and their differences.
Thanks, Prabhu Joseph
ify resources/log4j2-test.properties.
>
> `rootLogger.level = OFF` => `rootLogger.level = INFO`
>
> Best,
> Jingsong
>
> On Sun, May 8, 2022 at 7:29 PM Prabhu Joseph
> wrote:
> >
> > Hi, I am trying to understand a Flink Unit Test case and so was checking
>
will be present.
mvn -Dtest="StreamGraphGeneratorTest" -DfailIfNoTests=false test
Thanks,
Prabhu Joseph
36 matches
Mail list logo
