[GitHub] [flink] flinkbot commented on pull request #14978: [hotfix][flink-yarn] Modify options' description format.

2021-02-21 Thread GitBox
flinkbot commented on pull request #14978: URL: https://github.com/apache/flink/pull/14978#issuecomment-783171959 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

[jira] [Commented] (FLINK-21413) TtlMapState and TtlListState cannot be clean completely with Filesystem StateBackend

2021-02-21 Thread Yu Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21413?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17288229#comment-17288229 ] Yu Li commented on FLINK-21413: --- [~wind_ljy] would you like to work on the PR following the above

[GitHub] [flink] flinkbot edited a comment on pull request #14896: [FLINK-21176][docs] translate the updates of 'avro-confluent.zh.md' to Chinese

2021-02-21 Thread GitBox
flinkbot edited a comment on pull request #14896: URL: https://github.com/apache/flink/pull/14896#issuecomment-775006223 ## CI report: * a5f4e508be47fe26e8d0c416dd5104dbb0afbe89 UNKNOWN * b968335352d52a7e16f5875c0cc8557605a4cd26 Azure:

[jira] [Commented] (FLINK-20332) Add workers recovered from previous attempt to pending resources

2021-02-21 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20332?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17288227#comment-17288227 ] Till Rohrmann commented on FLINK-20332: --- Sounds good to me like this as a first step. > Add

[GitHub] [flink] ZhangChaoming opened a new pull request #14978: [hotfix][flink-yarn] Modify options' description format.

2021-02-21 Thread GitBox
ZhangChaoming opened a new pull request #14978: URL: https://github.com/apache/flink/pull/14978 ## What is the purpose of the change Modify the options' description format in `org/apache/flink/yarn/configuration/YarnConfigOptions.java`. ## Brief change log -

[GitHub] [flink] kylemeow commented on a change in pull request #12803: [FLINK-18461][table-planner-blink] Fix Changelog source can't be insert into upsert sink

2021-02-21 Thread GitBox
kylemeow commented on a change in pull request #12803: URL: https://github.com/apache/flink/pull/12803#discussion_r580043425 ## File path: flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/internal/executor/BufferReduceStatementExecutor.java

[GitHub] [flink] rmetzger commented on pull request #14967: [FLINK-21101][Azure] Add nightly profile to run all tests with the declarative scheduler

2021-02-21 Thread GitBox
rmetzger commented on pull request #14967: URL: https://github.com/apache/flink/pull/14967#issuecomment-783169464 Thanks a lot for your review. I addressed your comments, and ignored a few more tests, since there are still failures:

[GitHub] [flink] XComp commented on a change in pull request #14804: [FLINK-21188] Replaces ArchivedExecutionGraph by ExecutionGraphInfo

2021-02-21 Thread GitBox
XComp commented on a change in pull request #14804: URL: https://github.com/apache/flink/pull/14804#discussion_r580041891 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/JobManagerRunnerResult.java ## @@ -56,9 +57,10 @@ public boolean

[GitHub] [flink] jjiey commented on pull request #14896: [FLINK-21176][docs] translate the updates of 'avro-confluent.zh.md' to Chinese

2021-02-21 Thread GitBox
jjiey commented on pull request #14896: URL: https://github.com/apache/flink/pull/14896#issuecomment-783167261 Cheers! Thanks @fsk119 for your guidance! This is an automated message from the Apache Git Service. To respond to

[jira] [Assigned] (FLINK-21404) YARNITCase runs indefinitely

2021-02-21 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21404?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reassigned FLINK-21404: Assignee: Chesnay Schepler > YARNITCase runs indefinitely >

[GitHub] [flink] XBaith commented on pull request #14773: [FLINK-16153] Translate "Operator/windows" into Chinese

2021-02-21 Thread GitBox
XBaith commented on pull request #14773: URL: https://github.com/apache/flink/pull/14773#issuecomment-783166193 LGTM.Please resolve conflicts in this branch. This is an automated message from the Apache Git Service. To

[GitHub] [flink] flinkbot edited a comment on pull request #14896: [FLINK-21176][docs] translate the updates of 'avro-confluent.zh.md' to Chinese

2021-02-21 Thread GitBox
flinkbot edited a comment on pull request #14896: URL: https://github.com/apache/flink/pull/14896#issuecomment-775006223 ## CI report: * a5f4e508be47fe26e8d0c416dd5104dbb0afbe89 UNKNOWN * b968335352d52a7e16f5875c0cc8557605a4cd26 Azure:

[GitHub] [flink] fsk119 commented on pull request #14896: [FLINK-21176][docs] translate the updates of 'avro-confluent.zh.md' to Chinese

2021-02-21 Thread GitBox
fsk119 commented on pull request #14896: URL: https://github.com/apache/flink/pull/14896#issuecomment-783159166 Thanks for your update @jjiey . Cheers! CC @wuchong This is an automated message from the Apache Git

[jira] [Updated] (FLINK-16404) Avoid caching buffers for blocked input channels before barrier alignment

2021-02-21 Thread hanhan.zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16404?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] hanhan.zhang updated FLINK-16404: - Attachment: image-2021-02-22-15-30-03-318.png > Avoid caching buffers for blocked input

[jira] [Updated] (FLINK-16404) Avoid caching buffers for blocked input channels before barrier alignment

2021-02-21 Thread hanhan.zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16404?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] hanhan.zhang updated FLINK-16404: - Attachment: image-2021-02-22-15-29-55-096.png > Avoid caching buffers for blocked input

[jira] [Updated] (FLINK-16404) Avoid caching buffers for blocked input channels before barrier alignment

2021-02-21 Thread hanhan.zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16404?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] hanhan.zhang updated FLINK-16404: - Attachment: image-2021-02-22-15-27-57-983.png > Avoid caching buffers for blocked input

[GitHub] [flink] flinkbot edited a comment on pull request #14863: [FLINK-21203]Don’t collect -U&+U Row When they are equals In the LastRowFunction

2021-02-21 Thread GitBox
flinkbot edited a comment on pull request #14863: URL: https://github.com/apache/flink/pull/14863#issuecomment-773127996 ## CI report: * 6d858b431f14431f59bf6aaa34ab4579fa92c11b Azure:

[GitHub] [flink] kezhuw commented on pull request #14831: [FLINK-21086][runtime][checkpoint] CheckpointBarrierHandler Insert barriers for channels received EndOfPartition

2021-02-21 Thread GitBox
kezhuw commented on pull request #14831: URL: https://github.com/apache/flink/pull/14831#issuecomment-783149666 @gaoyunhaii Sorry, I propably targets wrong method, I means `StreamTask.triggerCheckpoint` and its overrides. May be not that serious, but I think it would be good to code

[GitHub] [flink] wuchong commented on a change in pull request #12803: [FLINK-18461][table-planner-blink] Fix Changelog source can't be insert into upsert sink

2021-02-21 Thread GitBox
wuchong commented on a change in pull request #12803: URL: https://github.com/apache/flink/pull/12803#discussion_r580023911 ## File path: flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/internal/executor/BufferReduceStatementExecutor.java

[GitHub] [flink] dianfu commented on pull request #14741: [FLINK-21021][python] Bump Beam to 2.27.0

2021-02-21 Thread GitBox
dianfu commented on pull request #14741: URL: https://github.com/apache/flink/pull/14741#issuecomment-783144647 @HuangXingBo Sorry for late response of this PR. There are some code conflicts. Could you help to rebase the PR to the latest master?

[jira] [Commented] (FLINK-21415) JDBC does not query data, and the cache will store an ArrayList without data

2021-02-21 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21415?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17288213#comment-17288213 ] Jark Wu commented on FLINK-21415: - If you want to have more accurate result, you can disable cache or

[GitHub] [flink] kylemeow commented on a change in pull request #12803: [FLINK-18461][table-planner-blink] Fix Changelog source can't be insert into upsert sink

2021-02-21 Thread GitBox
kylemeow commented on a change in pull request #12803: URL: https://github.com/apache/flink/pull/12803#discussion_r580019839 ## File path: flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/internal/executor/BufferReduceStatementExecutor.java

[GitHub] [flink] fsk119 commented on a change in pull request #14896: [FLINK-21176][docs] translate the updates of 'avro-confluent.zh.md' to Chinese

2021-02-21 Thread GitBox
fsk119 commented on a change in pull request #14896: URL: https://github.com/apache/flink/pull/14896#discussion_r580011099 ## File path: docs/content.zh/docs/connectors/table/formats/avro-confluent.md ## @@ -115,41 +115,40 @@ CREATE TABLE user_created ( 'topic' =

[jira] [Commented] (FLINK-21415) JDBC does not query data, and the cache will store an ArrayList without data

2021-02-21 Thread Shuai Xia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21415?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17288200#comment-17288200 ] Shuai Xia commented on FLINK-21415: --- This is very strange. It will result in that the data will not be

[jira] [Commented] (FLINK-21236) Don't explicitly use HeapMemorySegment in raw format serde

2021-02-21 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21236?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17288199#comment-17288199 ] Xintong Song commented on FLINK-21236: -- Shouldn't it be good enough to replace

[jira] [Closed] (FLINK-21417) Separate type specific memory segments.

2021-02-21 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21417?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song closed FLINK-21417. Fix Version/s: (was: 1.13.0) Resolution: Won't Do > Separate type specific memory

[jira] [Reopened] (FLINK-21417) Separate type specific memory segments.

2021-02-21 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21417?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song reopened FLINK-21417: -- Reverted via: * master (1.13): b81392665950c22ed347abcab611050a7fd1ae38 This is reverted due to

[jira] [Closed] (FLINK-21297) Support 'LOAD/UNLOAD MODULE' syntax

2021-02-21 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21297?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-21297. --- Resolution: Fixed Fixed in master: e2e11218516ad579bf2bd9c0fc5510f08cb6d243 > Support 'LOAD/UNLOAD MODULE'

[GitHub] [flink] wuchong merged pull request #14944: [FLINK-21297] Support 'LOAD/UNLOAD MODULE' syntax

2021-02-21 Thread GitBox
wuchong merged pull request #14944: URL: https://github.com/apache/flink/pull/14944 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

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

2021-02-21 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21375?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17288190#comment-17288190 ] Xintong Song commented on FLINK-21375: -- A 40% regression is observed with the

[GitHub] [flink] crazyzhou commented on pull request #14890: [FLINK-21178][Runtime/Checkpointing] Task failure should trigger master hook's reset()

2021-02-21 Thread GitBox
crazyzhou commented on pull request #14890: URL: https://github.com/apache/flink/pull/14890#issuecomment-783110723 Hi Stephan, sorry for the late reply for our holiday. > * Do Pravega setups always configure "ALL" as the failover strategy? We use the default `region`, it's

[GitHub] [flink] jjiey commented on a change in pull request #14896: [FLINK-21176][docs] translate the updates of 'avro-confluent.zh.md' to Chinese

2021-02-21 Thread GitBox
jjiey commented on a change in pull request #14896: URL: https://github.com/apache/flink/pull/14896#discussion_r579996787 ## File path: docs/content.zh/docs/connectors/table/formats/avro-confluent.md ## @@ -115,41 +115,40 @@ CREATE TABLE user_created ( 'topic' =

[GitHub] [flink] jjiey commented on a change in pull request #14896: [FLINK-21176][docs] translate the updates of 'avro-confluent.zh.md' to Chinese

2021-02-21 Thread GitBox
jjiey commented on a change in pull request #14896: URL: https://github.com/apache/flink/pull/14896#discussion_r579996787 ## File path: docs/content.zh/docs/connectors/table/formats/avro-confluent.md ## @@ -115,41 +115,40 @@ CREATE TABLE user_created ( 'topic' =

[GitHub] [flink] flinkbot edited a comment on pull request #14943: [FLINK-21354] Implement a StateChangelogStateBackend to forward state changes to St…

2021-02-21 Thread GitBox
flinkbot edited a comment on pull request #14943: URL: https://github.com/apache/flink/pull/14943#issuecomment-779315285 ## CI report: * f80b97c479ec82663e971553c54c8a6cda3122ff UNKNOWN * 8584b9ca7b9cf29f0f845aafe422f356e068cfe6 UNKNOWN *

[GitHub] [flink] flinkbot edited a comment on pull request #14943: [FLINK-21354] Implement a StateChangelogStateBackend to forward state changes to St…

2021-02-21 Thread GitBox
flinkbot edited a comment on pull request #14943: URL: https://github.com/apache/flink/pull/14943#issuecomment-779315285 ## CI report: * f80b97c479ec82663e971553c54c8a6cda3122ff UNKNOWN * 8584b9ca7b9cf29f0f845aafe422f356e068cfe6 UNKNOWN *

[GitHub] [flink] flinkbot edited a comment on pull request #14863: [FLINK-21203]Don’t collect -U&+U Row When they are equals In the LastRowFunction

2021-02-21 Thread GitBox
flinkbot edited a comment on pull request #14863: URL: https://github.com/apache/flink/pull/14863#issuecomment-773127996 ## CI report: * 5a83fbfcba47f2d46e6d8b7d7db541e91be0b88e Azure:

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

2021-02-21 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21375?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17288184#comment-17288184 ] Xintong Song commented on FLINK-21375: -- [~ykt836], thanks for the pointer. This might indeed be a

[jira] [Updated] (FLINK-21414) javax.net.ssl.SSLHandshakeException: Received fatal alert: certificate_unknown

2021-02-21 Thread Bhagi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21414?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bhagi updated FLINK-21414: -- Issue Type: New Feature (was: Bug) > javax.net.ssl.SSLHandshakeException: Received fatal alert:

[jira] [Created] (FLINK-21432) Web UI -- Error - {"errors":["Service temporarily unavailable due to an ongoing leader election. Please refresh."]}

2021-02-21 Thread Bhagi (Jira)
Bhagi created FLINK-21432: - Summary: Web UI -- Error - {"errors":["Service temporarily unavailable due to an ongoing leader election. Please refresh."]} Key: FLINK-21432 URL:

[GitHub] [flink] flinkbot edited a comment on pull request #14727: [FLINK-19945][Connectors / FileSystem]Support sink parallelism config…

2021-02-21 Thread GitBox
flinkbot edited a comment on pull request #14727: URL: https://github.com/apache/flink/pull/14727#issuecomment-765189922 ## CI report: * bc1b9f48c58cf4c5dba81083f1f8a9a6dce3a33f UNKNOWN * 12a81b7db9bd2dca5c456ba546807091d003338d Azure:

[GitHub] [flink] curcur commented on pull request #14943: [FLINK-21354] Implement a StateChangelogStateBackend to forward state changes to St…

2021-02-21 Thread GitBox
curcur commented on pull request #14943: URL: https://github.com/apache/flink/pull/14943#issuecomment-783078950 rebase This is an automated message from the Apache Git Service. To respond to the message, please log on to

[GitHub] [flink] flinkbot edited a comment on pull request #14863: [FLINK-21203]Don’t collect -U&+U Row When they are equals In the LastRowFunction

2021-02-21 Thread GitBox
flinkbot edited a comment on pull request #14863: URL: https://github.com/apache/flink/pull/14863#issuecomment-773127996 ## CI report: * 5a83fbfcba47f2d46e6d8b7d7db541e91be0b88e Azure:

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

2021-02-21 Thread GitBox
flinkbot edited a comment on pull request #14872: URL: https://github.com/apache/flink/pull/14872#issuecomment-773303946 ## CI report: * f6390443428d1f56a41251ffa412bf8eab820d86 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14727: [FLINK-19945][Connectors / FileSystem]Support sink parallelism config…

2021-02-21 Thread GitBox
flinkbot edited a comment on pull request #14727: URL: https://github.com/apache/flink/pull/14727#issuecomment-765189922 ## CI report: * bc1b9f48c58cf4c5dba81083f1f8a9a6dce3a33f UNKNOWN * 12a81b7db9bd2dca5c456ba546807091d003338d Azure:

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

2021-02-21 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21375?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17288170#comment-17288170 ] Kurt Young commented on FLINK-21375: Please keep this article in mind:

[GitHub] [flink] flinkbot edited a comment on pull request #14977: [FLINK-18726][table-planner-blink] Support INSERT INTO specific colum…

2021-02-21 Thread GitBox
flinkbot edited a comment on pull request #14977: URL: https://github.com/apache/flink/pull/14977#issuecomment-783054931 ## CI report: * aa8dede9e64d4c012d0cacc831d5993ec7fa9d06 Azure:

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

