[GitHub] [flink] flinkbot edited a comment on pull request #15497: [FLINK-22084][runtime] Use a consistent default max parallelism in the Adaptive Scheduler

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

[GitHub] [flink] tillrohrmann commented on pull request #15469: [BP-1.12][FLINK-22014][ha] Make sure that AbstractHaServices delete first the HA data before deleting blobs on closeAndCleanupAllData

tillrohrmann commented on pull request #15469: URL: https://github.com/apache/flink/pull/15469#issuecomment-815047195 Thanks for the review @zentol. Merging this PR now. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and

[GitHub] [flink] tillrohrmann commented on pull request #15470: [BP-1.11][FLINK-22014][ha] Make sure that AbstractHaServices delete first the HA data before deleting blobs on closeAndCleanupAllData

tillrohrmann commented on pull request #15470: URL: https://github.com/apache/flink/pull/15470#issuecomment-815046967 Thanks for the review @zentol. Merging this PR now. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and

[GitHub] [flink] tillrohrmann commented on pull request #15468: [FLINK-22014][ha] Make sure that AbstractHaServices delete first the HA data before deleting blobs on closeAndCleanupAllData

tillrohrmann commented on pull request #15468: URL: https://github.com/apache/flink/pull/15468#issuecomment-815045991 Thanks for the review @zentol. The failing test seems to be unrelated. Merging this PR now. -- This is an automated message from the Apache Git Service. To respond to

[jira] [Commented] (FLINK-22100) BatchFileSystemITCaseBase.testPartialDynamicPartition fail because of no output for 900 seconds

