[jira] [Commented] (FLINK-21999) The logic about whether Checkpoint is enabled.

[ https://issues.apache.org/jira/browse/FLINK-21999?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17314236#comment-17314236 ] ZhangWei commented on FLINK-21999: -- [~trohrmann] In current implementation, when check

[jira] [Commented] (FLINK-22055) RPC main thread executor may schedule commands with wrong time unit of delay

[ https://issues.apache.org/jira/browse/FLINK-22055?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17312196#comment-17312196 ] ZhangWei commented on FLINK-22055: -- [~xintongsong] I am est08zw, assign the ticket to m

[jira] [Created] (FLINK-22049) Simplify calculating the starting index of the local key-group range in InternalTimerServiceImpl constructor.

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-22

[jira] [Commented] (FLINK-21999) The logic about whether Checkpoint is enabled.

[ https://issues.apache.org/jira/browse/FLINK-21999?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17311443#comment-17311443 ] ZhangWei commented on FLINK-21999: -- [~trohrmann] glad to take it! > The logic about w

[jira] [Created] (FLINK-21999) The logic about whether Checkpoint is enabled.

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

[jira] [Created] (FLINK-21943) Redundant checkNotNull

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:

[jira] [Created] (FLINK-21754) Exception message does not point to the right path.

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

[jira] [Updated] (FLINK-20700) Default value type does not match the return type of method input()

[ https://issues.apache.org/jira/browse/FLINK-20700?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ZhangWei updated FLINK-20700: - Description: In org.apache.flink.table.annotation.FunctionHint, the return type of input() is an  arra

[jira] [Created] (FLINK-20700) Default value type does not match the return type of method input()

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

[jira] [Closed] (FLINK-14668) LocalExecutor#getOrCreateExecutionContext not working as expected

[ https://issues.apache.org/jira/browse/FLINK-14668?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhangwei closed FLINK-14668. Resolution: Fixed > LocalExecutor#getOrCreateExecutionContext not working as expected > --

[jira] [Commented] (FLINK-14668) LocalExecutor#getOrCreateExecutionContext not working as expected

[ https://issues.apache.org/jira/browse/FLINK-14668?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16969876#comment-16969876 ] zhangwei commented on FLINK-14668: -- I read it wrong. I'm sorry > LocalExecutor#getOrCr

[jira] [Updated] (FLINK-14668) LocalExecutor#getOrCreateExecutionContext not working as expected

[ https://issues.apache.org/jira/browse/FLINK-14668?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhangwei updated FLINK-14668: - Description: ExecutionContext  [copy|[https://github.com/apache/flink/blob/b0a9afdd24fb70131b1e80d46d0ca

[jira] [Created] (FLINK-14668) LocalExecutor#getOrCreateExecutionContext not working as expected

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 Is

[jira] [Closed] (FLINK-14211) Add jobManager address configuration for SqlClient

[ https://issues.apache.org/jira/browse/FLINK-14211?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhangwei closed FLINK-14211. Resolution: Incomplete > Add jobManager address configuration for SqlClient >

[jira] [Commented] (FLINK-14211) Add jobManager address configuration for SqlClient

[ https://issues.apache.org/jira/browse/FLINK-14211?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16945567#comment-16945567 ] zhangwei commented on FLINK-14211: -- sql-client did not add addressOption, so jobmanager

[jira] [Created] (FLINK-14211) Add jobManager address configuration for SqlClient

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