2021-02-21 Thread GitBox
flinkbot edited a comment on pull request #14872: URL: https://github.com/apache/flink/pull/14872#issuecomment-773303946 ## CI report: * f6390443428d1f56a41251ffa412bf8eab820d86 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14863: [FLINK-21203]Don’t collect -U&+U Row When they are equals In the LastRowFunction

2021-02-21 Thread GitBox
flinkbot edited a comment on pull request #14863: URL: https://github.com/apache/flink/pull/14863#issuecomment-773127996 ## CI report: * 5a83fbfcba47f2d46e6d8b7d7db541e91be0b88e Azure:

[GitHub] [flink] wangpeibin713 commented on pull request #14863: [FLINK-21203]Don’t collect -U&+U Row When they are equals In the LastRowFunction

2021-02-21 Thread GitBox
wangpeibin713 commented on pull request #14863: URL: https://github.com/apache/flink/pull/14863#issuecomment-783062794 > LGTM @wangpeibin713 could you fix the build failure and rebase to latest master branch? @leonardBang Thanks, I have fixed the build failure by `mvn

[GitHub] [flink] wuchong commented on pull request #14977: [FLINK-18726][table-planner-blink] Support INSERT INTO specific colum…

2021-02-21 Thread GitBox
wuchong commented on pull request #14977: URL: https://github.com/apache/flink/pull/14977#issuecomment-783061626 cc @leonardBang This is an automated message from the Apache Git Service. To respond to the message, please

[jira] [Commented] (FLINK-21430) Appear append data when flink sql sink mysql on key conflict

2021-02-21 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21430?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17288161#comment-17288161 ] Jark Wu commented on FLINK-21430: - I see. You are enriching your stream with your sink table. Currently,

[GitHub] [flink] cooper-xiang closed pull request #14974: [FLINK-21425][table-planner-blink] Fix equals and notEquals predicates implicit conversions

2021-02-21 Thread GitBox
cooper-xiang closed pull request #14974: URL: https://github.com/apache/flink/pull/14974 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

[jira] [Closed] (FLINK-21425) Incorrect implicit conversions in equals and notEquals filter predicates lead to not correctly evaluated by Table API

2021-02-21 Thread Suxing Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21425?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Suxing Lee closed FLINK-21425. -- Resolution: Later > Incorrect implicit conversions in equals and notEquals filter predicates lead >

[GitHub] [flink] gaoyunhaii commented on pull request #14831: [FLINK-21086][runtime][checkpoint] CheckpointBarrierHandler Insert barriers for channels received EndOfPartition

2021-02-21 Thread GitBox
gaoyunhaii commented on pull request #14831: URL: https://github.com/apache/flink/pull/14831#issuecomment-783059325 Hi @kezhuw very thanks for the deep thoughts and suggestions! > But instead of "Insert barriers for channels received EndOfPartition", I would suggest to count

[GitHub] [flink] flinkbot commented on pull request #14977: [FLINK-18726][table-planner-blink] Support INSERT INTO specific colum…

2021-02-21 Thread GitBox
flinkbot commented on pull request #14977: URL: https://github.com/apache/flink/pull/14977#issuecomment-783054931 ## CI report: * aa8dede9e64d4c012d0cacc831d5993ec7fa9d06 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #14863: [FLINK-21203]Don’t collect -U&+U Row When they are equals In the LastRowFunction

2021-02-21 Thread GitBox
flinkbot edited a comment on pull request #14863: URL: https://github.com/apache/flink/pull/14863#issuecomment-773127996 ## CI report: * 5a83fbfcba47f2d46e6d8b7d7db541e91be0b88e Azure:

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

2021-02-21 Thread WeiNan Zhao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21162?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17288158#comment-17288158 ] WeiNan Zhao commented on FLINK-21162: - |if (!${castedNeedle.nullTerm}) { | $resultTerm =

[GitHub] [flink] flinkbot commented on pull request #14977: [FLINK-18726][table-planner-blink] Support INSERT INTO specific colum…

2021-02-21 Thread GitBox
flinkbot commented on pull request #14977: URL: https://github.com/apache/flink/pull/14977#issuecomment-783038390 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

