ZhangWei created FLINK-22049:
Summary: Simplify calculating the starting index of the local
key-group range in InternalTimerServiceImpl constructor.
Key: FLINK-22049
URL: https://issues.apache.org/jira/browse/FLINK
ZhangWei created FLINK-21999:
Summary: The logic about whether Checkpoint is enabled.
Key: FLINK-21999
URL: https://issues.apache.org/jira/browse/FLINK-21999
Project: Flink
Issue Type: Bug
>ExecutionConfig at least once, so this ensures that on the server-side
>the execution config is never null.
>
>On 3/26/2021 11:18 AM, ZhangWei wrote:
>> Hello:
>>
>>
>> I was recently study the code about how the JobGraph generates. I
>> noticed in t
Hello:
I was recently study the code about how the JobGraph generates. I noticed
in the constructor of StreamingJobGraphGenerator, it constructs a JobGraph. And
in the constructor of JobGraph, it called setExecutionConfig(new
ExecutionConfig()) which serialized a default ExecutionConfig. T
ZhangWei created FLINK-21943:
Summary: Redundant checkNotNull
Key: FLINK-21943
URL: https://issues.apache.org/jira/browse/FLINK-21943
Project: Flink
Issue Type: Improvement
Components
ZhangWei created FLINK-21754:
Summary: Exception message does not point to the right path.
Key: FLINK-21754
URL: https://issues.apache.org/jira/browse/FLINK-21754
Project: Flink
Issue Type: Bug
ZhangWei created FLINK-20700:
Summary: Default value type does not match the return type of
method input()
Key: FLINK-20700
URL: https://issues.apache.org/jira/browse/FLINK-20700
Project: Flink
zhangwei created FLINK-14668:
Summary: LocalExecutor#getOrCreateExecutionContext not working as
expected
Key: FLINK-14668
URL: https://issues.apache.org/jira/browse/FLINK-14668
Project: Flink
zhangwei created FLINK-14211:
Summary: Add jobManager address configuration for SqlClient
Key: FLINK-14211
URL: https://issues.apache.org/jira/browse/FLINK-14211
Project: Flink
Issue Type
