zlzhang0122 created FLINK-33657:
---
Summary: Insert message in top n without row number didn't
consider it's number and may not correct
Key: FLINK-33657
URL: https://issues.apache.org/jira/browse/F
zlzhang0122 created FLINK-28909:
---
Summary: Add ribbon filter policy option in
RocksDBConfiguredOptions
Key: FLINK-28909
URL: https://issues.apache.org/jira/browse/FLINK-28909
Project: Flink
zlzhang0122 created FLINK-28598:
---
Summary: ClusterEntryPoint can't get the real exit reason when
shutting down
Key: FLINK-28598
URL: https://issues.apache.org/jira/browse/FLINK-28598
Project:
Hello, sorry to bother but I want to know what’s the progress of this FLIP, we
have facing the similar problem in Flink and FlinkSQL batch mode because of the
resource shortage momentary and I think this may help us. Thanks!
On 2022/05/30 16:11:24 "Afonso, Nuno" wrote:
> Hello everyone,
>
>
Hello, sorry to bother but I want to know what’s the progress of this FLIP, we
have facing the similar problem in Flink and FlinkSQL batch mode because of the
resource shortage momentary and I think this may help us. Thanks!
On 2022/05/30 16:11:24 "Afonso, Nuno" wrote:
> Hello everyone,
>
>
zlzhang0122 created FLINK-28197:
---
Summary: Flink didn't deletes the YARN application files when the
submit is failed in application mode
Key: FLINK-28197
URL: https://issues.apache.org/jira/browse/FLINK-
zlzhang0122 created FLINK-27608:
---
Summary: Flink may throw PartitionNotFound Exception if the
downstream task reached Running state earlier than it's upstream task
Key: FLINK-27608
URL: https://issues.apach
zlzhang0122 created FLINK-26788:
---
Summary: AbstractDeserializationSchema should add cause when thow
a FlinkRuntimeException
Key: FLINK-26788
URL: https://issues.apache.org/jira/browse/FLINK-26788
zlzhang0122 created FLINK-26129:
---
Summary: Using fail method instead of kill method when yarn
application deployment error occures
Key: FLINK-26129
URL: https://issues.apache.org/jira/browse/FLINK-26129
zlzhang0122 created FLINK-25068:
---
Summary: Show the maximum parallelism (number of key groups) of a
job in Web UI
Key: FLINK-25068
URL: https://issues.apache.org/jira/browse/FLINK-25068
Project: Flink
zlzhang0122 created FLINK-24854:
---
Summary: StateHandleSerializationTest unit test error
Key: FLINK-24854
URL: https://issues.apache.org/jira/browse/FLINK-24854
Project: Flink
Issue Type: Bug
zlzhang0122 created FLINK-24542:
---
Summary: Expose the freshness metrics for kafka connector
Key: FLINK-24542
URL: https://issues.apache.org/jira/browse/FLINK-24542
Project: Flink
Issue Type
zlzhang0122 created FLINK-24306:
---
Summary: group by index throw SqlValidatorException
Key: FLINK-24306
URL: https://issues.apache.org/jira/browse/FLINK-24306
Project: Flink
Issue Type: Bug
zlzhang0122 created FLINK-24207:
---
Summary: Add support of KeyedState in TwoPhaseCommitSinkFunction
Key: FLINK-24207
URL: https://issues.apache.org/jira/browse/FLINK-24207
Project: Flink
Issue
zlzhang0122 created FLINK-24201:
---
Summary: HistoryServer didn't contain TaskManager Logs
Key: FLINK-24201
URL: https://issues.apache.org/jira/browse/FLINK-24201
Project: Flink
Issue Type
zlzhang0122 created FLINK-24122:
---
Summary: Add support to do clean in history server
Key: FLINK-24122
URL: https://issues.apache.org/jira/browse/FLINK-24122
Project: Flink
Issue Type
zlzhang0122 created FLINK-23849:
---
Summary: Support react to the node decommissioning change state on
yarn and do graceful restart
Key: FLINK-23849
URL: https://issues.apache.org/jira/browse/FLINK-23849
zlzhang0122 created FLINK-23622:
---
Summary: Default filesystem scheme improvement
Key: FLINK-23622
URL: https://issues.apache.org/jira/browse/FLINK-23622
Project: Flink
Issue Type: Improvement
zlzhang0122 created FLINK-23564:
---
Summary: Make taskmanager.out and taskmanager.err rollable
Key: FLINK-23564
URL: https://issues.apache.org/jira/browse/FLINK-23564
Project: Flink
Issue Type
zlzhang0122 created FLINK-23561:
---
Summary: Detail the container completed message
Key: FLINK-23561
URL: https://issues.apache.org/jira/browse/FLINK-23561
Project: Flink
Issue Type: Improvement
zlzhang0122 created FLINK-23194:
---
Summary: Cache and reuse the ContainerLaunchContext and accelarate
the progress of createTaskExecutorLaunchContext on yarn
Key: FLINK-23194
URL: https://issues.apache.org/jira
zlzhang0122 created FLINK-23189:
---
Summary: Count and fail the task when the disk is error on
JobManager
Key: FLINK-23189
URL: https://issues.apache.org/jira/browse/FLINK-23189
Project: Flink
zlzhang0122 created FLINK-22711:
---
Summary: NoClassDefFoundError when running Flink 1.11.1 in
openJDK8u292-b10
Key: FLINK-22711
URL: https://issues.apache.org/jira/browse/FLINK-22711
Project: Flink
zlzhang0122 created FLINK-22447:
---
Summary: when job failed and restore from rocksdb, it produced a
exception "Could not load the native RocksDB library"
Key: FLINK-22447
URL: https://issues.apache.org/j
zlzhang0122 created FLINK-22091:
---
Summary: env.java.home option didn't take effect in resource
negotiator
Key: FLINK-22091
URL: https://issues.apache.org/jira/browse/FLINK-22091
Project:
zlzhang0122 created FLINK-21165:
---
Summary: Timestamps/Watermarks chained erroneously with previous
operator
Key: FLINK-21165
URL: https://issues.apache.org/jira/browse/FLINK-21165
Project: Flink
zlzhang0122 created FLINK-21120:
---
Summary: Add support for ignore abnormal watermark
Key: FLINK-21120
URL: https://issues.apache.org/jira/browse/FLINK-21120
Project: Flink
Issue Type
zlzhang0122 created FLINK-20891:
---
Summary: SystemResourcesCounterTest may caused endless loop when
some error occured
Key: FLINK-20891
URL: https://issues.apache.org/jira/browse/FLINK-20891
Project
zlzhang0122 created FLINK-20815:
---
Summary: Elasticsearch7DynamicSinkITCase failed caused by pulling
docker image error
Key: FLINK-20815
URL: https://issues.apache.org/jira/browse/FLINK-20815
Project
zlzhang0122 created FLINK-20800:
---
Summary: HadoopViewFileSystemTruncateTest failure caused by
AssumptionViolatedException
Key: FLINK-20800
URL: https://issues.apache.org/jira/browse/FLINK-20800
Project
zlzhang0122 created FLINK-20735:
---
Summary: Support configurable log level
Key: FLINK-20735
URL: https://issues.apache.org/jira/browse/FLINK-20735
Project: Flink
Issue Type: Improvement
zlzhang0122 created FLINK-20618:
---
Summary: Some of the source operator subtasks will stuck when
flink job in critical backpressure
Key: FLINK-20618
URL: https://issues.apache.org/jira/browse/FLINK-20618
zlzhang0122 created FLINK-20571:
---
Summary: Add dynamic open/close LatencyMarksEmitter to support
online debug and monitoring
Key: FLINK-20571
URL: https://issues.apache.org/jira/browse/FLINK-20571
zlzhang0122 created FLINK-20424:
---
Summary: The percent of acknowledged checkpoint seems incorrect
Key: FLINK-20424
URL: https://issues.apache.org/jira/browse/FLINK-20424
Project: Flink
Issue
zlzhang0122 created FLINK-20367:
---
Summary: Show the in-use config of job to users
Key: FLINK-20367
URL: https://issues.apache.org/jira/browse/FLINK-20367
Project: Flink
Issue Type: Improvement
zlzhang0122 created FLINK-19876:
---
Summary: Latency metrics can merge chain task latency metrics to
reduce the number of latency metrics
Key: FLINK-19876
URL: https://issues.apache.org/jira/browse/FLINK-19876
zlzhang0122 created FLINK-19594:
---
Summary: SubTasks start index don't unified and may confuse users
Key: FLINK-19594
URL: https://issues.apache.org/jira/browse/FLINK-19594
Project: Flink
zlzhang0122 created FLINK-14411:
---
Summary: OrcTableSource read error
Key: FLINK-14411
URL: https://issues.apache.org/jira/browse/FLINK-14411
Project: Flink
Issue Type: Bug
Affects Versions
38 matches
Mail list logo
