Guowei Ma created FLINK-21853:
-
Summary: Running HA per-job cluster (rocks, non-incremental)
end-to-end test could not finished in 900 seconds
Key: FLINK-21853
URL: https://issues.apache.org/jira/browse/FLINK-21853
Jingsong Lee created FLINK-21852:
Summary: Introduce SupportsAnyNull to BinaryRowData
Key: FLINK-21852
URL: https://issues.apache.org/jira/browse/FLINK-21852
Project: Flink
Issue Type:
Jingsong Lee created FLINK-21851:
Summary: Refactor BinaryRowDataKeySelector in testing
Key: FLINK-21851
URL: https://issues.apache.org/jira/browse/FLINK-21851
Project: Flink
Issue Type:
Yingjie Cao created FLINK-21850:
---
Summary: Improve document and config description of sort-merge
blocking shuffle
Key: FLINK-21850
URL: https://issues.apache.org/jira/browse/FLINK-21850
Project: Flink
Nicholas Jiang created FLINK-21849:
--
Summary: 'SHOW MODULES' tests for CliClientITCase lack the default
module test case
Key: FLINK-21849
URL: https://issues.apache.org/jira/browse/FLINK-21849
wangbin created FLINK-21848:
---
Summary: table api -window opening for event time。NullPointer
Key: FLINK-21848
URL: https://issues.apache.org/jira/browse/FLINK-21848
Project: Flink
Issue Type:
Thanks for checking, Till.
I have a follow up question for #2, do you know why the same job cannot
show up at the entropy checkpoint in Version 1.9.
For example:
*When it's running in v1.11, checkpoint path is: *
s3a://{bucket name}/dev/checkpoints/_entropy_/{job_id}/chk-1537
*When it's running
Hi Chen,
You are right that Flink changed its memory model with Flink 1.10. Now the
memory model is better defined and stricter. You can find information about
it here [1]. For some pointers towards potential problems please take a
look at [2].
What you need to do is to figure out where the
Hi Rainie,
1. I think what you need to do is to look for the {job_id} in all the
possible sub folders of the dev/checkpoints/ folder or you extract the
entropy from the logs.
2. According to [1] entropy should only be used for the data files and not
for the metadata files. The idea was to keep
How do other projects solve this problem?
Cheers,
Till
On Wed, Mar 17, 2021 at 3:45 AM Xingbo Huang wrote:
> Hi Chesnay,
>
> Yes, in most cases, we can indeed download the required jars in `setup.py`,
> which is also the solution I originally thought of reducing the size of
> wheel packages.
Shengkai Fang created FLINK-21847:
-
Summary: Introduce DESC grammar in sql parser
Key: FLINK-21847
URL: https://issues.apache.org/jira/browse/FLINK-21847
Project: Flink
Issue Type: Sub-task
Till Rohrmann created FLINK-21846:
-
Summary: Rethink whether failure of ExecutionGraph creation should
directly fail the job
Key: FLINK-21846
URL: https://issues.apache.org/jira/browse/FLINK-21846
Yogesh Kumbhare created FLINK-21845:
---
Summary: NOt able to read config in flink Migration
Key: FLINK-21845
URL: https://issues.apache.org/jira/browse/FLINK-21845
Project: Flink
Issue
Konstantin Knauf created FLINK-21844:
Summary: Do not auto-configure maxParallelism when setting
"scheduler-mode: reactive"
Key: FLINK-21844
URL: https://issues.apache.org/jira/browse/FLINK-21844
Wenlong Lyu created FLINK-21843:
---
Summary: Support StreamExecGroupWindowAggregate json ser/de
Key: FLINK-21843
URL: https://issues.apache.org/jira/browse/FLINK-21843
Project: Flink
Issue Type:
Wei Zhong created FLINK-21842:
-
Summary: Support user defined WindowAssigner, Trigger and
ProcessWindowFunction on Python DataStream API
Key: FLINK-21842
URL: https://issues.apache.org/jira/browse/FLINK-21842
JieFang.He created FLINK-21841:
--
Summary: Can not find kafka-connect with sql-kafka-connector
Key: FLINK-21841
URL: https://issues.apache.org/jira/browse/FLINK-21841
Project: Flink
Issue Type:
hayden zhou created FLINK-21840:
---
Summary: can't submit flink k8s session job with
kubernetes.rest-service.exposed.type=NodePort
Key: FLINK-21840
URL: https://issues.apache.org/jira/browse/FLINK-21840
18 matches
Mail list logo
