[jira] [Updated] (FLINK-22318) Support RENAME column name for ALTER TABLE statement

[ https://issues.apache.org/jira/browse/FLINK-22318?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] todd updated FLINK-22318: - Attachment: image-2021-04-26-13-58-19-302.png > Support RENAME column name for ALTER TABLE statement >

[GitHub] [flink] klion26 closed pull request #12287: [FLINK-16077][docs-zh] Translate Custom State Serialization page into Chinese

klion26 closed pull request #12287: URL: https://github.com/apache/flink/pull/12287 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service,

[GitHub] [flink] JingsongLi commented on pull request #15752: [FLINK-19606][table-runtime-blink] Refactor JoinConditionWithFullFilters from an inner class in AbstractStreamingJoinOperator to a common

JingsongLi commented on pull request #15752: URL: https://github.com/apache/flink/pull/15752#issuecomment-826527975 I recommend you configure it: https://ci.apache.org/projects/flink/flink-docs-master/docs/flinkdev/ide_setup/#code-formatting -- This is an automated message from the

[GitHub] [flink] klion26 opened a new pull request #15761: [FLINK-16077][docs-zh] Translate Custom State Serialization page into Chinese

klion26 opened a new pull request #15761: URL: https://github.com/apache/flink/pull/15761 ## What is the purpose of the change Translate Custom State Serialization page into Chinese ## Verifying this change This change is a trivial rework / code cleanup without any

[GitHub] [flink] lirui-apache commented on pull request #15653: [FLINK-22329][hive] Inject current ugi credentials into jobconf when getting file split in hive connector

lirui-apache commented on pull request #15653: URL: https://github.com/apache/flink/pull/15653#issuecomment-826527360 ``` Scenarios like kerberos are difficult to cover through unit tests ``` @zuston I'm not sure whether we need kerberos for this. E.g. is it possible to manually

[GitHub] [flink] JingsongLi commented on pull request #15752: [FLINK-19606][table-runtime-blink] Refactor JoinConditionWithFullFilters from an inner class in AbstractStreamingJoinOperator to a common

JingsongLi commented on pull request #15752: URL: https://github.com/apache/flink/pull/15752#issuecomment-826526971 @beyond1920 Compile failed. -- 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] [Created] (FLINK-22469) HistoryServer starts with NoSuchFileException

Gabor Somogyi created FLINK-22469: - Summary: HistoryServer starts with NoSuchFileException Key: FLINK-22469 URL: https://issues.apache.org/jira/browse/FLINK-22469 Project: Flink Issue Type:

[GitHub] [flink] flinkbot edited a comment on pull request #13459: [FLINK-18199] [chinese-translation]: translate FileSystem SQL Connector page into Chinese

flinkbot edited a comment on pull request #13459: URL: https://github.com/apache/flink/pull/13459#issuecomment-697158140 ## CI report: * 01e3a241fd858bb5c13bdd481f9659524f043abf UNKNOWN * dff3d40e963077fe2b8da5f4249090f702555008 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15760: [FLINK-19606][table-runtime-blink] Introduce WindowJoinOperator and WindowJoinOperatorBuilder.

flinkbot edited a comment on pull request #15760: URL: https://github.com/apache/flink/pull/15760#issuecomment-826500326 ## CI report: * 1d43ce7ad5aa1b1a53be0e304b1d5b9ed477c3b7 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15757: [FLINK-22445][python][docs] Add more examples of row-based operations in PyFlink doc

flinkbot edited a comment on pull request #15757: URL: https://github.com/apache/flink/pull/15757#issuecomment-826471744 ## CI report: * 3e0d896b418ab77a46cd6333dd512d034b56c30e Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15749: [hotfix][docs] Fix typo.

flinkbot edited a comment on pull request #15749: URL: https://github.com/apache/flink/pull/15749#issuecomment-826274666 ## CI report: * 6badad7b096fc3c49603f6af520b876e3b8cf51f Azure:

[jira] [Updated] (FLINK-22468) Make StateFun build with Java 11

[ https://issues.apache.org/jira/browse/FLINK-22468?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-22468: --- Labels: pull-request-available (was: ) > Make StateFun build with Java 11 >

[GitHub] [flink-statefun] tzulitai opened a new pull request #230: [FLINK-22468] Fix Java 11 build by adding dependency to javax.annotations

tzulitai opened a new pull request #230: URL: https://github.com/apache/flink-statefun/pull/230 This enables building StateFun with Java 11, since javax.annotations was removed with JDK 11. -- This is an automated message from the Apache Git Service. To respond to the message, please

[GitHub] [flink] michaelli916 commented on a change in pull request #13459: [FLINK-18199] [chinese-translation]: translate FileSystem SQL Connector page into Chinese

michaelli916 commented on a change in pull request #13459: URL: https://github.com/apache/flink/pull/13459#discussion_r619975027 ## File path: docs/content.zh/docs/connectors/table/filesystem.md ## @@ -217,13 +206,15 @@ To define when to commit a partition, providing partition

[GitHub] [flink] flinkbot commented on pull request #15760: [FLINK-19606][table-runtime-blink] Introduce WindowJoinOperator and WindowJoinOperatorBuilder.

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

[GitHub] [flink] flinkbot edited a comment on pull request #15759: [FLINK-22463][table-planner-blink] Fix IllegalArgumentException in WindowAttachedWindowingStrategy when two phase is enabled for dist

flinkbot edited a comment on pull request #15759: URL: https://github.com/apache/flink/pull/15759#issuecomment-826494695 ## CI report: * 99b2ac7e2b6705a1bf3b2d087c399bce199380ee Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15752: [FLINK-19606][table-runtime-blink] Refactor JoinConditionWithFullFilters from an inner class in AbstractStreamingJoinOperator to a co

flinkbot edited a comment on pull request #15752: URL: https://github.com/apache/flink/pull/15752#issuecomment-826336806 ## CI report: * e813ef5fd32db0aff193e39eaae067601695fde2 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13459: [FLINK-18199] [chinese-translation]: translate FileSystem SQL Connector page into Chinese

flinkbot edited a comment on pull request #13459: URL: https://github.com/apache/flink/pull/13459#issuecomment-697158140 ## CI report: * 1808abf9bddeaf27588794ffcb3c6690f7a19c7c Azure:

[jira] [Created] (FLINK-22468) Make StateFun build with Java 11

Tzu-Li (Gordon) Tai created FLINK-22468: --- Summary: Make StateFun build with Java 11 Key: FLINK-22468 URL: https://issues.apache.org/jira/browse/FLINK-22468 Project: Flink Issue Type:

[jira] [Updated] (FLINK-11222) Change api.scala.DataStream to api.datastream.DataStream for createHarnessTester in HarnessTestBase

[ https://issues.apache.org/jira/browse/FLINK-11222?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-11222: - Component/s: (was: Table SQL / Runtime) Table SQL / Legacy Planner >

[jira] [Updated] (FLINK-10795) STDDEV_POP error

[ https://issues.apache.org/jira/browse/FLINK-10795?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-10795: - Component/s: (was: Table SQL / Runtime) Table SQL / Legacy Planner >

[jira] [Updated] (FLINK-13372) Timestamp conversion bug in non-blink Table/SQL runtime

[ https://issues.apache.org/jira/browse/FLINK-13372?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-13372: - Component/s: (was: Table SQL / Runtime) Table SQL / Legacy Planner >

[jira] [Updated] (FLINK-19449) LEAD/LAG cannot work correctly in streaming mode

[ https://issues.apache.org/jira/browse/FLINK-19449?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-19449: - Component/s: (was: Table SQL / API) > LEAD/LAG cannot work correctly in streaming mode >

[jira] [Reopened] (FLINK-19449) LEAD/LAG cannot work correctly in streaming mode

[ https://issues.apache.org/jira/browse/FLINK-19449?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reopened FLINK-19449: -- > LEAD/LAG cannot work correctly in streaming mode >

[jira] [Closed] (FLINK-19449) LEAD/LAG cannot work correctly in streaming mode

[ https://issues.apache.org/jira/browse/FLINK-19449?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-19449. Resolution: Fixed > LEAD/LAG cannot work correctly in streaming mode >

[GitHub] [flink] flinkbot commented on pull request #15759: [FLINK-22463][table-planner-blink] Fix IllegalArgumentException in WindowAttachedWindowingStrategy when two phase is enabled for distinct ag

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

[GitHub] [flink] flinkbot edited a comment on pull request #15752: [FLINK-19606][table-runtime-blink] Refactor JoinConditionWithFullFilters from an inner class in AbstractStreamingJoinOperator to a co

flinkbot edited a comment on pull request #15752: URL: https://github.com/apache/flink/pull/15752#issuecomment-826336806 ## CI report: * Unknown: [CANCELED](TBD) * e813ef5fd32db0aff193e39eaae067601695fde2 UNKNOWN Bot commands The @flinkbot bot supports the

[GitHub] [flink-statefun] tzulitai closed pull request #229: [hotfix][docs] Fix typos in apache-kafka.md and aws-kinesis.md

tzulitai closed pull request #229: URL: https://github.com/apache/flink-statefun/pull/229 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service,

[GitHub] [flink-statefun] tzulitai commented on pull request #229: [hotfix][docs] Fix typos in apache-kafka.md and aws-kinesis.md

tzulitai commented on pull request #229: URL: https://github.com/apache/flink-statefun/pull/229#issuecomment-826494017 Thanks, merging this ... -- 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] flinkbot commented on pull request #15760: [FLINK-19606][table-runtime-blink] Introduce WindowJoinOperator and WindowJoinOperatorBuilder.

flinkbot commented on pull request #15760: URL: https://github.com/apache/flink/pull/15760#issuecomment-826493595 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 #13459: [FLINK-18199] [chinese-translation]: translate FileSystem SQL Connector page into Chinese

flinkbot edited a comment on pull request #13459: URL: https://github.com/apache/flink/pull/13459#issuecomment-697158140 ## CI report: * 6a8554ed2ec89143d83706e6d8a47f06e54a107b Azure:

[jira] [Created] (FLINK-22467) OverAggregateITCase.testRowNumberOnOver is unstable

Jingsong Lee created FLINK-22467: Summary: OverAggregateITCase.testRowNumberOnOver is unstable Key: FLINK-22467 URL: https://issues.apache.org/jira/browse/FLINK-22467 Project: Flink Issue

[jira] [Commented] (FLINK-21302) Fix NPE when use row_number() in over agg

[ https://issues.apache.org/jira/browse/FLINK-21302?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17331737#comment-17331737 ] Jingsong Lee commented on FLINK-21302: --

[jira] [Created] (FLINK-22466) KafkaSourceLegacyITCase.testOneToOneSources fail because the OperatorEvent lost

Guowei Ma created FLINK-22466: - Summary: KafkaSourceLegacyITCase.testOneToOneSources fail because the OperatorEvent lost Key: FLINK-22466 URL: https://issues.apache.org/jira/browse/FLINK-22466 Project:

[GitHub] [flink] beyond1920 commented on pull request #15479: [FLINK-19606][table-runtime-blink] Implement streaming window join operator

beyond1920 commented on pull request #15479: URL: https://github.com/apache/flink/pull/15479#issuecomment-826490931 @JingsongLi Thanks for suggestion, the second PR is https://github.com/apache/flink/pull/15760. please have a look, thanks. -- This is an automated message from the Apache

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

JingsongLi commented on a change in pull request #14880: URL: https://github.com/apache/flink/pull/14880#discussion_r619963485 ## File path: flink-table/flink-table-planner-blink/src/test/scala/org/apache/flink/table/planner/runtime/stream/sql/OverAggregateITCase.scala ## @@

[GitHub] [flink] beyond1920 commented on pull request #15760: [FLINK-19606][table-runtime-blink] Introduce WindowJoinOperator and WindowJoinOperatorBuilder.

beyond1920 commented on pull request #15760: URL: https://github.com/apache/flink/pull/15760#issuecomment-826490680 @JingsongLi This is the second pr which is from https://github.com/apache/flink/pull/15479, please a look at it. -- This is an automated message from the Apache Git

[GitHub] [flink] beyond1920 opened a new pull request #15760: [FLINK-19606][table-runtime-blink] Introduce WindowJoinOperator and WindowJoinOperatorBuilder.

beyond1920 opened a new pull request #15760: URL: https://github.com/apache/flink/pull/15760 ## What is the purpose of the change This pull request aims to introduce WindowJoinOperator and WindowJoinOperatorBuilder, which is second step of

[jira] [Issue Comment Deleted] (FLINK-22457) KafkaSourceLegacyITCase.testMultipleSourcesOnePartition fails because of timeout

[ https://issues.apache.org/jira/browse/FLINK-22457?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guowei Ma updated FLINK-22457: -- Comment: was deleted (was:

[jira] [Commented] (FLINK-22457) KafkaSourceLegacyITCase.testMultipleSourcesOnePartition fails because of timeout

[ https://issues.apache.org/jira/browse/FLINK-22457?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17331733#comment-17331733 ] Guowei Ma commented on FLINK-22457: ---

[jira] [Commented] (FLINK-22019) UnalignedCheckpointRescaleITCase hangs on azure

[ https://issues.apache.org/jira/browse/FLINK-22019?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17331732#comment-17331732 ] Guowei Ma commented on FLINK-22019: ---

[jira] [Created] (FLINK-22465) KafkaSourceITCase.testValueOnlyDeserializer hangs

Guowei Ma created FLINK-22465: - Summary: KafkaSourceITCase.testValueOnlyDeserializer hangs Key: FLINK-22465 URL: https://issues.apache.org/jira/browse/FLINK-22465 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-22451) Support (*) as parameter of table UserDefinedFunction

[ https://issues.apache.org/jira/browse/FLINK-22451?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17331730#comment-17331730 ] Yi Tang commented on FLINK-22451: - [~jark] It's clear and reasonable. I think we have reached consensus.

[GitHub] [flink] beyond1920 commented on pull request #15752: [FLINK-19606][table-runtime-blink] Refactor JoinConditionWithFullFilters from an inner class in AbstractStreamingJoinOperator to a common

beyond1920 commented on pull request #15752: URL: https://github.com/apache/flink/pull/15752#issuecomment-826486617 @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-22457) KafkaSourceLegacyITCase.testMultipleSourcesOnePartition fails because of timeout

[ https://issues.apache.org/jira/browse/FLINK-22457?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17331729#comment-17331729 ] Guowei Ma commented on FLINK-22457: ---

[jira] [Updated] (FLINK-22457) KafkaSourceLegacyITCase.testMultipleSourcesOnePartition fails because of timeout

[ https://issues.apache.org/jira/browse/FLINK-22457?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guowei Ma updated FLINK-22457: -- Affects Version/s: 1.13.0 > KafkaSourceLegacyITCase.testMultipleSourcesOnePartition fails because of

[GitHub] [flink] flinkbot commented on pull request #15759: [FLINK-22463][table-planner-blink] Fix IllegalArgumentException in WindowAttachedWindowingStrategy when two phase is enabled for distinct ag

flinkbot commented on pull request #15759: URL: https://github.com/apache/flink/pull/15759#issuecomment-826485216 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-21608) YARNHighAvailabilityITCase.testClusterClientRetrieval fails with "There is at least one application..."

[ https://issues.apache.org/jira/browse/FLINK-21608?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17331725#comment-17331725 ] Guowei Ma commented on FLINK-21608: ---

[jira] [Commented] (FLINK-22460) Conversion to relational algebra failed due to NOT NULL modifier

[ https://issues.apache.org/jira/browse/FLINK-22460?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17331727#comment-17331727 ] Shengkai Fang commented on FLINK-22460: --- Could you provide the ddl of the `result_1` ? >

[GitHub] [flink-web] leonardBang commented on a change in pull request #436: Add Apache Flink release 1.13.0

leonardBang commented on a change in pull request #436: URL: https://github.com/apache/flink-web/pull/436#discussion_r619948767 ## File path: _posts/2021-04-22-release-1.13.0.md ## @@ -0,0 +1,374 @@ +--- +layout: post +title: "Apache Flink 1.13.0 Release Announcement" +date:

[jira] [Updated] (FLINK-22463) IllegalArgumentException is thrown in WindowAttachedWindowingStrategy when two phase is enabled for distinct agg

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

[GitHub] [flink] godfreyhe opened a new pull request #15759: [FLINK-22463][table-planner-blink] Fix IllegalArgumentException in WindowAttachedWindowingStrategy when two phase is enabled for distinct a

godfreyhe opened a new pull request #15759: URL: https://github.com/apache/flink/pull/15759 ## What is the purpose of the change *The windowStart in WindowAttachedWindowingStrategy may be -1 when two phase is enabled for distinct agg (see

[jira] [Commented] (FLINK-22195) YARNHighAvailabilityITCase.testClusterClientRetrieval because of TestTimedOutException

[ https://issues.apache.org/jira/browse/FLINK-22195?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17331724#comment-17331724 ] Guowei Ma commented on FLINK-22195: ---

[GitHub] [flink] flinkbot edited a comment on pull request #15758: [FLINK-21247][table] Fix problem in MapDataSerializer#copy when there exists custom MapData

flinkbot edited a comment on pull request #15758: URL: https://github.com/apache/flink/pull/15758#issuecomment-826479500 ## CI report: * 422de5b7c373f51311b0e8f4f48a1a679e9f Azure:

[GitHub] [flink] beyond1920 commented on pull request #15752: [FLINK-19606][table-runtime-blink] Refactor JoinConditionWithFullFilters from an inner class in AbstractStreamingJoinOperator to a common

beyond1920 commented on pull request #15752: URL: https://github.com/apache/flink/pull/15752#issuecomment-826483950 @JingsongLi I have updated based on your suggestion, thanks. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub

[jira] [Created] (FLINK-22464) OperatorEventSendingCheckpointITCase.testOperatorEventLostWithReaderFailure hangs with `AdaptiveScheduler`

Guowei Ma created FLINK-22464: - Summary: OperatorEventSendingCheckpointITCase.testOperatorEventLostWithReaderFailure hangs with `AdaptiveScheduler` Key: FLINK-22464 URL:

[GitHub] [flink] flinkbot edited a comment on pull request #13459: [FLINK-18199] [chinese-translation]: translate FileSystem SQL Connector page into Chinese

flinkbot edited a comment on pull request #13459: URL: https://github.com/apache/flink/pull/13459#issuecomment-697158140 ## CI report: * 6a8554ed2ec89143d83706e6d8a47f06e54a107b Azure:

[jira] [Commented] (FLINK-22458) Failed when operating empty catalog table

[ https://issues.apache.org/jira/browse/FLINK-22458?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17331722#comment-17331722 ] Jark Wu commented on FLINK-22458: - Seems like a duplicate issue of FLINK-20784. > Failed when

[jira] [Updated] (FLINK-22463) IllegalArgumentException is thrown in WindowAttachedWindowingStrategy when two phase is enabled for distinct agg

[ https://issues.apache.org/jira/browse/FLINK-22463?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-22463: --- Component/s: Table SQL / Planner > IllegalArgumentException is thrown in

[jira] [Updated] (FLINK-22458) Failed when operating empty catalog table

[ https://issues.apache.org/jira/browse/FLINK-22458?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-22458: Component/s: (was: Table SQL / API) Connectors / Hive > Failed when operating empty

[jira] [Updated] (FLINK-22463) IllegalArgumentException is thrown in WindowAttachedWindowingStrategy when two phase is enabled for distinct agg

[ https://issues.apache.org/jira/browse/FLINK-22463?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-22463: --- Fix Version/s: 1.14.0 1.13.0 > IllegalArgumentException is thrown in

[GitHub] [flink] beyond1920 commented on a change in pull request #15752: [FLINK-19606][table-runtime-blink] Refactor JoinConditionWithFullFilters from an inner class in AbstractStreamingJoinOperator

beyond1920 commented on a change in pull request #15752: URL: https://github.com/apache/flink/pull/15752#discussion_r619955955 ## File path: flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/join/JoinConditionWithNullFilters.java ##

[jira] [Created] (FLINK-22463) IllegalArgumentException is thrown in WindowAttachedWindowingStrategy when two phase is enabled for distinct agg

godfrey he created FLINK-22463: -- Summary: IllegalArgumentException is thrown in WindowAttachedWindowingStrategy when two phase is enabled for distinct agg Key: FLINK-22463 URL:

[jira] [Assigned] (FLINK-22463) IllegalArgumentException is thrown in WindowAttachedWindowingStrategy when two phase is enabled for distinct agg

[ https://issues.apache.org/jira/browse/FLINK-22463?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he reassigned FLINK-22463: -- Assignee: godfrey he > IllegalArgumentException is thrown in WindowAttachedWindowingStrategy

[jira] [Updated] (FLINK-22463) IllegalArgumentException is thrown in WindowAttachedWindowingStrategy when two phase is enabled for distinct agg

[ https://issues.apache.org/jira/browse/FLINK-22463?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-22463: --- Affects Version/s: 1.13.0 > IllegalArgumentException is thrown in WindowAttachedWindowingStrategy

[GitHub] [flink] beyond1920 commented on a change in pull request #15752: [FLINK-19606][table-runtime-blink] Refactor JoinConditionWithFullFilters from an inner class in AbstractStreamingJoinOperator

beyond1920 commented on a change in pull request #15752: URL: https://github.com/apache/flink/pull/15752#discussion_r619955472 ## File path: flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/join/JoinConditionWithNullFilters.java ##

[jira] [Commented] (FLINK-22451) Support (*) as parameter of table UserDefinedFunction

[ https://issues.apache.org/jira/browse/FLINK-22451?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17331718#comment-17331718 ] Jark Wu commented on FLINK-22451: - Yes, I think {{$("*")}} is just a syntax-sugar, e.g.

[jira] [Created] (FLINK-22462) JdbcExactlyOnceSinkE2eTest.testInsert failed because of too many clients.

Guowei Ma created FLINK-22462: - Summary: JdbcExactlyOnceSinkE2eTest.testInsert failed because of too many clients. Key: FLINK-22462 URL: https://issues.apache.org/jira/browse/FLINK-22462 Project: Flink

[GitHub] [flink-web] wuchong commented on a change in pull request #436: Add Apache Flink release 1.13.0

wuchong commented on a change in pull request #436: URL: https://github.com/apache/flink-web/pull/436#discussion_r619953910 ## File path: _posts/2021-04-22-release-1.13.0.md ## @@ -0,0 +1,450 @@ +--- +layout: post +title: "Apache Flink 1.13.0 Release Announcement" +date:

[GitHub] [flink-web] wuchong commented on a change in pull request #436: Add Apache Flink release 1.13.0

wuchong commented on a change in pull request #436: URL: https://github.com/apache/flink-web/pull/436#discussion_r619945545 ## File path: _posts/2021-04-22-release-1.13.0.md ## @@ -0,0 +1,450 @@ +--- +layout: post +title: "Apache Flink 1.13.0 Release Announcement" +date:

[jira] [Commented] (FLINK-21235) leaderChange_withBlockingJobManagerTermination_doesNotAffectNewLeader hang

[ https://issues.apache.org/jira/browse/FLINK-21235?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17331715#comment-17331715 ] Guowei Ma commented on FLINK-21235: ---

[jira] [Updated] (FLINK-22461) Resuming Savepoint (file, async, scale down) end-to-end test failed because of binding port failed

[ https://issues.apache.org/jira/browse/FLINK-22461?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guowei Ma updated FLINK-22461: -- Summary: Resuming Savepoint (file, async, scale down) end-to-end test failed because of binding port

[jira] [Created] (FLINK-22461) Resuming Savepoint (file, async, scale down) end-to-end test failed because of binding port fail

Guowei Ma created FLINK-22461: - Summary: Resuming Savepoint (file, async, scale down) end-to-end test failed because of binding port fail Key: FLINK-22461 URL: https://issues.apache.org/jira/browse/FLINK-22461

[GitHub] [flink] flinkbot commented on pull request #15758: [FLINK-21247][table] Fix problem in MapDataSerializer#copy when there exists custom MapData

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

[GitHub] [flink] flinkbot edited a comment on pull request #15757: [FLINK-22445][python][docs] Add more examples of row-based operations in PyFlink doc

flinkbot edited a comment on pull request #15757: URL: https://github.com/apache/flink/pull/15757#issuecomment-826471744 ## CI report: * 3e0d896b418ab77a46cd6333dd512d034b56c30e Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15749: [hotfix][docs] Fix typo.

flinkbot edited a comment on pull request #15749: URL: https://github.com/apache/flink/pull/15749#issuecomment-826274666 ## CI report: * dcb1c523cfc78840a41573b765913e575822c195 Azure:

[GitHub] [flink] JingsongLi commented on a change in pull request #13459: [FLINK-18199] [chinese-translation]: translate FileSystem SQL Connector page into Chinese

JingsongLi commented on a change in pull request #13459: URL: https://github.com/apache/flink/pull/13459#discussion_r619951102 ## File path: docs/content.zh/docs/connectors/table/filesystem.md ## @@ -217,13 +206,15 @@ To define when to commit a partition, providing partition

[jira] [Closed] (FLINK-19449) LEAD/LAG cannot work correctly in streaming mode

[ https://issues.apache.org/jira/browse/FLINK-19449?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-19449. Resolution: Fixed Fixed via: master: 362f4aea1eec38472d94fc8527d8e1275110b03c

[GitHub] [flink] JingsongLi merged pull request #15747: [FLINK-19449][table-planner] LEAD/LAG cannot work correctly in streaming mode

JingsongLi merged pull request #15747: URL: https://github.com/apache/flink/pull/15747 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service,

[jira] [Updated] (FLINK-22460) Conversion to relational algebra failed due to NOT NULL modifier

[ https://issues.apache.org/jira/browse/FLINK-22460?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Haiwei Zhou updated FLINK-22460: Summary: Conversion to relational algebra failed due to NOT NULL modifier (was: Conversion to

[jira] [Created] (FLINK-22460) Conversion to relational algebra failed caused by ''

Haiwei Zhou created FLINK-22460: --- Summary: Conversion to relational algebra failed caused by '' Key: FLINK-22460 URL: https://issues.apache.org/jira/browse/FLINK-22460 Project: Flink Issue

[GitHub] [flink] JingsongLi commented on pull request #15747: [FLINK-19449][table-planner] LEAD/LAG cannot work correctly in streaming mode

JingsongLi commented on pull request #15747: URL: https://github.com/apache/flink/pull/15747#issuecomment-826476037 I will split commits and merge. -- 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

[GitHub] [flink-web] leonardBang commented on a change in pull request #436: Add Apache Flink release 1.13.0

leonardBang commented on a change in pull request #436: URL: https://github.com/apache/flink-web/pull/436#discussion_r619948767 ## File path: _posts/2021-04-22-release-1.13.0.md ## @@ -0,0 +1,374 @@ +--- +layout: post +title: "Apache Flink 1.13.0 Release Announcement" +date:

[GitHub] [flink] wangwei1025 commented on a change in pull request #15746: [FLINK-17783][Table SQL/Ecosystem]Add array,map,row types support for orc row writer

wangwei1025 commented on a change in pull request #15746: URL: https://github.com/apache/flink/pull/15746#discussion_r619948239 ## File path: flink-formats/flink-orc/src/main/java/org/apache/flink/orc/vector/RowDataVectorizer.java ## @@ -151,8 +160,114 @@ private static void

[jira] [Commented] (FLINK-17783) Add array,map,row types support for orc row writer

[ https://issues.apache.org/jira/browse/FLINK-17783?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17331709#comment-17331709 ] Wang Wei commented on FLINK-17783: -- In this PR, I implements array,map,row types support for

[jira] [Commented] (FLINK-22451) Support (*) as parameter of table UserDefinedFunction

[ https://issues.apache.org/jira/browse/FLINK-22451?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17331708#comment-17331708 ] Yi Tang commented on FLINK-22451: - Did you mean, we can leave the choice to the users? If they want to

[jira] [Created] (FLINK-22459) FlinkKafkaProducerITCase testScaleUpAfterScalingDown failed because of Timeout expired after 60000milliseconds while awaiting EndTxn(COMMIT)

Guowei Ma created FLINK-22459: - Summary: FlinkKafkaProducerITCase testScaleUpAfterScalingDown failed because of Timeout expired after 6milliseconds while awaiting EndTxn(COMMIT) Key: FLINK-22459 URL:

[jira] [Commented] (FLINK-22449) Casting an invalid constant string to int throws exception from SinkNotNullEnforcer

[ https://issues.apache.org/jira/browse/FLINK-22449?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17331705#comment-17331705 ] Kurt Young commented on FLINK-22449: Whether changing the result type nullability should be align

[GitHub] [flink] flinkbot edited a comment on pull request #15749: [hotfix][docs] Fix typo.

flinkbot edited a comment on pull request #15749: URL: https://github.com/apache/flink/pull/15749#issuecomment-826274666 ## CI report: * dcb1c523cfc78840a41573b765913e575822c195 Azure:

[GitHub] [flink] flinkbot commented on pull request #15757: [FLINK-22445][python][docs] Add more examples of row-based operations in PyFlink doc

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

[jira] [Commented] (FLINK-22312) YARNSessionFIFOSecuredITCase>YARNSessionFIFOITCase.checkForProhibitedLogContents due to the heartbeat exception with Yarn RM

[ https://issues.apache.org/jira/browse/FLINK-22312?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17331704#comment-17331704 ] Guowei Ma commented on FLINK-22312: ---

[GitHub] [flink] michaelli916 commented on a change in pull request #13459: [FLINK-18199] [chinese-translation]: translate FileSystem SQL Connector page into Chinese

michaelli916 commented on a change in pull request #13459: URL: https://github.com/apache/flink/pull/13459#discussion_r619944619 ## File path: docs/content.zh/docs/connectors/table/filesystem.md ## @@ -397,17 +389,21 @@ The parallelism of writing files into external file

[GitHub] [flink] michaelli916 commented on a change in pull request #13459: [FLINK-18199] [chinese-translation]: translate FileSystem SQL Connector page into Chinese

michaelli916 commented on a change in pull request #13459: URL: https://github.com/apache/flink/pull/13459#discussion_r619944384 ## File path: docs/content.zh/docs/connectors/table/filesystem.md ## @@ -279,24 +264,27 @@ Time extractors define extracting time from partition

[GitHub] [flink] JingsongLi commented on pull request #15746: [FLINK-17783][Table SQL/Ecosystem]Add array,map,row types support for orc row writer

JingsongLi commented on pull request #15746: URL: https://github.com/apache/flink/pull/15746#issuecomment-826470370 @lirui-apache Can u take a look too? -- 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

[GitHub] [flink] flinkbot commented on pull request #15758: [FLINK-21247][table] Fix problem in MapDataSerializer#copy when there exists custom MapData

flinkbot commented on pull request #15758: URL: https://github.com/apache/flink/pull/15758#issuecomment-826470354 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] cshuo commented on pull request #15758: [FLINK-21247][table] Fix problem in MapDataSerializer#copy when there exists custom MapData

cshuo commented on pull request #15758: URL: https://github.com/apache/flink/pull/15758#issuecomment-826470296 cc @JingsongLi -- 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] JingsongLi commented on a change in pull request #15746: [FLINK-17783][Table SQL/Ecosystem]Add array,map,row types support for orc row writer

JingsongLi commented on a change in pull request #15746: URL: https://github.com/apache/flink/pull/15746#discussion_r619943822 ## File path: flink-formats/flink-orc/src/main/java/org/apache/flink/orc/vector/RowDataVectorizer.java ## @@ -151,8 +160,114 @@ private static void

[GitHub] [flink] flinkbot edited a comment on pull request #13459: [FLINK-18199] [chinese-translation]: translate FileSystem SQL Connector page into Chinese

flinkbot edited a comment on pull request #13459: URL: https://github.com/apache/flink/pull/13459#issuecomment-697158140 ## CI report: * 6a8554ed2ec89143d83706e6d8a47f06e54a107b Azure:

[GitHub] [flink] cshuo opened a new pull request #15758: [FLINK-21247][table] Fix problem in MapDataSerializer#copy when there exists custom MapData

cshuo opened a new pull request #15758: URL: https://github.com/apache/flink/pull/15758 ## What is the purpose of the change This is a cherry-pick for [FLINK-21247](https://github.com/apache/flink/pull/15569). -- This is an automated message from the Apache Git Service. To

[jira] [Created] (FLINK-22458) Failed when operating empty catalog table

Spongebob created FLINK-22458: - Summary: Failed when operating empty catalog table Key: FLINK-22458 URL: https://issues.apache.org/jira/browse/FLINK-22458 Project: Flink Issue Type: Bug

  1   2   3   4   >