[jira] [Commented] (FLINK-28060) Kafka Commit on checkpointing fails repeatedly after a broker restart

2022-06-22 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28060?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17557289#comment-17557289 ] Martijn Visser commented on FLINK-28060: I'm not sure that we have a test for this behaviour. It

[GitHub] [flink] chenzihao5 commented on a diff in pull request #19797: [FLINK-27741][table-planner] Fix NPE when use dense_rank() and rank()…

2022-06-22 Thread GitBox
chenzihao5 commented on code in PR #19797: URL: https://github.com/apache/flink/pull/19797#discussion_r903383377 ## flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/planner/runtime/stream/sql/OverAggregateITCase.scala: ## @@ -159,6 +159,66 @@ class

[jira] [Closed] (FLINK-28190) NullPointerException is thrown if the intermediate result of nesting UDFs is used

2022-06-22 Thread Caizhi Weng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28190?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Caizhi Weng closed FLINK-28190. --- Resolution: Not A Problem > NullPointerException is thrown if the intermediate result of nesting

[jira] [Updated] (FLINK-28166) Configurable Automatic Retries on Error

2022-06-22 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28166?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-28166: --- Labels: pull-request-available (was: ) > Configurable Automatic Retries on Error >

[jira] [Commented] (FLINK-28160) org.apache.flink.api.common.InvalidProgramException: Table program cannot be compiled.

2022-06-22 Thread cjh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28160?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17557259#comment-17557259 ] cjh commented on FLINK-28160: - [~twalthr] , The original SQL query is as follows: select     dt_str,    

[GitHub] [flink-kubernetes-operator] morhidi opened a new pull request, #273: [FLINK-28166] Configurable Automatic Retries on Error

2022-06-22 Thread GitBox
morhidi opened a new pull request, #273: URL: https://github.com/apache/flink-kubernetes-operator/pull/273 JOSDK defaults to the following retry configuration (exponential backoff) ``` GenericRetry.defaultLimitedExponentialRetry() .setInitialInterval(2000)

[jira] [Commented] (FLINK-27292) Translate the "Data Type Extraction" section of "Data Types" in to Chinese

