[jira] [Updated] (FLINK-22341) Describe table doesn't work with hive dialect

[ https://issues.apache.org/jira/browse/FLINK-22341?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-22341: --- Labels: pull-request-available (was: ) > Describe table doesn't work with hive dialect >

[GitHub] [flink] lirui-apache opened a new pull request #15660: [FLINK-22341][hive] Fix describe table for hive dialect

lirui-apache opened a new pull request #15660: URL: https://github.com/apache/flink/pull/15660 ## What is the purpose of the change Fix `DESCRIBE TABLE` for hive dialect ## Brief change log - Fix `HiveParserDDLSemanticAnalyzer.analyzeDescribeTable` -

[GitHub] [flink] fsk119 commented on a change in pull request #15585: [FLINK-22065] [sql-client]Beautify the parse error exception

fsk119 commented on a change in pull request #15585: URL: https://github.com/apache/flink/pull/15585#discussion_r615553121 ## File path: flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/cli/CliStrings.java ## @@ -179,6 +179,10 @@ private CliStrings() {

[jira] [Updated] (FLINK-22327) NPE exception happens if it throws exception in finishBundle during job shutdown

[ https://issues.apache.org/jira/browse/FLINK-22327?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-22327: Fix Version/s: (was: 1.13.0) 1.13.1 > NPE exception happens if it throws exception

[jira] [Updated] (FLINK-22327) NPE exception happens if it throws exception in finishBundle during job shutdown

[ https://issues.apache.org/jira/browse/FLINK-22327?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-22327: Fix Version/s: 1.14.0 > NPE exception happens if it throws exception in finishBundle during job >

[jira] [Comment Edited] (FLINK-22327) NPE exception happens if it throws exception in finishBundle during job shutdown

[ https://issues.apache.org/jira/browse/FLINK-22327?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17324644#comment-17324644 ] Dian Fu edited comment on FLINK-22327 at 4/19/21, 5:42 AM: --- Fixed in - master

[GitHub] [flink] LadyForest commented on a change in pull request #13011: [FLINK-16384][table sql/client] Support SHOW CREATE TABLE statement

LadyForest commented on a change in pull request #13011: URL: https://github.com/apache/flink/pull/13011#discussion_r615554085 ## File path: flink-table/flink-sql-parser-hive/src/main/codegen/includes/parserImpls.ftl ## @@ -252,6 +252,22 @@ SqlShowTables SqlShowTables() :

[jira] [Created] (FLINK-22341) Describe table doesn't work with hive dialect

Rui Li created FLINK-22341: -- Summary: Describe table doesn't work with hive dialect Key: FLINK-22341 URL: https://issues.apache.org/jira/browse/FLINK-22341 Project: Flink Issue Type: Bug

[GitHub] [flink] beyond1920 commented on pull request #14880: [FLINK-21302][table-planner-blink] Fix NPE when use row_number() in over agg

beyond1920 commented on pull request #14880: URL: https://github.com/apache/flink/pull/14880#issuecomment-822179197 @godfreyhe Thanks for the review. I've addressed. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use

[GitHub] [flink] wuchong commented on a change in pull request #15658: [FLINK-18206][table-api / sql-client] Fix the incorrect timestamp display

wuchong commented on a change in pull request #15658: URL: https://github.com/apache/flink/pull/15658#discussion_r61551 ## File path: flink-table/flink-table-common/src/main/java/org/apache/flink/table/utils/PrintUtils.java ## @@ -309,9 +561,9 @@ public static String

[jira] [Created] (FLINK-22340) Concurrent access to ThresholdMeter may lead to NPE

Xintong Song created FLINK-22340: Summary: Concurrent access to ThresholdMeter may lead to NPE Key: FLINK-22340 URL: https://issues.apache.org/jira/browse/FLINK-22340 Project: Flink Issue

[jira] [Commented] (FLINK-22277) Refactor sql client's DynamicResult

[ https://issues.apache.org/jira/browse/FLINK-22277?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17324698#comment-17324698 ] Nicholas Jiang commented on FLINK-22277: [~jark], could you please assign this to me? I'm

[GitHub] [flink] wangyang0918 commented on pull request #15602: [FLINK-22264][docs] Fix misleading statement about Flink Job Cluster Kubernetes Support in Flink Architecture page

wangyang0918 commented on pull request #15602: URL: https://github.com/apache/flink/pull/15602#issuecomment-822170584 cc @tillrohrmann Could you help with merging this PR? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and

[GitHub] [flink] wangyang0918 commented on pull request #15501: [FLINK-22054][k8s] Using a shared watcher for ConfigMap watching

wangyang0918 commented on pull request #15501: URL: https://github.com/apache/flink/pull/15501#issuecomment-822166508 Sorry for the late response. If we really think it is a major problem that each job has a dedicated watch, then I lean to use the shared informer to replace plain watch.

[GitHub] [flink] pnowojski commented on a change in pull request #15631: [FLINK-20103][tests] Add UnalignedCheckpointsStressITCase

pnowojski commented on a change in pull request #15631: URL: https://github.com/apache/flink/pull/15631#discussion_r615540856 ## File path: flink-tests/src/test/java/org/apache/flink/test/checkpointing/UnalignedCheckpointStressITCase.java ## @@ -0,0 +1,553 @@ +/* + * Licensed

[GitHub] [flink] pnowojski commented on a change in pull request #15631: [FLINK-20103][tests] Add UnalignedCheckpointsStressITCase

pnowojski commented on a change in pull request #15631: URL: https://github.com/apache/flink/pull/15631#discussion_r615540856 ## File path: flink-tests/src/test/java/org/apache/flink/test/checkpointing/UnalignedCheckpointStressITCase.java ## @@ -0,0 +1,553 @@ +/* + * Licensed

[GitHub] [flink] flinkbot edited a comment on pull request #15659: [FLINK-22338][blink planner] Clear watermark output when test finishe…

flinkbot edited a comment on pull request #15659: URL: https://github.com/apache/flink/pull/15659#issuecomment-822156612 ## CI report: * ece93ac34030b5c514d888fd93b4224ee1775865 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15658: [FLINK-18206][table-api / sql-client] Fix the incorrect timestamp display

flinkbot edited a comment on pull request #15658: URL: https://github.com/apache/flink/pull/15658#issuecomment-822156568 ## CI report: * fe8c2a3c2293b07ef2dd72bbf020dc0a0dd34944 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15585: [FLINK-22065] [sql-client]Beautify the parse error exception

flinkbot edited a comment on pull request #15585: URL: https://github.com/apache/flink/pull/15585#issuecomment-818496243 ## CI report: * 43ba5f79a68e74db6f5eb14733ec99c3329cc439 UNKNOWN * bd68953c401834138beddab51de36159970d3214 Azure:

[jira] [Commented] (FLINK-22155) Fix EXPLAIN implementation

[ https://issues.apache.org/jira/browse/FLINK-22155?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17324680#comment-17324680 ] WeiNan Zhao commented on FLINK-22155: - please assgin to me , i will do it > Fix EXPLAIN

[GitHub] [flink] flinkbot commented on pull request #15658: [FLINK-18206][table-api / sql-client] Fix the incorrect timestamp display

flinkbot commented on pull request #15658: URL: https://github.com/apache/flink/pull/15658#issuecomment-822156568 ## CI report: * fe8c2a3c2293b07ef2dd72bbf020dc0a0dd34944 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #15657: [FLINK-22335][runtime][config] Increase default resource wait timeout for the adaptive scheduler.

flinkbot edited a comment on pull request #15657: URL: https://github.com/apache/flink/pull/15657#issuecomment-822150567 ## CI report: * 16939921d94de5421c6cb8453c5a9158a40bee4a Azure:

[GitHub] [flink] flinkbot commented on pull request #15659: [FLINK-22338][blink planner] Clear watermark output when test finishe…

flinkbot commented on pull request #15659: URL: https://github.com/apache/flink/pull/15659#issuecomment-822156612 ## CI report: * ece93ac34030b5c514d888fd93b4224ee1775865 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #15585: [FLINK-22065] [sql-client]Beautify the parse error exception

flinkbot edited a comment on pull request #15585: URL: https://github.com/apache/flink/pull/15585#issuecomment-818496243 ## CI report: * 43ba5f79a68e74db6f5eb14733ec99c3329cc439 UNKNOWN * bd68953c401834138beddab51de36159970d3214 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15524: [FLINK-21667][runtime] Defer starting ResourceManager to after obtaining leadership.

flinkbot edited a comment on pull request #15524: URL: https://github.com/apache/flink/pull/15524#issuecomment-815574117 ## CI report: * dede9f2601a1835e66b200b56769068a3502e136 Azure:

[GitHub] [flink] flinkbot commented on pull request #15658: [FLINK-18206][table-api / sql-client] Fix the incorrect timestamp display

flinkbot commented on pull request #15658: URL: https://github.com/apache/flink/pull/15658#issuecomment-822150888 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the

[GitHub] [flink] flinkbot commented on pull request #15659: [FLINK-22338][blink planner] Clear watermark output when test finishe…

flinkbot commented on pull request #15659: URL: https://github.com/apache/flink/pull/15659#issuecomment-822150875 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the

[GitHub] [flink] flinkbot commented on pull request #15657: [FLINK-22335][runtime][config] Increase default resource wait timeout for the adaptive scheduler.

flinkbot commented on pull request #15657: URL: https://github.com/apache/flink/pull/15657#issuecomment-822150567 ## CI report: * 16939921d94de5421c6cb8453c5a9158a40bee4a UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #15633: [FLINK-22085][tests] Update NetworkFailureHandler to prevent closeOnFlush() from being called recursively

flinkbot edited a comment on pull request #15633: URL: https://github.com/apache/flink/pull/15633#issuecomment-820496249 ## CI report: * 4e2263dfc3d5a4851bed61db5b74fb6297a05418 Azure:

[jira] [Updated] (FLINK-22338) Clear watermark output when test finished for FromElementSourceFunctionWithWatermark

[ https://issues.apache.org/jira/browse/FLINK-22338?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-22338: --- Labels: pull-request-available (was: ) > Clear watermark output when test finished for >

[GitHub] [flink] flinkbot edited a comment on pull request #15524: [FLINK-21667][runtime] Defer starting ResourceManager to after obtaining leadership.

flinkbot edited a comment on pull request #15524: URL: https://github.com/apache/flink/pull/15524#issuecomment-815574117 ## CI report: * 06d48c6d781b30b59b4a4f95ee7a1eaa03f89939 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15476: [FLINK-22098][table-planner-blink] Fix bug for window join: plan is wrong if join condition contain 'IS NOT DISTINCT FROM'

flinkbot edited a comment on pull request #15476: URL: https://github.com/apache/flink/pull/15476#issuecomment-812307606 ## CI report: * f85197c7bb0c334252f289fd440e041ebb8ca26f Azure:

[GitHub] [flink] fsk119 opened a new pull request #15659: [FLINK-22338][blink planner] Clear watermark output when test finishe…

fsk119 opened a new pull request #15659: URL: https://github.com/apache/flink/pull/15659 …d for FromElementSourceFunctionWithWatermark ## What is the purpose of the change *Clear the watermark output per test. To reproduce this bug, please run `SourceWatermarkITCase`

[jira] [Commented] (FLINK-20329) Elasticsearch7DynamicSinkITCase hangs

[ https://issues.apache.org/jira/browse/FLINK-20329?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17324675#comment-17324675 ] Rui Li commented on FLINK-20329: Here's another instance:

[jira] [Updated] (FLINK-18206) The timestamp is displayed incorrectly

[ https://issues.apache.org/jira/browse/FLINK-18206?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-18206: --- Labels: pull-request-available (was: ) > The timestamp is displayed incorrectly >

[GitHub] [flink] leonardBang commented on pull request #15658: [FLINK-18206][table-api / sql-client] Fix the incorrect timestamp display

leonardBang commented on pull request #15658: URL: https://github.com/apache/flink/pull/15658#issuecomment-822148907 cc @fsk119 Could you help take a look this PR? -- 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] leonardBang opened a new pull request #15658: [FLINK-18206][table-api / sql-client] Fix the incorrect timestamp display

leonardBang opened a new pull request #15658: URL: https://github.com/apache/flink/pull/15658 ## What is the purpose of the change * This pull request fix the incorrect timestamp display in Sql-Client ## Brief change log - Format TIMESTAMP/TIMESTAMP_LTZ type data

[GitHub] [flink] LadyForest commented on a change in pull request #13011: [FLINK-16384][table sql/client] Support SHOW CREATE TABLE statement

LadyForest commented on a change in pull request #13011: URL: https://github.com/apache/flink/pull/13011#discussion_r615522665 ## File path: flink-table/flink-table-common/src/main/java/org/apache/flink/table/api/constraints/UniqueConstraint.java ## @@ -75,21 +76,26 @@ public

[GitHub] [flink] flinkbot edited a comment on pull request #15656: [FLINK-22233][Table SQL / API]Modified the spelling error of word "constant" in source code

flinkbot edited a comment on pull request #15656: URL: https://github.com/apache/flink/pull/15656#issuecomment-822135263 ## CI report: * f80ef656c7aa47da98de32c314f77a2c951ea628 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15566: [FLINK-21798][test] Fail on double-freeing memory segment for CI tests.

flinkbot edited a comment on pull request #15566: URL: https://github.com/apache/flink/pull/15566#issuecomment-817640645 ## CI report: * cd38fff04c018505d9e62818d6571b2d656f7258 Azure:

[GitHub] [flink] flinkbot commented on pull request #15657: [FLINK-22335][runtime][config] Increase default resource wait timeout for the adaptive scheduler.

flinkbot commented on pull request #15657: URL: https://github.com/apache/flink/pull/15657#issuecomment-822140711 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the

[GitHub] [flink] flinkbot edited a comment on pull request #15633: [FLINK-22085][tests] Update NetworkFailureHandler to prevent closeOnFlush() from being called recursively

flinkbot edited a comment on pull request #15633: URL: https://github.com/apache/flink/pull/15633#issuecomment-820496249 ## CI report: * 4e2263dfc3d5a4851bed61db5b74fb6297a05418 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15476: [FLINK-22098][table-planner-blink] Fix bug for window join: plan is wrong if join condition contain 'IS NOT DISTINCT FROM'

flinkbot edited a comment on pull request #15476: URL: https://github.com/apache/flink/pull/15476#issuecomment-812307606 ## CI report: * f85197c7bb0c334252f289fd440e041ebb8ca26f Azure:

[jira] [Updated] (FLINK-22335) Increase default resource wait timeout for the adaptive scheduler

[ https://issues.apache.org/jira/browse/FLINK-22335?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-22335: --- Labels: pull-request-available (was: ) > Increase default resource wait timeout for the

[GitHub] [flink] xintongsong opened a new pull request #15657: [FLINK-22335][runtime][config] Increase default resource wait timeout for the adaptive scheduler.

xintongsong opened a new pull request #15657: URL: https://github.com/apache/flink/pull/15657 -- 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. For queries about this

[GitHub] [flink] xintongsong commented on pull request #15657: [FLINK-22335][runtime][config] Increase default resource wait timeout for the adaptive scheduler.

xintongsong commented on pull request #15657: URL: https://github.com/apache/flink/pull/15657#issuecomment-822140220 cc @tillrohrmann -- 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] [Created] (FLINK-22339) Fix some encoding exceptions were not thrown in cython coders

Huang Xingbo created FLINK-22339: Summary: Fix some encoding exceptions were not thrown in cython coders Key: FLINK-22339 URL: https://issues.apache.org/jira/browse/FLINK-22339 Project: Flink

[jira] [Updated] (FLINK-22338) Clear watermark output when test finished for FromElementSourceFunctionWithWatermark

[ https://issues.apache.org/jira/browse/FLINK-22338?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shengkai Fang updated FLINK-22338: -- Fix Version/s: 1.13.0 > Clear watermark output when test finished for >

[jira] [Created] (FLINK-22338) Clear watermark output when test finished for FromElementSourceFunctionWithWatermark

Shengkai Fang created FLINK-22338: - Summary: Clear watermark output when test finished for FromElementSourceFunctionWithWatermark Key: FLINK-22338 URL: https://issues.apache.org/jira/browse/FLINK-22338

[jira] [Closed] (FLINK-22337) Support 'ALTER TABLE ADD' statement

[ https://issues.apache.org/jira/browse/FLINK-22337?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jane Chan closed FLINK-22337. - Resolution: Duplicate > Support 'ALTER TABLE ADD' statement > --- > >

[jira] [Commented] (FLINK-22170) Manual test for hive dialect

[ https://issues.apache.org/jira/browse/FLINK-22170?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17324665#comment-17324665 ] Shengkai Fang commented on FLINK-22170: --- Thanks for [~lirui] detailed guidance. I have verified

[GitHub] [flink] lindong28 commented on pull request #15633: [FLINK-22085][tests] Update NetworkFailureHandler to prevent closeOnFlush() from being called recursively

lindong28 commented on pull request #15633: URL: https://github.com/apache/flink/pull/15633#issuecomment-822137671 Thank you @dawidwys for the helpful comments. I have updated the PR as suggested. Could you take another look? -- This is an automated message from the Apache Git

[jira] [Created] (FLINK-22337) Support 'ALTER TABLE ADD' statement

Jane Chan created FLINK-22337: - Summary: Support 'ALTER TABLE ADD' statement Key: FLINK-22337 URL: https://issues.apache.org/jira/browse/FLINK-22337 Project: Flink Issue Type: Sub-task

[jira] [Commented] (FLINK-22299) should remind users to ignoreParseErrors option when parser failed

[ https://issues.apache.org/jira/browse/FLINK-22299?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17324664#comment-17324664 ] zoucao commented on FLINK-22299: Hi [~lzljs3620320], I think FLINK-20795 is same ticket as this, but no

[jira] [Comment Edited] (FLINK-8531) Support separation of "Exclusive", "Shared" and "Task owned" state

[ https://issues.apache.org/jira/browse/FLINK-8531?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17324663#comment-17324663 ] Yun Tang edited comment on FLINK-8531 at 4/19/21, 3:13 AM: --- [~fanrui] I think

[jira] [Commented] (FLINK-8531) Support separation of "Exclusive", "Shared" and "Task owned" state

[ https://issues.apache.org/jira/browse/FLINK-8531?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17324663#comment-17324663 ] Yun Tang commented on FLINK-8531: - [~fanrui] I think you could loot at FLINK-13856 first which has

[jira] [Updated] (FLINK-17232) Rethink the implicit behavior to use the Service externalIP as the address of the Endpoint

[ https://issues.apache.org/jira/browse/FLINK-17232?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yang Wang updated FLINK-17232: -- Labels: (was: stale-assigned) > Rethink the implicit behavior to use the Service externalIP as the

[jira] [Updated] (FLINK-22233) Spelling error of word "constant" in source code

[ https://issues.apache.org/jira/browse/FLINK-22233?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-22233: --- Labels: pull-request-available starter (was: starter) > Spelling error of word "constant"

[jira] [Updated] (FLINK-16601) Correct the way to get Endpoint address for NodePort rest Service

[ https://issues.apache.org/jira/browse/FLINK-16601?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yang Wang updated FLINK-16601: -- Labels: (was: stale-assigned) > Correct the way to get Endpoint address for NodePort rest Service >

[jira] [Updated] (FLINK-17231) Deprecate possible implicit fallback from LB to NodePort When retrieving Endpoint of LB Service

[ https://issues.apache.org/jira/browse/FLINK-17231?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yang Wang updated FLINK-17231: -- Labels: (was: stale-assigned) > Deprecate possible implicit fallback from LB to NodePort When

[GitHub] [flink] flinkbot commented on pull request #15656: [FLINK-22233][Table SQL / API]Modified the spelling error of word "constant" in source code

flinkbot commented on pull request #15656: URL: https://github.com/apache/flink/pull/15656#issuecomment-822135263 ## CI report: * f80ef656c7aa47da98de32c314f77a2c951ea628 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #15566: [FLINK-21798][test] Fail on double-freeing memory segment for CI tests.

flinkbot edited a comment on pull request #15566: URL: https://github.com/apache/flink/pull/15566#issuecomment-817640645 ## CI report: * cd38fff04c018505d9e62818d6571b2d656f7258 Azure:

[jira] [Closed] (FLINK-22104) SqlClientTest.testExecuteSqlFile fail

[ https://issues.apache.org/jira/browse/FLINK-22104?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-22104. --- Fix Version/s: 1.14.0 Resolution: Fixed Fixed in - master:

[jira] [Updated] (FLINK-17707) Support configuring replica of Deployment based HA setups

[ https://issues.apache.org/jira/browse/FLINK-17707?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yang Wang updated FLINK-17707: -- Labels: pull-request-available (was: pull-request-available stale-assigned) > Support configuring

[GitHub] [flink] flinkbot edited a comment on pull request #15121: The method $(String) is undefined for the type TableExample

flinkbot edited a comment on pull request #15121: URL: https://github.com/apache/flink/pull/15121#issuecomment-793480240 ## CI report: * cf26ce895a7956d258acc073817f578558e78227 UNKNOWN * 709c4110370b845f42d916a06e56c6026cf2fac8 UNKNOWN *

[GitHub] [flink] wuchong closed pull request #15534: [FLINK-22104][sql-client] Fix unstable SqlClientTest.testExecuteSqlFile

wuchong closed pull request #15534: URL: https://github.com/apache/flink/pull/15534 -- 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. For queries about this service,

[jira] [Commented] (FLINK-22326) Job contains Iterate Operator always fails on Checkpoint

[ https://issues.apache.org/jira/browse/FLINK-22326?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17324657#comment-17324657 ] Zhilong Hong commented on FLINK-22326: -- Hi, [~qqibrow], JIRA is mainly used for issue reporting and

[jira] [Created] (FLINK-22336) [umbrella] Enhance testing for built-in functions

Jingsong Lee created FLINK-22336: Summary: [umbrella] Enhance testing for built-in functions Key: FLINK-22336 URL: https://issues.apache.org/jira/browse/FLINK-22336 Project: Flink Issue

[jira] [Assigned] (FLINK-22335) Increase default resource wait timeout for the adaptive scheduler

[ https://issues.apache.org/jira/browse/FLINK-22335?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song reassigned FLINK-22335: Assignee: Xintong Song > Increase default resource wait timeout for the adaptive

[jira] [Commented] (FLINK-22135) Test the adaptive scheduler

[ https://issues.apache.org/jira/browse/FLINK-22135?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17324655#comment-17324655 ] Xintong Song commented on FLINK-22135: -- Sounds good. I've created FLINK-22335 for increasing the

[jira] [Closed] (FLINK-22135) Test the adaptive scheduler

[ https://issues.apache.org/jira/browse/FLINK-22135?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song closed FLINK-22135. Resolution: Done > Test the adaptive scheduler > --- > >

[jira] [Created] (FLINK-22335) Increase default resource wait timeout for the adaptive scheduler

Xintong Song created FLINK-22335: Summary: Increase default resource wait timeout for the adaptive scheduler Key: FLINK-22335 URL: https://issues.apache.org/jira/browse/FLINK-22335 Project: Flink

[GitHub] [flink] hackergin commented on pull request #15655: [FLINK-11746][thrift] Add thrift format support in Flink

hackergin commented on pull request #15655: URL: https://github.com/apache/flink/pull/15655#issuecomment-822131337 @Myasuka pr submitted , please take time to review when you are free, thanks . -- This is an automated message from the Apache Git Service. To respond to the message,

[GitHub] [flink] beyond1920 commented on pull request #15476: [FLINK-22098][table-planner-blink] Fix bug for window join: plan is wrong if join condition contain 'IS NOT DISTINCT FROM'

beyond1920 commented on pull request #15476: URL: https://github.com/apache/flink/pull/15476#issuecomment-822130446 @godfreyhe Thanks for review, I've addressed failed case -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and

[GitHub] [flink] lindong28 commented on a change in pull request #15633: [FLINK-22085][tests] Update NetworkFailureHandler to prevent closeOnFlush() from being called recursively

lindong28 commented on a change in pull request #15633: URL: https://github.com/apache/flink/pull/15633#discussion_r615512096 ## File path: flink-test-utils-parent/flink-test-utils/src/main/java/org/apache/flink/networking/NetworkFailureHandler.java ## @@ -73,8 +76,10 @@

[jira] [Commented] (FLINK-22233) Spelling error of word "constant" in source code

[ https://issues.apache.org/jira/browse/FLINK-22233?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17324652#comment-17324652 ] yongsheng commented on FLINK-22233: --- [~jark] I have open a pull request for this,please check 

[GitHub] [flink] flinkbot commented on pull request #15656: Modified th spelling error of word "constant" in source codeSpelling …

flinkbot commented on pull request #15656: URL: https://github.com/apache/flink/pull/15656#issuecomment-822128180 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the

[GitHub] [flink] wysstartgo commented on pull request #15656: Modified th spelling error of word "constant" in source codeSpelling …

wysstartgo commented on pull request #15656: URL: https://github.com/apache/flink/pull/15656#issuecomment-822127644 Modified the spelling error of word "constant" in source code -- This is an automated message from the Apache Git Service. To respond to the message, please log on to

[GitHub] [flink] wysstartgo opened a new pull request #15656: Modified th spelling error of word "constant" in source codeSpelling …

wysstartgo opened a new pull request #15656: URL: https://github.com/apache/flink/pull/15656 ## What is the purpose of the change Modified the spelling error of word "constant" in source code. As described in FLINK-22233. ## Brief change log - The description

[jira] [Updated] (FLINK-22099) Fix bug for semi/anti window join.

[ https://issues.apache.org/jira/browse/FLINK-22099?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andy updated FLINK-22099: - Description: Fix bug for Semi/Anti WindowJoin. {code:java} //代码占位符 @Test def testSemiJoinIN(): Unit = { val

[GitHub] [flink] flinkbot edited a comment on pull request #15477: [FLINK-22099][table-planner-blink] Fix bug for semi/anti window join.

flinkbot edited a comment on pull request #15477: URL: https://github.com/apache/flink/pull/15477#issuecomment-812337208 ## CI report: * fb7df56df7e4b5e1cf9f1eee726f9d338c0187e6 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15121: The method $(String) is undefined for the type TableExample

flinkbot edited a comment on pull request #15121: URL: https://github.com/apache/flink/pull/15121#issuecomment-793480240 ## CI report: * cf26ce895a7956d258acc073817f578558e78227 UNKNOWN * 709c4110370b845f42d916a06e56c6026cf2fac8 UNKNOWN *

[GitHub] [flink] SteNicholas edited a comment on pull request #15020: [FLINK-21445][kubernetes] Application mode does not set the configuration when building PackagedProgram

SteNicholas edited a comment on pull request #15020: URL: https://github.com/apache/flink/pull/15020#issuecomment-819508156 @XComp @wangyang0918 I have followed the detailed review comments. Please help to review the update of the pull request. -- This is an automated message from the

[GitHub] [flink] flinkbot edited a comment on pull request #15477: [FLINK-22099][table-planner-blink] Fix bug for semi/anti window join.

flinkbot edited a comment on pull request #15477: URL: https://github.com/apache/flink/pull/15477#issuecomment-812337208 ## CI report: * fb7df56df7e4b5e1cf9f1eee726f9d338c0187e6 Azure:

[jira] [Commented] (FLINK-22233) Spelling error of word "constant" in source code

[ https://issues.apache.org/jira/browse/FLINK-22233?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17324646#comment-17324646 ] yongsheng commented on FLINK-22233: --- [~jark]   I find this problem mainly appears in three places:

[GitHub] [flink] dianfu commented on pull request #15649: [FLINK-22327][python] Set bundleStarted to false even if it throws exception in finishBundle

dianfu commented on pull request #15649: URL: https://github.com/apache/flink/pull/15649#issuecomment-822116939 Closed via e64ed75a5f2dd89f8a23665a54ba3239bd362fdd -- 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] dianfu closed pull request #15649: [FLINK-22327][python] Set bundleStarted to false even if it throws exception in finishBundle

dianfu closed pull request #15649: URL: https://github.com/apache/flink/pull/15649 -- 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. For queries about this service, please

[jira] [Closed] (FLINK-22327) NPE exception happens if it throws exception in finishBundle during job shutdown

[ https://issues.apache.org/jira/browse/FLINK-22327?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-22327. --- Resolution: Fixed Fixed in - master via 4f41e6dae85ce53d8dde432715b90789be719204 - release-1.12 via

[GitHub] [flink] dianfu closed pull request #15650: [FLINK-22327][python] Set bundleStarted to false even if it throws exception in finishBundle

dianfu closed pull request #15650: URL: https://github.com/apache/flink/pull/15650 -- 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. For queries about this service, please

[jira] [Created] (FLINK-22334) Fail to translate the hive-sql in STREAMING mode

Shengkai Fang created FLINK-22334: - Summary: Fail to translate the hive-sql in STREAMING mode Key: FLINK-22334 URL: https://issues.apache.org/jira/browse/FLINK-22334 Project: Flink Issue

[GitHub] [flink] beyond1920 commented on pull request #15477: [FLINK-22099][table-planner-blink] Fix bug for semi/anti window join.

beyond1920 commented on pull request #15477: URL: https://github.com/apache/flink/pull/15477#issuecomment-822113140 @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

[jira] [Commented] (FLINK-22099) Fix bug for semi/anti window join.

[ https://issues.apache.org/jira/browse/FLINK-22099?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17324639#comment-17324639 ] godfrey he commented on FLINK-22099: [~qingru zhang], please add some description for this bug,

[jira] [Updated] (FLINK-21799) Detect and fail explicitly on managed memory leaking

[ https://issues.apache.org/jira/browse/FLINK-21799?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-21799: - Labels: (was: stale-assigned) > Detect and fail explicitly on managed memory leaking >

[jira] [Updated] (FLINK-20988) Various resource allocation improvements for active resource managers

[ https://issues.apache.org/jira/browse/FLINK-20988?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-20988: - Labels: Umbrella (was: Umbrella stale-assigned) > Various resource allocation improvements for

[jira] [Updated] (FLINK-21375) Refactor HybridMemorySegment

[ https://issues.apache.org/jira/browse/FLINK-21375?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-21375: - Labels: (was: stale-assigned) > Refactor HybridMemorySegment > >

[jira] [Commented] (FLINK-21667) Standby RM might remove resources from Kubernetes

[ https://issues.apache.org/jira/browse/FLINK-21667?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17324636#comment-17324636 ] Xintong Song commented on FLINK-21667: -- A PR has been opened for this ticket. We are waiting for

[jira] [Updated] (FLINK-21667) Standby RM might remove resources from Kubernetes

[ https://issues.apache.org/jira/browse/FLINK-21667?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-21667: - Labels: pull-request-available (was: pull-request-available stale-assigned) > Standby RM might

[jira] [Commented] (FLINK-19711) Parsing of invalid CSV fails even with ignoreParseErrors is enabled

[ https://issues.apache.org/jira/browse/FLINK-19711?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17324629#comment-17324629 ] Austin Cawley-Edwards commented on FLINK-19711: --- I had difficulty reproducing this in

[jira] [Assigned] (FLINK-21538) Elasticsearch6DynamicSinkITCase.testWritingDocuments fails when submitting job

[ https://issues.apache.org/jira/browse/FLINK-21538?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Austin Cawley-Edwards reassigned FLINK-21538: - Assignee: (was: Austin Cawley-Edwards) >

[GitHub] [flink] flinkbot edited a comment on pull request #15655: [FLINK-11746][thrift] Add thrift format support in Flink

flinkbot edited a comment on pull request #15655: URL: https://github.com/apache/flink/pull/15655#issuecomment-822040292 ## CI report: * da4b1ee8634ae3cca64ead40c02f7c2f29a11408 Azure:

  1   2   >