[jira] [Created] (FLINK-34262) Support to set user specified labels for Rest Service Object

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

[jira] [Created] (FLINK-34142) TaskManager WorkingDirectory is not removed during shutdown

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

[jira] [Created] (FLINK-34132) Batch WordCount job fails when run with AdaptiveBatch scheduler

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

[jira] [Created] (FLINK-33957) Generic Log-Based Incremental Checkpoint fails when Task Local Recovery is enabled

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

[jira] [Created] (FLINK-33862) Flink Unit Test Failures on 1.18.0

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

[jira] [Created] (FLINK-33753) ContinuousFileReaderOperator consume records as mini batch

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

[jira] [Created] (FLINK-33536) Flink Table API CSV streaming sink throws "IOException: Stream closed"

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 Project:

[jira] [Created] (FLINK-33529) PyFlink fails with "No module named 'cloudpickle"

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 Issue

[jira] [Created] (FLINK-33523) DataType ARRAY fails to cast into Object[]

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

[jira] [Created] (FLINK-33473) Update Flink client to 1.18.0

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

[jira] [Created] (FLINK-33358) Flink SQL Client fails to start in Flink on YARN

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

[jira] [Created] (FLINK-32484) AdaptiveScheduler combined restart during scaling out

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

[jira] [Created] (FLINK-32253) Blocklist unblockResources does not update for pending containers

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

[jira] [Created] (FLINK-32173) Flink Job Metrics returns stale values in the first request after an update in the values

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

[jira] [Created] (FLINK-31196) Flink on YARN honors env.java.home

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

[jira] [Created] (FLINK-31080) Idle slots are not released due to a mismatch in time between DeclarativeSlotPoolService and SlotSharingSlotAllocator

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:

[jira] [Created] (FLINK-30377) CommonExecSink does not use ClientWrapperClassLoader while extracting Type from KeyedStream

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

[jira] [Created] (FLINK-30375) SqlClient leaks flink-table-planner jar under /tmp

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

[jira] [Created] (FLINK-30277) Allow PYTHONPATH of Python Worker to be configurable

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

[jira] [Created] (FLINK-30111) CacheRead fails with Intermediate data set with ID not found

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

[jira] [Created] (FLINK-30097) CachedDataStream java example in the document is not correct

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

[jira] [Created] (FLINK-29680) Create/Use Database with DatabaseName "default" fails

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 Project: Flink

[jira] [Created] (FLINK-29432) Replace GenericUDFNvl with GenericUDFCoalesce

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:

[jira] [Created] (FLINK-28406) Build fails on retrieving org.pentaho:pentaho-aggdesigner-algorithm

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

[jira] [Created] (FLINK-28216) Hadoop S3FileSystemFactory does not honor fs.s3.impl

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

[jira] [Created] (FLINK-28112) Misleading error message when Hadoop S3FileSystem is used and not at classpath

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

[jira] [Created] (FLINK-28102) Flink AkkaRpcSystemLoader fails when temporary directory is a symlink

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: