[jira] [Updated] (FLINK-27409) Cleanup stale slot allocation record when the resource requirement of a job is empty

[ https://issues.apache.org/jira/browse/FLINK-27409?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-27409: - Component/s: Runtime / Coordination > Cleanup stale slot allocation record when the resource

[GitHub] [flink] KarmaGYZ opened a new pull request, #19581: [BP-1.15][FLINK-27409][runtime] Cleanup stale slot allocation record when the …

KarmaGYZ opened a new pull request, #19581: URL: https://github.com/apache/flink/pull/19581 …resource requirement of a job is empty -- 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] flinkbot commented on pull request #19580: [FLINK-27409][runtime] Cleanup stale slot allocation record when the …

flinkbot commented on PR #19580: URL: https://github.com/apache/flink/pull/19580#issuecomment-1109406713 ## CI report: * 37f8128ae3e10483995c80e64668ed4de5d8cc74 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Commented] (FLINK-27262) Enrich validator for FlinkSesionJob

[ https://issues.apache.org/jira/browse/FLINK-27262?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17527928#comment-17527928 ] Aitozi commented on FLINK-27262: I have one thing to discuss here: do we need to support user create a

[jira] [Updated] (FLINK-27409) Cleanup stale slot allocation record when the resource requirement of a job is empty

[ https://issues.apache.org/jira/browse/FLINK-27409?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yangze Guo updated FLINK-27409: --- Fix Version/s: 1.16.0 1.15.1 > Cleanup stale slot allocation record when the

[jira] [Updated] (FLINK-27409) Cleanup stale slot allocation record when the resource requirement of a job is empty

[ https://issues.apache.org/jira/browse/FLINK-27409?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yangze Guo updated FLINK-27409: --- Affects Version/s: 1.15.0 > Cleanup stale slot allocation record when the resource requirement of a

[jira] [Updated] (FLINK-27409) Cleanup stale slot allocation record when the resource requirement of a job is empty

[ https://issues.apache.org/jira/browse/FLINK-27409?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-27409: --- Labels: pull-request-available (was: ) > Cleanup stale slot allocation record when the

[GitHub] [flink] KarmaGYZ opened a new pull request, #19580: [FLINK-27409][runtime] Cleanup stale slot allocation record when the …

KarmaGYZ opened a new pull request, #19580: URL: https://github.com/apache/flink/pull/19580 …resource requirement of a job is empty ## What is the purpose of the change Clean up stale slot allocation records when the resource requirement of a job is empty. ##

[jira] [Updated] (FLINK-27406) After canceling the job, it is falsely reported as a job failure.

[ https://issues.apache.org/jira/browse/FLINK-27406?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guowei Ma updated FLINK-27406: -- Labels: usability (was: ) > After canceling the job, it is falsely reported as a job failure. >

[jira] [Comment Edited] (FLINK-27304) Flink doesn't support Hive primitive type void yet

[ https://issues.apache.org/jira/browse/FLINK-27304?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17527148#comment-17527148 ] luoyuxia edited comment on FLINK-27304 at 4/26/22 6:33 AM: --- [~tartarus] Thanks

[jira] [Commented] (FLINK-27377) Job master blocks on marking vertex finished

[ https://issues.apache.org/jira/browse/FLINK-27377?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17527925#comment-17527925 ] Guowei Ma commented on FLINK-27377: --- Hi, [~yittg] Thanks for your detail explanation.  Do you have

[jira] [Commented] (FLINK-27379) CodeGenException: Unable to find common type of

[ https://issues.apache.org/jira/browse/FLINK-27379?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17527922#comment-17527922 ] luoyuxia commented on FLINK-27379: -- More detail analysis is in

[jira] [Commented] (FLINK-27346) [umbrella] Introduce Hive reader for table store

[ https://issues.apache.org/jira/browse/FLINK-27346?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17527921#comment-17527921 ] Jingsong Lee commented on FLINK-27346: -- (This can also have a FLIP, we can have a clear definition

[jira] [Comment Edited] (FLINK-27296) CalcOperator CodeGenException: Boolean expression type expected

[ https://issues.apache.org/jira/browse/FLINK-27296?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17527920#comment-17527920 ] luoyuxia edited comment on FLINK-27296 at 4/26/22 6:29 AM: --- More detail

[jira] [Comment Edited] (FLINK-27296) CalcOperator CodeGenException: Boolean expression type expected

[ https://issues.apache.org/jira/browse/FLINK-27296?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17527920#comment-17527920 ] luoyuxia edited comment on FLINK-27296 at 4/26/22 6:29 AM: --- More detail

[jira] [Commented] (FLINK-27296) CalcOperator CodeGenException: Boolean expression type expected

[ https://issues.apache.org/jira/browse/FLINK-27296?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17527920#comment-17527920 ] luoyuxia commented on FLINK-27296: -- More detail analysis is in

[jira] [Comment Edited] (FLINK-27364) Support DESC EXTENDED partition statement for partitioned table

[ https://issues.apache.org/jira/browse/FLINK-27364?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17527913#comment-17527913 ] dalongliu edited comment on FLINK-27364 at 4/26/22 6:26 AM: [~nicholasjiang]

[jira] [Commented] (FLINK-27402) Unexpected boolean expression simplification for AND expression

[ https://issues.apache.org/jira/browse/FLINK-27402?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17527917#comment-17527917 ] luoyuxia commented on FLINK-27402: -- Updating: from my sides, it may not a problem for it's not allowed

[jira] [Comment Edited] (FLINK-27364) Support DESC EXTENDED partition statement for partitioned table

[ https://issues.apache.org/jira/browse/FLINK-27364?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17527913#comment-17527913 ] dalongliu edited comment on FLINK-27364 at 4/26/22 6:23 AM: [~nicholasjiang]

[jira] [Commented] (FLINK-27364) Support DESC EXTENDED partition statement for partitioned table

[ https://issues.apache.org/jira/browse/FLINK-27364?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17527913#comment-17527913 ] dalongliu commented on FLINK-27364: --- [~nicholasjiang] thanks for your remind, desc table extended is

[jira] [Comment Edited] (FLINK-27408) Package Flink runtime dependencies into associated table store modules instead of flink-table-store-dist

[ https://issues.apache.org/jira/browse/FLINK-27408?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17527896#comment-17527896 ] Jingsong Lee edited comment on FLINK-27408 at 4/26/22 6:16 AM: --- master:

[jira] [Updated] (FLINK-27408) Package Flink runtime dependencies into associated table store modules instead of flink-table-store-dist

[ https://issues.apache.org/jira/browse/FLINK-27408?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-27408: - Fix Version/s: table-store-0.1.0 (was: table-store-0.2.0) > Package

[jira] [Created] (FLINK-27409) Cleanup stale slot allocation record when the resource requirement of a job is empty

Yangze Guo created FLINK-27409: -- Summary: Cleanup stale slot allocation record when the resource requirement of a job is empty Key: FLINK-27409 URL: https://issues.apache.org/jira/browse/FLINK-27409

[GitHub] [flink] flinkbot commented on pull request #19579: [FLINK-25097][table-planner] Fix bug in inner join when the filter co…

flinkbot commented on PR #19579: URL: https://github.com/apache/flink/pull/19579#issuecomment-1109387504 ## CI report: * 80a47cf09086dbb563b6c0a532b8ca57053c4ac7 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] luoyuxia commented on a diff in pull request #19419: [FLINK-22317][table] Support DROP column/constraint/watermark for ALTER TABLE statement

luoyuxia commented on code in PR #19419: URL: https://github.com/apache/flink/pull/19419#discussion_r858313219 ## flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/utils/OperationConverterUtils.java: ## @@ -117,6 +128,193 @@ public static Operation

[GitHub] [flink] swuferhong opened a new pull request, #19579: [FLINK-25097][table-planner] Fix bug in inner join when the filter co…

swuferhong opened a new pull request, #19579: URL: https://github.com/apache/flink/pull/19579 …ndition is boolean type ## What is the purpose of the change Fix bug in inner join when the filter condition is boolean type ## Brief change log *(for

[jira] [Assigned] (FLINK-27401) CEP supports AggregateFunction in IterativeCondition

[ https://issues.apache.org/jira/browse/FLINK-27401?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin reassigned FLINK-27401: Assignee: Yue Ma (was: Yue Ma) > CEP supports AggregateFunction in IterativeCondition >

[jira] [Commented] (FLINK-27370) Add a new SessionJobState - Failed

[ https://issues.apache.org/jira/browse/FLINK-27370?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17527908#comment-17527908 ] Aitozi commented on FLINK-27370: It previously have a {{success=true/false}} field do you mean that ?

[jira] [Assigned] (FLINK-27401) CEP supports AggregateFunction in IterativeCondition

[ https://issues.apache.org/jira/browse/FLINK-27401?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin reassigned FLINK-27401: Assignee: Yue Ma > CEP supports AggregateFunction in IterativeCondition >

<    1   2   3   4