[GitHub] [flink] JingsongLi commented on a change in pull request #17520: [FLINK-24565][avro] Port avro file format factory to BulkReaderFormatFactory

2021-10-31 Thread GitBox
JingsongLi commented on a change in pull request #17520: URL: https://github.com/apache/flink/pull/17520#discussion_r739763596 ## File path: flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AbstractAvroBulkFormat.java ## @@ -0,0 +1,207 @@ +/* + * Licensed

[GitHub] [flink] curcur commented on pull request #17591: [FLINK-24671][runtime] Return 0 buffers in use until subpartition vie…

2021-10-31 Thread GitBox
curcur commented on pull request #17591: URL: https://github.com/apache/flink/pull/17591#issuecomment-955665980 LGTM. Thanks @akalash! BTW, could you double check/confirm that `RemoteInputChannel` does not have/does not need consider the same problem! -- This is an

[jira] [Updated] (FLINK-24492) incorrect implicit type conversion between numeric and (var)char

2021-10-31 Thread godfrey he (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24492?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-24492: --- Fix Version/s: 1.13.4 1.14.1 1.15.0 > incorrect implicit type

[GitHub] [flink] godfreyhe commented on pull request #17604: [FLINK-23919][table-planner-blink] Fix field name conflict bug in `WindowUtil`

2021-10-31 Thread GitBox
godfreyhe commented on pull request #17604: URL: https://github.com/apache/flink/pull/17604#issuecomment-955713147 @flinkbot run azure -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the

[jira] [Commented] (FLINK-24708) `ConvertToNotInOrInRule` has a bug which leads to wrong result

2021-10-31 Thread godfrey he (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24708?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17436500#comment-17436500 ] godfrey he commented on FLINK-24708: Thanks for reporting this bug. [~qingru zhang] Currently the

[GitHub] [flink] hililiwei removed a comment on pull request #17106: [FLINK-20443][API/DataStream] ContinuousProcessingTimeTrigger doesn't fire at the end of the window

2021-10-31 Thread GitBox
hililiwei removed a comment on pull request #17106: URL: https://github.com/apache/flink/pull/17106#issuecomment-954725635 @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

[jira] [Updated] (FLINK-24631) Avoiding directly use the labels as selector for deployment and service

2021-10-31 Thread Aitozi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24631?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aitozi updated FLINK-24631: --- Description: We create deployment use the pod selector directly from labels, which is not necessary and

[GitHub] [flink] flinkbot edited a comment on pull request #17612: [FLINK-24247][TableAPI/SQL] Uniformly limit the value of ABS(offset) …

2021-10-31 Thread GitBox
flinkbot edited a comment on pull request #17612: URL: https://github.com/apache/flink/pull/17612#issuecomment-955298058 ## CI report: * 60ca7a7cd135ee0101649fab30712c7efa160fb9 Azure:

[jira] [Updated] (FLINK-20346) Explain ChangelogMode for sinks

2021-10-31 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20346?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-20346: --- Labels: auto-deprioritized-major stale-minor (was: auto-deprioritized-major) I am the

[jira] [Updated] (FLINK-20350) [Kinesis][GCP PubSub] Incompatible Connectors due to Guava conflict

2021-10-31 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20350?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-20350: --- Labels: auto-deprioritized-major stale-minor (was: auto-deprioritized-major) I am the

[jira] [Updated] (FLINK-20289) Computed columns can be calculated after ChangelogNormalize to reduce shuffle

2021-10-31 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20289?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-20289: --- Labels: auto-deprioritized-major stale-minor (was: auto-deprioritized-major) I am the

[jira] [Updated] (FLINK-20281) Window aggregation supports changelog stream input

2021-10-31 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20281?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-20281: --- Labels: auto-deprioritized-major stale-minor (was: auto-deprioritized-major) I am the

[jira] [Updated] (FLINK-20255) Nested decorrelate failed

2021-10-31 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20255?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-20255: --- Labels: auto-deprioritized-major stale-minor (was: auto-deprioritized-major) I am the

[jira] [Updated] (FLINK-20257) Flink web-ui metrics page add metrics selector Can't see the full name of the metics

2021-10-31 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20257?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-20257: --- Labels: auto-deprioritized-major stale-minor (was: auto-deprioritized-major) I am the

[jira] [Updated] (FLINK-20210) "RequestFactory" interface in flink elasticsearch connector doesn't support "routing" param

2021-10-31 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20210?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-20210: --- Labels: auto-deprioritized-major stale-minor (was: auto-deprioritized-major) I am the

[jira] [Updated] (FLINK-20174) Make BulkFormat more extensible

2021-10-31 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20174?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-20174: --- Labels: auto-deprioritized-major stale-minor (was: auto-deprioritized-major) I am the

[jira] [Updated] (FLINK-20248) `ParquetSchemaConverter` can not convert Array type to parquet Type

2021-10-31 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20248?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-20248: --- Labels: auto-deprioritized-major stale-minor (was: auto-deprioritized-major) I am the

[jira] [Updated] (FLINK-20340) Use StreamFormat instead of DelimitedInputFormat in DeserializationSchemaAdapter

2021-10-31 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20340?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-20340: --- Labels: auto-deprioritized-major stale-minor (was: auto-deprioritized-major) I am the

[jira] [Closed] (FLINK-24492) incorrect implicit type conversion between numeric and (var)char

2021-10-31 Thread godfrey he (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24492?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he closed FLINK-24492. -- Resolution: Fixed Fixed in 1.15.0: 25dc6eacd38bd7a70883fc8e54f0bec8dc5861c0 Fixed in 1.14.1:

[GitHub] [flink] flinkbot edited a comment on pull request #17604: [FLINK-23919][table-planner-blink] Fix field name conflict bug in `WindowUtil`

2021-10-31 Thread GitBox
flinkbot edited a comment on pull request #17604: URL: https://github.com/apache/flink/pull/17604#issuecomment-954664725 ## CI report: * db26794d5bd076c1389715d25df346ae8f0edf72 Azure:

[GitHub] [flink-ml] gaoyunhaii commented on a change in pull request #16: [FLINK-9][iteration] Support per-round iteration

2021-10-31 Thread GitBox
gaoyunhaii commented on a change in pull request #16: URL: https://github.com/apache/flink-ml/pull/16#discussion_r739822786 ## File path: flink-ml-iteration/src/main/java/org/apache/flink/iteration/config/IterationOptions.java ## @@ -0,0 +1,33 @@ +/* + * Licensed to the

[jira] [Commented] (FLINK-5964) Change TypeSerializers to allow construction of immutable types

2021-10-31 Thread Nicolas Ferrario (Jira)
[ https://issues.apache.org/jira/browse/FLINK-5964?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17436499#comment-17436499 ] Nicolas Ferrario commented on FLINK-5964: - Agree. We started to replace our Scala pipelines with

[GitHub] [flink] flinkbot edited a comment on pull request #17613: [FLINK-24536][Table SQL/Planner] flink sql support bang equal '!='

2021-10-31 Thread GitBox
flinkbot edited a comment on pull request #17613: URL: https://github.com/apache/flink/pull/17613#issuecomment-955719048 ## CI report: * 6d4c2789b1bb6e6248c31337e73ae88a29cfca86 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17598: [WIP][FLINK-24703][connectors][formats] Add FileSource support for reading CSV files.

2021-10-31 Thread GitBox
flinkbot edited a comment on pull request #17598: URL: https://github.com/apache/flink/pull/17598#issuecomment-954282485 ## CI report: * ee8fa611b135924ad3a083ff71dbcbc2e1895351 Azure:

[jira] [Commented] (FLINK-24631) Avoiding directly use the labels as selector for deployment and service

2021-10-31 Thread Aitozi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24631?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17436508#comment-17436508 ] Aitozi commented on FLINK-24631: Hi [~wangyang0918], Do you have any inputs for this ?  > Avoiding

[GitHub] [flink-ml] gaoyunhaii commented on a change in pull request #14: [FLINK-8][iteration] Add per-round operator wrappers

2021-10-31 Thread GitBox
gaoyunhaii commented on a change in pull request #14: URL: https://github.com/apache/flink-ml/pull/14#discussion_r739765047 ## File path: flink-ml-iteration/src/main/java/org/apache/flink/iteration/operator/perround/AbstractPerRoundWrapperOperator.java ## @@ -0,0 +1,482 @@

[GitHub] [flink-ml] gaoyunhaii commented on a change in pull request #14: [FLINK-8][iteration] Add per-round operator wrappers

2021-10-31 Thread GitBox
gaoyunhaii commented on a change in pull request #14: URL: https://github.com/apache/flink-ml/pull/14#discussion_r739765187 ## File path: flink-ml-iteration/src/main/java/org/apache/flink/iteration/operator/perround/MultipleInputPerRoundWrapperOperator.java ## @@ -0,0 +1,143

[GitHub] [flink-ml] gaoyunhaii commented on a change in pull request #14: [FLINK-8][iteration] Add per-round operator wrappers

2021-10-31 Thread GitBox
gaoyunhaii commented on a change in pull request #14: URL: https://github.com/apache/flink-ml/pull/14#discussion_r739765096 ## File path: flink-ml-iteration/pom.xml ## @@ -61,6 +61,14 @@ under the License. provided + Review comment: I

[GitHub] [flink-ml] gaoyunhaii commented on a change in pull request #14: [FLINK-8][iteration] Add per-round operator wrappers

2021-10-31 Thread GitBox
gaoyunhaii commented on a change in pull request #14: URL: https://github.com/apache/flink-ml/pull/14#discussion_r739765316 ## File path: flink-ml-iteration/src/main/java/org/apache/flink/iteration/proxy/state/ProxyKeyedStateBackend.java ## @@ -0,0 +1,235 @@ +/* + * Licensed

[GitHub] [flink] flinkbot edited a comment on pull request #17106: [FLINK-20443][API/DataStream] ContinuousProcessingTimeTrigger doesn't fire at the end of the window

2021-10-31 Thread GitBox
flinkbot edited a comment on pull request #17106: URL: https://github.com/apache/flink/pull/17106#issuecomment-910662440 ## CI report: * bc06f66402036c872851c92a4d64a27a7bef918b UNKNOWN * 5443a0cb5c553f09e98218d2e120121378275d62 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17106: [FLINK-20443][API/DataStream] ContinuousProcessingTimeTrigger doesn't fire at the end of the window

2021-10-31 Thread GitBox
flinkbot edited a comment on pull request #17106: URL: https://github.com/apache/flink/pull/17106#issuecomment-910662440 ## CI report: * bc06f66402036c872851c92a4d64a27a7bef918b UNKNOWN * 5443a0cb5c553f09e98218d2e120121378275d62 Azure:

[GitHub] [flink] godfreyhe closed pull request #17344: [FLINK-20895] [flink-table-planner] support local aggregate push down in table planner

2021-10-31 Thread GitBox
godfreyhe closed pull request #17344: URL: https://github.com/apache/flink/pull/17344 -- 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. To unsubscribe, e-mail:

[jira] [Assigned] (FLINK-24708) `ConvertToNotInOrInRule` has a bug which leads to wrong result

2021-10-31 Thread godfrey he (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24708?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he reassigned FLINK-24708: -- Assignee: JING ZHANG > `ConvertToNotInOrInRule` has a bug which leads to wrong result >

[GitHub] [flink] flinkbot edited a comment on pull request #17604: [FLINK-23919][table-planner-blink] Fix field name conflict bug in `WindowUtil`

2021-10-31 Thread GitBox
flinkbot edited a comment on pull request #17604: URL: https://github.com/apache/flink/pull/17604#issuecomment-954664725 ## CI report: * db26794d5bd076c1389715d25df346ae8f0edf72 Azure:

[jira] [Commented] (FLINK-21321) Change RocksDB incremental checkpoint re-scaling to use deleteRange

2021-10-31 Thread Nicolas Ferrario (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21321?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17436498#comment-17436498 ] Nicolas Ferrario commented on FLINK-21321: -- This would be really useful for us. We have a

[jira] [Comment Edited] (FLINK-24708) `ConvertToNotInOrInRule` has a bug which leads to wrong result

2021-10-31 Thread godfrey he (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24708?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17436500#comment-17436500 ] godfrey he edited comment on FLINK-24708 at 10/31/21, 3:30 PM: --- Thanks for

[GitHub] [flink] JingsongLi merged pull request #17528: [FLINK-24563][table-planner] Fix NullPointerException when comparing timestamp_ltz with random string

2021-10-31 Thread GitBox
JingsongLi merged pull request #17528: URL: https://github.com/apache/flink/pull/17528 -- 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. To unsubscribe, e-mail:

[GitHub] [flink] curcur edited a comment on pull request #17591: [FLINK-24671][runtime] Return 0 buffers in use until subpartition vie…

2021-10-31 Thread GitBox
curcur edited a comment on pull request #17591: URL: https://github.com/apache/flink/pull/17591#issuecomment-955665980 LGTM. Thanks @akalash! BTW, could you double check/confirm that `RemoteInputChannel` does not have/does not need to consider the same problem! I think so,

[GitHub] [flink] flinkbot edited a comment on pull request #17106: [FLINK-20443][API/DataStream] ContinuousProcessingTimeTrigger doesn't fire at the end of the window

2021-10-31 Thread GitBox
flinkbot edited a comment on pull request #17106: URL: https://github.com/apache/flink/pull/17106#issuecomment-910662440 ## CI report: * bc06f66402036c872851c92a4d64a27a7bef918b UNKNOWN * 5443a0cb5c553f09e98218d2e120121378275d62 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17106: [FLINK-20443][API/DataStream] ContinuousProcessingTimeTrigger doesn't fire at the end of the window

2021-10-31 Thread GitBox
flinkbot edited a comment on pull request #17106: URL: https://github.com/apache/flink/pull/17106#issuecomment-910662440 ## CI report: * bc06f66402036c872851c92a4d64a27a7bef918b UNKNOWN * 5443a0cb5c553f09e98218d2e120121378275d62 Azure:

[GitHub] [flink] godfreyhe closed pull request #17444: [FLINK-24492][table-planner]incorrect implicit type conversion between numeric and (var)char

2021-10-31 Thread GitBox
godfreyhe closed pull request #17444: URL: https://github.com/apache/flink/pull/17444 -- 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. To unsubscribe, e-mail:

[jira] [Commented] (FLINK-24652) Add operator wrapper for per-round operators

2021-10-31 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24652?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17436477#comment-17436477 ] Yun Gao commented on FLINK-24652: - Fix on master via 

[jira] [Closed] (FLINK-24652) Add operator wrapper for per-round operators

2021-10-31 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24652?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao closed FLINK-24652. --- Resolution: Fixed > Add operator wrapper for per-round operators >

[jira] [Assigned] (FLINK-20895) Support LocalAggregatePushDown in Blink planner

2021-10-31 Thread godfrey he (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20895?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he reassigned FLINK-20895: -- Assignee: Peng Yu > Support LocalAggregatePushDown in Blink planner >

[jira] [Closed] (FLINK-20895) Support LocalAggregatePushDown in Blink planner

2021-10-31 Thread godfrey he (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20895?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he closed FLINK-20895. -- Resolution: Fixed Fixed in 1.15.0: 34d581b230712d3fd01ce9cfd822acd0df413a92 > Support

[GitHub] [flink] flinkbot commented on pull request #17613: [FLINK-24536][Table SQL/Planner] flink sql support bang equal '!='

2021-10-31 Thread GitBox
flinkbot commented on pull request #17613: URL: https://github.com/apache/flink/pull/17613#issuecomment-955721245 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 #17598: [WIP][FLINK-24703][connectors][formats] Add FileSource support for reading CSV files.

2021-10-31 Thread GitBox
flinkbot edited a comment on pull request #17598: URL: https://github.com/apache/flink/pull/17598#issuecomment-954282485 ## CI report: * ee8fa611b135924ad3a083ff71dbcbc2e1895351 Azure:

[GitHub] [flink] JingsongLi merged pull request #17529: [FLINK-24563][table-planner] Fix NullPointerException when comparing timestamp_ltz with random string

2021-10-31 Thread GitBox
JingsongLi merged pull request #17529: URL: https://github.com/apache/flink/pull/17529 -- 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. To unsubscribe, e-mail:

[jira] [Closed] (FLINK-24408) org.codehaus.janino.InternalCompilerException: Compiling "StreamExecValues$200": Code of method "nextRecord(Ljava/lang/Object;)Ljava/lang/Object;" of class "StreamExecVal

2021-10-31 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24408?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-24408. Resolution: Fixed master: 39ec06aa304504777a8769a10350360fcb439d56 release-1.14:

[GitHub] [flink] flinkbot edited a comment on pull request #17612: [FLINK-24247][TableAPI/SQL] Uniformly limit the value of ABS(offset) …

2021-10-31 Thread GitBox
flinkbot edited a comment on pull request #17612: URL: https://github.com/apache/flink/pull/17612#issuecomment-955298058 ## CI report: * 60ca7a7cd135ee0101649fab30712c7efa160fb9 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17605: [FLINK-24704][table] Fix exception when the input record loses monotonicity on the sort key field of UpdatableTopNFunction

2021-10-31 Thread GitBox
flinkbot edited a comment on pull request #17605: URL: https://github.com/apache/flink/pull/17605#issuecomment-954693023 ## CI report: * 2e9cea2efeb7e9f4722275a20f8551f27833fd95 Azure:

[jira] [Assigned] (FLINK-24492) incorrect implicit type conversion between numeric and (var)char

2021-10-31 Thread godfrey he (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24492?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he reassigned FLINK-24492: -- Assignee: xuyang > incorrect implicit type conversion between numeric and (var)char >

[jira] [Updated] (FLINK-24492) incorrect implicit type conversion between numeric and (var)char

2021-10-31 Thread godfrey he (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24492?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-24492: --- Component/s: Table SQL / Planner > incorrect implicit type conversion between numeric and (var)char

[GitHub] [flink] flinkbot edited a comment on pull request #17605: [FLINK-24704][table] Fix exception when the input record loses monotonicity on the sort key field of UpdatableTopNFunction

2021-10-31 Thread GitBox
flinkbot edited a comment on pull request #17605: URL: https://github.com/apache/flink/pull/17605#issuecomment-954693023 ## CI report: * 2e9cea2efeb7e9f4722275a20f8551f27833fd95 Azure:

[jira] [Commented] (FLINK-21321) Change RocksDB incremental checkpoint re-scaling to use deleteRange

2021-10-31 Thread Yu Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21321?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17436506#comment-17436506 ] Yu Li commented on FLINK-21321: --- Since we've upgraded FRocksDB version to 6.20.3 in 1.14, it's possible to

[GitHub] [flink] JingsongLi merged pull request #17586: [FLINK-24408][table-planner] Enable code splitting for large number of VALUES clause

2021-10-31 Thread GitBox
JingsongLi merged pull request #17586: URL: https://github.com/apache/flink/pull/17586 -- 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. To unsubscribe, e-mail:

[jira] [Closed] (FLINK-24563) Comparing timstamp_ltz with random string throws NullPointerException

2021-10-31 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24563?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-24563. Resolution: Fixed master: 75e5a89529f4c1bec87d7090e527ce64e9188bc1 release-1.14:

[GitHub] [flink] flinkbot edited a comment on pull request #17106: [FLINK-20443][API/DataStream] ContinuousProcessingTimeTrigger doesn't fire at the end of the window

2021-10-31 Thread GitBox
flinkbot edited a comment on pull request #17106: URL: https://github.com/apache/flink/pull/17106#issuecomment-910662440 ## CI report: * bc06f66402036c872851c92a4d64a27a7bef918b UNKNOWN * 5443a0cb5c553f09e98218d2e120121378275d62 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17106: [FLINK-20443][API/DataStream] ContinuousProcessingTimeTrigger doesn't fire at the end of the window

2021-10-31 Thread GitBox
flinkbot edited a comment on pull request #17106: URL: https://github.com/apache/flink/pull/17106#issuecomment-910662440 ## CI report: * bc06f66402036c872851c92a4d64a27a7bef918b UNKNOWN * 5443a0cb5c553f09e98218d2e120121378275d62 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17605: [FLINK-24704][table] Fix exception when the input record loses monotonicity on the sort key field of UpdatableTopNFunction

2021-10-31 Thread GitBox
flinkbot edited a comment on pull request #17605: URL: https://github.com/apache/flink/pull/17605#issuecomment-954693023 ## CI report: * 2e9cea2efeb7e9f4722275a20f8551f27833fd95 Azure:

[GitHub] [flink-ml] guoweiM commented on a change in pull request #14: [FLINK-24652][iteration] Add per-round operator wrappers

2021-10-31 Thread GitBox
guoweiM commented on a change in pull request #14: URL: https://github.com/apache/flink-ml/pull/14#discussion_r739805858 ## File path: pom.xml ## @@ -18,726 +18,730 @@ specific language governing permissions and limitations under the License. -->

[jira] [Updated] (FLINK-24652) Add operator wrapper for per-round operators

2021-10-31 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24652?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-24652: --- Labels: pull-request-available (was: ) > Add operator wrapper for per-round operators >

[GitHub] [flink-ml] gaoyunhaii closed pull request #14: [FLINK-24652][iteration] Add per-round operator wrappers

2021-10-31 Thread GitBox
gaoyunhaii closed pull request #14: URL: https://github.com/apache/flink-ml/pull/14 -- 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. To unsubscribe, e-mail:

[jira] [Commented] (FLINK-21409) Add Avro to DataTypes & Serialization docs

2021-10-31 Thread Nicolas Ferrario (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21409?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17436496#comment-17436496 ] Nicolas Ferrario commented on FLINK-21409: -- I think this is important. We learned the hard way

[jira] [Commented] (FLINK-24633) JobManager pod may stuck in containerCreating status during failover

2021-10-31 Thread Aitozi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24633?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17436505#comment-17436505 ] Aitozi commented on FLINK-24633: I'am not sure whether it is the common behavior of kubernetes scheduler

[GitHub] [flink-ml] gaoyunhaii commented on a change in pull request #14: [FLINK-8][iteration] Add per-round operator wrappers

2021-10-31 Thread GitBox
gaoyunhaii commented on a change in pull request #14: URL: https://github.com/apache/flink-ml/pull/14#discussion_r739764735 ## File path: flink-ml-iteration/src/main/java/org/apache/flink/iteration/operator/perround/AbstractPerRoundWrapperOperator.java ## @@ -0,0 +1,482 @@

[GitHub] [flink-ml] gaoyunhaii commented on a change in pull request #14: [FLINK-8][iteration] Add per-round operator wrappers

2021-10-31 Thread GitBox
gaoyunhaii commented on a change in pull request #14: URL: https://github.com/apache/flink-ml/pull/14#discussion_r739764795 ## File path: flink-ml-iteration/src/main/java/org/apache/flink/iteration/operator/perround/PerRoundOperatorWrapper.java ## @@ -0,0 +1,80 @@ +/* + *

[jira] [Updated] (FLINK-20294) Expose value format metadata in Kinesis table source

2021-10-31 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20294?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-20294: --- Labels: auto-deprioritized-major stale-minor (was: auto-deprioritized-major) I am the

[GitHub] [flink] lincoln-lil commented on pull request #17605: [FLINK-24704][table] Fix exception when the input record loses monotonicity on the sort key field of UpdatableTopNFunction

2021-10-31 Thread GitBox
lincoln-lil commented on pull request #17605: URL: https://github.com/apache/flink/pull/17605#issuecomment-955692359 @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

[GitHub] [flink] flinkbot edited a comment on pull request #17612: [FLINK-24247][TableAPI/SQL] Uniformly limit the value of ABS(offset) …

2021-10-31 Thread GitBox
flinkbot edited a comment on pull request #17612: URL: https://github.com/apache/flink/pull/17612#issuecomment-955298058 ## CI report: * 0beeae7f9fb5906011d9039e157f58ec2ccd1d21 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17106: [FLINK-20443][API/DataStream] ContinuousProcessingTimeTrigger doesn't fire at the end of the window

2021-10-31 Thread GitBox
flinkbot edited a comment on pull request #17106: URL: https://github.com/apache/flink/pull/17106#issuecomment-910662440 ## CI report: * bc06f66402036c872851c92a4d64a27a7bef918b UNKNOWN * b03315617bebee70f340a75bfbc78cf650190c41 Azure:

[jira] [Updated] (FLINK-24536) flink sql where condition is not supported != writing

2021-10-31 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24536?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-24536: --- Labels: pull-request-available (was: ) > flink sql where condition is not supported !=

[GitHub] [flink] hililiwei opened a new pull request #17613: [FLINK-24536][Table SQL/Planner] flink sql support bang equal '!='

2021-10-31 Thread GitBox
hililiwei opened a new pull request #17613: URL: https://github.com/apache/flink/pull/17613 ## What is the purpose of the change flink sql support bang equal '!=' https://issues.apache.org/jira/browse/FLINK-24536 ## Brief change log flink sql support bang

[GitHub] [flink] flinkbot commented on pull request #17613: [FLINK-24536][Table SQL/Planner] flink sql support bang equal '!='

2021-10-31 Thread GitBox
flinkbot commented on pull request #17613: URL: https://github.com/apache/flink/pull/17613#issuecomment-955719048 ## CI report: * 6d4c2789b1bb6e6248c31337e73ae88a29cfca86 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #17604: [FLINK-23919][table-planner-blink] Fix field name conflict bug in `WindowUtil`

2021-10-31 Thread GitBox
flinkbot edited a comment on pull request #17604: URL: https://github.com/apache/flink/pull/17604#issuecomment-954664725 ## CI report: * db26794d5bd076c1389715d25df346ae8f0edf72 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17601: [FLINK-24697][flink-connectors-kafka] add auto.offset.reset configuration for group-offsets startup mode

2021-10-31 Thread GitBox
flinkbot edited a comment on pull request #17601: URL: https://github.com/apache/flink/pull/17601#issuecomment-954546978 ## CI report: * 9c400a2e2f502fcedbf4ed773e497c44e23f0ecf Azure:

[jira] [Updated] (FLINK-24708) `ConvertToNotInOrInRule` has a bug which leads to wrong result

2021-10-31 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24708?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-24708: --- Fix Version/s: 1.15.0 > `ConvertToNotInOrInRule` has a bug which leads to wrong result >

[jira] [Updated] (FLINK-24708) `ConvertToNotInOrInRule` has a bug which leads to wrong result

2021-10-31 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24708?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-24708: --- Priority: Critical (was: Major) > `ConvertToNotInOrInRule` has a bug which leads to wrong result >

[GitHub] [flink] flinkbot edited a comment on pull request #17365: [hotfix][web]Modify the configuration of prettier

2021-10-31 Thread GitBox
flinkbot edited a comment on pull request #17365: URL: https://github.com/apache/flink/pull/17365#issuecomment-928705859 ## CI report: * c877606f26e4de8ad5e6b62a05dcbf88eed6807a Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17365: [hotfix][web]Modify the configuration of prettier

2021-10-31 Thread GitBox
flinkbot edited a comment on pull request #17365: URL: https://github.com/apache/flink/pull/17365#issuecomment-928705859 ## CI report: * c877606f26e4de8ad5e6b62a05dcbf88eed6807a Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17604: [FLINK-23919][table-planner-blink] Fix field name conflict bug in `WindowUtil`

2021-10-31 Thread GitBox
flinkbot edited a comment on pull request #17604: URL: https://github.com/apache/flink/pull/17604#issuecomment-954664725 ## CI report: * db26794d5bd076c1389715d25df346ae8f0edf72 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17365: [hotfix][web]Modify the configuration of prettier

2021-10-31 Thread GitBox
flinkbot edited a comment on pull request #17365: URL: https://github.com/apache/flink/pull/17365#issuecomment-928705859 ## CI report: * c877606f26e4de8ad5e6b62a05dcbf88eed6807a Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17365: [hotfix][web]Modify the configuration of prettier

2021-10-31 Thread GitBox
flinkbot edited a comment on pull request #17365: URL: https://github.com/apache/flink/pull/17365#issuecomment-928705859 ## CI report: * c877606f26e4de8ad5e6b62a05dcbf88eed6807a Azure:

[jira] [Resolved] (FLINK-24709) Fix the issue of interval join java case content in the official document case

2021-10-31 Thread XiaShengSheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24709?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] XiaShengSheng resolved FLINK-24709. --- Resolution: Fixed > Fix the issue of interval join java case content in the official

[jira] [Reopened] (FLINK-24709) Fix the issue of interval join java case content in the official document case

2021-10-31 Thread XiaShengSheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24709?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] XiaShengSheng reopened FLINK-24709: --- > Fix the issue of interval join java case content in the official document case >

[GitHub] [flink] flinkbot edited a comment on pull request #17542: [FLINK-17782] Add array,map,row types support for parquet row writer

2021-10-31 Thread GitBox
flinkbot edited a comment on pull request #17542: URL: https://github.com/apache/flink/pull/17542#issuecomment-949170131 ## CI report: * 6d75c9ad1b7ec1ef5121b0d2f348f2a6b966eb73 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17365: [hotfix][web]Modify the configuration of prettier

2021-10-31 Thread GitBox
flinkbot edited a comment on pull request #17365: URL: https://github.com/apache/flink/pull/17365#issuecomment-928705859 ## CI report: * c877606f26e4de8ad5e6b62a05dcbf88eed6807a Azure:

[GitHub] [flink] zekai-li commented on pull request #17365: [hotfix][web]Modify the configuration of prettier

2021-10-31 Thread GitBox
zekai-li commented on pull request #17365: URL: https://github.com/apache/flink/pull/17365#issuecomment-955878296 @hadronzoo -- 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

[GitHub] [flink] flinkbot edited a comment on pull request #17365: [hotfix][web]Modify the configuration of prettier

2021-10-31 Thread GitBox
flinkbot edited a comment on pull request #17365: URL: https://github.com/apache/flink/pull/17365#issuecomment-928705859 ## CI report: * c877606f26e4de8ad5e6b62a05dcbf88eed6807a Azure:

[GitHub] [flink-ml] guoweiM commented on a change in pull request #17: [FLINK-10][iteration] Support the checkpoints for the iteration.

2021-10-31 Thread GitBox
guoweiM commented on a change in pull request #17: URL: https://github.com/apache/flink-ml/pull/17#discussion_r739942123 ## File path: flink-ml-iteration/src/main/java/org/apache/flink/iteration/operator/HeadOperatorCheckpointAligner.java ## @@ -0,0 +1,104 @@ +/* + * Licensed

[GitHub] [flink] flinkbot edited a comment on pull request #17509: [FLINK-24501][table-runtime] Stores window progress into state in order to check whether an input element is late or not for window-t

2021-10-31 Thread GitBox
flinkbot edited a comment on pull request #17509: URL: https://github.com/apache/flink/pull/17509#issuecomment-945571594 ## CI report: * 0dbb0411fb710a0d0082edb89782d99dc053140a Azure:

[jira] [Assigned] (FLINK-24704) Exception occurs when the input record loses monotonicity on the sort key field of UpdatableTopNFunction

2021-10-31 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24704?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reassigned FLINK-24704: Assignee: lincoln lee > Exception occurs when the input record loses monotonicity on the

[GitHub] [flink] flinkbot edited a comment on pull request #17509: [FLINK-24501][table-runtime] Stores window progress into state in order to check whether an input element is late or not for window-t

2021-10-31 Thread GitBox
flinkbot edited a comment on pull request #17509: URL: https://github.com/apache/flink/pull/17509#issuecomment-945571594 ## CI report: * 0dbb0411fb710a0d0082edb89782d99dc053140a Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17509: [FLINK-24501][table-runtime] Stores window progress into state in order to check whether an input element is late or not for window-t

2021-10-31 Thread GitBox
flinkbot edited a comment on pull request #17509: URL: https://github.com/apache/flink/pull/17509#issuecomment-945571594 ## CI report: * 0dbb0411fb710a0d0082edb89782d99dc053140a Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17509: [FLINK-24501][table-runtime] Stores window progress into state in order to check whether an input element is late or not for window-t

2021-10-31 Thread GitBox
flinkbot edited a comment on pull request #17509: URL: https://github.com/apache/flink/pull/17509#issuecomment-945571594 ## CI report: * 0dbb0411fb710a0d0082edb89782d99dc053140a Azure:

[jira] [Commented] (FLINK-24713) Postpone resourceManager serving after the recovery phase has finished

2021-10-31 Thread Aitozi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24713?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17436620#comment-17436620 ] Aitozi commented on FLINK-24713: cc [~trohrmann] , looking forward to your opinions. > Postpone

[GitHub] [flink] flinkbot edited a comment on pull request #17601: [FLINK-24697][flink-connectors-kafka] add auto.offset.reset configuration for group-offsets startup mode

2021-10-31 Thread GitBox
flinkbot edited a comment on pull request #17601: URL: https://github.com/apache/flink/pull/17601#issuecomment-954546978 ## CI report: * 9c400a2e2f502fcedbf4ed773e497c44e23f0ecf Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17365: [hotfix][web]Modify the configuration of prettier

2021-10-31 Thread GitBox
flinkbot edited a comment on pull request #17365: URL: https://github.com/apache/flink/pull/17365#issuecomment-928705859 ## CI report: * c877606f26e4de8ad5e6b62a05dcbf88eed6807a Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17365: [hotfix][web]Modify the configuration of prettier

2021-10-31 Thread GitBox
flinkbot edited a comment on pull request #17365: URL: https://github.com/apache/flink/pull/17365#issuecomment-928705859 ## CI report: * c877606f26e4de8ad5e6b62a05dcbf88eed6807a Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17365: [hotfix][web]Modify the configuration of prettier

2021-10-31 Thread GitBox
flinkbot edited a comment on pull request #17365: URL: https://github.com/apache/flink/pull/17365#issuecomment-928705859 ## CI report: * c877606f26e4de8ad5e6b62a05dcbf88eed6807a Azure:

  1   2   >