[ https://issues.apache.org/jira/browse/FLINK-22100?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17316468#comment-17316468 ] Till Rohrmann commented on FLINK-22100: --- Another instance:

[jira] [Commented] (FLINK-21559) Python DataStreamTests::test_process_function failed on AZP

[ https://issues.apache.org/jira/browse/FLINK-21559?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17316466#comment-17316466 ] Dawid Wysakowicz commented on FLINK-21559: -- Hey [~hxbks2ks] any update on the issue? > Python

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

kezhuw commented on a change in pull request #15507: URL: https://github.com/apache/flink/pull/15507#discussion_r608799934 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/environment/StreamExecutionEnvironment.java ## @@ -1096,12 +1096,7 @@

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

kezhuw commented on pull request #15507: URL: https://github.com/apache/flink/pull/15507#issuecomment-815040749 Hi @dawidwys, I have pushed fixup commit for next reviewing cycle. Please confirm whether I have resolve your concerns. Thanks. -- This is an automated message from the Apache

[jira] [Updated] (FLINK-20975) HiveTableSourceITCase.testPartitionFilter fails on AZP

[ https://issues.apache.org/jira/browse/FLINK-20975?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-20975: - Priority: Major (was: Critical) > HiveTableSourceITCase.testPartitionFilter fails on

[jira] [Updated] (FLINK-20956) SQLClientSchemaRegistryITCase.testWriting unstable

[ https://issues.apache.org/jira/browse/FLINK-20956?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-20956: - Priority: Major (was: Critical) > SQLClientSchemaRegistryITCase.testWriting unstable >

[jira] [Assigned] (FLINK-20956) SQLClientSchemaRegistryITCase.testWriting unstable

[ https://issues.apache.org/jira/browse/FLINK-20956?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz reassigned FLINK-20956: Assignee: (was: Dawid Wysakowicz) >

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

kezhuw commented on a change in pull request #15507: URL: https://github.com/apache/flink/pull/15507#discussion_r608798087 ## File path: flink-streaming-java/src/test/java/org/apache/flink/streaming/api/functions/FromElementsFunctionTest.java ## @@ -68,6 +88,135 @@ public

[jira] [Updated] (FLINK-20329) Elasticsearch7DynamicSinkITCase hangs

[ https://issues.apache.org/jira/browse/FLINK-20329?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-20329: - Priority: Major (was: Critical) > Elasticsearch7DynamicSinkITCase hangs >

[jira] [Commented] (FLINK-20263) Improve exception when metadata name mismatch

[ https://issues.apache.org/jira/browse/FLINK-20263?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17316458#comment-17316458 ] Dawid Wysakowicz commented on FLINK-20263: -- Do we want to have that in 1.13 [~twalthr]? Or

[jira] [Commented] (FLINK-18071) CoordinatorEventsExactlyOnceITCase.checkListContainsSequence fails on CI

[ https://issues.apache.org/jira/browse/FLINK-18071?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17316448#comment-17316448 ] Dawid Wysakowicz commented on FLINK-18071: -- Is there a committer that will have time in 1.13 to

[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_r608790720 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/entrypoint/ClusterEntrypoint.java ## @@ -165,7 +165,7 @@ protected

[jira] [Created] (FLINK-22144) Test display last n exceptions/causes for job restarts in Web UI

Till Rohrmann created FLINK-22144: - Summary: Test display last n exceptions/causes for job restarts in Web UI Key: FLINK-22144 URL: https://issues.apache.org/jira/browse/FLINK-22144 Project: Flink

[jira] [Resolved] (FLINK-22105) SubtaskCheckpointCoordinatorTest.testForceAlignedCheckpointResultingInPriorityEvents unstable

[ https://issues.apache.org/jira/browse/FLINK-22105?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan resolved FLINK-22105. --- Resolution: Fixed Merged into master 3cf8597cf3b847519fa12925a2b984e80304   >

[GitHub] [flink] rkhachatryan merged pull request #15505: [FLINK-22105][tests] Fix checkpoint id in testForceAlignedCheckpointResultingInPriorityEvents

rkhachatryan merged pull request #15505: URL: https://github.com/apache/flink/pull/15505 -- 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] rkhachatryan commented on pull request #15505: [FLINK-22105][tests] Fix checkpoint id in testForceAlignedCheckpointResultingInPriorityEvents

rkhachatryan commented on pull request #15505: URL: https://github.com/apache/flink/pull/15505#issuecomment-815025774 Thanks for reviewing! AZP is green, merging. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use

[GitHub] [flink] austince commented on pull request #15497: [FLINK-22084][runtime] Use a consistent default max parallelism in the Adaptive Scheduler

austince commented on pull request #15497: URL: https://github.com/apache/flink/pull/15497#issuecomment-815023918 @flinkbot run azure -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the

[GitHub] [flink] austince removed a comment on pull request #15497: [FLINK-22084][runtime] Use a consistent default max parallelism in the Adaptive Scheduler

austince removed a comment on pull request #15497: URL: https://github.com/apache/flink/pull/15497#issuecomment-814484686 @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] [Updated] (FLINK-22004) Translate Flink Roadmap to Chinese.

[ https://issues.apache.org/jira/browse/FLINK-22004?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-22004: --- Labels: pull-request-available (was: ) > Translate Flink Roadmap to Chinese. >

[GitHub] [flink-web] curcur opened a new pull request #429: [FLINK-22004] Translate Flink Roadmap to Chinese

curcur opened a new pull request #429: URL: https://github.com/apache/flink-web/pull/429 1. Translate Flink Roadmap to Chinese 2. Feature Radar (Figure) may also need to be translated 3. Already built locally. -- This is an automated message from the Apache Git Service. To respond

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

wangyang0918 commented on a change in pull request #15396: URL: https://github.com/apache/flink/pull/15396#discussion_r608777149 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/entrypoint/ClusterEntrypoint.java ## @@ -165,7 +165,7 @@ protected

[GitHub] [flink] flinkbot edited a comment on pull request #15505: [FLINK-22105][tests] Fix checkpoint id in testForceAlignedCheckpointResultingInPriorityEvents

flinkbot edited a comment on pull request #15505: URL: https://github.com/apache/flink/pull/15505#issuecomment-814806701 ## CI report: * b4b82eed66c64dd99cfdf132eb46874cede23aa4 Azure:

[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: * 2c5c9cd624420c6fd1a5e884c2951f3ee8d28f69 Azure:

[jira] [Commented] (FLINK-17012) Expose stage of task initialization

[ https://issues.apache.org/jira/browse/FLINK-17012?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17316427#comment-17316427 ] Piotr Nowojski commented on FLINK-17012: Fixing colours of {{RECOVERING}} state in WebUI merged

[jira] [Commented] (FLINK-22139) Flink Jobmanager & Task Manger logs are not writing to the logs files

[ https://issues.apache.org/jira/browse/FLINK-22139?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17316425#comment-17316425 ] Kenneth William Krugler commented on FLINK-22139: - Hi [~bhagi__R] - apologies if I

[GitHub] [flink] pnowojski merged pull request #15462: [FLINK-17012][webui] Added support of RECOVERING state

pnowojski merged pull request #15462: URL: https://github.com/apache/flink/pull/15462 -- 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] 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:

[GitHub] [flink] flinkbot edited a comment on pull request #15494: [FLINK-17957] [table-api][parser] Forbidden syntax "CREATE SYSTEM FUNCTION" for sql parser

flinkbot edited a comment on pull request #15494: URL: https://github.com/apache/flink/pull/15494#issuecomment-814059954 ## CI report: * a0782bb05bb4283e4c56303b9c9ca8456de29bd8 Azure:

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

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

flinkbot edited a comment on pull request #15501: URL: https://github.com/apache/flink/pull/15501#issuecomment-814722337 ## CI report: * 86ed730cae0817b0566ddbc0b89d49d027e64048 Azure:

[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 * 46b4644a2a5d473b01dfb4e2a6e4b1ec3cc483d1 Azure:

[jira] [Comment Edited] (FLINK-14184) Provide a stage listener API to be invoked per task manager

[ https://issues.apache.org/jira/browse/FLINK-14184?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17316420#comment-17316420 ] Bob Tiernay edited comment on FLINK-14184 at 4/7/21, 3:22 PM: -- This is a

[jira] [Commented] (FLINK-14184) Provide a stage listener API to be invoked per task manager

[ https://issues.apache.org/jira/browse/FLINK-14184?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17316420#comment-17316420 ] Bob Tiernay commented on FLINK-14184: - This is a very important feature for a number of use cases

[GitHub] [flink] YuvalItzchakov commented on pull request #15307: [FLINK-21675][table-planner-blink] Allow Predicate Pushdown with Watermark Assigner Between Filter and Scan

YuvalItzchakov commented on pull request #15307: URL: https://github.com/apache/flink/pull/15307#issuecomment-814991935 > The CI test fails. Please take a look and fix these tests. @fsk119 Working on it. I'm not sure which part of the plan actually breaks as the message is pretty

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

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

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

flinkbot edited a comment on pull request #15501: URL: https://github.com/apache/flink/pull/15501#issuecomment-814722337 ## CI report: * 86ed730cae0817b0566ddbc0b89d49d027e64048 Azure:

[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: * 0f243b503db4139ae824badcfa911df0fc984bf9 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15494: [FLINK-17957] [table-api][parser] Forbidden syntax "CREATE SYSTEM FUNCTION" for sql parser

flinkbot edited a comment on pull request #15494: URL: https://github.com/apache/flink/pull/15494#issuecomment-814059954 ## CI report: * a0782bb05bb4283e4c56303b9c9ca8456de29bd8 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15485: [FLINK-20387][table] Support TIMESTAMP_LTZ as rowtime attribute

flinkbot edited a comment on pull request #15485: URL: https://github.com/apache/flink/pull/15485#issuecomment-812897189 ## CI report: * ee69df73cd5a7e61efa44b704eb5d551db23d7e8 Azure:

[GitHub] [flink] tillrohrmann commented on pull request #15470: [BP-1.11][FLINK-22014][ha] Make sure that AbstractHaServices delete first the HA data before deleting blobs on closeAndCleanupAllData

tillrohrmann commented on pull request #15470: URL: https://github.com/apache/flink/pull/15470#issuecomment-814977339 Because the `AbstractHaServices` have only been introduced with 1.12. -- This is an automated message from the Apache Git Service. To respond to the message, please log

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

kezhuw commented on a change in pull request #15507: URL: https://github.com/apache/flink/pull/15507#discussion_r608719116 ## File path: flink-streaming-java/src/test/java/org/apache/flink/streaming/api/graph/StreamGraphGeneratorTest.java ## @@ -209,6 +211,25 @@ public void

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

yittg commented on pull request #15501: URL: https://github.com/apache/flink/pull/15501#issuecomment-814969966 Thanks, @tillrohrmann , @wangyang0918 > There seems to be a compilation error Yeah , i didn't realize the local CheckStyle plugin does not work. I have added

[GitHub] [flink] flinkbot edited a comment on pull request #15516: [FLINK-22138][table] Allow casting between row and structured type

flinkbot edited a comment on pull request #15516: URL: https://github.com/apache/flink/pull/15516#issuecomment-814954048 ## CI report: * 9dbf1e2f5690e1ea44632dace8a97e137d61e951 Azure:

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

[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: * e1402f82f8ad3e7bae30e025589d71cc2e7f309a Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15485: [FLINK-20387][table] Support TIMESTAMP_LTZ as rowtime attribute

flinkbot edited a comment on pull request #15485: URL: https://github.com/apache/flink/pull/15485#issuecomment-812897189 ## CI report: * 2b01969060aa805ea4f0acea721ec56c496194f0 Azure:

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

kezhuw commented on a change in pull request #15507: URL: https://github.com/apache/flink/pull/15507#discussion_r608713145 ## File path: flink-streaming-java/src/test/java/org/apache/flink/streaming/api/functions/FromElementsFunctionTest.java ## @@ -68,6 +88,135 @@ public

[jira] [Commented] (FLINK-11838) Create RecoverableWriter for GCS

[ https://issues.apache.org/jira/browse/FLINK-11838?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17316376#comment-17316376 ] Galen Warren commented on FLINK-11838: -- Working on the new PR now ... coming soon. > Create

[GitHub] [flink] flinkbot commented on pull request #15516: [FLINK-22138][table] Allow casting between row and structured type

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

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

flinkbot edited a comment on pull request #15514: URL: https://github.com/apache/flink/pull/15514#issuecomment-814909943 ## CI report: * 23d0c581a4f20e169a1129bc3b7faa23ec6a856c Azure:

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

flinkbot edited a comment on pull request #15515: URL: https://github.com/apache/flink/pull/15515#issuecomment-814924196 ## CI report: * a0e75bf2e180d2c9ebc1b5f69ef4b40dbe519b35 Azure:

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

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

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

[jira] [Updated] (FLINK-22120) Remove duplicate code in generated code for map get

[ https://issues.apache.org/jira/browse/FLINK-22120?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zou updated FLINK-22120: Summary: Remove duplicate code in generated code for map get (was: Bug when generate code for map get) > Remove

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

dawidwys commented on a change in pull request #15507: URL: https://github.com/apache/flink/pull/15507#discussion_r608676177 ## File path: flink-streaming-java/src/test/java/org/apache/flink/streaming/api/functions/FromElementsFunctionTest.java ## @@ -68,6 +88,135 @@ public

[jira] [Assigned] (FLINK-13785) Implement type inference for time functions

[ https://issues.apache.org/jira/browse/FLINK-13785?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther reassigned FLINK-13785: Assignee: Timo Walther > Implement type inference for time functions >

[jira] [Assigned] (FLINK-13785) Implement type inference for time functions

[ https://issues.apache.org/jira/browse/FLINK-13785?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther reassigned FLINK-13785: Assignee: (was: Timo Walther) > Implement type inference for time functions >

[jira] [Assigned] (FLINK-13785) Implement type inference for time functions

[ https://issues.apache.org/jira/browse/FLINK-13785?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther reassigned FLINK-13785: Assignee: (was: Timo Walther) > Implement type inference for time functions >

[GitHub] [flink] flinkbot commented on pull request #15516: [FLINK-22138][table] Allow casting between row and structured type

flinkbot commented on pull request #15516: URL: https://github.com/apache/flink/pull/15516#issuecomment-814931418 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] [Updated] (FLINK-22138) Allow casting between row and structured type

[ https://issues.apache.org/jira/browse/FLINK-22138?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-22138: --- Labels: pull-request-available (was: ) > Allow casting between row and structured type >

[GitHub] [flink] twalthr opened a new pull request #15516: [FLINK-22138][table] Allow casting between row and structured type

twalthr opened a new pull request #15516: URL: https://github.com/apache/flink/pull/15516 ## What is the purpose of the change This enables a flexible use of row and structured types. It reduces friction in the edge cases such as functions, `toDataStream` and `collect`. ##

[jira] [Updated] (FLINK-22138) Allow casting between row and structured type

[ https://issues.apache.org/jira/browse/FLINK-22138?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-22138: - Summary: Allow casting between row and structured type (was: Better support structured types

[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-814924196 ## CI report: * a0e75bf2e180d2c9ebc1b5f69ef4b40dbe519b35 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

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

flinkbot edited a comment on pull request #15514: URL: https://github.com/apache/flink/pull/15514#issuecomment-814909943 ## CI report: * 23d0c581a4f20e169a1129bc3b7faa23ec6a856c Azure:

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

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

[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

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

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

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

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

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

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

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

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

[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

[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

[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

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

[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=17316311#comment-17316311 ] Xintong Song commented on FLINK-20663: -- [~zhou_yb], This indeed looks similar. Is it possible for

[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=17316306#comment-17316306 ] Fu Kai edited comment on FLINK-22113 at 4/7/21, 12:50 PM: -- Hi Jark,  Thank you

[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=17316306#comment-17316306 ] Fu Kai edited comment on FLINK-22113 at 4/7/21, 12:49 PM: -- Hi Jark,  Thank you

[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=17316306#comment-17316306 ] Fu Kai commented on FLINK-22113: Hi Jark,  Thank you for the valuable information. My follow up

[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

[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

[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

[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

[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

[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

[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

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

[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=17316295#comment-17316295 ] Dawid Wysakowicz commented on FLINK-22062: -- Hey, [~sjwiesman] any progress on this issue? >

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

<    1   2   3   4   5   6   >