[GitHub] [flink] hameizi commented on pull request #15564: [FLINK-22207][connectors/hive]Hive Catalog retrieve Flink Properties …

hameizi commented on pull request #15564: URL: https://github.com/apache/flink/pull/15564#issuecomment-819246948 @KurtYoung I fix in the new commit, please review thanks -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and

[GitHub] [flink] flinkbot edited a comment on pull request #15601: [FLINK-18071][FLINK-21996][coordination] - Part two: Ensure reliable OperatorEvent to running Task matching

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

[GitHub] [flink] flinkbot edited a comment on pull request #15545: [FLINK-22167][table-planner] Partial insert not works when complex fields reorder

flinkbot edited a comment on pull request #15545: URL: https://github.com/apache/flink/pull/15545#issuecomment-816526358 ## CI report: * 55e3eb5247e7f6c44ef4e6bef04c34c8fc6af348 Azure:

[GitHub] [flink] kezhuw commented on pull request #15557: [FLINK-21996][coordination] - Part one: Tests and adjusted threading model

kezhuw commented on pull request #15557: URL: https://github.com/apache/flink/pull/15557#issuecomment-819230272 @StephanEwen HI, all my concerns are either solved or answered. From my side, it is in a merge-able state. It still be good and helpful if @tillrohrmann and/or @becketqin could

[GitHub] [flink] kezhuw commented on a change in pull request #15557: [FLINK-21996][coordination] - Part one: Tests and adjusted threading model

kezhuw commented on a change in pull request #15557: URL: https://github.com/apache/flink/pull/15557#discussion_r612937053 ## File path: flink-tests/src/test/java/org/apache/flink/runtime/operators/coordination/OperatorEventSendingCheckpointITCase.java ## @@ -0,0 +1,449 @@

[GitHub] [flink] flinkbot edited a comment on pull request #15602: [FLINK-22264][docs] Fix misleading statement about Flink Job Cluster Kubernetes Support in Flink Architecture page

flinkbot edited a comment on pull request #15602: URL: https://github.com/apache/flink/pull/15602#issuecomment-819181043 ## CI report: * d6c10842849e1d47bb035ac4ee140395f9214f3b UNKNOWN * a63a44d02327232df329255b5e5ab40484238b92 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15545: [FLINK-22167][table-planner] Partial insert not works when complex fields reorder

flinkbot edited a comment on pull request #15545: URL: https://github.com/apache/flink/pull/15545#issuecomment-816526358 ## CI report: * 55e3eb5247e7f6c44ef4e6bef04c34c8fc6af348 Azure:

[jira] [Commented] (FLINK-22263) Using TIMESTAMPADD function with partition value has some problem when push partition into TableSource

