[jira] [Commented] (FLINK-22069) Check Log Pollution for 1.13 release

2021-04-12 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22069?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17319167#comment-17319167 ] Till Rohrmann commented on FLINK-22069: --- Thanks for collecting all the logging problems [~chesnay]

[GitHub] [flink] flinkbot commented on pull request #15563: [FLINK-21748][sql-client] Fix unstable LocalExecutorITCase.testBatchQ…

2021-04-12 Thread GitBox
flinkbot commented on pull request #15563: URL: https://github.com/apache/flink/pull/15563#issuecomment-817611262 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] zentol merged pull request #15552: [FLINK-22184][client] Shutdown client outside of netty thread

2021-04-12 Thread GitBox
zentol merged pull request #15552: URL: https://github.com/apache/flink/pull/15552 -- 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

[GitHub] [flink] flinkbot commented on pull request #15562: [FLINK-22169][sql-client] Beautify the CliTableauResultView when print

2021-04-12 Thread GitBox
flinkbot commented on pull request #15562: URL: https://github.com/apache/flink/pull/15562#issuecomment-817610135 ## CI report: * 237ebdca2e429a3a9fc12a1e258ddcc709b31e43 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #15543: [FLINK-17803][table] Should throw a readable exception when group by Map type

2021-04-12 Thread GitBox
flinkbot edited a comment on pull request #15543: URL: https://github.com/apache/flink/pull/15543#issuecomment-816526178 ## CI report: * 21474ea8e4628d60cf02c716f30211cf73b7b45f Azure:

[jira] [Commented] (FLINK-15729) Table planner dependency instructions for executing in IDE can be improved

2021-04-12 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15729?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17319159#comment-17319159 ] Jark Wu commented on FLINK-15729: - Is it in {{Project Structure => Modules => Dependencies => Scope}} ?

[jira] [Commented] (FLINK-22075) Incorrect null outputs in left join

2021-04-12 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22075?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17319156#comment-17319156 ] lincoln lee commented on FLINK-22075: - So according to my understanding,this is not a blocker for

[jira] [Closed] (FLINK-22151) Implement type inference for agg functions

2021-04-12 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22151?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-22151. Fix Version/s: 1.13.0 Resolution: Fixed Fixed in 1.13.0: [table] Update type inference of

[jira] [Updated] (FLINK-21748) LocalExecutorITCase.testBatchQueryExecutionMultipleTimes[Planner: old] fails

2021-04-12 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21748?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-21748: --- Labels: pull-request-available test-stability (was: test-stability) >

[GitHub] [flink] fsk119 opened a new pull request #15563: [FLINK-21748][sql-client] Fix unstable LocalExecutorITCase.testBatchQ…

2021-04-12 Thread GitBox
fsk119 opened a new pull request #15563: URL: https://github.com/apache/flink/pull/15563 …ueryExecutionMultipleTimes[Planner: old] ## What is the purpose of the change *Considering we have introduced new sql-client testing framework and we are going to remove old

[GitHub] [flink] twalthr closed pull request #15551: [FLINK-22151][table] Implement type inference for agg functions

2021-04-12 Thread GitBox
twalthr closed pull request #15551: URL: https://github.com/apache/flink/pull/15551 -- 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,

[GitHub] [flink] KurtYoung commented on a change in pull request #15562: [FLINK-22169][sql-client] Beautify the CliTableauResultView when print

2021-04-12 Thread GitBox
KurtYoung commented on a change in pull request #15562: URL: https://github.com/apache/flink/pull/15562#discussion_r611413441 ## File path: flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/cli/CliTableauResultView.java ## @@ -132,11 +145,23 @@ private

[jira] [Commented] (FLINK-22014) Flink JobManager failed to restart after failure in kubernetes HA setup

2021-04-12 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22014?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17319149#comment-17319149 ] Till Rohrmann commented on FLINK-22014: --- Downgrading this ticket for the time being because we

[jira] [Closed] (FLINK-21891) The .staging_xxx directory isn't deleted after writing data to hive table in batch mode

2021-04-12 Thread Re0 Beatrice (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21891?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Re0 Beatrice closed FLINK-21891. Resolution: Fixed solved by https://issues.apache.org/jira/browse/FLINK-20230 > The .staging_xxx

[jira] [Updated] (FLINK-22014) Flink JobManager failed to restart after failure in kubernetes HA setup

2021-04-12 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22014?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-22014: -- Priority: Major (was: Critical) > Flink JobManager failed to restart after failure in

[GitHub] [flink] flinkbot edited a comment on pull request #15155: [FLINK-21660][table-api-java][hive] Stop using is_generic to differen…

2021-04-12 Thread GitBox
flinkbot edited a comment on pull request #15155: URL: https://github.com/apache/flink/pull/15155#issuecomment-79675 ## CI report: * 0359e7f7b997b5fa08951fd78eccd7626c9bd2c6 Azure:

[GitHub] [flink] tillrohrmann commented on pull request #15484: [FLINK-21999][Runtime/Coordination] uniformize the logic about whether checkpoint is enabled and fix some typo.

2021-04-12 Thread GitBox
tillrohrmann commented on pull request #15484: URL: https://github.com/apache/flink/pull/15484#issuecomment-817591912 @est08zw are you intending to update this PR? Otherwise I will close it at the end of this week. -- This is an automated message from the Apache Git Service. To respond

[GitHub] [flink] itinycheng commented on pull request #15555: [FLINK-21891][table-runtime-blink] Use FileSystem instance to delete the temporary directory '.staging_xxx'

2021-04-12 Thread GitBox
itinycheng commented on pull request #1: URL: https://github.com/apache/flink/pull/1#issuecomment-817590999 Solved by https://github.com/apache/flink/pull/15541 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use

[GitHub] [flink] itinycheng closed pull request #15555: [FLINK-21891][table-runtime-blink] Use FileSystem instance to delete the temporary directory '.staging_xxx'

2021-04-12 Thread GitBox
itinycheng closed pull request #1: URL: https://github.com/apache/flink/pull/1 -- 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] [Updated] (FLINK-21699) SecurityUtils JaasModule make JVM dirty

2021-04-12 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21699?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-21699: -- Priority: Major (was: Blocker) > SecurityUtils JaasModule make JVM dirty >

[jira] [Updated] (FLINK-22208) Bump snappy-java to 1.1.5+

2021-04-12 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22208?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-22208: - Fix Version/s: 1.12.3 1.11.4 > Bump snappy-java to 1.1.5+ >

[GitHub] [flink] itinycheng commented on a change in pull request #15555: [FLINK-21891][table-runtime-blink] Use FileSystem instance to delete the temporary directory '.staging_xxx'

2021-04-12 Thread GitBox
itinycheng commented on a change in pull request #1: URL: https://github.com/apache/flink/pull/1#discussion_r611409487 ## File path: flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/filesystem/FileSystemOutputFormat.java ## @@ -85,15 +85,26

[jira] [Commented] (FLINK-15729) Table planner dependency instructions for executing in IDE can be improved

2021-04-12 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15729?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17319128#comment-17319128 ] Chesnay Schepler commented on FLINK-15729: -- No; he means the option in IntelliJ that puts

[GitHub] [flink] flinkbot commented on pull request #15562: [FLINK-22169][sql-client] Beautify the CliTableauResultView when print

2021-04-12 Thread GitBox
flinkbot commented on pull request #15562: URL: https://github.com/apache/flink/pull/15562#issuecomment-817581951 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 #15543: [FLINK-17803][table] Should throw a readable exception when group by Map type

2021-04-12 Thread GitBox
flinkbot edited a comment on pull request #15543: URL: https://github.com/apache/flink/pull/15543#issuecomment-816526178 ## CI report: * 21474ea8e4628d60cf02c716f30211cf73b7b45f Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15496: [FLINK-21990][streaming] Cancel task before clean up if execution was…

2021-04-12 Thread GitBox
flinkbot edited a comment on pull request #15496: URL: https://github.com/apache/flink/pull/15496#issuecomment-814224240 ## CI report: * db7d0ea73a5272d44c744fa975520fb3c893a045 Azure:

[jira] [Updated] (FLINK-22169) Beautify the CliTableauResultView when print

2021-04-12 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22169?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-22169: --- Labels: pull-request-available (was: ) > Beautify the CliTableauResultView when print >

[jira] [Commented] (FLINK-21012) AvroFileFormatFactory uses non-deserializable lambda function

2021-04-12 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21012?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17319124#comment-17319124 ] Dawid Wysakowicz commented on FLINK-21012: -- Thanks [~airblader] ! > AvroFileFormatFactory uses

[GitHub] [flink] fsk119 opened a new pull request #15562: [FLINK-22169][sql-client] Beautify the CliTableauResultView when print

2021-04-12 Thread GitBox
fsk119 opened a new pull request #15562: URL: https://github.com/apache/flink/pull/15562 ## What is the purpose of the change *Use `PrintUtils#columnWidthsByContent` to calculate column width in batch mode. To prevent OOM, we only retrieve part of data.* ## Verifying

[jira] [Created] (FLINK-22208) Bump snappy-java to 1.1.5+

2021-04-12 Thread Chesnay Schepler (Jira)
Chesnay Schepler created FLINK-22208: Summary: Bump snappy-java to 1.1.5+ Key: FLINK-22208 URL: https://issues.apache.org/jira/browse/FLINK-22208 Project: Flink Issue Type: Improvement

[GitHub] [flink] KurtYoung commented on pull request #14872: [FLINK-21162] [Blink Planner]use "IF(col = '' OR col IS NULL, 'a', 'b')",when co…

2021-04-12 Thread GitBox
KurtYoung commented on pull request #14872: URL: https://github.com/apache/flink/pull/14872#issuecomment-817578146 FYI: this issue is already covered by another PR: https://github.com/apache/flink/pull/15547 -- This is an automated message from the Apache Git Service. To respond to the

[jira] [Assigned] (FLINK-21012) AvroFileFormatFactory uses non-deserializable lambda function

2021-04-12 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21012?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther reassigned FLINK-21012: Assignee: Ingo Bürk > AvroFileFormatFactory uses non-deserializable lambda function >

[jira] [Commented] (FLINK-21012) AvroFileFormatFactory uses non-deserializable lambda function

2021-04-12 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-21012?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17319117#comment-17319117 ] Ingo Bürk commented on FLINK-21012: --- I can take this over, would be great to put this into 1.13. >

[jira] [Closed] (FLINK-21162) FLINK SQL IF function semantic incorrect

2021-04-12 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21162?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-21162. -- Resolution: Fixed > FLINK SQL IF function semantic incorrect >

[jira] [Closed] (FLINK-22015) SQL filter containing OR and IS NULL will produce an incorrect result.

2021-04-12 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22015?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-22015. -- Resolution: Fixed fixed: a3be1cc5ed55d8d93a56fa22d3f3421ae6b65722 > SQL filter containing OR and IS

[jira] [Closed] (FLINK-22206) Add support server-mode submit for flink SQL. eg : FlinkServer

2021-04-12 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22206?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-22206. --- Resolution: Duplicate This is somewhat called SQL Client Gateway mode in Flink. > Add support server-mode

[GitHub] [flink] KurtYoung merged pull request #15547: [FLINK-22015][table-planner-blink] Exclude IS NULL from SEARCH operators

2021-04-12 Thread GitBox
KurtYoung merged pull request #15547: URL: https://github.com/apache/flink/pull/15547 -- 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-15729) Table planner dependency instructions for executing in IDE can be improved

2021-04-12 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15729?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17319109#comment-17319109 ] Jark Wu commented on FLINK-15729: - [~tzulitai] do you mean we mention that the "provided" scope needs to

[GitHub] [flink] flinkbot edited a comment on pull request #15548: [FLINK-22082][planner] Nested projection push down doesn't work for d…

2021-04-12 Thread GitBox
flinkbot edited a comment on pull request #15548: URL: https://github.com/apache/flink/pull/15548#issuecomment-816538966 ## CI report: * 5563d82537bdc6255d50a25408837658b9a6a8b7 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15498: [FLINK-22121][table-planner-blink] FlinkLogicalRankRuleBase now check if name of rankNumberType already exists in the input

2021-04-12 Thread GitBox
flinkbot edited a comment on pull request #15498: URL: https://github.com/apache/flink/pull/15498#issuecomment-814575824 ## CI report: * f4eef7b3c08ea4869ab9959ee20c46d97ad31bd6 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15525: [FLINK-22154][table-planner-blink] Fix bug where PushFilterIntoTableSourceScanRule fails to deal with IN expressions

2021-04-12 Thread GitBox
flinkbot edited a comment on pull request #15525: URL: https://github.com/apache/flink/pull/15525#issuecomment-815836876 ## CI report: * 52bd4858800e3753d22746fd0f14b027587b743e Azure:

[jira] [Commented] (FLINK-22207) Hive Catalog retrieve Flink Properties error

2021-04-12 Thread wangzeyu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22207?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17319108#comment-17319108 ] wangzeyu commented on FLINK-22207: -- i will resolve this bug > Hive Catalog retrieve Flink Properties

[GitHub] [flink] flinkbot edited a comment on pull request #15496: [FLINK-21990][streaming] Cancel task before clean up if execution was…

2021-04-12 Thread GitBox
flinkbot edited a comment on pull request #15496: URL: https://github.com/apache/flink/pull/15496#issuecomment-814224240 ## CI report: * db7d0ea73a5272d44c744fa975520fb3c893a045 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15438: [FLINK-22000] Set a default character set in InputStreamReader to sol…

2021-04-12 Thread GitBox
flinkbot edited a comment on pull request #15438: URL: https://github.com/apache/flink/pull/15438#issuecomment-810469495 ## CI report: * d16ff5596d58f30aa2752007efc8f7908059596d Azure:

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

2021-04-12 Thread GitBox
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] dawidwys commented on a change in pull request #15550: [FLINK-21031] Reenable JobMasterStopWithSavepointIT

2021-04-12 Thread GitBox
dawidwys commented on a change in pull request #15550: URL: https://github.com/apache/flink/pull/15550#discussion_r611393155 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/TaskExecutor.java ## @@ -932,9 +932,9 @@ public void

[jira] [Commented] (FLINK-22069) Check Log Pollution for 1.13 release

2021-04-12 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22069?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17319107#comment-17319107 ] Chesnay Schepler commented on FLINK-22069: -- I've opened a PR addressing some of the found

[jira] [Commented] (FLINK-22129) OrcFileSystemITCase hangs on azure

2021-04-12 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22129?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17319105#comment-17319105 ] Jark Wu commented on FLINK-22129: - May be related to FLINK-21996. > OrcFileSystemITCase hangs on azure

[jira] [Commented] (FLINK-22207) Hive Catalog retrieve Flink Properties error

2021-04-12 Thread MaChengLong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22207?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17319100#comment-17319100 ] MaChengLong commented on FLINK-22207: - As you said it should use replaceFirst to get flink

[GitHub] [flink-jira-bot] knaufk commented on a change in pull request #1: [Flink-22032] Adding Bot with Initial Rule

2021-04-12 Thread GitBox
knaufk commented on a change in pull request #1: URL: https://github.com/apache/flink-jira-bot/pull/1#discussion_r611387324 ## File path: flink_jira_bot.py ## @@ -0,0 +1,162 @@ + +# Licensed to

