[GitHub] [flink] flinkbot commented on pull request #15514: [hot fix]remove the semicolon

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

[GitHub] [flink] flinkbot edited a comment on pull request #15510: [BP-1.12][FLINK-21980][zk] ZooKeeperRunningJobsRegistry creates an empty znode

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

[GitHub] [flink] flinkbot edited a comment on pull request #15512: [FLINK-22142][ci] Don't log Kafka connector output to the AZP console

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

[GitHub] [flink] flinkbot edited a comment on pull request #15513: [FLINK-22143][table runtime] fix less lines than requested returned by LimitableBulk…

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

[GitHub] [flink] flinkbot edited a comment on pull request #15511: [BP-1.11][FLINK-21980][zk] ZooKeeperRunningJobsRegistry creates an empty znode

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

[GitHub] [flink] flinkbot edited a comment on pull request #15504: [FLINK-21873][connector/common] Harden CoordinatedSourceRescaleITCase by checking exceptions more leniently.

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

[GitHub] [flink] flinkbot edited a comment on pull request #15503: [FLINK-21873][connector/common] Harden CoordinatedSourceRescaleITCase by checking exceptions more leniently.

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

[GitHub] [flink] flinkbot edited a comment on pull request #15489: [FLINK-22106][table-planner-blink] Result type of GeneratedExpression in StringCallGen should be compatible with their definition in

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

[GitHub] [flink] flinkbot edited a comment on pull request #15393: [FLINK-21980][Runtime/Coordination] ZooKeeperRunningJobsRegistry creates an empty znode

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

[GitHub] [flink] flinkbot commented on pull request #15515: [FLINK-22102][hive] Throw meaningful exceptions for unsupported DDLs

flinkbot commented on pull request #15515: URL: https://github.com/apache/flink/pull/15515#issuecomment-814908991 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-22102) Throw meaningful exceptions for features we don't support