[jira] [Comment Edited] (FLINK-21430) Appear append data when flink sql sink mysql on key conflict

2021-02-21 Thread Yu Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21430?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17288154#comment-17288154 ] Yu Wang edited comment on FLINK-21430 at 2/22/21, 3:23 AM: --- [~jark] Thanks for

[jira] [Commented] (FLINK-21430) Appear append data when flink sql sink mysql on key conflict

2021-02-21 Thread Yu Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21430?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17288154#comment-17288154 ] Yu Wang commented on FLINK-21430: - [~jark]thanks for your reminding > Appear append data when flink sql

[jira] [Updated] (FLINK-21430) Appear append data when flink sql sink mysql on key conflict

2021-02-21 Thread Yu Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21430?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yu Wang updated FLINK-21430: Description: kafka data:

[jira] [Updated] (FLINK-18726) Support INSERT INTO specific columns

2021-02-21 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18726?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-18726: --- Labels: pull-request-available sprint (was: sprint) > Support INSERT INTO specific columns

[jira] [Commented] (FLINK-21325) NoResourceAvailableException while cancel then resubmit jobs

2021-02-21 Thread hayden zhou (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21325?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17288151#comment-17288151 ] hayden zhou commented on FLINK-21325: - this problem always occurs after cluster runed several days

[GitHub] [flink] docete opened a new pull request #14977: [FLINK-18726][table-planner-blink] Support INSERT INTO specific colum…

2021-02-21 Thread GitBox
docete opened a new pull request #14977: URL: https://github.com/apache/flink/pull/14977 …ns in blink planner ## What is the purpose of the change This PR supports INSERT INTO specific columns in blink planner. ## Brief change log - aa8dede: Support INSERT INTO

[jira] [Commented] (FLINK-21325) NoResourceAvailableException while cancel then resubmit jobs

2021-02-21 Thread hayden zhou (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21325?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17288150#comment-17288150 ] hayden zhou commented on FLINK-21325: - i found some exception like this {code:java} 2021-02-22

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

2021-02-21 Thread WeiNan Zhao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21162?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17288149#comment-17288149 ] WeiNan Zhao commented on FLINK-21162: - [~ykt836] Thanks for the investigation [~ykt836],but when i

[jira] [Commented] (FLINK-21413) TtlMapState and TtlListState cannot be clean completely with Filesystem StateBackend

2021-02-21 Thread Jiayi Liao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21413?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17288147#comment-17288147 ] Jiayi Liao commented on FLINK-21413: [~liyu] Oops... I didn't notice that the #remove(UK) method

[jira] [Commented] (FLINK-21430) Appear append data when flink sql sink mysql on key conflict

2021-02-21 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21430?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17288146#comment-17288146 ] Jark Wu commented on FLINK-21430: - Please update description in English. > Appear append data when

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

2021-02-21 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21162?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17288145#comment-17288145 ] Jark Wu commented on FLINK-21162: - Thanks for the investigation [~ykt836], I also checked {{null in

[jira] [Created] (FLINK-21431) UpsertKafkaTableITCase.testTemporalJoin hang

2021-02-21 Thread Guowei Ma (Jira)
Guowei Ma created FLINK-21431: - Summary: UpsertKafkaTableITCase.testTemporalJoin hang Key: FLINK-21431 URL: https://issues.apache.org/jira/browse/FLINK-21431 Project: Flink Issue Type: Bug

[jira] [Updated] (FLINK-21430) Appear append data when flink sql sink mysql on key conflict

2021-02-21 Thread Yu Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21430?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yu Wang updated FLINK-21430: Description: kafka 数据格式:

[GitHub] [flink] flinkbot edited a comment on pull request #14863: [FLINK-21203]Don’t collect -U&+U Row When they are equals In the LastRowFunction

2021-02-21 Thread GitBox
flinkbot edited a comment on pull request #14863: URL: https://github.com/apache/flink/pull/14863#issuecomment-773127996 ## CI report: * 5a83fbfcba47f2d46e6d8b7d7db541e91be0b88e Azure:

[jira] [Updated] (FLINK-21430) Appear append data when flink sql sink mysql on key conflict

2021-02-21 Thread Yu Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21430?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yu Wang updated FLINK-21430: Description: kafka 数据格式:

[jira] [Updated] (FLINK-21429) JsonFileCompactionITCase>CompactionITCaseBase.testNonPartition

2021-02-21 Thread Guowei Ma (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21429?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guowei Ma updated FLINK-21429: -- Labels: test-stability (was: ) > JsonFileCompactionITCase>CompactionITCaseBase.testNonPartition >

[jira] [Commented] (FLINK-20723) testCassandraPojoNoAnnotatedKeyspaceAtLeastOnceSink failed due to NoHostAvailableException

2021-02-21 Thread Guowei Ma (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20723?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17288144#comment-17288144 ] Guowei Ma commented on FLINK-20723: ---

[jira] [Updated] (FLINK-21430) Appear append data when flink sql sink mysql on key conflict

2021-02-21 Thread Yu Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21430?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yu Wang updated FLINK-21430: Description: kafka 数据格式:

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

2021-02-21 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21162?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17288143#comment-17288143 ] Kurt Young edited comment on FLINK-21162 at 2/22/21, 2:54 AM: -- I don't

[jira] [Created] (FLINK-21430) Appear append data when flink sql sink mysql on key conflict

2021-02-21 Thread Yu Wang (Jira)
Yu Wang created FLINK-21430: --- Summary: Appear append data when flink sql sink mysql on key conflict Key: FLINK-21430 URL: https://issues.apache.org/jira/browse/FLINK-21430 Project: Flink Issue

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

2021-02-21 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21162?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17288143#comment-17288143 ] Kurt Young commented on FLINK-21162: I don't we should change this behavior. I checked all the

[jira] [Created] (FLINK-21429) JsonFileCompactionITCase>CompactionITCaseBase.testNonPartition

2021-02-21 Thread Guowei Ma (Jira)
Guowei Ma created FLINK-21429: - Summary: JsonFileCompactionITCase>CompactionITCaseBase.testNonPartition Key: FLINK-21429 URL: https://issues.apache.org/jira/browse/FLINK-21429 Project: Flink

[jira] [Comment Edited] (FLINK-21424) Lookup Hive partitioned table throws exception

2021-02-21 Thread HideOnBush (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21424?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17288140#comment-17288140 ] HideOnBush edited comment on FLINK-21424 at 2/22/21, 2:48 AM: -- Hi

[jira] [Commented] (FLINK-20420) ES6 ElasticsearchSinkITCase failed due to no output for 900 seconds

2021-02-21 Thread Guowei Ma (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20420?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17288141#comment-17288141 ] Guowei Ma commented on FLINK-20420: ---

[jira] [Updated] (FLINK-21428) DeclarativeSchedulerSlotSharingITCase.testSchedulingOfJobRequiringSlotSharing fail

2021-02-21 Thread Guowei Ma (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21428?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guowei Ma updated FLINK-21428: -- Labels: test-stability (was: ) >

[jira] [Created] (FLINK-21428) DeclarativeSchedulerSlotSharingITCase.testSchedulingOfJobRequiringSlotSharing fail

2021-02-21 Thread Guowei Ma (Jira)
Guowei Ma created FLINK-21428: - Summary: DeclarativeSchedulerSlotSharingITCase.testSchedulingOfJobRequiringSlotSharing fail Key: FLINK-21428 URL: https://issues.apache.org/jira/browse/FLINK-21428

[jira] [Commented] (FLINK-21424) Lookup Hive partitioned table throws exception

2021-02-21 Thread HideOnBush (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21424?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17288140#comment-17288140 ] HideOnBush commented on FLINK-21424: Hi [~jark]。It's a problem。I gave the wrong message before, I

[jira] [Updated] (FLINK-21424) Lookup Hive partitioned table throws exception

2021-02-21 Thread HideOnBush (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21424?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] HideOnBush updated FLINK-21424: --- Description: {code:java} Flink view cannot use hive temporal{code} The kafka table can temporal

[jira] [Updated] (FLINK-21424) Lookup Hive partitioned table throws exception

2021-02-21 Thread HideOnBush (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21424?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] HideOnBush updated FLINK-21424: --- Attachment: screenshot-1.png > Lookup Hive partitioned table throws exception >

[jira] [Updated] (FLINK-21424) Lookup Hive partitioned table throws exception

2021-02-21 Thread HideOnBush (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21424?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] HideOnBush updated FLINK-21424: --- Attachment: screenshot-2.png > Lookup Hive partitioned table throws exception >

[GitHub] [flink] flinkbot edited a comment on pull request #14863: [FLINK-21203]Don’t collect -U&+U Row When they are equals In the LastRowFunction

2021-02-21 Thread GitBox
flinkbot edited a comment on pull request #14863: URL: https://github.com/apache/flink/pull/14863#issuecomment-773127996 ## CI report: * 5a83fbfcba47f2d46e6d8b7d7db541e91be0b88e Azure:

[GitHub] [flink] fsk119 commented on a change in pull request #14896: [FLINK-21176][docs] translate the updates of 'avro-confluent.zh.md' to Chinese

2021-02-21 Thread GitBox
fsk119 commented on a change in pull request #14896: URL: https://github.com/apache/flink/pull/14896#discussion_r579927532 ## File path: docs/content.zh/docs/connectors/table/formats/avro-confluent.md ## @@ -115,41 +115,40 @@ CREATE TABLE user_created ( 'topic' =

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

2021-02-21 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21162?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17288139#comment-17288139 ] Jark Wu commented on FLINK-21162: - Yes. I think {{null IN (...)}} should return unknown, and unkown is

[jira] [Commented] (FLINK-21425) Incorrect implicit conversions in equals and notEquals filter predicates lead to not correctly evaluated by Table API

2021-02-21 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21425?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17288138#comment-17288138 ] Jark Wu commented on FLINK-21425: - Hi [~Suxing Lee], Flink doesn't support implict type conversion

[jira] [Commented] (FLINK-21234) testKafkaSourceSinkWithKeyAndPartialValue[legacy = false, format = csv] hang

2021-02-21 Thread Guowei Ma (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21234?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17288137#comment-17288137 ] Guowei Ma commented on FLINK-21234: ---

[jira] [Commented] (FLINK-21325) NoResourceAvailableException while cancel then resubmit jobs

2021-02-21 Thread hayden zhou (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21325?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17288136#comment-17288136 ] hayden zhou commented on FLINK-21325: - how to get logs for the specific failed job?[~rmetzger] >

[jira] [Closed] (FLINK-20536) Update migration tests in master to cover migration from release-1.12

2021-02-21 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20536?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-20536. --- Resolution: Fixed Merged to - master via 02595913c3d91aee486092c266ec147c15c45c9a ~

[GitHub] [flink] Sunt-ing removed a comment on pull request #14812: [hotfix][javadoc] fix syntax error for PlannerContext.java: from "be overwrite" to "be overwritten"

2021-02-21 Thread GitBox
Sunt-ing removed a comment on pull request #14812: URL: https://github.com/apache/flink/pull/14812#issuecomment-782559546 @wuchong Hi, hope you have a great Spring Festival! This PR has been created for a long time. It's merely for a simple syntax error. Could you please review it after

[jira] [Assigned] (FLINK-20536) Update migration tests in master to cover migration from release-1.12

2021-02-21 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20536?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu reassigned FLINK-20536: --- Assignee: Dian Fu > Update migration tests in master to cover migration from release-1.12 >

[GitHub] [flink] dianfu merged pull request #14972: [FLINK-20536][tests] Update migration tests in master to cover migration from release-1.12

2021-02-21 Thread GitBox
dianfu merged pull request #14972: URL: https://github.com/apache/flink/pull/14972 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

[GitHub] [flink] dianfu merged pull request #14971: [FLINK-20536][tests] Update migration tests in master to cover migration from release-1.12

2021-02-21 Thread GitBox
dianfu merged pull request #14971: URL: https://github.com/apache/flink/pull/14971 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

[jira] [Commented] (FLINK-17441) FlinkKinesisConsumerTest.testPeriodicWatermark: watermark count expected:<2> but was:<1>

2021-02-21 Thread Guowei Ma (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17441?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17288132#comment-17288132 ] Guowei Ma commented on FLINK-17441: --- another case

  1   2   >