[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 pro

[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&focusedCommentId=17288229#comment-17288229 ] Yu Li commented on FLINK-21413: --- [~wind_ljy] would you like to work on the PR following th

[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: [SUCCESS](https://dev.azure.com/apache-fl

[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&focusedCommentId=17288227#comment-17288227 ] Till Rohrmann commented on FLINK-20332: --- Sounds good to me like this as a first st

[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: https://dev.azure.com/rmetzger/Flink/_build/results?build

[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 isInitializat

[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 respon

[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: [SUCCESS](https://dev.azure.com/apache-fl

[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 Ser

[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 channels

[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 channels

[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 channels

[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: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[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 trigge

[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&focusedCommentId=17288213#comment-17288213 ] Jark Wu commented on FLINK-21415: - If you want to have more accurate result, you can dis

[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' = 'user_event

[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&focusedCommentId=17288200#comment-17288200 ] Shuai Xia commented on FLINK-21415: --- This is very strange. It will result in that the

[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&focusedCommentId=17288199#comment-17288199 ] Xintong Song commented on FLINK-21236: -- Shouldn't it be good enough to replace {{He

[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 segme

[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 p

[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&focusedCommentId=17288190#comment-17288190 ] Xintong Song commented on FLINK-21375: -- A 40% regression is observed with the {{ser

[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 the

[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' = 'user_events

[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' = 'user_events

[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 * 236b938b10e8bc442e905bb5309ca0eb9f23

[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 * 236b938b10e8bc442e905bb5309ca0eb9f23

[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: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[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&focusedCommentId=17288184#comment-17288184 ] Xintong Song commented on FLINK-21375: -- [~ykt836], thanks for the pointer. This mi

[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: certificate_u

[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: https://issues.apache.org/jira/browse/FLINK-21

[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: [FAILURE](https://dev.azure.com/apache-fl

[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 Git

[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: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[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: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[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: [FAILURE](https://dev.azure.com/apache-fl

[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&focusedCommentId=17288170#comment-17288170 ] Kurt Young commented on FLINK-21375: Please keep this article in mind: [https://fli

[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: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[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: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[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: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[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 spotless:apply

[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 log

[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&focusedCommentId=17288161#comment-17288161 ] Jark Wu commented on FLINK-21430: - I see. You are enriching your stream with your sink t

[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 g

[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 > t

[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 EndOfPa

[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 r

[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: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[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&focusedCommentId=17288158#comment-17288158 ] WeiNan Zhao commented on FLINK-21162: - |if (!${castedNeedle.nullTerm}) { | $resultTe

[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 pro

[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&focusedCommentId=17288154#comment-17288154 ] Yu Wang edited comment on FLINK-21430 at 2/22/21, 3:23 AM: --- [~

[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&focusedCommentId=17288154#comment-17288154 ] Yu Wang commented on FLINK-21430: - [~jark]thanks for your reminding > Appear append dat

[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: {"building_id":"trRlI9PL","sofa_id":"dJI53xLp","floor_num":10,"occupy_status":1,"

[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&focusedCommentId=17288151#comment-17288151 ] hayden zhou commented on FLINK-21325: - this problem always occurs after cluster rune

[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 sp

[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&focusedCommentId=17288150#comment-17288150 ] hayden zhou commented on FLINK-21325: - i found some exception like this {code:java

[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&focusedCommentId=17288149#comment-17288149 ] WeiNan Zhao commented on FLINK-21162: - [~ykt836] Thanks for the investigation [~ykt8

[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&focusedCommentId=17288147#comment-17288147 ] Jiayi Liao commented on FLINK-21413: [~liyu] Oops... I didn't notice that the #remov

[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&focusedCommentId=17288146#comment-17288146 ] Jark Wu commented on FLINK-21430: - Please update description in English. > Appear appe

[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&focusedCommentId=17288145#comment-17288145 ] Jark Wu commented on FLINK-21162: - Thanks for the investigation [~ykt836], I also checke

[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 数据格式: {"building_id":"trRlI9PL","sofa_id":"dJI53xLp","floor_num":10,"occupy_status":1,"

[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: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[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 数据格式: {"building_id":"trRlI9PL","sofa_id":"dJI53xLp","floor_num":10,"occupy_status":1,"

[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] [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 数据格式: {"building_id":"trRlI9PL","sofa_id":"dJI53xLp","floor_num":10,"occupy_status":1,"

[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&focusedCommentId=17288144#comment-17288144 ] Guowei Ma commented on FLINK-20723: --- https://dev.azure.com/apache-flink/apache-flink/_

[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&focusedCommentId=17288143#comment-17288143 ] Kurt Young edited comment on FLINK-21162 at 2/22/21, 2:54 AM:

[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 Typ

[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&focusedCommentId=17288143#comment-17288143 ] Kurt Young commented on FLINK-21162: I don't we should change this behavior. I check

[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 Iss

[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&focusedCommentId=17288140#comment-17288140 ] HideOnBush edited comment on FLINK-21424 at 2/22/21, 2:48 AM:

[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&focusedCommentId=17288141#comment-17288141 ] Guowei Ma commented on FLINK-20420: --- https://dev.azure.com/apache-flink/apache-flink/_

[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: ) > DeclarativeSchedulerSlotSharingITCase.testSchedulingOfJobRequiringSl

[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 Project

[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&focusedCommentId=17288140#comment-17288140 ] HideOnBush commented on FLINK-21424: Hi [~jark]。It's a problem。I gave the wrong mess

[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 join

[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: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[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' = 'user_event

[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&focusedCommentId=17288139#comment-17288139 ] Jark Wu commented on FLINK-21162: - Yes. I think {{null IN (...)}} should return unknown,

[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&focusedCommentId=17288138#comment-17288138 ] Jark Wu commented on FLINK-21425: - Hi [~Suxing Lee], Flink doesn't support implict type

[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&focusedCommentId=17288137#comment-17288137 ] Guowei Ma commented on FLINK-21234: --- https://dev.azure.com/apache-flink/apache-flink/_

[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&focusedCommentId=17288136#comment-17288136 ] hayden zhou commented on FLINK-21325: - how to get logs for the specific failed job?[

[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 ~ 7f4e707c1d475df24617996

[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 ha

[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 t

[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 t

[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&focusedCommentId=17288132#comment-17288132 ] Guowei Ma commented on FLINK-17441: --- another case https://dev.azure.com/apache-flink/

  1   2   >