[jira] [Updated] (FLINK-21967) Add documentation on the operation of blocking result partition

2021-04-12 Thread Yingjie Cao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21967?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yingjie Cao updated FLINK-21967: Priority: Critical (was: Blocker) > Add documentation on the operation of blocking result

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

2021-04-12 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18206?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-18206: --- Priority: Critical (was: Blocker) > The timestamp is displayed incorrectly >

[GitHub] [flink] JingsongLi merged pull request #15544: [FLINK-17371][table-runtime] Open testDefaultDecimalCasting case in DecimalTypeTest

2021-04-12 Thread GitBox
JingsongLi merged pull request #15544: URL: https://github.com/apache/flink/pull/15544 -- 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] [Assigned] (FLINK-22144) Test display last n exceptions/causes for job restarts in Web UI

2021-04-12 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22144?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz reassigned FLINK-22144: Assignee: Dawid Wysakowicz > Test display last n exceptions/causes for job

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

2021-04-12 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22170?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-22170: --- Assignee: Shengkai Fang > Manual test for hive dialect > > >

[jira] [Assigned] (FLINK-22176) Test SQL Client manually

2021-04-12 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22176?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-22176: --- Assignee: Rui Li > Test SQL Client manually > > > Key:

[jira] [Assigned] (FLINK-22160) Test Window TVF based aggregation and TopN

2021-04-12 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22160?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-22160: --- Assignee: Leonard Xu > Test Window TVF based aggregation and TopN >

[jira] [Assigned] (FLINK-22179) Manual test time function changes and new time attributes support

2021-04-12 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22179?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-22179: --- Assignee: Jark Wu > Manual test time function changes and new time attributes support >

[jira] [Commented] (FLINK-22127) Enrich error message of read buffer request timeout exception

