[jira] [Closed] (FLINK-6958) Async I/O timeout not work

[ https://issues.apache.org/jira/browse/FLINK-6958?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-6958. Resolution: Abandoned Closing this ticket as abandoned. > Async I/O timeout not work > ---

[jira] [Created] (FLINK-22368) UnalignedCheckpointITCase hangs on azure

Dawid Wysakowicz created FLINK-22368: Summary: UnalignedCheckpointITCase hangs on azure Key: FLINK-22368 URL: https://issues.apache.org/jira/browse/FLINK-22368 Project: Flink Issue Type:

[jira] [Commented] (FLINK-22345) CoordinatorEventsExactlyOnceITCase hangs on azure

[ https://issues.apache.org/jira/browse/FLINK-22345?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17325532#comment-17325532 ] Dawid Wysakowicz commented on FLINK-22345: -- https://dev.azure.com/apache-flink/

[GitHub] [flink] lirui-apache commented on pull request #14484: [FLINK-20722][hive] HiveTableSink should copy the record when convert…

lirui-apache commented on pull request #14484: URL: https://github.com/apache/flink/pull/14484#issuecomment-823021103 @godfreyhe Thanks for your comments. PR updated accordingly. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHu

[GitHub] [flink] flinkbot edited a comment on pull request #15668: [FLINK-21174][coordination] Optimize the performance of DefaultResourceAllocationStrategy

flinkbot edited a comment on pull request #15668: URL: https://github.com/apache/flink/pull/15668#issuecomment-822310910 ## CI report: * d2518709273629655be88001f8a2d2af71130b95 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Updated] (FLINK-22360) Docker e2e tests do not work on 1.x branch if it has not been released

[ https://issues.apache.org/jira/browse/FLINK-22360?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-22360: - Priority: Critical (was: Blocker) > Docker e2e tests do not work on 1.x branch if it ha

[GitHub] [flink] flinkbot edited a comment on pull request #15667: Reduce the delete file api when the checkpoint is completed. [FLINK-…

flinkbot edited a comment on pull request #15667: URL: https://github.com/apache/flink/pull/15667#issuecomment-822292375 ## CI report: * 6d20ec3b129d82e1ea1f8b3c08d5a8baaba7414c Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #15660: [FLINK-22341][hive] Fix describe table for hive dialect

flinkbot edited a comment on pull request #15660: URL: https://github.com/apache/flink/pull/15660#issuecomment-822207649 ## CI report: * 17257e0ec57d6819af0c945b88f4831fd3306da2 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #15658: [FLINK-18206][table-api / sql-client] Fix the incorrect timestamp display

flinkbot edited a comment on pull request #15658: URL: https://github.com/apache/flink/pull/15658#issuecomment-822156568 ## CI report: * 1a8bf8e0a3f13a0ab00b93ccdf4ee9ff94c61063 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

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

flinkbot edited a comment on pull request #15561: URL: https://github.com/apache/flink/pull/15561#issuecomment-817508957 ## CI report: * 85afc0e14a28cdf84f44a2013306e3257421 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Created] (FLINK-22367) JobMasterStopWithSavepointITCase.terminateWithSavepointWithoutComplicationsShouldSucceedAndLeadJobToFinished times out

Dawid Wysakowicz created FLINK-22367: Summary: JobMasterStopWithSavepointITCase.terminateWithSavepointWithoutComplicationsShouldSucceedAndLeadJobToFinished times out Key: FLINK-22367 URL: https://issues.apach

[GitHub] [flink] rmetzger commented on pull request #15577: [FLINK-22001] Forward exceptions thrown during initialization to the user

rmetzger commented on pull request #15577: URL: https://github.com/apache/flink/pull/15577#issuecomment-823014078 Thanks a lot for your review! Your comments are very helpful! I thought about representing the states in the Runner more nicely as well, as there are quite a few fields t

[jira] [Created] (FLINK-22366) HiveSinkCompactionITCase fails on azure

Dawid Wysakowicz created FLINK-22366: Summary: HiveSinkCompactionITCase fails on azure Key: FLINK-22366 URL: https://issues.apache.org/jira/browse/FLINK-22366 Project: Flink Issue Type: B

[jira] [Commented] (FLINK-22366) HiveSinkCompactionITCase fails on azure

[ https://issues.apache.org/jira/browse/FLINK-22366?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17325512#comment-17325512 ] Dawid Wysakowicz commented on FLINK-22366: -- cc [~lzljs3620320] [~Leonard Xu] >

[GitHub] [flink] flinkbot edited a comment on pull request #15660: [FLINK-22341][hive] Fix describe table for hive dialect

flinkbot edited a comment on pull request #15660: URL: https://github.com/apache/flink/pull/15660#issuecomment-822207649 ## CI report: * 17257e0ec57d6819af0c945b88f4831fd3306da2 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Commented] (FLINK-22275) Datagen add a max lag option for a series of timestamp-related types

[ https://issues.apache.org/jira/browse/FLINK-22275?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17325511#comment-17325511 ] Yi Tang commented on FLINK-22275: - [~jark] Any thoughts more? > Datagen add a max lag o

[jira] [Closed] (FLINK-22156) HiveDialectQueryITCase fails on Azure because of no output for 900 seconds

[ https://issues.apache.org/jira/browse/FLINK-22156?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Li closed FLINK-22156. -- Resolution: Cannot Reproduce Close this one as the related tickets are resolved. Please reopen if this issue

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

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

[jira] [Commented] (FLINK-22203) KafkaChangelogTableITCase.testKafkaCanalChangelogSource fail due to ConcurrentModificationException

[ https://issues.apache.org/jira/browse/FLINK-22203?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17325508#comment-17325508 ] Dawid Wysakowicz commented on FLINK-22203: -- cc [~jark] > KafkaChangelogTableI

[GitHub] [flink] leonardBang commented on a change in pull request #15658: [FLINK-18206][table-api / sql-client] Fix the incorrect timestamp display

leonardBang commented on a change in pull request #15658: URL: https://github.com/apache/flink/pull/15658#discussion_r616374968 ## File path: flink-table/flink-table-common/src/main/java/org/apache/flink/table/utils/PrintUtils.java ## @@ -174,27 +215,238 @@ public static void

[jira] [Resolved] (FLINK-22359) Python tests do not pass on 1.x branch if it has not been released

[ https://issues.apache.org/jira/browse/FLINK-22359?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Huang Xingbo resolved FLINK-22359. -- Resolution: Fixed Merged into release-1.13 via adeb0dbe30618b1d9e3856fcb6071fe88ba15811 > Pyt

[jira] [Commented] (FLINK-22361) flink run -c not upload udf jar

[ https://issues.apache.org/jira/browse/FLINK-22361?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17325502#comment-17325502 ] Yang Wang commented on FLINK-22361: --- It is called {{yarn.ship-directories}} before rel

[GitHub] [flink] HuangXingBo closed pull request #15680: [FLINK-22359][python] Set the version to 1.13.dev0 for PyFlink

HuangXingBo closed pull request #15680: URL: https://github.com/apache/flink/pull/15680 -- 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, pl

[jira] [Closed] (FLINK-22297) Perform early check to ensure that the length of the result is the same as the input for Pandas UDF

[ https://issues.apache.org/jira/browse/FLINK-22297?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-22297. --- Fix Version/s: 1.12.3 1.13.0 Resolution: Fixed Merged to - master via 24031e55e4cf

[GitHub] [flink] dianfu commented on pull request #15682: [FLINK-22297][python] Perform early validation for the result of Pand…

dianfu commented on pull request #15682: URL: https://github.com/apache/flink/pull/15682#issuecomment-823002811 Closed via 599b7ee7a3505fcc875aafb75a2b061684881b74 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the U

[GitHub] [flink] dianfu closed pull request #15682: [FLINK-22297][python] Perform early validation for the result of Pand…

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

[GitHub] [flink] dianfu closed pull request #15681: [FLINK-22297][python] Perform early validation for the result of Pandas UDF

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

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

zuston commented on pull request #15653: URL: https://github.com/apache/flink/pull/15653#issuecomment-822990758 Gentle ping~ @wuchong @wangyang0918 @lirui-apache -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the UR

[jira] [Updated] (FLINK-22327) NPE exception happens if it throws exception in finishBundle during job shutdown

[ https://issues.apache.org/jira/browse/FLINK-22327?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-22327: Fix Version/s: (was: 1.13.1) (was: 1.14.0) 1.13.0 > NPE exce

[jira] [Updated] (FLINK-22339) Fix some encoding exceptions were not thrown in cython coders

[ https://issues.apache.org/jira/browse/FLINK-22339?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-22339: Fix Version/s: (was: 1.13.1) (was: 1.14.0) 1.13.0 > Fix some

[GitHub] [flink] zuston commented on pull request #15624: [FLINK-22294][hive] Hive reading fail when getting file numbers on different filesystem nameservices

zuston commented on pull request #15624: URL: https://github.com/apache/flink/pull/15624#issuecomment-822989558 Will merge? @lirui-apache -- 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 spe

[GitHub] [flink] curcur commented on pull request #15636: [FLINK-22239][jdbc] Support exactly-once (sink) for PgSql and MySql

curcur commented on pull request #15636: URL: https://github.com/apache/flink/pull/15636#issuecomment-822987125 I've done with the tests as well. -- 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] [Resolved] (FLINK-22160) Test Window TVF based aggregation and TopN

[ https://issues.apache.org/jira/browse/FLINK-22160?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu resolved FLINK-22160. Resolution: Resolved > Test Window TVF based aggregation and TopN > --

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

[ https://issues.apache.org/jira/browse/FLINK-22160?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17325479#comment-17325479 ] Leonard Xu commented on FLINK-22160: * Tested TUMBLE/HOP/CUMULATE TVF in Sql-Client,

[GitHub] [flink] SteNicholas commented on pull request #15020: [FLINK-21445][kubernetes] Application mode does not set the configuration when building PackagedProgram

SteNicholas commented on pull request #15020: URL: https://github.com/apache/flink/pull/15020#issuecomment-822984976 @XComp @wangyang0918 I have followed the detailed review comments. Please help to review the update of the pull request. -- This is an automated message from the Apache G

[GitHub] [flink] SteNicholas removed a comment on pull request #15020: [FLINK-21445][kubernetes] Application mode does not set the configuration when building PackagedProgram

SteNicholas removed a comment on pull request #15020: URL: https://github.com/apache/flink/pull/15020#issuecomment-819508156 @XComp @wangyang0918 I have followed the detailed review comments. Please help to review the update of the pull request. -- This is an automated message from the A

[GitHub] [flink] flinkbot edited a comment on pull request #15595: [FLINK-22171][sql-client][docs] Update the SQL Client doc

flinkbot edited a comment on pull request #15595: URL: https://github.com/apache/flink/pull/15595#issuecomment-818681408 ## CI report: * b7a82f07683d5a76f6743d68cb4cd174c0453bca UNKNOWN * 0b78a5c66116de0181cc645da264115b4b1ee79c Azure: [FAILURE](https://dev.azure.com/apache-fl

[GitHub] [flink] leonardBang commented on a change in pull request #15642: [FLINK-22159][FLINK-22302][docs][table] Restructure SQL "Queries" pages and add docs for the new window TVF based operations

leonardBang commented on a change in pull request #15642: URL: https://github.com/apache/flink/pull/15642#discussion_r616316388 ## File path: docs/content.zh/docs/dev/table/sql/queries/window-tvf.md ## @@ -0,0 +1,264 @@ +--- +title: "窗口函数" +weight: 6 +type: docs +--- + + +# Win

[GitHub] [flink] flinkbot edited a comment on pull request #15670: [FLINK-22346][sql-client] Remove sql-client-defaults.yaml

flinkbot edited a comment on pull request #15670: URL: https://github.com/apache/flink/pull/15670#issuecomment-822351871 ## CI report: * 76e54259c49220ecb75209c378d289bfbca6533a Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #15595: [FLINK-22171][sql-client][docs] Update the SQL Client doc

flinkbot edited a comment on pull request #15595: URL: https://github.com/apache/flink/pull/15595#issuecomment-818681408 ## CI report: * b7a82f07683d5a76f6743d68cb4cd174c0453bca UNKNOWN * 0b78a5c66116de0181cc645da264115b4b1ee79c Azure: [FAILURE](https://dev.azure.com/apache-fl

[GitHub] [flink] dianfu commented on pull request #15681: [FLINK-22297][python] Perform early validation for the result of Pandas UDF

dianfu commented on pull request #15681: URL: https://github.com/apache/flink/pull/15681#issuecomment-822975464 @YikSanChan :) -- 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 comme

[jira] [Commented] (FLINK-22365) Images are not displayed in "Data Sources" documentation page

[ https://issues.apache.org/jira/browse/FLINK-22365?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17325471#comment-17325471 ] Jark Wu commented on FLINK-22365: - cc [~sjwiesman] > Images are not displayed in "Data

[jira] [Created] (FLINK-22365) Images are not displayed in "Data Sources" documentation page

Jark Wu created FLINK-22365: --- Summary: Images are not displayed in "Data Sources" documentation page Key: FLINK-22365 URL: https://issues.apache.org/jira/browse/FLINK-22365 Project: Flink Issue Ty

[jira] [Assigned] (FLINK-22364) Translate the page of "Data Sources" to Chinese.

[ https://issues.apache.org/jira/browse/FLINK-22364?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-22364: --- Assignee: Senhong Liu > Translate the page of "Data Sources" to Chinese. >

[GitHub] [flink] wuchong commented on a change in pull request #15658: [FLINK-18206][table-api / sql-client] Fix the incorrect timestamp display

wuchong commented on a change in pull request #15658: URL: https://github.com/apache/flink/pull/15658#discussion_r616333796 ## File path: flink-table/flink-table-common/src/main/java/org/apache/flink/table/utils/PrintUtils.java ## @@ -174,27 +209,264 @@ public static void prin

[GitHub] [flink] flinkbot edited a comment on pull request #15670: [FLINK-22346][sql-client] Remove sql-client-defaults.yaml

flinkbot edited a comment on pull request #15670: URL: https://github.com/apache/flink/pull/15670#issuecomment-822351871 ## CI report: * 76e54259c49220ecb75209c378d289bfbca6533a Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #15682: [FLINK-22297][python] Perform early validation for the result of Pand…

flinkbot edited a comment on pull request #15682: URL: https://github.com/apache/flink/pull/15682#issuecomment-822960773 ## CI report: * 4efbadb337e2779683970225793633a3edb7a4b5 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #15683: [FLINK-22362]Don't appear target address when taskmanager connect to jobmanager error

flinkbot edited a comment on pull request #15683: URL: https://github.com/apache/flink/pull/15683#issuecomment-822960823 ## CI report: * c31947044463827b662c8239d630b52fdad3eca1 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #15595: [FLINK-22171][sql-client][docs] Update the SQL Client doc

flinkbot edited a comment on pull request #15595: URL: https://github.com/apache/flink/pull/15595#issuecomment-818681408 ## CI report: * b7a82f07683d5a76f6743d68cb4cd174c0453bca UNKNOWN * 0b78a5c66116de0181cc645da264115b4b1ee79c Azure: [FAILURE](https://dev.azure.com/apache-fl

[GitHub] [flink] flinkbot edited a comment on pull request #14894: [FLINK-20895][flink-table-planner-blink] support local aggregate push down in blink planner

flinkbot edited a comment on pull request #14894: URL: https://github.com/apache/flink/pull/14894#issuecomment-774905432 ## CI report: * 8b5155d221e948da1d3919162cea2f8cfcb92d19 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Commented] (FLINK-22364) Translate the page of "Data Sources" to Chinese.

[ https://issues.apache.org/jira/browse/FLINK-22364?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17325464#comment-17325464 ] Senhong Liu commented on FLINK-22364: - [~jark] Could you please assign this ticket t

[GitHub] [flink] godfreyhe commented on a change in pull request #14484: [FLINK-20722][hive] HiveTableSink should copy the record when convert…

godfreyhe commented on a change in pull request #14484: URL: https://github.com/apache/flink/pull/14484#discussion_r616333752 ## File path: flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/multipleinput/MultipleInputStreamOperatorBase.java #

[jira] [Commented] (FLINK-22361) flink run -c not upload udf jar

[ https://issues.apache.org/jira/browse/FLINK-22361?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17325462#comment-17325462 ] todd commented on FLINK-22361: -- yarn.ship-files is a parameter of version 1.12. In addition

[jira] [Created] (FLINK-22364) Translate the page of "Data Sources" to Chinese.

Senhong Liu created FLINK-22364: --- Summary: Translate the page of "Data Sources" to Chinese. Key: FLINK-22364 URL: https://issues.apache.org/jira/browse/FLINK-22364 Project: Flink Issue Type: Im

[GitHub] [flink] flinkbot commented on pull request #15683: [FLINK-22362]Don't appear target address when taskmanager connect to jobmanager error

flinkbot commented on pull request #15683: URL: https://github.com/apache/flink/pull/15683#issuecomment-822960823 ## CI report: * c31947044463827b662c8239d630b52fdad3eca1 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[GitHub] [flink] flinkbot commented on pull request #15682: [FLINK-22297][python] Perform early validation for the result of Pand…

flinkbot commented on pull request #15682: URL: https://github.com/apache/flink/pull/15682#issuecomment-822960773 ## CI report: * 4efbadb337e2779683970225793633a3edb7a4b5 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[GitHub] [flink] flinkbot edited a comment on pull request #15680: [FLINK-22359][python] Reset version to 1.13-SNAPSHOT

flinkbot edited a comment on pull request #15680: URL: https://github.com/apache/flink/pull/15680#issuecomment-822928365 ## CI report: * 71c256a205b987a867e86e47505968db9fccc81f Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #15681: [FLINK-22297][python] Perform early validation for the result of Pandas UDF

flinkbot edited a comment on pull request #15681: URL: https://github.com/apache/flink/pull/15681#issuecomment-822948644 ## CI report: * cb7fcc6d2c4a66793756112e9d2c83eb83d222e2 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #15657: [FLINK-22335][runtime][config] Increase default resource wait timeout for the adaptive scheduler.

flinkbot edited a comment on pull request #15657: URL: https://github.com/apache/flink/pull/15657#issuecomment-822150567 ## CI report: * 16939921d94de5421c6cb8453c5a9158a40bee4a Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

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

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

[GitHub] [flink] flinkbot edited a comment on pull request #14894: [FLINK-20895][flink-table-planner-blink] support local aggregate push down in blink planner

flinkbot edited a comment on pull request #14894: URL: https://github.com/apache/flink/pull/14894#issuecomment-774905432 ## CI report: * 8b5155d221e948da1d3919162cea2f8cfcb92d19 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

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

flinkbot edited a comment on pull request #14880: URL: https://github.com/apache/flink/pull/14880#issuecomment-774029330 ## CI report: * 4b1a437943dbf05b91590eed252f8ba83f14cdb9 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Closed] (FLINK-22363) Python test pipeline failed because of failure of downloading deps.

[ https://issues.apache.org/jira/browse/FLINK-22363?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guowei Ma closed FLINK-22363. - Fix Version/s: 1.13.0 Resolution: Duplicate > Python test pipeline failed because of failure of d

[jira] [Commented] (FLINK-22363) Python test pipeline failed because of failure of downloading deps.

[ https://issues.apache.org/jira/browse/FLINK-22363?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17325457#comment-17325457 ] Guowei Ma commented on FLINK-22363: --- https://dev.azure.com/apache-flink/apache-flink/_

[jira] [Created] (FLINK-22363) Python test pipeline failed because of failure of downloading deps.

Guowei Ma created FLINK-22363: - Summary: Python test pipeline failed because of failure of downloading deps. Key: FLINK-22363 URL: https://issues.apache.org/jira/browse/FLINK-22363 Project: Flink

[GitHub] [flink] 1996fanrui commented on a change in pull request #15667: Reduce the delete file api when the checkpoint is completed. [FLINK-…

1996fanrui commented on a change in pull request #15667: URL: https://github.com/apache/flink/pull/15667#discussion_r616324659 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CompletedCheckpoint.java ## @@ -291,6 +306,33 @@ public boolean shouldBe

[jira] [Updated] (FLINK-20896) Support SupportsAggregatePushDown for JDBC TableSource

[ https://issues.apache.org/jira/browse/FLINK-20896?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sebastian Liu updated FLINK-20896: -- Labels: (was: stale-assigned) > Support SupportsAggregatePushDown for JDBC TableSource > ---

[jira] [Commented] (FLINK-20896) Support SupportsAggregatePushDown for JDBC TableSource

[ https://issues.apache.org/jira/browse/FLINK-20896?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17325455#comment-17325455 ] Sebastian Liu commented on FLINK-20896: --- Still working on this, pending in other s

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

[ https://issues.apache.org/jira/browse/FLINK-20895?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sebastian Liu updated FLINK-20895: -- Labels: pull-request-available (was: pull-request-available stale-assigned) > Support LocalAg

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

[ https://issues.apache.org/jira/browse/FLINK-20895?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17325453#comment-17325453 ] Sebastian Liu commented on FLINK-20895: --- Updated the PR, still working on this. >

[GitHub] [flink] sebastianliu commented on pull request #14894: [FLINK-20895][flink-table-planner-blink] support local aggregate push down in blink planner

sebastianliu commented on pull request #14894: URL: https://github.com/apache/flink/pull/14894#issuecomment-822950848 @godfreyhe @wuchong Hi, sorry that the push of this feature is delayed for some reasons. I will follow up this ASAP. I have introduced an `AggregatePushDownSpec `. Hope you

[jira] [Commented] (FLINK-22361) flink run -c not upload udf jar

[ https://issues.apache.org/jira/browse/FLINK-22361?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17325452#comment-17325452 ] Yang Wang commented on FLINK-22361: --- If you want to ship jars/files, then you should u

[jira] [Updated] (FLINK-22361) flink run -c not upload udf jar

[ https://issues.apache.org/jira/browse/FLINK-22361?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yang Wang updated FLINK-22361: -- Priority: Minor (was: Blocker) > flink run -c not upload udf jar > --- >

[jira] [Updated] (FLINK-22362) Don't appear target address when taskmanager connect to jobmanager error

[ https://issues.apache.org/jira/browse/FLINK-22362?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-22362: --- Labels: pull-request-available (was: ) > Don't appear target address when taskmanager conne

[GitHub] [flink] YikSanChan commented on pull request #15681: [FLINK-22297][python] Perform early validation for the result of Pandas UDF

YikSanChan commented on pull request #15681: URL: https://github.com/apache/flink/pull/15681#issuecomment-822948988 @dianfu This is great! -- 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 spe

[GitHub] [flink] flinkbot commented on pull request #15683: [FLINK-22362]Don't appear target address when taskmanager connect to jobmanager error

flinkbot commented on pull request #15683: URL: https://github.com/apache/flink/pull/15683#issuecomment-822948893 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

[GitHub] [flink] flinkbot commented on pull request #15681: [FLINK-22297][python] Perform early validation for the result of Pandas UDF

flinkbot commented on pull request #15681: URL: https://github.com/apache/flink/pull/15681#issuecomment-822948644 ## CI report: * cb7fcc6d2c4a66793756112e9d2c83eb83d222e2 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[GitHub] [flink] flinkbot edited a comment on pull request #15680: [FLINK-22359][python] Reset version to 1.13-SNAPSHOT

flinkbot edited a comment on pull request #15680: URL: https://github.com/apache/flink/pull/15680#issuecomment-822928365 ## CI report: * 71c256a205b987a867e86e47505968db9fccc81f Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #15657: [FLINK-22335][runtime][config] Increase default resource wait timeout for the adaptive scheduler.

flinkbot edited a comment on pull request #15657: URL: https://github.com/apache/flink/pull/15657#issuecomment-822150567 ## CI report: * 16939921d94de5421c6cb8453c5a9158a40bee4a Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #15636: [FLINK-22239][jdbc] Support exactly-once (sink) for PgSql and MySql

flinkbot edited a comment on pull request #15636: URL: https://github.com/apache/flink/pull/15636#issuecomment-820725807 ## CI report: * f9e372fc6d647b67af6c8ce1c4962c46e9bcf785 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

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

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

[GitHub] [flink] gentlewangyu opened a new pull request #15683: Don't appear target address when taskmanager connect to jobmanager error

gentlewangyu opened a new pull request #15683: URL: https://github.com/apache/flink/pull/15683 ## What is the purpose of the change *(For example: This pull request makes task deployment go through the blob server, rather than through RPC. That way we avoid re-transferring th

[GitHub] [flink] flinkbot commented on pull request #15682: [FLINK-22297][python] Perform early validation for the result of Pand…

flinkbot commented on pull request #15682: URL: https://github.com/apache/flink/pull/15682#issuecomment-822947649 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

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

flinkbot edited a comment on pull request #14880: URL: https://github.com/apache/flink/pull/14880#issuecomment-774029330 ## CI report: * 4b1a437943dbf05b91590eed252f8ba83f14cdb9 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] dianfu opened a new pull request #15682: [FLINK-22297][python] Perform early validation for the result of Pand…

dianfu opened a new pull request #15682: URL: https://github.com/apache/flink/pull/15682 ## What is the purpose of the change *This pull request performs early validation for the result of Pandas UDF, e.g. ensure the result length is equal to the input length, validates the result t

[GitHub] [flink] flinkbot commented on pull request #15681: [FLINK-22297][python] Perform early validation for the result of Pandas UDF

flinkbot commented on pull request #15681: URL: https://github.com/apache/flink/pull/15681#issuecomment-822945162 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] [Updated] (FLINK-22297) Perform early check to ensure that the length of the result is the same as the input for Pandas UDF

[ https://issues.apache.org/jira/browse/FLINK-22297?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-22297: --- Labels: pull-request-available (was: ) > Perform early check to ensure that the length of t

[GitHub] [flink] dianfu opened a new pull request #15681: [FLINK-22297][python] Perform early validation for the result of Pandas UDF

dianfu opened a new pull request #15681: URL: https://github.com/apache/flink/pull/15681 ## What is the purpose of the change *This pull request performs early validation for the result of Pandas UDF, e.g. ensure the result length is equal to the input length, validates the resu

[GitHub] [flink] flinkbot edited a comment on pull request #15680: [FLINK-22359][python] Reset version to 1.13-SNAPSHOT

flinkbot edited a comment on pull request #15680: URL: https://github.com/apache/flink/pull/15680#issuecomment-822928365 ## CI report: * 71c256a205b987a867e86e47505968db9fccc81f Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #15658: [FLINK-18206][table-api / sql-client] Fix the incorrect timestamp display

flinkbot edited a comment on pull request #15658: URL: https://github.com/apache/flink/pull/15658#issuecomment-822156568 ## CI report: * 3fb642a0baf02d20af8ed2fcccae8493205f1e66 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Created] (FLINK-22362) Don't appear target address when taskmanager connect to jobmanager error

Yu Wang created FLINK-22362: --- Summary: Don't appear target address when taskmanager connect to jobmanager error Key: FLINK-22362 URL: https://issues.apache.org/jira/browse/FLINK-22362 Project: Flink

[jira] [Closed] (FLINK-22338) Clear watermark output when test finished for FromElementSourceFunctionWithWatermark

[ https://issues.apache.org/jira/browse/FLINK-22338?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-22338. Resolution: Fixed release-1.13: 5d4b451c6146a8a0470f4c17c76caa0411dbeffd > Clear watermark output

[jira] [Assigned] (FLINK-22338) Clear watermark output when test finished for FromElementSourceFunctionWithWatermark

[ https://issues.apache.org/jira/browse/FLINK-22338?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reassigned FLINK-22338: Assignee: Shengkai Fang > Clear watermark output when test finished for > FromElementSou

[GitHub] [flink] JingsongLi merged pull request #15672: [FLINK-22338][table-planner] Clear watermark output when test finished for FromElementSourceFunctionWithWatermark

JingsongLi merged pull request #15672: URL: https://github.com/apache/flink/pull/15672 -- 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, ple

[jira] [Commented] (FLINK-22021) PushFilterIntoLegacyTableSourceScanRule fails to deal with INTERVAL types

[ https://issues.apache.org/jira/browse/FLINK-22021?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17325436#comment-17325436 ] Jingsong Lee commented on FLINK-22021: -- release-1.12: 8c146a5610a6438326789cf573901

[GitHub] [flink] JingsongLi merged pull request #15615: [FLINK-22021][table-planner-blink] Fix exception when PushFilterIntoLegacyTableSourceScanRule is faced with INTERVAL types

JingsongLi merged pull request #15615: URL: https://github.com/apache/flink/pull/15615 -- 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, ple

[GitHub] [flink] fsk119 commented on pull request #15672: [FLINK-22338][table-planner] Clear watermark output when test finished for FromElementSourceFunctionWithWatermark

fsk119 commented on pull request #15672: URL: https://github.com/apache/flink/pull/15672#issuecomment-822937383 The failed test is not related to the PR. -- 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 t

[jira] [Updated] (FLINK-22092) HiveConf can cache hiveSiteURL from classpath and cause FileNotFoundException

[ https://issues.apache.org/jira/browse/FLINK-22092?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Li updated FLINK-22092: --- Summary: HiveConf can cache hiveSiteURL from classpath and cause FileNotFoundException (was: Prevent HiveCa

[GitHub] [flink] JingsongLi merged pull request #15483: [FLINK-22092][hive] Ignore static conf file URLs in HiveConf

JingsongLi merged pull request #15483: URL: https://github.com/apache/flink/pull/15483 -- 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, ple

[jira] [Commented] (FLINK-21073) Mention that RocksDB ignores equals/hashCode because it works on binary data

[ https://issues.apache.org/jira/browse/FLINK-21073?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17325429#comment-17325429 ] Yun Tang commented on FLINK-21073: -- Merged in master: 653811c70895f13f04b8c86fbd9b80d0c

  1   2   3   4   5   6   >