2022-06-22 Thread jjiey (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27292?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17557274#comment-17557274 ] jjiey commented on FLINK-27292: --- Hi [~jark], Could you assign this to me? thank you. > Translate the

[GitHub] [flink] pnowojski commented on pull request #20038: [FLINK-26762][docs] Document overdraft buffers

2022-06-22 Thread GitBox
pnowojski commented on PR #20038: URL: https://github.com/apache/flink/pull/20038#issuecomment-1162728339 It would create even more garbage commits in the master, so let's keep it as it is. -- This is an automated message from the Apache Git Service. To respond to the message, please log

[jira] [Commented] (FLINK-27667) YARNHighAvailabilityITCase fails with "Failed to delete temp directory /tmp/junit1681"

2022-06-22 Thread Biao Geng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27667?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17557287#comment-17557287 ] Biao Geng commented on FLINK-27667: --- Hi [~martijnvisser] , I see [~ferenc-csaky]  has created the PR

[jira] [Closed] (FLINK-27667) YARNHighAvailabilityITCase fails with "Failed to delete temp directory /tmp/junit1681"

2022-06-22 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27667?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser closed FLINK-27667. -- Fix Version/s: 1.16.0 Resolution: Fixed Fixed in master:

[GitHub] [flink] zhoulii commented on a diff in pull request #20039: [FLINK-28133][runtime] Rework DefaultScheduler to directly deploy executions

2022-06-22 Thread GitBox
zhoulii commented on code in PR #20039: URL: https://github.com/apache/flink/pull/20039#discussion_r903336973 ## flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/DefaultExecutionDeployer.java: ## @@ -0,0 +1,386 @@ +/* + * Licensed to the Apache Software Foundation

[jira] [Updated] (FLINK-28175) Improve LicenseChecker output

2022-06-22 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28175?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-28175: --- Labels: pull-request-available (was: ) > Improve LicenseChecker output >

[GitHub] [flink] zentol commented on pull request #20003: [FLINK-28080][runtime] Introduce MutableURLClassLoader as parent class of FlinkUserClassLoader and SafetyNetWrapperClassLoader

2022-06-22 Thread GitBox
zentol commented on PR #20003: URL: https://github.com/apache/flink/pull/20003#issuecomment-1162721597 > If we force to use parent-first mode, then the classloader behavior is inconsistent between local job compiling and distributed. Say the user wants to use child-first for distributed

[jira] [Created] (FLINK-28192) RescaleBucketITCase is not stable

2022-06-22 Thread Jane Chan (Jira)
Jane Chan created FLINK-28192: - Summary: RescaleBucketITCase is not stable Key: FLINK-28192 URL: https://issues.apache.org/jira/browse/FLINK-28192 Project: Flink Issue Type: Bug

[GitHub] [flink-kubernetes-operator] gyfora opened a new pull request, #274: [FLINK-28180] Unify Application and SessionJob reconciler logic

2022-06-22 Thread GitBox
gyfora opened a new pull request, #274: URL: https://github.com/apache/flink-kubernetes-operator/pull/274 This PR includes a refactor and unification of the reconciler hieararchy we have right now: - SessionReconciler - AbstractDeploymentReconciler - ApplicationReconciler

[jira] [Updated] (FLINK-28180) Unify Application and SessionJob reconcilers

2022-06-22 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28180?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-28180: --- Labels: pull-request-available (was: ) > Unify Application and SessionJob reconcilers >

[GitHub] [flink-kubernetes-operator] gyfora commented on pull request #274: [FLINK-28180] Unify Application and SessionJob reconciler logic

2022-06-22 Thread GitBox
gyfora commented on PR #274: URL: https://github.com/apache/flink-kubernetes-operator/pull/274#issuecomment-1162750385 cc @Aitozi -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific

[GitHub] [flink] zentol commented on pull request #20003: [FLINK-28080][runtime] Introduce MutableURLClassLoader as parent class of FlinkUserClassLoader and SafetyNetWrapperClassLoader

2022-06-22 Thread GitBox
zentol commented on PR #20003: URL: https://github.com/apache/flink/pull/20003#issuecomment-1162750463 I'm pretty sure you are correct. We never actually had the case where we had a tree of classloaders with different order settings between nodes. It's always been either all

[jira] [Commented] (FLINK-27741) Fix NPE when use dense_rank() and rank() in over aggregation

2022-06-22 Thread chenzihao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27741?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17557303#comment-17557303 ] chenzihao commented on FLINK-27741: --- Hi, [~godfreyhe] . Can you help to confirm this ticket? What do

[jira] [Assigned] (FLINK-28146) Sync blocklist information between JobMaster & ResourceManager

2022-06-22 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28146?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu reassigned FLINK-28146: --- Assignee: Lijie Wang > Sync blocklist information between JobMaster & ResourceManager >

[GitHub] [flink] nyingping commented on pull request #20028: [hotfix][docs] Remove redundant "." from sample code

2022-06-22 Thread GitBox
nyingping commented on PR #20028: URL: https://github.com/apache/flink/pull/20028#issuecomment-1162687881 @Myasuka updated. sorry for delay. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the

[jira] [Closed] (FLINK-27972) Race condition between task/savepoint notification failure

2022-06-22 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27972?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-27972. Fix Version/s: 1.16.0 Resolution: Fixed master:

[jira] [Assigned] (FLINK-28068) Control the total memory of a sink task

2022-06-22 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28068?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reassigned FLINK-28068: Assignee: Jingsong Lee > Control the total memory of a sink task >

[GitHub] [flink] zentol merged pull request #19968: [FLINK-27972][coordination] Wait until savepoint operation is complete

2022-06-22 Thread GitBox
zentol merged PR #19968: URL: https://github.com/apache/flink/pull/19968 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail:

[jira] [Assigned] (FLINK-28143) Introduce BlocklistHandler

2022-06-22 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28143?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu reassigned FLINK-28143: --- Assignee: Lijie Wang > Introduce BlocklistHandler > -- > >

[jira] [Assigned] (FLINK-28145) Let ResourceManager support blocklist mechanism

2022-06-22 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28145?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu reassigned FLINK-28145: --- Assignee: Lijie Wang > Let ResourceManager support blocklist mechanism >

[jira] [Assigned] (FLINK-28130) FLIP-224: Blocklist Mechanism

2022-06-22 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28130?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu reassigned FLINK-28130: --- Assignee: Lijie Wang > FLIP-224: Blocklist Mechanism > - > >

[jira] [Assigned] (FLINK-28144) Let JobMaster support blocklist mechanism

2022-06-22 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28144?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu reassigned FLINK-28144: --- Assignee: Lijie Wang > Let JobMaster support blocklist mechanism >

[jira] [Assigned] (FLINK-28142) Enrich TaskManagerLocation with node information

2022-06-22 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28142?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu reassigned FLINK-28142: --- Assignee: Lijie Wang > Enrich TaskManagerLocation with node information >

[GitHub] [flink] zhoulii commented on a diff in pull request #20039: [FLINK-28133][runtime] Rework DefaultScheduler to directly deploy executions

2022-06-22 Thread GitBox
zhoulii commented on code in PR #20039: URL: https://github.com/apache/flink/pull/20039#discussion_r903335396 ## flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/DefaultExecutionDeployer.java: ## @@ -0,0 +1,386 @@ +/* + * Licensed to the Apache Software Foundation

[jira] [Commented] (FLINK-28192) RescaleBucketITCase is not stable

2022-06-22 Thread Jane Chan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28192?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17557292#comment-17557292 ] Jane Chan commented on FLINK-28192: --- Maybe we don't need this assertion, let me remove it. cc

[GitHub] [flink-kubernetes-operator] gyfora commented on a diff in pull request #273: [FLINK-28166] Configurable Automatic Retries on Error

2022-06-22 Thread GitBox
gyfora commented on code in PR #273: URL: https://github.com/apache/flink-kubernetes-operator/pull/273#discussion_r903396030 ## flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/config/KubernetesOperatorConfigOptions.java: ## @@ -203,4 +203,28 @@

[GitHub] [flink] gaborgsomogyi commented on pull request #20011: [FLINK-28112][filesystems] Fix error message when directly supported file system is not able to be handled

2022-06-22 Thread GitBox
gaborgsomogyi commented on PR #20011: URL: https://github.com/apache/flink/pull/20011#issuecomment-1162678662 @MartijnVisser I've added your suggestions, may I ask to have another look plz? -- This is an automated message from the Apache Git Service. To respond to the message, please log

[jira] [Comment Edited] (FLINK-27292) Translate the "Data Type Extraction" section of "Data Types" in to Chinese

2022-06-22 Thread jjiey (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27292?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17557274#comment-17557274 ] jjiey edited comment on FLINK-27292 at 6/22/22 6:44 AM: Thank [~yckkcy] for your

[GitHub] [flink] wuchong commented on pull request #20003: [FLINK-28080][runtime] Introduce MutableURLClassLoader as parent class of FlinkUserClassLoader and SafetyNetWrapperClassLoader

2022-06-22 Thread GitBox
wuchong commented on PR #20003: URL: https://github.com/apache/flink/pull/20003#issuecomment-1162734430 This still seems inconsistent classloader behavior compared to the distributed execution. Please correct me if I'm wrong. When resolve-order is child-first, the classloader order

[jira] [Commented] (FLINK-26541) SQL Client should support submitting SQL jobs in application mode

2022-06-22 Thread LuNing Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26541?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17557293#comment-17557293 ] LuNing Wang commented on FLINK-26541: - big +1 for this feature > SQL Client should support

[GitHub] [flink] wuchong commented on pull request #20003: [FLINK-28080][runtime] Introduce MutableURLClassLoader as parent class of FlinkUserClassLoader and SafetyNetWrapperClassLoader

2022-06-22 Thread GitBox
wuchong commented on PR #20003: URL: https://github.com/apache/flink/pull/20003#issuecomment-1162757295 Thank you @zentol . So are you fine with the `MutableURLClassLoader` approach which is straightforward and (looks like so far) has no side effects? -- This is an automated message

[GitHub] [flink] chenzihao5 commented on a diff in pull request #19797: [FLINK-27741][table-planner] Fix NPE when use dense_rank() and rank()…

2022-06-22 Thread GitBox
chenzihao5 commented on code in PR #19797: URL: https://github.com/apache/flink/pull/19797#discussion_r903392287 ## flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/functions/aggfunctions/RankLikeAggFunctionBase.java: ## @@ -98,7 +98,7 @@ protected

[GitHub] [flink] XComp commented on a diff in pull request #19907: [FLINK-27692][state] Support local recovery for materialized part of changelog

2022-06-22 Thread GitBox
XComp commented on code in PR #19907: URL: https://github.com/apache/flink/pull/19907#discussion_r903346279 ## flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/TaskExecutor.java: ## @@ -685,13 +687,27 @@ public CompletableFuture submitTask(

[GitHub] [flink] zentol opened a new pull request, #20041: [FLINK-28175][ci] Improve license checker output

2022-06-22 Thread GitBox
zentol opened a new pull request, #20041: URL: https://github.com/apache/flink/pull/20041 With this PR the output of the license checker is grouped by module and severity, hopefully making the problems easier to understand. -- This is an automated message from the Apache Git Service. To

[jira] [Updated] (FLINK-28191) 【flink-runtime】Achieve metrics summary and unified active reporting

2022-06-22 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28191?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-28191: --- Affects Version/s: (was: 1.14.3) > 【flink-runtime】Achieve metrics summary and unified

[GitHub] [flink] bgeng777 commented on pull request #20012: [FLINK-27667][yarn-tests] Stabilize flaky YARN integration tests

2022-06-22 Thread GitBox
bgeng777 commented on PR #20012: URL: https://github.com/apache/flink/pull/20012#issuecomment-1162724423 LGTM as well. Thanks @ferenc-csaky ! -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the

[GitHub] [flink] MartijnVisser merged pull request #20012: [FLINK-27667][yarn-tests] Stabilize flaky YARN integration tests

2022-06-22 Thread GitBox
MartijnVisser merged PR #20012: URL: https://github.com/apache/flink/pull/20012 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail:

[jira] [Assigned] (FLINK-28193) Enable to identify whether a job vertex contains source/sink operators

2022-06-22 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28193?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu reassigned FLINK-28193: --- Assignee: Zhu Zhu > Enable to identify whether a job vertex contains source/sink operators >

[jira] [Created] (FLINK-28193) Enable to identify whether a job vertex contains source/sink operators

2022-06-22 Thread Zhu Zhu (Jira)
Zhu Zhu created FLINK-28193: --- Summary: Enable to identify whether a job vertex contains source/sink operators Key: FLINK-28193 URL: https://issues.apache.org/jira/browse/FLINK-28193 Project: Flink

[GitHub] [flink] flinkbot commented on pull request #20043: [FLINK-28193][runtime] Enable to identify whether a job vertex contains source/sink operators

2022-06-22 Thread GitBox
flinkbot commented on PR #20043: URL: https://github.com/apache/flink/pull/20043#issuecomment-1162794636 ## CI report: * ba3c08d53b06c92f5345ae2dd20357411484d155 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink-kubernetes-operator] gyfora commented on a diff in pull request #268: [FLINK-27914] Integrate JOSDK metrics with Flink Metrics reporter

2022-06-22 Thread GitBox
gyfora commented on code in PR #268: URL: https://github.com/apache/flink-kubernetes-operator/pull/268#discussion_r903452192 ## flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/config/KubernetesOperatorConfigOptions.java: ## @@ -203,4 +203,11 @@

[GitHub] [flink] reswqa commented on a diff in pull request #20039: [FLINK-28133][runtime] Rework DefaultScheduler to directly deploy executions

2022-06-22 Thread GitBox
reswqa commented on code in PR #20039: URL: https://github.com/apache/flink/pull/20039#discussion_r903456529 ## flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/DefaultExecutionDeployerTest.java: ## @@ -0,0 +1,388 @@ +/* + * Licensed to the Apache Software

[GitHub] [flink] wuchong commented on a diff in pull request #19823: [FLINK-27766][sql-gateway] Introduce the framework of the SqlGatewayService

2022-06-22 Thread GitBox
wuchong commented on code in PR #19823: URL: https://github.com/apache/flink/pull/19823#discussion_r903436449 ## flink-table/flink-sql-gateway/src/main/java/org/apache/flink/table/gateway/service/utils/ThreadUtils.java: ## @@ -0,0 +1,49 @@ +/* + * Licensed to the Apache

[GitHub] [flink] MartijnVisser merged pull request #20044: [hotfix][ci] Update libssl download link

2022-06-22 Thread GitBox
MartijnVisser merged PR #20044: URL: https://github.com/apache/flink/pull/20044 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail:

[GitHub] [flink] liuzhuang2017 commented on pull request #19966: [hotfix][docs] Fix the Intellij key nouns.

2022-06-22 Thread GitBox
liuzhuang2017 commented on PR #19966: URL: https://github.com/apache/flink/pull/19966#issuecomment-1162875025 @mbalassi ,Sorry to bother you again, can you help me review this pr? Thank you. -- This is an automated message from the Apache Git Service. To respond to the message, please

[GitHub] [flink] zentol commented on pull request #20041: [FLINK-28175][ci] Improve license checker output

2022-06-22 Thread GitBox
zentol commented on PR #20041: URL: https://github.com/apache/flink/pull/20041#issuecomment-1162888702 @flinkbot run azure -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment.

[jira] [Updated] (FLINK-28068) Control the total memory of a sink task

2022-06-22 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28068?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-28068: --- Labels: pull-request-available (was: ) > Control the total memory of a sink task >

[GitHub] [flink-table-store] JingsongLi opened a new pull request, #171: [FLINK-28068] Introduce MemoryPoolFactory to share and preempt memory for multiple writers

2022-06-22 Thread GitBox
JingsongLi opened a new pull request, #171: URL: https://github.com/apache/flink-table-store/pull/171 Currently, Sink's MemTable memory is self-managed Heap, and compaction also consumes memory, which is not very easy to use, and the memory problem will be more serious if there are

[GitHub] [flink] KarmaGYZ commented on a diff in pull request #20042: [FLINK-19358][runtime] Make the job id distinct in application mode w…

2022-06-22 Thread GitBox
KarmaGYZ commented on code in PR #20042: URL: https://github.com/apache/flink/pull/20042#discussion_r903535308 ## flink-clients/src/main/java/org/apache/flink/client/cli/CliFrontend.java: ## @@ -208,6 +210,16 @@ protected void runApplication(String[] args) throws Exception {

[jira] [Commented] (FLINK-27832) SplitAggregateITCase tests failed with Could not acquire the minimum required resources

2022-06-22 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27832?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17557367#comment-17557367 ] Chesnay Schepler commented on FLINK-27832: -- This is the build from zhu zhu:

[jira] [Updated] (FLINK-24666) Add job level "table.exec.state-staled.error-handling" option and apply to related stateful stream operators

2022-06-22 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24666?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-24666: Summary: Add job level "table.exec.state-staled.error-handling" option and apply to related

[jira] [Commented] (FLINK-28198) CassandraConnectorITCase#testRaiseCassandraRequestsTimeouts fails with timeout

2022-06-22 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28198?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17557388#comment-17557388 ] Martijn Visser commented on FLINK-28198: [~echauchot] I'm seeing this failure quite frequently,

[jira] [Created] (FLINK-28198) CassandraConnectorITCase#testRaiseCassandraRequestsTimeouts fails with timeout

2022-06-22 Thread Martijn Visser (Jira)
Martijn Visser created FLINK-28198: -- Summary: CassandraConnectorITCase#testRaiseCassandraRequestsTimeouts fails with timeout Key: FLINK-28198 URL: https://issues.apache.org/jira/browse/FLINK-28198

[jira] [Commented] (FLINK-28199) Failures on YARNHighAvailabilityITCase.testClusterClientRetrieval and YARNHighAvailabilityITCase.testKillYarnSessionClusterEntrypoint

2022-06-22 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28199?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17557390#comment-17557390 ] Martijn Visser commented on FLINK-28199: [~ferenc-csaky] [~bgeng777] This error occurred after

[jira] [Commented] (FLINK-27703) FileChannelManagerImplTest.testDirectoriesCleanupOnKillWithoutCallerHook failed with The marker file was not found within 10000 msecs

2022-06-22 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27703?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17557392#comment-17557392 ] Martijn Visser commented on FLINK-27703:

[jira] [Updated] (FLINK-27703) FileChannelManagerImplTest.testDirectoriesCleanupOnKillWithoutCallerHook failed with The marker file was not found within 10000 msecs

2022-06-22 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27703?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-27703: --- Priority: Critical (was: Major) >

[GitHub] [flink] flinkbot commented on pull request #20048: [FLINK-19869][connectors/jdbc] Add support for postgres UUID type

2022-06-22 Thread GitBox
flinkbot commented on PR #20048: URL: https://github.com/apache/flink/pull/20048#issuecomment-1163008132 ## CI report: * 1efa958a738744969e25c59f1ce58f65c0d972d1 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink-web] yangjf2019 opened a new pull request, #552: [hotfix][docs] Eliminate the redundant symbol '/' from the jump link url

2022-06-22 Thread GitBox
yangjf2019 opened a new pull request, #552: URL: https://github.com/apache/flink-web/pull/552 When the user clicks on the 'Getting started' --> 'with flink' jump in https://flink.apache.org/, there is a redundant '/' symbol in the url, which I have eliminated. -- This is an automated

[GitHub] [flink] mbalassi commented on pull request #20037: [hotfix][docs] Fix the inaccessible documentation link.

2022-06-22 Thread GitBox
mbalassi commented on PR #20037: URL: https://github.com/apache/flink/pull/20037#issuecomment-1162845179 @flinkbot run azure -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment.

[jira] [Commented] (FLINK-28053) Introduce queue to execute request in sequence

2022-06-22 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28053?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17557329#comment-17557329 ] Jark Wu commented on FLINK-28053: - Similar issue in HiveServer: HIVE-11402 > Introduce queue to execute

[GitHub] [flink] flinkbot commented on pull request #20045: [FLINK-28194][python] Remove avro sql jar workaround

2022-06-22 Thread GitBox
flinkbot commented on PR #20045: URL: https://github.com/apache/flink/pull/20045#issuecomment-1162876594 ## CI report: * b75234d42f6c40593ba8163f735aa981272c951b UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] nyingping commented on pull request #20028: [hotfix][docs] Remove redundant "." from sample code

2022-06-22 Thread GitBox
nyingping commented on PR #20028: URL: https://github.com/apache/flink/pull/20028#issuecomment-1162909126 @Myasuka Updated. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment.

[GitHub] [flink] zentol opened a new pull request, #20046: [FLINK-28196][build] Rename hadoop.version property

2022-06-22 Thread GitBox
zentol opened a new pull request, #20046: URL: https://github.com/apache/flink/pull/20046 Prevent conflicts with the `hadoop.version` property in the Hadoop parent pom, when using Maven 3.8.5+. This lead to our modules that use Hadoop 3 to partially bundle Hadoop 2.8.5 when

[jira] [Updated] (FLINK-28196) Rename hadoop.version property

2022-06-22 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28196?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-28196: --- Labels: pull-request-available (was: ) > Rename hadoop.version property >

[GitHub] [flink-table-store] JingsongLi commented on a diff in pull request #167: [FLINK-28129] Add documentation for rescale bucket

2022-06-22 Thread GitBox
JingsongLi commented on code in PR #167: URL: https://github.com/apache/flink-table-store/pull/167#discussion_r903568556 ## docs/content/docs/development/rescale-bucket.md: ## @@ -0,0 +1,141 @@ +--- +title: "Rescale Bucket" +weight: 5 +type: docs +aliases: +-

[GitHub] [flink] rkhachatryan commented on a diff in pull request #19679: [FLINK-23143][state/changelog] Support state migration for ChangelogS…

2022-06-22 Thread GitBox
rkhachatryan commented on code in PR #19679: URL: https://github.com/apache/flink/pull/19679#discussion_r903571015 ## flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBKeyedStateBackend.java: ## @@ -477,6 +478,50 @@

[GitHub] [flink] liujiawinds commented on pull request #20047: [FLINK-28173][formats] Cover default dependencies with guava exclusion in `hadoop3-tests` profile

2022-06-22 Thread GitBox
liujiawinds commented on PR #20047: URL: https://github.com/apache/flink/pull/20047#issuecomment-1162929493 @MartijnVisser @zentol Could you have a look? Btw, Is there any way to trigger hadoop3 cron build manually? -- This is an automated message from the Apache Git Service. To

[jira] [Closed] (FLINK-27792) InterruptedException thrown by ChannelStateWriterImpl

2022-06-22 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27792?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-27792. Resolution: Duplicate > InterruptedException thrown by ChannelStateWriterImpl >

[jira] [Commented] (FLINK-28187) Duplicate job submission for FlinkSessionJob

2022-06-22 Thread Aitozi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28187?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17557387#comment-17557387 ] Aitozi commented on FLINK-28187: thanks, I will check it now > Duplicate job submission for

[GitHub] [flink] fsk119 commented on a diff in pull request #19823: [FLINK-27766][sql-gateway] Introduce the framework of the SqlGatewayService

2022-06-22 Thread GitBox
fsk119 commented on code in PR #19823: URL: https://github.com/apache/flink/pull/19823#discussion_r903621101 ## flink-table/flink-sql-gateway/src/main/java/org/apache/flink/table/gateway/service/utils/ThreadUtils.java: ## @@ -0,0 +1,49 @@ +/* + * Licensed to the Apache Software

[jira] [Created] (FLINK-28199) Failures on YARNHighAvailabilityITCase.testClusterClientRetrieval and YARNHighAvailabilityITCase.testKillYarnSessionClusterEntrypoint

2022-06-22 Thread Martijn Visser (Jira)
Martijn Visser created FLINK-28199: -- Summary: Failures on YARNHighAvailabilityITCase.testClusterClientRetrieval and YARNHighAvailabilityITCase.testKillYarnSessionClusterEntrypoint Key: FLINK-28199 URL:

[GitHub] [flink] bobby-richard opened a new pull request, #20048: [FLINK-19869][connectors/jdbc] Add support for postgres UUID type

2022-06-22 Thread GitBox
bobby-richard opened a new pull request, #20048: URL: https://github.com/apache/flink/pull/20048 ## What is the purpose of the change Add support for reading and writing postgres UUID types via Flink SQL STRING type ## Brief change log - modified

[jira] [Commented] (FLINK-28187) Duplicate job submission for FlinkSessionJob

2022-06-22 Thread Aitozi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28187?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17557404#comment-17557404 ] Aitozi commented on FLINK-28187: I get your meaning now, but I think the case is a bit different from

[jira] [Commented] (FLINK-26270) Flink SQL write data to kafka by CSV format , decimal type was converted to scientific notation

2022-06-22 Thread fengjk (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26270?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17557410#comment-17557410 ] fengjk commented on FLINK-26270: Can you assign this problem to me. > Flink SQL write data to kafka by

[GitHub] [flink] fsk119 commented on a diff in pull request #19823: [FLINK-27766][sql-gateway] Introduce the framework of the SqlGatewayService

2022-06-22 Thread GitBox
fsk119 commented on code in PR #19823: URL: https://github.com/apache/flink/pull/19823#discussion_r903417787 ## flink-table/flink-sql-gateway/src/test/java/org/apache/flink/table/gateway/service/result/ResultFetcherTest.java: ## @@ -0,0 +1,355 @@ +/* + * Licensed to the Apache

[GitHub] [flink-kubernetes-operator] gyfora commented on a diff in pull request #268: [FLINK-27914] Integrate JOSDK metrics with Flink Metrics reporter

2022-06-22 Thread GitBox
gyfora commented on code in PR #268: URL: https://github.com/apache/flink-kubernetes-operator/pull/268#discussion_r903434917 ## flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/config/KubernetesOperatorConfigOptions.java: ## @@ -203,4 +203,11 @@

[GitHub] [flink-kubernetes-operator] SteNicholas commented on a diff in pull request #268: [FLINK-27914] Integrate JOSDK metrics with Flink Metrics reporter

2022-06-22 Thread GitBox
SteNicholas commented on code in PR #268: URL: https://github.com/apache/flink-kubernetes-operator/pull/268#discussion_r903447982 ## flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/config/KubernetesOperatorConfigOptions.java: ## @@ -203,4 +203,11

[GitHub] [flink-web] fsk119 opened a new pull request, #553: Add Shengkai Fang to the committer list and rebuild the html

2022-06-22 Thread GitBox
fsk119 opened a new pull request, #553: URL: https://github.com/apache/flink-web/pull/553 Modified Web snapshot: ![image](https://user-images.githubusercontent.com/33114724/174984069-eebba57d-8f70-42b9-ab82-2f3675321201.png)

[jira] [Commented] (FLINK-28192) RescaleBucketITCase is not stable

2022-06-22 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28192?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17557324#comment-17557324 ] Jingsong Lee commented on FLINK-28192: -- master: d8e415ae88677698903d0445cbca19dd12270a75 >

[GitHub] [flink-table-store] JingsongLi merged pull request #170: [FLINK-28192] Remove job status assertion in RescaleBucketITCase

2022-06-22 Thread GitBox
JingsongLi merged PR #170: URL: https://github.com/apache/flink-table-store/pull/170 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail:

[jira] [Updated] (FLINK-28192) RescaleBucketITCase is not stable

2022-06-22 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28192?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-28192: --- Labels: pull-request-available (was: ) > RescaleBucketITCase is not stable >

[jira] [Closed] (FLINK-28192) RescaleBucketITCase is not stable

2022-06-22 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28192?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-28192. Assignee: Jane Chan Resolution: Fixed > RescaleBucketITCase is not stable >

[GitHub] [flink] MartijnVisser commented on pull request #20012: [FLINK-27667][yarn-tests] Stabilize flaky YARN integration tests

2022-06-22 Thread GitBox
MartijnVisser commented on PR #20012: URL: https://github.com/apache/flink/pull/20012#issuecomment-1162857409 You too @mbalassi :) -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific

[GitHub] [flink] MartijnVisser opened a new pull request, #20044: [hotfix][ci] Update libssl download link

2022-06-22 Thread GitBox
MartijnVisser opened a new pull request, #20044: URL: https://github.com/apache/flink/pull/20044 ## What is the purpose of the change * Fix CI due to a new libssl being released ## Brief change log * Changed libssl download link ## Verifying this change

[GitHub] [flink] MartijnVisser merged pull request #19966: [hotfix][docs] Fix the Intellij key nouns.

2022-06-22 Thread GitBox
MartijnVisser merged PR #19966: URL: https://github.com/apache/flink/pull/19966 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail:

[jira] [Updated] (FLINK-28194) Remove workaround around avro sql jar

2022-06-22 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28194?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-28194: --- Labels: pull-request-available (was: ) > Remove workaround around avro sql jar >

[GitHub] [flink] liuzhuang2017 commented on pull request #19966: [hotfix][docs] Fix the Intellij key nouns.

2022-06-22 Thread GitBox
liuzhuang2017 commented on PR #19966: URL: https://github.com/apache/flink/pull/19966#issuecomment-1162884234 @MartijnVisser , Thank you very much for your review. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the

[GitHub] [flink-web] fsk119 merged pull request #553: Add Shengkai Fang to the committer list and rebuild the html

2022-06-22 Thread GitBox
fsk119 merged PR #553: URL: https://github.com/apache/flink-web/pull/553 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail:

[jira] [Commented] (FLINK-28173) Multiple Parquet format tests are failing with NoSuchMethodError

2022-06-22 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28173?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17557345#comment-17557345 ] Martijn Visser commented on FLINK-28173: [~sonice_lj] I've assigned it to you. > Multiple

[jira] [Assigned] (FLINK-28173) Multiple Parquet format tests are failing with NoSuchMethodError

2022-06-22 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28173?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser reassigned FLINK-28173: -- Assignee: jia liu > Multiple Parquet format tests are failing with NoSuchMethodError

[jira] [Commented] (FLINK-27832) SplitAggregateITCase tests failed with Could not acquire the minimum required resources

2022-06-22 Thread Roman Khachatryan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27832?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17557348#comment-17557348 ] Roman Khachatryan commented on FLINK-27832: --- [~zhuzh] could you check whether

[GitHub] [flink-table-store] LadyForest commented on a diff in pull request #167: [FLINK-28129] Add documentation for rescale bucket

2022-06-22 Thread GitBox
LadyForest commented on code in PR #167: URL: https://github.com/apache/flink-table-store/pull/167#discussion_r903578903 ## docs/content/docs/development/rescale-bucket.md: ## @@ -0,0 +1,141 @@ +--- +title: "Rescale Bucket" +weight: 5 +type: docs +aliases: +-

[GitHub] [flink] zhuzhurk commented on pull request #20043: [FLINK-28193][runtime] Enable to identify whether a job vertex contains source/sink operators

2022-06-22 Thread GitBox
zhuzhurk commented on PR #20043: URL: https://github.com/apache/flink/pull/20043#issuecomment-116290 > Could you not infer this from the size of `inputs`/`results` in the `JobVertex`? A job vertex with no input/output does not mean it is a true source/sink vertex. -

[GitHub] [flink-ml] zhipeng93 opened a new pull request, #114: [FLINK-27096] Optimize VectorAssembler performance

2022-06-22 Thread GitBox
zhipeng93 opened a new pull request, #114: URL: https://github.com/apache/flink-ml/pull/114 This PR optimizes the performance of VectorAssembler. It increases the throughput by 30%-50%. -- This is an automated message from the Apache Git Service. To respond to the message, please log on

  1   2   3   4   >