2021-04-12 Thread Guowei Ma (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22127?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17319096#comment-17319096 ] Guowei Ma commented on FLINK-22127: --- Fixed in master : cbf3c5f86420c06c32b5cc0237d2288592c8b808 >

[jira] [Closed] (FLINK-22127) Enrich error message of read buffer request timeout exception

2021-04-12 Thread Guowei Ma (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22127?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guowei Ma closed FLINK-22127. - Resolution: Fixed > Enrich error message of read buffer request timeout exception >

[GitHub] [flink] guoweiM closed pull request #15499: [FLINK-22127][network] Enrich error message of read buffer request timeout to tell the user how to solve the problem when using sort-merge blocking

2021-04-12 Thread GitBox
guoweiM closed pull request #15499: URL: https://github.com/apache/flink/pull/15499 -- 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] [Assigned] (FLINK-22158) Test native Kubernetes pod template

2021-04-12 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22158?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz reassigned FLINK-22158: Assignee: Robert Metzger > Test native Kubernetes pod template >

[jira] [Assigned] (FLINK-22153) Manually test the sort-merge blocking shuffle

2021-04-12 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22153?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz reassigned FLINK-22153: Assignee: Till Rohrmann > Manually test the sort-merge blocking shuffle >

[jira] [Assigned] (FLINK-22132) Test unaligned checkpoints rescaling manually on a real cluster

2021-04-12 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22132?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski reassigned FLINK-22132: -- Assignee: Anton Kalashnikov > Test unaligned checkpoints rescaling manually on a

[GitHub] [flink] akalash commented on pull request #15496: [FLINK-21990][streaming] Cancel task before clean up if execution was…

2021-04-12 Thread GitBox
akalash commented on pull request #15496: URL: https://github.com/apache/flink/pull/15496#issuecomment-817548945 @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

[jira] [Commented] (FLINK-21859) Batch job fails due to "Could not mark slot 61a637e3977c58a0e6b73533c419297d active"

2021-04-12 Thread Yingjie Cao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21859?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17319083#comment-17319083 ] Yingjie Cao commented on FLINK-21859: - OK, I will try to reproduce the issue with DEBUG logs

[jira] [Comment Edited] (FLINK-22201) Incorrect output for simple sql query

2021-04-12 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22201?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17319085#comment-17319085 ] Jark Wu edited comment on FLINK-22201 at 4/12/21, 7:07 AM: --- [~jamii],

[jira] [Commented] (FLINK-22201) Incorrect output for simple sql query

2021-04-12 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22201?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17319085#comment-17319085 ] Jark Wu commented on FLINK-22201: - [~jamii], {{execution.runtime-mode=BATCH}} is a SQL Client

[GitHub] [flink] pnowojski commented on a change in pull request #15550: [FLINK-21031] Reenable JobMasterStopWithSavepointIT

2021-04-12 Thread GitBox
pnowojski commented on a change in pull request #15550: URL: https://github.com/apache/flink/pull/15550#discussion_r611375235 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/TaskExecutor.java ## @@ -932,9 +932,9 @@ public void

[GitHub] [flink] TsReaper commented on pull request #15547: [FLINK-22015][table-planner-blink] Exclude IS NULL from SEARCH operators

2021-04-12 Thread GitBox
TsReaper commented on pull request #15547: URL: https://github.com/apache/flink/pull/15547#issuecomment-817544458 Azure passed in https://dev.azure.com/tsreaper96/Flink/_build/results?buildId=152=results -- This is an automated message from the Apache Git Service. To respond to the

[GitHub] [flink] flinkbot edited a comment on pull request #15548: [FLINK-22082][planner] Nested projection push down doesn't work for d…

2021-04-12 Thread GitBox
flinkbot edited a comment on pull request #15548: URL: https://github.com/apache/flink/pull/15548#issuecomment-816538966 ## CI report: * 5563d82537bdc6255d50a25408837658b9a6a8b7 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15499: [FLINK-22127][network] Enrich error message of read buffer request timeout to tell the user how to solve the problem when using sort-

2021-04-12 Thread GitBox
flinkbot edited a comment on pull request #15499: URL: https://github.com/apache/flink/pull/15499#issuecomment-814647050 ## CI report: * 1046d3b7f2d28cc36ed2a5b296fe3ae316afbede Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15525: [FLINK-22154][table-planner-blink] Fix bug where PushFilterIntoTableSourceScanRule fails to deal with IN expressions

2021-04-12 Thread GitBox
flinkbot edited a comment on pull request #15525: URL: https://github.com/apache/flink/pull/15525#issuecomment-815836876 ## CI report: * 52bd4858800e3753d22746fd0f14b027587b743e Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15498: [FLINK-22121][table-planner-blink] FlinkLogicalRankRuleBase now check if name of rankNumberType already exists in the input

2021-04-12 Thread GitBox
flinkbot edited a comment on pull request #15498: URL: https://github.com/apache/flink/pull/15498#issuecomment-814575824 ## CI report: * f4eef7b3c08ea4869ab9959ee20c46d97ad31bd6 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15438: [FLINK-22000] Set a default character set in InputStreamReader to sol…

2021-04-12 Thread GitBox
flinkbot edited a comment on pull request #15438: URL: https://github.com/apache/flink/pull/15438#issuecomment-810469495 ## CI report: * e81fecf9cb69c9c87103c6e8646e15c7cad160ea Azure:

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

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

[jira] [Updated] (FLINK-20188) Add Documentation for new File Source

2021-04-12 Thread Stephan Ewen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20188?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen updated FLINK-20188: - Priority: Critical (was: Blocker) > Add Documentation for new File Source >

[jira] [Commented] (FLINK-22075) Incorrect null outputs in left join

2021-04-12 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22075?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17319078#comment-17319078 ] lincoln lee commented on FLINK-22075: - The watermark is applied to both side of the join here

[jira] [Comment Edited] (FLINK-22207) Hive Catalog retrieve Flink Properties error

2021-04-12 Thread wangzeyu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22207?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17319061#comment-17319061 ] wangzeyu edited comment on FLINK-22207 at 4/12/21, 6:50 AM: So here's my

[jira] [Closed] (FLINK-20230) INSERT INTO EMPTY VALUES, THROW FileNotFoundException

2021-04-12 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20230?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-20230. Resolution: Fixed master (1.13): 562f31a3ebe53d6827591dfa84501e2babda3693 > INSERT INTO EMPTY

[jira] [Commented] (FLINK-22207) Hive Catalog retrieve Flink Properties error

2021-04-12 Thread wangzeyu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22207?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17319061#comment-17319061 ] wangzeyu commented on FLINK-22207: -- So here's my solution , change replace to replaceFirst {code:java}

[GitHub] [flink] JingsongLi merged pull request #15541: [FLINK-20230][table] FileSystemOutputFormat should delete file using FileSystemFactory

2021-04-12 Thread GitBox
JingsongLi merged pull request #15541: URL: https://github.com/apache/flink/pull/15541 -- 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] [Closed] (FLINK-22106) ResultType of GeneratedExpression in StringCallGen should be compatible with their definition in FlinkSqlOperatorTable

2021-04-12 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22106?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-22106. Resolution: Fixed master (1.13): 73f66d91207b96958cdb596310781e56ffc0515e > ResultType of

[GitHub] [flink] JingsongLi commented on pull request #15489: [FLINK-22106][table-planner-blink] Result type of GeneratedExpression in StringCallGen should be compatible with their definition in Flink

2021-04-12 Thread GitBox
JingsongLi commented on pull request #15489: URL: https://github.com/apache/flink/pull/15489#issuecomment-817534391 > @TsReaper Can you create a PR for release-1.13? Ignore me, there is no release-1.13 branch now. -- This is an automated message from the Apache Git Service. To

[jira] [Created] (FLINK-22207) Hive Catalog retrieve Flink Properties error

2021-04-12 Thread wangzeyu (Jira)
wangzeyu created FLINK-22207: Summary: Hive Catalog retrieve Flink Properties error Key: FLINK-22207 URL: https://issues.apache.org/jira/browse/FLINK-22207 Project: Flink Issue Type: Bug

[GitHub] [flink] flinkbot edited a comment on pull request #15561: [FLINK-20695][ha] Clean up ha data for job if globally terminated

2021-04-12 Thread GitBox
flinkbot edited a comment on pull request #15561: URL: https://github.com/apache/flink/pull/15561#issuecomment-817508957 ## CI report: * 85afc0e14a28cdf84f44a2013306e3257421 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15542: [FLINK-21950][core][test] Fix double-freeing memory segment in DemultiplexingRecordDeserializerTest.

2021-04-12 Thread GitBox
flinkbot edited a comment on pull request #15542: URL: https://github.com/apache/flink/pull/15542#issuecomment-816526082 ## CI report: * 06888b2e303afb0f80bb9f3db815c8ae21d2371b Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15499: [FLINK-22127][network] Enrich error message of read buffer request timeout to tell the user how to solve the problem when using sort-

2021-04-12 Thread GitBox
flinkbot edited a comment on pull request #15499: URL: https://github.com/apache/flink/pull/15499#issuecomment-814647050 ## CI report: * 1046d3b7f2d28cc36ed2a5b296fe3ae316afbede Azure:

[GitHub] [flink] dbgp2021 commented on pull request #15438: [FLINK-22000] Set a default character set in InputStreamReader to sol…

2021-04-12 Thread GitBox
dbgp2021 commented on pull request #15438: URL: https://github.com/apache/flink/pull/15438#issuecomment-817529443 Hi @StephanEwen , thanks for your recommendation, I have changed the code correspondingly, which use StandardCharsets.UTF_8. Please review. Thanks. -- This is an

[jira] [Commented] (FLINK-20722) HiveTableSink should copy the record when converting RowData to Row

2021-04-12 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20722?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17319056#comment-17319056 ] Dawid Wysakowicz commented on FLINK-20722: -- Do you plan to include it in 1.13 [~jark] 

[jira] [Created] (FLINK-22206) Add support server-mode submit for flink SQL. eg : FlinkServer

2021-04-12 Thread xiangtao (Jira)
xiangtao created FLINK-22206: Summary: Add support server-mode submit for flink SQL. eg : FlinkServer Key: FLINK-22206 URL: https://issues.apache.org/jira/browse/FLINK-22206 Project: Flink

[jira] [Commented] (FLINK-21012) AvroFileFormatFactory uses non-deserializable lambda function

2021-04-12 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21012?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17319055#comment-17319055 ] Dawid Wysakowicz commented on FLINK-21012: -- [~jark] [~lzljs3620320]  Do you plan to include it

[jira] [Assigned] (FLINK-20379) Update KafkaRecordDeserializationSchema to enable reuse of DeserializationSchema and KafkaDeserializationSchema

2021-04-12 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20379?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz reassigned FLINK-20379: Assignee: Jiangjie Qin > Update KafkaRecordDeserializationSchema to enable reuse

[GitHub] [flink-statefun-playground] tzulitai closed pull request #11: [FLINK-22185] Add k8s example

2021-04-12 Thread GitBox
tzulitai closed pull request #11: URL: https://github.com/apache/flink-statefun-playground/pull/11 -- 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

[jira] [Resolved] (FLINK-22191) PyFlinkStreamUserDefinedFunctionTests.test_udf_in_join_condition_2 fail due to NPE

2021-04-12 Thread Huang Xingbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22191?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Huang Xingbo resolved FLINK-22191. -- Resolution: Fixed Merged into master via 7debc0677aa1e3c0eaac8c21bdc5d045aa86401c Merged into

[GitHub] [flink] JingsongLi commented on pull request #15489: [FLINK-22106][table-planner-blink] Result type of GeneratedExpression in StringCallGen should be compatible with their definition in Flink

2021-04-12 Thread GitBox
JingsongLi commented on pull request #15489: URL: https://github.com/apache/flink/pull/15489#issuecomment-817523393 @TsReaper Can you create a PR for release-1.13? -- 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] JingsongLi merged pull request #15489: [FLINK-22106][table-planner-blink] Result type of GeneratedExpression in StringCallGen should be compatible with their definition in FlinkSqlOpe

2021-04-12 Thread GitBox
JingsongLi merged pull request #15489: URL: https://github.com/apache/flink/pull/15489 -- 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] [Updated] (FLINK-22191) PyFlinkStreamUserDefinedFunctionTests.test_udf_in_join_condition_2 fail due to NPE

2021-04-12 Thread Huang Xingbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22191?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Huang Xingbo updated FLINK-22191: - Fix Version/s: 1.12.3 1.13.0 >

[jira] [Commented] (FLINK-22205) Does it support gpu coding in flink?

2021-04-12 Thread ying zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22205?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17319052#comment-17319052 ] ying zhang commented on FLINK-22205: ok,thanks,I make a question in user/dev ML > Does it support

[GitHub] [flink] HuangXingBo closed pull request #15560: [FLINK-22191][python] Fix the thread safe problem in PythonSharedResources

2021-04-12 Thread GitBox
HuangXingBo closed pull request #15560: URL: https://github.com/apache/flink/pull/15560 -- 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,

<    2   3   4   5   6   7   8   >