[ https://issues.apache.org/jira/browse/FLINK-22102?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-22102: --- Labels: pull-request-available (was: ) > Throw meaningful exceptions for features we don't

[GitHub] [flink] lirui-apache opened a new pull request #15515: [FLINK-22102][hive] Throw meaningful exceptions for unsupported DDLs

lirui-apache opened a new pull request #15515: URL: https://github.com/apache/flink/pull/15515 ## What is the purpose of the change Currently hive dialect can silently ignore unsupported DDL features like hive's storage handler table. This PR is to make sure we throw a meanin

[GitHub] [flink] AHeise commented on pull request #15505: [FLINK-22105] Don't finish output channel state write in testForceAlignedCheckpointResultingInPriorityEvents

AHeise commented on pull request #15505: URL: https://github.com/apache/flink/pull/15505#issuecomment-814895446 Btw I think you need to adjust PR title. -- 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

[GitHub] [flink] AHeise commented on a change in pull request #15505: [FLINK-22105] Don't finish output channel state write in testForceAlignedCheckpointResultingInPriorityEvents

AHeise commented on a change in pull request #15505: URL: https://github.com/apache/flink/pull/15505#discussion_r608626180 ## File path: flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/SubtaskCheckpointCoordinatorTest.java ## @@ -198,14 +198,6 @@ pu

[jira] [Commented] (FLINK-20663) Managed memory may not be released in time when operators use managed memory frequently

[ https://issues.apache.org/jira/browse/FLINK-20663?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17316311#comment-17316311 ] Xintong Song commented on FLINK-20663: -- [~zhou_yb], This indeed looks similar. Is

[jira] [Comment Edited] (FLINK-22113) UniqueKey constraint is lost with multiple sources join in SQL

[ https://issues.apache.org/jira/browse/FLINK-22113?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17316306#comment-17316306 ] Fu Kai edited comment on FLINK-22113 at 4/7/21, 12:50 PM: -- Hi J

[jira] [Comment Edited] (FLINK-22113) UniqueKey constraint is lost with multiple sources join in SQL

[ https://issues.apache.org/jira/browse/FLINK-22113?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17316306#comment-17316306 ] Fu Kai edited comment on FLINK-22113 at 4/7/21, 12:49 PM: -- Hi J

[jira] [Commented] (FLINK-22113) UniqueKey constraint is lost with multiple sources join in SQL

[ https://issues.apache.org/jira/browse/FLINK-22113?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17316306#comment-17316306 ] Fu Kai commented on FLINK-22113: Hi Jark,  Thank you for the valuable information. My f

[GitHub] [flink] tillrohrmann commented on a change in pull request #15396: [FLINK-21008][coordination] Register ClusterEntrypoint#closeAsync as shutdown hook for the cleanup

tillrohrmann commented on a change in pull request #15396: URL: https://github.com/apache/flink/pull/15396#discussion_r607786784 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/entrypoint/ClusterEntrypointTest.java ## @@ -22,50 +22,279 @@ import org.apache.

[GitHub] [flink] flinkbot commented on pull request #15514: [hot fix]remove the semicolon

flinkbot commented on pull request #15514: URL: https://github.com/apache/flink/pull/15514#issuecomment-814884579 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] Baibaiwuguo opened a new pull request #15514: [hot fix]remove the semicolon

Baibaiwuguo opened a new pull request #15514: URL: https://github.com/apache/flink/pull/15514 ## What is the purpose of the change code standards ## Brief change log - *remove the semicolon in enum ClientUtils* ## Documentation - Does th

[GitHub] [flink] flinkbot commented on pull request #15513: [FLINK-22143][table runtime] fix less lines than requested returned by LimitableBulk…

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

[GitHub] [flink] flinkbot commented on pull request #15512: [FLINK-22142][ci] Don't log Kafka connector output to the AZP console

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

[GitHub] [flink] flinkbot commented on pull request #15511: [BP-1.11][FLINK-21980][zk] ZooKeeperRunningJobsRegistry creates an empty znode

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

[GitHub] [flink] flinkbot commented on pull request #15510: [BP-1.12][FLINK-21980][zk] ZooKeeperRunningJobsRegistry creates an empty znode

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

[GitHub] [flink] flinkbot edited a comment on pull request #15495: [FLINK-21305][table-planner-blink] Fix Cumulative and Hopping window should accumulate late events belonging to the cleaned slice

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

[jira] [Commented] (FLINK-22062) Add "Data Sources" (FLIP-27 sources overview page) page from 1.12.x to master

[ https://issues.apache.org/jira/browse/FLINK-22062?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17316295#comment-17316295 ] Dawid Wysakowicz commented on FLINK-22062: -- Hey, [~sjwiesman] any progress on t

[GitHub] [flink] flinkbot edited a comment on pull request #15393: [FLINK-21980][Runtime/Coordination] ZooKeeperRunningJobsRegistry creates an empty znode

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

[jira] [Commented] (FLINK-21817) New Kafka Source might break subtask and split assignment upon rescale

[ https://issues.apache.org/jira/browse/FLINK-21817?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17316294#comment-17316294 ] Dawid Wysakowicz commented on FLINK-21817: -- Double checking... Is the task stil

[jira] [Updated] (FLINK-18934) Idle stream does not advance watermark in connected stream

[ https://issues.apache.org/jira/browse/FLINK-18934?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-18934: - Priority: Blocker (was: Critical) > Idle stream does not advance watermark in connected

[jira] [Updated] (FLINK-18934) Idle stream does not advance watermark in connected stream

[ https://issues.apache.org/jira/browse/FLINK-18934?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-18934: - Fix Version/s: (was: 1.11.4) (was: 1.13.0) > Idle stream does

[GitHub] [flink] wuchong commented on a change in pull request #15506: [FLINK-21240][jdbc] Fix JDBC row converter doesn't support external LocalDateTime type

wuchong commented on a change in pull request #15506: URL: https://github.com/apache/flink/pull/15506#discussion_r608612167 ## File path: flink-connectors/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/internal/AbstractJdbcRowConverterTest.java ## @@ -0,0 +

[jira] [Commented] (FLINK-22143) Flink returns less rows than expected when using limit in SQL

[ https://issues.apache.org/jira/browse/FLINK-22143?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17316290#comment-17316290 ] Jark Wu commented on FLINK-22143: - cc [~lzljs3620320] > Flink returns less rows than ex

[GitHub] [flink] leonardBang commented on a change in pull request #15485: [FLINK-20387][table] Support TIMESTAMP_LTZ as rowtime attribute

leonardBang commented on a change in pull request #15485: URL: https://github.com/apache/flink/pull/15485#discussion_r608606945 ## File path: flink-table/flink-table-runtime-blink/src/test/java/org/apache/flink/table/runtime/util/TimeWindowUtilTest.java ## @@ -0,0 +1,74 @@ +pa

[jira] [Updated] (FLINK-22143) Flink returns less rows than expected when using limit in SQL

[ https://issues.apache.org/jira/browse/FLINK-22143?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-22143: Component/s: Connectors / FileSystem > Flink returns less rows than expected when using limit in SQL > ---

[GitHub] [flink] flinkbot commented on pull request #15513: [FLINK-22143][table runtime] fix less lines than requested returned by LimitableBulk…

flinkbot commented on pull request #15513: URL: https://github.com/apache/flink/pull/15513#issuecomment-814873384 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-22143) Flink returns less rows than expected when using limit in SQL

[ https://issues.apache.org/jira/browse/FLINK-22143?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-22143: --- Labels: pull-request-available (was: ) > Flink returns less rows than expected when using l

[GitHub] [flink] iyupeng opened a new pull request #15513: [FLINK-22143] fix less lines than requested returned by LimitableBulk…

iyupeng opened a new pull request #15513: URL: https://github.com/apache/flink/pull/15513 …Format ## What is the purpose of the change * fix less lines than requested returned by LimitableBulkFormat under certain conditions ## Brief change log - check null

[jira] [Commented] (FLINK-22113) UniqueKey constraint is lost with multiple sources join in SQL

[ https://issues.apache.org/jira/browse/FLINK-22113?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17316283#comment-17316283 ] Jark Wu commented on FLINK-22113: - [~zhihao], it only affects performance. The count wil

[GitHub] [flink] flinkbot edited a comment on pull request #15502: [FLINK-22131][python] Fix the bug of general udf and pandas udf chained together in map operation

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

[GitHub] [flink] flinkbot edited a comment on pull request #15500: [FLINK-22077] Fix incorrect way to create cross-region ConsumedPartitionGroups in PipelinedRegionSchedulingStrategy

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

[GitHub] [flink] flinkbot edited a comment on pull request #15496: [FLINK-21990][streaming] Cancel task before clean up if execution was…

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

[GitHub] [flink] flinkbot commented on pull request #15511: [BP-1.11][FLINK-21980][zk] ZooKeeperRunningJobsRegistry creates an empty znode

flinkbot commented on pull request #15511: URL: https://github.com/apache/flink/pull/15511#issuecomment-814868578 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 #15512: [FLINK-22142][ci] Don't log Kafka connector output to the AZP console

flinkbot commented on pull request #15512: URL: https://github.com/apache/flink/pull/15512#issuecomment-814868549 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 #15510: [BP-1.12][FLINK-21980][zk] ZooKeeperRunningJobsRegistry creates an empty znode

flinkbot commented on pull request #15510: URL: https://github.com/apache/flink/pull/15510#issuecomment-814868601 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] [Created] (FLINK-22143) Flink returns less rows than expected when using limit in SQL

Peng Yu created FLINK-22143: --- Summary: Flink returns less rows than expected when using limit in SQL Key: FLINK-22143 URL: https://issues.apache.org/jira/browse/FLINK-22143 Project: Flink Issue Ty

[jira] [Assigned] (FLINK-22128) Window aggregation should have unique keys

[ https://issues.apache.org/jira/browse/FLINK-22128?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-22128: --- Assignee: Jark Wu > Window aggregation should have unique keys > --

[jira] [Updated] (FLINK-22142) Remove console logging for Kafka connector for AZP runs

[ https://issues.apache.org/jira/browse/FLINK-22142?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-22142: --- Labels: pull-request-available (was: ) > Remove console logging for Kafka connector for AZP

[GitHub] [flink] tillrohrmann opened a new pull request #15512: [FLINK-22142][ci] Don't log Kafka connector output to the AZP console

tillrohrmann opened a new pull request #15512: URL: https://github.com/apache/flink/pull/15512 This commit removes the console logging of the Kafka connector to the AZP console. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to G

[jira] [Created] (FLINK-22142) Remove console logging for Kafka connector for AZP runs

Till Rohrmann created FLINK-22142: - Summary: Remove console logging for Kafka connector for AZP runs Key: FLINK-22142 URL: https://issues.apache.org/jira/browse/FLINK-22142 Project: Flink Iss

[GitHub] [flink] wuchong commented on a change in pull request #15494: [FLINK-17957] [table-api][parser] Forbidden syntax "CREATE SYSTEM FUNCTION" for sql parser

wuchong commented on a change in pull request #15494: URL: https://github.com/apache/flink/pull/15494#discussion_r608587419 ## File path: flink-table/flink-sql-parser/src/main/java/org/apache/flink/sql/parser/utils/ParserResource.java ## @@ -33,4 +33,7 @@ @Resources.Bas

[GitHub] [flink] tillrohrmann opened a new pull request #15511: [BP-1.11][FLINK-21980][zk] ZooKeeperRunningJobsRegistry creates an empty znode

tillrohrmann opened a new pull request #15511: URL: https://github.com/apache/flink/pull/15511 Backport of #15393 to `release-1.11`. -- 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 #15489: [FLINK-22106][table-planner-blink] Result type of GeneratedExpression in StringCallGen should be compatible with their definit

JingsongLi commented on a change in pull request #15489: URL: https://github.com/apache/flink/pull/15489#discussion_r608586451 ## File path: flink-table/flink-table-planner-blink/src/test/scala/org/apache/flink/table/planner/expressions/ScalarFunctionsTest.scala ## @@ -4061,4

[GitHub] [flink] tillrohrmann opened a new pull request #15510: [BP-1.12][FLINK-21980][zk] ZooKeeperRunningJobsRegistry creates an empty znode

tillrohrmann opened a new pull request #15510: URL: https://github.com/apache/flink/pull/15510 Backport of #15393 to `release-1.12`. -- 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

[jira] [Commented] (FLINK-20663) Managed memory may not be released in time when operators use managed memory frequently

[ https://issues.apache.org/jira/browse/FLINK-20663?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17316264#comment-17316264 ] zhou commented on FLINK-20663: --  here is script (the data set amount is small ) :  /space

[GitHub] [flink] tillrohrmann commented on pull request #15393: [FLINK-21980][Runtime/Coordination] ZooKeeperRunningJobsRegistry creates an empty znode

tillrohrmann commented on pull request #15393: URL: https://github.com/apache/flink/pull/15393#issuecomment-814847507 The test failure seems to be unrelated. Merging this PR now. -- 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 #15505: [FLINK-22105] Don't finish output channel state write in testForceAlignedCheckpointResultingInPriorityEvents

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

[GitHub] [flink] flinkbot edited a comment on pull request #15502: [FLINK-22131][python] Fix the bug of general udf and pandas udf chained together in map operation

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

[GitHub] [flink] flinkbot edited a comment on pull request #15499: [FLINK-22127][network] Enrich error message of read buffer request timeout to tell the user how to solve the problem when using sort-

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

[jira] [Commented] (FLINK-20663) Managed memory may not be released in time when operators use managed memory frequently

[ https://issues.apache.org/jira/browse/FLINK-20663?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17316250#comment-17316250 ] Xintong Song commented on FLINK-20663: -- [~zhou_yb], Could you share some more info

[jira] [Created] (FLINK-22141) Manually test exactly-once JDBC sink

Roman Khachatryan created FLINK-22141: - Summary: Manually test exactly-once JDBC sink Key: FLINK-22141 URL: https://issues.apache.org/jira/browse/FLINK-22141 Project: Flink Issue Type: Te

[GitHub] [flink] flinkbot edited a comment on pull request #15508: [BP-1.12][FLINK-22006][k8s] Support to configure max concurrent requests for fabric8 Kubernetes client via JAVA opts or envs

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

[GitHub] [flink] flinkbot edited a comment on pull request #15509: [FLINK-18356][Azure] Enforce memory limit on custom CI servers

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

[GitHub] [flink] flinkbot edited a comment on pull request #15505: [FLINK-22105] Don't finish output channel state write in testForceAlignedCheckpointResultingInPriorityEvents

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

[jira] [Created] (FLINK-22140) Test the unified binary savepoint

Dawid Wysakowicz created FLINK-22140: Summary: Test the unified binary savepoint Key: FLINK-22140 URL: https://issues.apache.org/jira/browse/FLINK-22140 Project: Flink Issue Type: Task

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

[jira] [Commented] (FLINK-20663) Managed memory may not be released in time when operators use managed memory frequently

[ https://issues.apache.org/jira/browse/FLINK-20663?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17316227#comment-17316227 ] zhou commented on FLINK-20663: -- the problem is still exist on flink1.12.2,what should I do?

[GitHub] [flink] wangyang0918 edited a comment on pull request #15501: [FLINK-22054][k8s] Using a shared watcher for ConfigMap watching

wangyang0918 edited a comment on pull request #15501: URL: https://github.com/apache/flink/pull/15501#issuecomment-814822642 @tillrohrmann Yes, I will have a look at this PR first and then ping you for the final approve. -- This is an automated message from the Apache Git Service. To res

[GitHub] [flink] wangyang0918 edited a comment on pull request #15501: [FLINK-22054][k8s] Using a shared watcher for ConfigMap watching

wangyang0918 edited a comment on pull request #15501: URL: https://github.com/apache/flink/pull/15501#issuecomment-814822642 @tillrohrmann Yes, I will have a look at this PR first and ping you for the final approve. -- This is an automated message from the Apache Git Service. To respond

[GitHub] [flink] wangyang0918 commented on pull request #15501: [FLINK-22054][k8s] Using a shared watcher for ConfigMap watching

wangyang0918 commented on pull request #15501: URL: https://github.com/apache/flink/pull/15501#issuecomment-814822642 @tillrohrmann Yes, I will have a look at this PR first and ping you for the final check. -- This is an automated message from the Apache Git Service. To respond to the me

[jira] [Closed] (FLINK-22094) Update release scripts after documentation switch to Hugo

[ https://issues.apache.org/jira/browse/FLINK-22094?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz closed FLINK-22094. Resolution: Fixed Fixed in a43df52f8367c47de2f68f43dcbdd5e8699f47b4 > Update release scri

[GitHub] [flink] flinkbot commented on pull request #15508: [BP-1.12][FLINK-22006][k8s] Support to configure max concurrent requests for fabric8 Kubernetes client via JAVA opts or envs

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

[GitHub] [flink] flinkbot commented on pull request #15509: [FLINK-18356][Azure] Enforce memory limit on custom CI servers

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

[GitHub] [flink] dawidwys merged pull request #15473: [FLINK-22094] Update release scripts after documentation switch to Hugo

dawidwys merged pull request #15473: URL: https://github.com/apache/flink/pull/15473 -- 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, pleas

[GitHub] [flink] flinkbot edited a comment on pull request #15507: [FLINK-21386][datastream] Postpone FromElementsFunction serialization to respect later type customization

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

[GitHub] [flink] flinkbot edited a comment on pull request #15506: [FLINK-21240][jdbc] Fix JDBC row converter doesn't support external LocalDateTime type

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

[GitHub] [flink] flinkbot edited a comment on pull request #15504: [FLINK-21873][connector/common] Harden CoordinatedSourceRescaleITCase by checking exceptions more leniently.

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

[GitHub] [flink] flinkbot edited a comment on pull request #15505: [FLINK-22105] Don't finish output channel state write in testForceAlignedCheckpointResultingInPriorityEvents

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

[GitHub] [flink] flinkbot edited a comment on pull request #15480: [FLINK-22006][k8s] Support to configure max concurrent requests for fabric8 Kubernetes client via JAVA opts or envs

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

[jira] [Commented] (FLINK-21025) SQLClientHBaseITCase fails when untarring HBase

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

[GitHub] [flink] rkhachatryan commented on a change in pull request #15505: [FLINK-22105] Don't finish output channel state write in testForceAlignedCheckpointResultingInPriorityEvents

rkhachatryan commented on a change in pull request #15505: URL: https://github.com/apache/flink/pull/15505#discussion_r608547577 ## File path: flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/SubtaskCheckpointCoordinatorTest.java ## @@ -198,14 +198,6

[jira] [Commented] (FLINK-18634) FlinkKafkaProducerITCase.testRecoverCommittedTransaction failed with "Timeout expired after 60000milliseconds while awaiting InitProducerId"

[ https://issues.apache.org/jira/browse/FLINK-18634?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17316208#comment-17316208 ] Till Rohrmann commented on FLINK-18634: --- Another instance: https://dev.azure.com/

[GitHub] [flink] wuchong commented on a change in pull request #15485: [FLINK-20387][table] Support TIMESTAMP_LTZ as rowtime attribute

wuchong commented on a change in pull request #15485: URL: https://github.com/apache/flink/pull/15485#discussion_r608401319 ## File path: flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/utils/LogicalTypeChecks.java ## @@ -122,24 +126,13 @@ pub

[GitHub] [flink] flinkbot commented on pull request #15507: [FLINK-21386][datastream] Postpone FromElementsFunction serialization to respect later type customization

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

[GitHub] [flink] flinkbot commented on pull request #15506: [FLINK-21240][jdbc] Fix JDBC row converter doesn't support external LocalDateTime type

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

[GitHub] [flink] flinkbot commented on pull request #15509: [FLINK-18356][Azure] Enforce memory limit on custom CI servers

flinkbot commented on pull request #15509: URL: https://github.com/apache/flink/pull/15509#issuecomment-814806761 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 #15505: [FLINK-22105] Don't finish output channel state write in testForceAlignedCheckpointResultingInPriorityEvents

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

[GitHub] [flink] flinkbot commented on pull request #15504: [FLINK-21873][connector/common] Harden CoordinatedSourceRescaleITCase by checking exceptions more leniently.

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

[GitHub] [flink] flinkbot edited a comment on pull request #15503: [FLINK-21873][connector/common] Harden CoordinatedSourceRescaleITCase by checking exceptions more leniently.

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

[GitHub] [flink] flinkbot edited a comment on pull request #15480: [FLINK-22006][k8s] Support to configure max concurrent requests for fabric8 Kubernetes client via JAVA opts or envs

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

[jira] [Commented] (FLINK-18356) Exit code 137 returned from process when testing pyflink

[ https://issues.apache.org/jira/browse/FLINK-18356?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17316205#comment-17316205 ] Robert Metzger commented on FLINK-18356: Before reducing the concurrent builds (

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

[jira] [Updated] (FLINK-18356) Exit code 137 returned from process when testing pyflink

[ https://issues.apache.org/jira/browse/FLINK-18356?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-18356: --- Labels: pull-request-available test-stability (was: test-stability) > Exit code 137 returne

[GitHub] [flink] rmetzger opened a new pull request #15509: [FLINK-18356][Azure] Enforce memory limit on custom CI servers

rmetzger opened a new pull request #15509: URL: https://github.com/apache/flink/pull/15509 This PR is a test on our custom CI infrastructure to see if the tests are stable if we enforce a memory limit. -- This is an automated message from the Apache Git Service. To respond to the message

[GitHub] [flink] flinkbot commented on pull request #15508: [BP-1.12][FLINK-22006][k8s] Support to configure max concurrent requests for fabric8 Kubernetes client via JAVA opts or envs

flinkbot commented on pull request #15508: URL: https://github.com/apache/flink/pull/15508#issuecomment-814803602 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] tillrohrmann opened a new pull request #15508: [BP-1.12][FLINK-22006][k8s] Support to configure max concurrent requests for fabric8 Kubernetes client via JAVA opts or envs

tillrohrmann opened a new pull request #15508: URL: https://github.com/apache/flink/pull/15508 Backport of #15480 to `release-1.12`. -- 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

[jira] [Assigned] (FLINK-21386) FromElements ignores returns()

[ https://issues.apache.org/jira/browse/FLINK-21386?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz reassigned FLINK-21386: Assignee: Kezhu Wang > FromElements ignores returns() > -

[GitHub] [flink] flinkbot commented on pull request #15507: [FLINK-21386][datastream] Postpone FromElementsFunction serialization to respect later type customization

flinkbot commented on pull request #15507: URL: https://github.com/apache/flink/pull/15507#issuecomment-814797865 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the pro

[jira] [Commented] (FLINK-16947) ArtifactResolutionException: Could not transfer artifact. Entry [...] has not been leased from this pool

[ https://issues.apache.org/jira/browse/FLINK-16947?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17316200#comment-17316200 ] Robert Metzger commented on FLINK-16947: Updated to the latest docker image in m

[jira] [Updated] (FLINK-21386) FromElements ignores returns()

[ https://issues.apache.org/jira/browse/FLINK-21386?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-21386: --- Labels: pull-request-available usability (was: usability) > FromElements ignores returns()

<    1   2   3   4   5   6   >