[ https://issues.apache.org/jira/browse/FLINK-22263?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17320694#comment-17320694 ] hehuiyuan commented on FLINK-22263: --- [~lzljs3620320]  ok. > Using TIMESTAMPADD function with

[jira] [Comment Edited] (FLINK-22047) Could not find FLINSHED Flink job and can't submit job

[ https://issues.apache.org/jira/browse/FLINK-22047?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17320693#comment-17320693 ] hayden zhou edited comment on FLINK-22047 at 4/14/21, 4:30 AM: ---

[jira] [Commented] (FLINK-22047) Could not find FLINSHED Flink job and can't submit job

[ https://issues.apache.org/jira/browse/FLINK-22047?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17320693#comment-17320693 ] hayden zhou commented on FLINK-22047: - [~trohrmann] thanks for your reply, hopes to see the fixed

[jira] [Commented] (FLINK-22263) Using TIMESTAMPADD function with partition value has some problem when push partition into TableSource

[ https://issues.apache.org/jira/browse/FLINK-22263?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17320691#comment-17320691 ] Jingsong Lee commented on FLINK-22263: -- You can re-open FLINK-22021 and create a PR for 1.12. >

[jira] [Commented] (FLINK-22263) Using TIMESTAMPADD function with partition value has some problem when push partition into TableSource

[ https://issues.apache.org/jira/browse/FLINK-22263?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17320690#comment-17320690 ] Jingsong Lee commented on FLINK-22263: -- Yes, you can cherry-pick this to 1.12. > Using

[GitHub] [flink] flinkbot edited a comment on pull request #15603: [FLINK-22169][sql-client] Beautify the CliTableauResultView when print

flinkbot edited a comment on pull request #15603: URL: https://github.com/apache/flink/pull/15603#issuecomment-819212209 ## CI report: * a230294e88fd9cef432d1d53d41a163318efcf5d Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15604: [FLINK-22265][javadocs]Abnormal document display

flinkbot edited a comment on pull request #15604: URL: https://github.com/apache/flink/pull/15604#issuecomment-819212247 ## CI report: * 8ca0e185d9016d9a0b4debafb90b1f59d8bdcee4 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15605: [FLINK-21996][coordination] - Part 3&4: Ensure OperatorEvent transport losses are handled

flinkbot edited a comment on pull request #15605: URL: https://github.com/apache/flink/pull/15605#issuecomment-819212302 ## CI report: * d2111f6d5a17e9263399aac7c188083c793b418d Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15557: [FLINK-21996][coordination] - Part one: Tests and adjusted threading model

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

[GitHub] [flink] flinkbot edited a comment on pull request #15533: [FLINK-22063][table] Fix bug that some join conditions are lost when …

flinkbot edited a comment on pull request #15533: URL: https://github.com/apache/flink/pull/15533#issuecomment-816380956 ## CI report: * d4454ba96d5ca1b821b16192cd669eb87be74de7 Azure:

[GitHub] [flink] JingsongLi commented on a change in pull request #15545: [FLINK-22167][table-planner] Partial insert not works when complex fields reorder

JingsongLi commented on a change in pull request #15545: URL: https://github.com/apache/flink/pull/15545#discussion_r612925447 ## File path: flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/calcite/PreValidateReWriter.scala ## @@ -272,7

[jira] [Commented] (FLINK-22263) Using TIMESTAMPADD function with partition value has some problem when push partition into TableSource

[ https://issues.apache.org/jira/browse/FLINK-22263?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17320680#comment-17320680 ] hehuiyuan commented on FLINK-22263: --- Hi  [~lzljs3620320] , why not merge to 1.12 ?   If this can be

[GitHub] [flink] flinkbot commented on pull request #15605: [FLINK-21996][coordination] - Part 3&4: Ensure OperatorEvent transport losses are handled

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

[GitHub] [flink] flinkbot commented on pull request #15604: [FLINK-22265][javadocs]Abnormal document display

flinkbot commented on pull request #15604: URL: https://github.com/apache/flink/pull/15604#issuecomment-819212247 ## CI report: * 8ca0e185d9016d9a0b4debafb90b1f59d8bdcee4 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot commented on pull request #15603: [FLINK-22169][sql-client] Beautify the CliTableauResultView when print

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

[GitHub] [flink] flinkbot edited a comment on pull request #15533: [FLINK-22063][table] Fix bug that some join conditions are lost when …

flinkbot edited a comment on pull request #15533: URL: https://github.com/apache/flink/pull/15533#issuecomment-816380956 ## CI report: * d4454ba96d5ca1b821b16192cd669eb87be74de7 Azure:

[jira] [Commented] (FLINK-20633) test_configuration.test_add_all test failed in py35

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

[jira] [Commented] (FLINK-20254) HiveTableSourceITCase.testStreamPartitionReadByCreateTime times out

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

[GitHub] [flink] flinkbot commented on pull request #15603: [FLINK-22169][sql-client] Beautify the CliTableauResultView when print

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

[GitHub] [flink] flinkbot commented on pull request #15604: [FLINK-22265][javadocs]Abnormal document display

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

[GitHub] [flink] flinkbot commented on pull request #15605: [FLINK-21996][coordination] - Part 3&4: Ensure OperatorEvent transport losses are handled

flinkbot commented on pull request #15605: URL: https://github.com/apache/flink/pull/15605#issuecomment-819207661 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] [Created] (FLINK-22270) Python test pipeline no output for 900 seconds

Guowei Ma created FLINK-22270: - Summary: Python test pipeline no output for 900 seconds Key: FLINK-22270 URL: https://issues.apache.org/jira/browse/FLINK-22270 Project: Flink Issue Type: Bug

[jira] [Updated] (FLINK-22270) Python test pipeline no output for 900 seconds

[ https://issues.apache.org/jira/browse/FLINK-22270?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guowei Ma updated FLINK-22270: -- Affects Version/s: (was: 1.12.2) 1.11.3 > Python test pipeline no output

[GitHub] [flink] flinkbot edited a comment on pull request #15602: [FLINK-22264][docs] Fix misleading statement about Flink Job Cluster Kubernetes Support in Flink Architecture page

flinkbot edited a comment on pull request #15602: URL: https://github.com/apache/flink/pull/15602#issuecomment-819181043 ## CI report: * d6c10842849e1d47bb035ac4ee140395f9214f3b UNKNOWN * a63a44d02327232df329255b5e5ab40484238b92 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15600: [FLINK-22144][runtime][runtime-web] Adds more documentation and moves option

flinkbot edited a comment on pull request #15600: URL: https://github.com/apache/flink/pull/15600#issuecomment-819054138 ## CI report: * c104e20035af2d1fcecd864d7d906b8d3bd07da9 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15578: [FLINK-21431][upsert-kafka] Use testcontainers for KafkaTable ITCase

flinkbot edited a comment on pull request #15578: URL: https://github.com/apache/flink/pull/15578#issuecomment-817840111 ## CI report: * 0bde4a74b86b0c4dbb1537cda28760bfe2265238 Azure:

[GitHub] [flink] fsk119 closed pull request #15562: [FLINK-22169][sql-client] Beautify the CliTableauResultView when print

fsk119 closed pull request #15562: URL: https://github.com/apache/flink/pull/15562 -- 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] KurtYoung commented on pull request #15562: [FLINK-22169][sql-client] Beautify the CliTableauResultView when print

KurtYoung commented on pull request #15562: URL: https://github.com/apache/flink/pull/15562#issuecomment-819205886 you can close this one -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the

[jira] [Commented] (FLINK-17510) StreamingKafkaITCase. testKafka timeouts on downloading Kafka

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

[GitHub] [flink] StephanEwen opened a new pull request #15605: [FLINK-21996][coordination] - Part 3&4: Ensure OperatorEvent transport losses are handled

StephanEwen opened a new pull request #15605: URL: https://github.com/apache/flink/pull/15605 ## This is based on #15557 and #15601 Only the last commit, named *"[FLINK-21996][coordination] Ensure exactly-once guarantees for OperatorEvent RPCs"* is relevant. It is a fairly small

[jira] [Commented] (FLINK-22122) StreamingKafkaITCase Fail due to TestTimedOutException

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

[jira] [Commented] (FLINK-19863) SQLClientHBaseITCase.testHBase failed with "java.io.IOException: Process failed due to timeout"

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

[jira] [Updated] (FLINK-22265) Abnormal document display

[ https://issues.apache.org/jira/browse/FLINK-22265?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-22265: --- Labels: pull-request-available (was: ) > Abnormal document display >

[GitHub] [flink] BoYiZhang opened a new pull request #15604: [FLINK-22265][javadocs]Abnormal document display

BoYiZhang opened a new pull request #15604: URL: https://github.com/apache/flink/pull/15604 fix Abnormal document display -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the

[jira] [Commented] (FLINK-22248) JobMasterStopWithSavepointITCase.suspendWithSavepointWithoutComplicationsShouldSucceedAndLeadJobToFinished fail because of TestTimedOutException

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

[GitHub] [flink] fsk119 commented on pull request #15562: [FLINK-22169][sql-client] Beautify the CliTableauResultView when print

fsk119 commented on pull request #15562: URL: https://github.com/apache/flink/pull/15562#issuecomment-819202821 Continue in #15603. -- 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] fsk119 opened a new pull request #15603: [FLINK-22169][sql-client] Beautify the CliTableauResultView when print

fsk119 opened a new pull request #15603: URL: https://github.com/apache/flink/pull/15603 ## What is the purpose of the change *Use `PrintUtils#printAsTableauForm` to calculate column width in batch mode..* ## Verifying this change This change is already covered

[jira] [Created] (FLINK-22269) JobMasterStopWithSavepointITCase.throwingExceptionOnCallbackWithRestartsShouldSimplyRestartInSuspend failed.

Guowei Ma created FLINK-22269: - Summary: JobMasterStopWithSavepointITCase.throwingExceptionOnCallbackWithRestartsShouldSimplyRestartInSuspend failed. Key: FLINK-22269 URL:

[GitHub] [flink] flinkbot edited a comment on pull request #15538: [FLINK-21032][table] Not use ParallelFiniteTestSource in CompactionITCaseBase

flinkbot edited a comment on pull request #15538: URL: https://github.com/apache/flink/pull/15538#issuecomment-816475885 ## CI report: * 46ce52e1b6dde0b57aefe08d525ccfdb89500aa7 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15525: [FLINK-22154][table-planner-blink] Fix bug where PushFilterIntoTableSourceScanRule fails to deal with IN expressions

flinkbot edited a comment on pull request #15525: URL: https://github.com/apache/flink/pull/15525#issuecomment-815836876 ## CI report: * 8179c44907265a7a7aa4294888c003a3a67d5f7b 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 * 709c4110370b845f42d916a06e56c6026cf2fac8 UNKNOWN *

[jira] [Updated] (FLINK-22266) JobMasterStopWithSavepointITCase.throwingExceptionOnCallbackWithNoRestartsShouldFailTheTerminate fail

[ https://issues.apache.org/jira/browse/FLINK-22266?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guowei Ma updated FLINK-22266: -- Summary:

[GitHub] [flink] JingsongLi commented on pull request #15533: [FLINK-22063][table] Fix bug that some join conditions are lost when …

JingsongLi commented on pull request #15533: URL: https://github.com/apache/flink/pull/15533#issuecomment-819200390 @cshuo Please add some comments to explain why -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the

[jira] [Commented] (FLINK-22266) JobMasterStopWithSavepointITCase.throwingExceptionOnCallbackWithoutRestartsHelper fail

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

[jira] [Updated] (FLINK-22266) JobMasterStopWithSavepointITCase.throwingExceptionOnCallbackWithoutRestartsHelper fail

[ https://issues.apache.org/jira/browse/FLINK-22266?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guowei Ma updated FLINK-22266: -- Priority: Critical (was: Major) >

[jira] [Created] (FLINK-22268) JobMasterStopWithSavepointITCase.testRestartCheckpointCoordinatorIfStopWithSavepointFails fail because of "Not all required tasks are currently running."

Guowei Ma created FLINK-22268: - Summary: JobMasterStopWithSavepointITCase.testRestartCheckpointCoordinatorIfStopWithSavepointFails fail because of "Not all required tasks are currently running." Key: FLINK-22268

[jira] [Created] (FLINK-22267) Savepoint an application for source of upsert-kafka, then restart the application from the savepoint, state not be recovered.

Carl created FLINK-22267: Summary: Savepoint an application for source of upsert-kafka, then restart the application from the savepoint, state not be recovered. Key: FLINK-22267 URL:

[jira] [Created] (FLINK-22266) JobMasterStopWithSavepointITCase.throwingExceptionOnCallbackWithoutRestartsHelper fail

Guowei Ma created FLINK-22266: - Summary: JobMasterStopWithSavepointITCase.throwingExceptionOnCallbackWithoutRestartsHelper fail Key: FLINK-22266 URL: https://issues.apache.org/jira/browse/FLINK-22266

[jira] [Commented] (FLINK-22265) Abnormal document display

[ https://issues.apache.org/jira/browse/FLINK-22265?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17320664#comment-17320664 ] BoYi Zhang commented on FLINK-22265: I'll fix that > Abnormal document display >

[jira] [Commented] (FLINK-22262) Flink on Kubernetes ConfigMaps are created without OwnerReference

[ https://issues.apache.org/jira/browse/FLINK-22262?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17320663#comment-17320663 ] Yang Wang commented on FLINK-22262: --- I think we could not set the owner reference for the HA related

[GitHub] [flink] flinkbot edited a comment on pull request #15578: [FLINK-21431][upsert-kafka] Use testcontainers for KafkaTable ITCase

flinkbot edited a comment on pull request #15578: URL: https://github.com/apache/flink/pull/15578#issuecomment-817840111 ## CI report: * 0bde4a74b86b0c4dbb1537cda28760bfe2265238 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15602: [FLINK-22264][docs] Fix misleading statement about Flink Job Cluster Kubernetes Support in Flink Architecture page

flinkbot edited a comment on pull request #15602: URL: https://github.com/apache/flink/pull/15602#issuecomment-819181043 ## CI report: * d6c10842849e1d47bb035ac4ee140395f9214f3b UNKNOWN * a63a44d02327232df329255b5e5ab40484238b92 UNKNOWN Bot commands The

[GitHub] [flink] flinkbot edited a comment on pull request #15538: [FLINK-21032][table] Not use ParallelFiniteTestSource in CompactionITCaseBase

flinkbot edited a comment on pull request #15538: URL: https://github.com/apache/flink/pull/15538#issuecomment-816475885 ## CI report: * 46ce52e1b6dde0b57aefe08d525ccfdb89500aa7 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15525: [FLINK-22154][table-planner-blink] Fix bug where PushFilterIntoTableSourceScanRule fails to deal with IN expressions

flinkbot edited a comment on pull request #15525: URL: https://github.com/apache/flink/pull/15525#issuecomment-815836876 ## CI report: * 7f423888b031f3ebbf56596984709158de3a47d1 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 * 709c4110370b845f42d916a06e56c6026cf2fac8 UNKNOWN *

[jira] [Created] (FLINK-22265) Abnormal document display

BoYi Zhang created FLINK-22265: -- Summary: Abnormal document display Key: FLINK-22265 URL: https://issues.apache.org/jira/browse/FLINK-22265 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-22264) Fix misleading statement about per-job mode support for Kubernetes in Concept/Flink Architecture page

[ https://issues.apache.org/jira/browse/FLINK-22264?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17320660#comment-17320660 ] Fuyao Li commented on FLINK-22264: -- Thanks. Please refer to the PR I submitted for details. 

[jira] [Commented] (FLINK-22264) Fix misleading statement about per-job mode support for Kubernetes in Concept/Flink Architecture page

[ https://issues.apache.org/jira/browse/FLINK-22264?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17320659#comment-17320659 ] Yang Wang commented on FLINK-22264: --- I have assigned this ticket to you. > Fix misleading statement

[jira] [Updated] (FLINK-22263) Using TIMESTAMPADD function with partition value has some problem when push partition into TableSource

[ https://issues.apache.org/jira/browse/FLINK-22263?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-22263: Fix Version/s: 1.13.0 > Using TIMESTAMPADD function with partition value has some problem when push >

[jira] [Closed] (FLINK-22263) Using TIMESTAMPADD function with partition value has some problem when push partition into TableSource

[ https://issues.apache.org/jira/browse/FLINK-22263?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-22263. --- Resolution: Fixed > Using TIMESTAMPADD function with partition value has some problem when push >

[jira] [Updated] (FLINK-22263) Using TIMESTAMPADD function with partition value has some problem when push partition into TableSource

[ https://issues.apache.org/jira/browse/FLINK-22263?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-22263: --- Component/s: Table SQL / Planner > Using TIMESTAMPADD function with partition value has some

[jira] [Updated] (FLINK-22263) Using TIMESTAMPADD function with partition value has some problem when push partition into TableSource

[ https://issues.apache.org/jira/browse/FLINK-22263?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-22263: --- Affects Version/s: 1.12.2 > Using TIMESTAMPADD function with partition value has some problem when

[GitHub] [flink] flinkbot commented on pull request #15602: [FLINK-22264][docs] Fix misleading statement about Flink Job Cluster Kubernetes Support in Flink Architecture page

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

[GitHub] [flink] JingsongLi commented on pull request #15538: [FLINK-21032][table] Not use ParallelFiniteTestSource in CompactionITCaseBase

JingsongLi commented on pull request #15538: URL: https://github.com/apache/flink/pull/15538#issuecomment-819180941 @leonardBang Nice catch! I have fixed source and compact operator. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to

[GitHub] [flink] flinkbot edited a comment on pull request #15523: [FLINK-22109][table-planner-blink] Resolve misleading exception message in invalid nested function

flinkbot edited a comment on pull request #15523: URL: https://github.com/apache/flink/pull/15523#issuecomment-815495525 ## CI report: * 550f2676535859243f738113dd5258edd0655e81 Azure:

[jira] [Closed] (FLINK-22245) Reuse PrintUtils.MAX_COLUMN_WIDTH in CliChangelogResultView and CliTableResultView

[ https://issues.apache.org/jira/browse/FLINK-22245?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-22245. --- Resolution: Fixed Fixed in master: a66487d4d2f77bb09b9961655cc5922c3e5c098c > Reuse

[GitHub] [flink] wuchong merged pull request #15580: [FLINK-22245][sql-client] Reuse PrintUtils.MAX_COLUMN_WIDTH in CliCha…

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

[jira] [Commented] (FLINK-21992) Fix availability notification in UnionInputGate

[ https://issues.apache.org/jira/browse/FLINK-21992?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17320653#comment-17320653 ] Guowei Ma commented on FLINK-21992: --- We also see the same stack in our internal tests without

[jira] [Assigned] (FLINK-22264) Fix misleading statement about per-job mode support for Kubernetes in Concept/Flink Architecture page

[ https://issues.apache.org/jira/browse/FLINK-22264?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yang Wang reassigned FLINK-22264: - Assignee: Fuyao Li > Fix misleading statement about per-job mode support for Kubernetes in >

[GitHub] [flink] leonardBang commented on pull request #15533: [FLINK-22063][table] Fix bug that some join conditions are lost when …

leonardBang commented on pull request #15533: URL: https://github.com/apache/flink/pull/15533#issuecomment-819176809 The failed test is not related to this PR, cc @JingsongLi could you help merge? -- This is an automated message from the Apache Git Service. To respond to the message,

[GitHub] [flink] xintongsong commented on pull request #15599: [FLINK-11838][flink-gs-fs-hadoop] Create Google Storage file system with recoverable writer support

xintongsong commented on pull request #15599: URL: https://github.com/apache/flink/pull/15599#issuecomment-819175527 Thanks for preparing this PR, @galenwarren. I'll try to take a look asap. Quick response to your questions. - The licensing issues are described

[jira] [Closed] (FLINK-21012) AvroFileFormatFactory uses non-deserializable lambda function

[ https://issues.apache.org/jira/browse/FLINK-21012?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-21012. Resolution: Fixed master (1.13): 7cb5d1c1977a0ac65e0954ea0abf49461a4c0e6c 1.12: 

[jira] [Comment Edited] (FLINK-21012) AvroFileFormatFactory uses non-deserializable lambda function

[ https://issues.apache.org/jira/browse/FLINK-21012?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17320644#comment-17320644 ] Jingsong Lee edited comment on FLINK-21012 at 4/14/21, 2:22 AM:

[GitHub] [flink] JingsongLi merged pull request #15596: [FLINK-21012][format-avro] Replace lambda with anonymous class to prevent serialization issue

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

[jira] [Commented] (FLINK-21012) AvroFileFormatFactory uses non-deserializable lambda function

[ https://issues.apache.org/jira/browse/FLINK-21012?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17320644#comment-17320644 ] Jingsong Lee commented on FLINK-21012: -- [~airblader] Yes~ > AvroFileFormatFactory uses

[GitHub] [flink] wuchong commented on pull request #15534: [FLINK-22104][sql-client] Fix unstable SqlClientTest.testExecuteSqlFile

wuchong commented on pull request #15534: URL: https://github.com/apache/flink/pull/15534#issuecomment-819173236 The build hangs on sql client tests. Please have a check. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and

[GitHub] [flink] flinkbot commented on pull request #15602: [FLINK-22264][docs] Fix misleading statement about Flink Job Cluster Kubernetes Support in Flink Architecture page

flinkbot commented on pull request #15602: URL: https://github.com/apache/flink/pull/15602#issuecomment-819170222 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-22264) Fix misleading statement about per-job mode support for Kubernetes in Concept/Flink Architecture page

[ https://issues.apache.org/jira/browse/FLINK-22264?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-22264: --- Labels: pull-request-available (was: ) > Fix misleading statement about per-job mode

[GitHub] [flink] FuyaoLi2017 opened a new pull request #15602: [FLINK-22264][docs] Fix misleading statement about Flink Job Cluster Kubernetes Support in Flink Architecture page

FuyaoLi2017 opened a new pull request #15602: URL: https://github.com/apache/flink/pull/15602 ## What is the purpose of the change I noticed a conflict in the document statement for per-job mode support for Kubernetes. In the doc here [1], it mentions in a Flink Job

[GitHub] [flink] flinkbot edited a comment on pull request #15523: [FLINK-22109][table-planner-blink] Resolve misleading exception message in invalid nested function

flinkbot edited a comment on pull request #15523: URL: https://github.com/apache/flink/pull/15523#issuecomment-815495525 ## CI report: * 550f2676535859243f738113dd5258edd0655e81 Azure:

[jira] [Closed] (FLINK-17371) Failed to cast decimal from string or double

[ https://issues.apache.org/jira/browse/FLINK-17371?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-17371. Resolution: Fixed master (1.13): f6fc76936cc3302e4784b334c8e392abe199e992

[GitHub] [flink] JingsongLi merged pull request #15568: [FLINK-17371][table-runtime] Add cases for decimal casting

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

[jira] [Closed] (FLINK-21305) Fix Cumulative and Hopping window should accumulate late events belonging to the cleaned slice

[ https://issues.apache.org/jira/browse/FLINK-21305?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-21305. --- Resolution: Fixed Fixed in master: 3dd50dd01e49c79d33165a737974cb8e913cb195 > Fix Cumulative and Hopping

[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=17320638#comment-17320638 ] Xintong Song commented on FLINK-11838: -- Thanks [~galenwarren]. I'll try to take a look asap. Just

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

wuchong commented on pull request #15495: URL: https://github.com/apache/flink/pull/15495#issuecomment-819165646 Merging... -- 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.

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

wuchong merged pull request #15495: URL: https://github.com/apache/flink/pull/15495 -- 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] xintongsong closed pull request #14875: [FLINK-11838][flink-gs-fs-hadoop] Add GCS FileSystem with RecoverableWriter

xintongsong closed pull request #14875: URL: https://github.com/apache/flink/pull/14875 -- 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 #15601: [FLINK-18071][FLINK-21996][coordination] - Part two: Ensure reliable OperatorEvent to running Task matching

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

[GitHub] [flink] KurtYoung commented on pull request #15564: [FLINK-22207][connectors/hive]Hive Catalog retrieve Flink Properties …

KurtYoung commented on pull request #15564: URL: https://github.com/apache/flink/pull/15564#issuecomment-819161036 [ERROR] Failed to execute goal com.diffplug.spotless:spotless-maven-plugin:2.4.2:check (spotless-check) on project flink-connector-hive_2.11: The following files had format

[jira] [Commented] (FLINK-20779) Add documentation for row-based operation in Python Table API

[ https://issues.apache.org/jira/browse/FLINK-20779?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17320631#comment-17320631 ] Huang Xingbo commented on FLINK-20779: -- Hi [~dwysakowicz], I'm working this and will open a

[jira] [Comment Edited] (FLINK-20779) Add documentation for row-based operation in Python Table API

[ https://issues.apache.org/jira/browse/FLINK-20779?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17320631#comment-17320631 ] Huang Xingbo edited comment on FLINK-20779 at 4/14/21, 1:41 AM: Hi

[jira] [Closed] (FLINK-22261) Python StreamingModeDataStreamTests is failed on Azure

[ https://issues.apache.org/jira/browse/FLINK-22261?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-22261. --- Resolution: Duplicate This issue should have been fixed in FLINK-22191. > Python

[jira] [Updated] (FLINK-22261) Python StreamingModeDataStreamTests is failed on Azure

[ https://issues.apache.org/jira/browse/FLINK-22261?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-22261: Fix Version/s: (was: 1.13.0) > Python StreamingModeDataStreamTests is failed on Azure >

  1   2   3   4   5   6   >