[jira] [Assigned] (FLINK-23635) PrestoS3FileSystemITCase.testConfigKeysForwarding

2021-08-04 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23635?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song reassigned FLINK-23635: Assignee: Ingo Bürk > PrestoS3FileSystemITCase.testConfigKeysForwarding >

[GitHub] [flink] AHeise commented on pull request #16399: [FLINK-23621][datastream] FLIP-177: Extend Sink API

2021-08-04 Thread GitBox
AHeise commented on pull request #16399: URL: https://github.com/apache/flink/pull/16399#issuecomment-893183144 @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 specific

[GitHub] [flink] AHeise commented on a change in pull request #16559: [FLINK-18562] Support for Hadoop ABFS for Azure Datalake Gen2 accounts

2021-08-04 Thread GitBox
AHeise commented on a change in pull request #16559: URL: https://github.com/apache/flink/pull/16559#discussion_r683145725 ## File path: flink-filesystems/flink-azure-fs-hadoop/src/main/java/org/apache/flink/fs/azurefs/AbstractAzureFSFactory.java ## @@ -75,18 +76,27 @@ public

[GitHub] [flink] AHeise commented on pull request #16559: [FLINK-18562] Support for Hadoop ABFS for Azure Datalake Gen2 accounts

2021-08-04 Thread GitBox
AHeise commented on pull request #16559: URL: https://github.com/apache/flink/pull/16559#issuecomment-893180068 > Thanks for the Pointers @AHeise, I did some digging last few days on the azurite. There is good news and bad news, Good news is, It looks like we could use that for testing

[jira] [Commented] (FLINK-23635) PrestoS3FileSystemITCase.testConfigKeysForwarding

2021-08-04 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-23635?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17393622#comment-17393622 ] Ingo Bürk commented on FLINK-23635: --- Yes, that's very likely related. I'll look into this a bit as

[GitHub] [flink] flinkbot edited a comment on pull request #16628: [FLINK-23453][streaming] Created the buffer size calculator for the ability to automatically change the buffer size based on the thro

2021-08-04 Thread GitBox
flinkbot edited a comment on pull request #16628: URL: https://github.com/apache/flink/pull/16628#issuecomment-888479610 ## CI report: * 2ec4ffbc46a818b19a7ee35b9850e7765fdc88c9 Azure:

[GitHub] [flink] AHeise commented on a change in pull request #16559: [FLINK-18562] Support for Hadoop ABFS for Azure Datalake Gen2 accounts

2021-08-04 Thread GitBox
AHeise commented on a change in pull request #16559: URL: https://github.com/apache/flink/pull/16559#discussion_r683142635 ## File path: flink-filesystems/flink-s3-fs-hadoop/src/main/java/org/apache/flink/fs/s3hadoop/HadoopS3AccessHelper.java ## @@ -52,8 +55,22 @@

[GitHub] [flink] flinkbot edited a comment on pull request #16559: [FLINK-18562] Support for Hadoop ABFS for Azure Datalake Gen2 accounts

2021-08-04 Thread GitBox
flinkbot edited a comment on pull request #16559: URL: https://github.com/apache/flink/pull/16559#issuecomment-884516771 ## CI report: * 0f6e0c61cb4703de06f4326bce75aea8dd586de8 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16670: [FLINK-23581][docs] Change site.download_url to https://flink.apache.…

2021-08-04 Thread GitBox
flinkbot edited a comment on pull request #16670: URL: https://github.com/apache/flink/pull/16670#issuecomment-890847824 ## CI report: * 2c198e1c32a09eb51f6345214c85fe22f56193b2 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16628: [FLINK-23453][streaming] Created the buffer size calculator for the ability to automatically change the buffer size based on the thro

2021-08-04 Thread GitBox
flinkbot edited a comment on pull request #16628: URL: https://github.com/apache/flink/pull/16628#issuecomment-888479610 ## CI report: * 2ec4ffbc46a818b19a7ee35b9850e7765fdc88c9 Azure:

[jira] [Assigned] (FLINK-23607) Cleanup unnecessary dependencies in dstl pom.xml

2021-08-04 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23607?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuan Mei reassigned FLINK-23607: Assignee: (was: Yuan Mei) > Cleanup unnecessary dependencies in dstl pom.xml >

[jira] [Assigned] (FLINK-23607) Cleanup unnecessary dependencies in dstl pom.xml

2021-08-04 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23607?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuan Mei reassigned FLINK-23607: Assignee: Yuan Mei > Cleanup unnecessary dependencies in dstl pom.xml >

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

2021-08-04 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22312?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song reopened FLINK-22312: -- Reopening. New instance in 1.12.

[jira] [Commented] (FLINK-22198) KafkaTableITCase hang.

2021-08-04 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22198?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17393591#comment-17393591 ] Xintong Song commented on FLINK-22198: --

[jira] [Created] (FLINK-23636) NotifyCheckpointAbortedITCase.testNotifyCheckpointAborted fails on azure

2021-08-04 Thread Xintong Song (Jira)
Xintong Song created FLINK-23636: Summary: NotifyCheckpointAbortedITCase.testNotifyCheckpointAborted fails on azure Key: FLINK-23636 URL: https://issues.apache.org/jira/browse/FLINK-23636 Project:

[GitHub] [flink] flinkbot edited a comment on pull request #16701: [FLINK-23617][datastream] Co-locate sink operators with same parallelism

2021-08-04 Thread GitBox
flinkbot edited a comment on pull request #16701: URL: https://github.com/apache/flink/pull/16701#issuecomment-892491133 ## CI report: * 34884c0567ded09b7413aaeffd8cc4d5819c3bd3 UNKNOWN * 615e76371b3d251b16d530dc8b31b5c27d143122 Azure:

[jira] [Updated] (FLINK-23544) Window TVF Supports session window in plan

2021-08-04 Thread JING ZHANG (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23544?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] JING ZHANG updated FLINK-23544: --- Description: Window TVF would support SESSION window in the following case: # SESSION Window TVF

[jira] [Commented] (FLINK-23493) python tests hang on Azure

2021-08-04 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23493?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17393587#comment-17393587 ] Xintong Song commented on FLINK-23493: --

[GitHub] [flink] beyond1920 commented on a change in pull request #16620: [FLINK-23246][table-planner] Refactor the time indicator materialization

2021-08-04 Thread GitBox
beyond1920 commented on a change in pull request #16620: URL: https://github.com/apache/flink/pull/16620#discussion_r683105222 ## File path: flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/stream/sql/DeduplicateTest.xml ## @@ -207,7

[GitHub] [flink] flinkbot edited a comment on pull request #16620: [FLINK-23246][table-planner] Refactor the time indicator materialization

2021-08-04 Thread GitBox
flinkbot edited a comment on pull request #16620: URL: https://github.com/apache/flink/pull/16620#issuecomment-888120908 ## CI report: * 12c0dbb7a1359053f4804910f58f06434e542dad UNKNOWN * 7af3da3e3b9f75ede4ac13755743320ff8ac5e83 Azure:

[jira] [Issue Comment Deleted] (FLINK-23558) E2e tests fail because of quiesced system timers service

2021-08-04 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23558?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuan Mei updated FLINK-23558: - Comment: was deleted (was: merged commit 

[jira] [Resolved] (FLINK-23558) E2e tests fail because of quiesced system timers service

2021-08-04 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23558?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuan Mei resolved FLINK-23558. -- Fix Version/s: 1.14.0 Resolution: Fixed merged commit 

[jira] [Commented] (FLINK-23558) E2e tests fail because of quiesced system timers service

2021-08-04 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23558?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17393583#comment-17393583 ] Yuan Mei commented on FLINK-23558: -- merged commit 

[jira] [Closed] (FLINK-23619) Remove PythonTimestampsAndWatermarksOperator

2021-08-04 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23619?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-23619. --- Resolution: Fixed Merged to master via 67dfee08b6456f1b1a7c875bbce84be1c218fc08 > Remove

[GitHub] [flink] dianfu closed pull request #16703: [FLINK-23619][python] Remove PythonTimestampsAndWatermarksOperator

2021-08-04 Thread GitBox
dianfu closed pull request #16703: URL: https://github.com/apache/flink/pull/16703 -- 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. To unsubscribe, e-mail:

[GitHub] [flink] curcur commented on pull request #16653: [FLINK-23558][streaming] Ignoring RejectedExecutionException during s…

2021-08-04 Thread GitBox
curcur commented on pull request #16653: URL: https://github.com/apache/flink/pull/16653#issuecomment-893129290 Thanks for fixing this @akalash , merged. -- 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] curcur merged pull request #16653: [FLINK-23558][streaming] Ignoring RejectedExecutionException during s…

2021-08-04 Thread GitBox
curcur merged pull request #16653: URL: https://github.com/apache/flink/pull/16653 -- 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. To unsubscribe, e-mail:

[GitHub] [flink] flinkbot edited a comment on pull request #16670: [FLINK-23581][docs] Change site.download_url to https://flink.apache.…

2021-08-04 Thread GitBox
flinkbot edited a comment on pull request #16670: URL: https://github.com/apache/flink/pull/16670#issuecomment-890847824 ## CI report: * ad956a1a904b3b83ca4a9c505a35fafb0d83b713 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16620: [FLINK-23246][table-planner] Refactor the time indicator materialization

2021-08-04 Thread GitBox
flinkbot edited a comment on pull request #16620: URL: https://github.com/apache/flink/pull/16620#issuecomment-888120908 ## CI report: * 12c0dbb7a1359053f4804910f58f06434e542dad UNKNOWN * 7af3da3e3b9f75ede4ac13755743320ff8ac5e83 Azure:

[jira] [Comment Edited] (FLINK-23635) PrestoS3FileSystemITCase.testConfigKeysForwarding

2021-08-04 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23635?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17393571#comment-17393571 ] Xintong Song edited comment on FLINK-23635 at 8/5/21, 2:51 AM: ---

[jira] [Commented] (FLINK-23635) PrestoS3FileSystemITCase.testConfigKeysForwarding

2021-08-04 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23635?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17393571#comment-17393571 ] Xintong Song commented on FLINK-23635: --

[jira] [Updated] (FLINK-22674) Provide JobID when apply shuffle resource by ShuffleMaster

2021-08-04 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22674?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-22674: Fix Version/s: 1.14.0 > Provide JobID when apply shuffle resource by ShuffleMaster >

[jira] [Updated] (FLINK-23214) Make ShuffleMaster a cluster level shared service

2021-08-04 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23214?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-23214: Fix Version/s: 1.14.0 > Make ShuffleMaster a cluster level shared service >

[jira] [Closed] (FLINK-23249) Introduce ShuffleMasterContext to ShuffleMaster

2021-08-04 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23249?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu closed FLINK-23249. --- Resolution: Done Done via 0ee4038ef596b22630bc814f677fa489d3796241 > Introduce ShuffleMasterContext to

[jira] [Updated] (FLINK-22675) Add lifecycle methods to ShuffleMaster

2021-08-04 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22675?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-22675: Fix Version/s: 1.14.0 > Add lifecycle methods to ShuffleMaster > -- >

[jira] [Closed] (FLINK-23214) Make ShuffleMaster a cluster level shared service

2021-08-04 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23214?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu closed FLINK-23214. --- Resolution: Done Done via 81e1db3c439c1758dccd1a20f2f6b70120f48ef7 > Make ShuffleMaster a cluster level

[jira] [Closed] (FLINK-22674) Provide JobID when apply shuffle resource by ShuffleMaster

2021-08-04 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22674?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu closed FLINK-22674. --- Resolution: Done Done via 6bc8399e7f1738ec22cb1082c096269b5106cee5 > Provide JobID when apply shuffle

[jira] [Assigned] (FLINK-22675) Add lifecycle methods to ShuffleMaster

2021-08-04 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22675?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu reassigned FLINK-22675: --- Assignee: Yingjie Cao (was: Zhu Zhu) > Add lifecycle methods to ShuffleMaster >

[jira] [Closed] (FLINK-22675) Add lifecycle methods to ShuffleMaster

2021-08-04 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22675?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu closed FLINK-22675. --- Resolution: Done Done via 80df36b51af791f67126e07e182015ea6ea73fd2 > Add lifecycle methods to

[jira] [Assigned] (FLINK-22674) Provide JobID when apply shuffle resource by ShuffleMaster

2021-08-04 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22674?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu reassigned FLINK-22674: --- Assignee: Yingjie Cao > Provide JobID when apply shuffle resource by ShuffleMaster >

[jira] [Assigned] (FLINK-22675) Add lifecycle methods to ShuffleMaster

2021-08-04 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22675?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu reassigned FLINK-22675: --- Assignee: Zhu Zhu > Add lifecycle methods to ShuffleMaster >

[jira] [Assigned] (FLINK-23214) Make ShuffleMaster a cluster level shared service

2021-08-04 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23214?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu reassigned FLINK-23214: --- Assignee: Yingjie Cao > Make ShuffleMaster a cluster level shared service >

[jira] [Assigned] (FLINK-23249) Introduce ShuffleMasterContext to ShuffleMaster

2021-08-04 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23249?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu reassigned FLINK-23249: --- Assignee: Yingjie Cao > Introduce ShuffleMasterContext to ShuffleMaster >

[jira] [Assigned] (FLINK-22910) Refine ShuffleMaster lifecycle management for pluggable shuffle service framework

2021-08-04 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22910?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu reassigned FLINK-22910: --- Assignee: Yingjie Cao > Refine ShuffleMaster lifecycle management for pluggable shuffle service >

[GitHub] [flink] godfreyhe commented on a change in pull request #16620: [FLINK-23246][table-planner] Refactor the time indicator materialization

2021-08-04 Thread GitBox
godfreyhe commented on a change in pull request #16620: URL: https://github.com/apache/flink/pull/16620#discussion_r683086290 ## File path: flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/calcite/RelTimeIndicatorConverter.java ## @@ -544,11

[jira] [Commented] (FLINK-23208) Late processing timers need to wait 1ms at least to be fired

2021-08-04 Thread Jiayi Liao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23208?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17393563#comment-17393563 ] Jiayi Liao commented on FLINK-23208: [~pnowojski] Yes. It's in-progress, I'm pretty busy these days

[GitHub] [flink] zhuzhurk closed pull request #16465: [FLINK-22910][runtime] Refine ShuffleMaster lifecycle management for pluggable shuffle service framework

2021-08-04 Thread GitBox
zhuzhurk closed pull request #16465: URL: https://github.com/apache/flink/pull/16465 -- 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. To unsubscribe, e-mail:

[GitHub] [flink] zhuzhurk commented on pull request #16465: [FLINK-22910][runtime] Refine ShuffleMaster lifecycle management for pluggable shuffle service framework

2021-08-04 Thread GitBox
zhuzhurk commented on pull request #16465: URL: https://github.com/apache/flink/pull/16465#issuecomment-893116856 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] flinkbot edited a comment on pull request #16670: [FLINK-23581][docs] Change site.download_url to https://flink.apache.…

2021-08-04 Thread GitBox
flinkbot edited a comment on pull request #16670: URL: https://github.com/apache/flink/pull/16670#issuecomment-890847824 ## CI report: * ad956a1a904b3b83ca4a9c505a35fafb0d83b713 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16599: [FLINK-23479][table-planner] Fix the unstable test cases about json plan

2021-08-04 Thread GitBox
flinkbot edited a comment on pull request #16599: URL: https://github.com/apache/flink/pull/16599#issuecomment-886750468 ## CI report: * 770b177feb77709640e01f6410fbed386daac997 Azure:

[jira] [Closed] (FLINK-23609) Codegen error of "Infinite or NaN at java.math.BigDecimal.(BigDecimal.java:898)"

2021-08-04 Thread xiaojin.wy (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23609?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xiaojin.wy closed FLINK-23609. -- Resolution: Won't Fix > Codegen error of "Infinite or NaN at >

[GitHub] [flink] tisonkun merged pull request #16662: [hotfix][connector][jdbc] Corrected exception variable name

2021-08-04 Thread GitBox
tisonkun merged pull request #16662: URL: https://github.com/apache/flink/pull/16662 -- 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. To unsubscribe, e-mail:

[jira] [Commented] (FLINK-23635) PrestoS3FileSystemITCase.testConfigKeysForwarding

2021-08-04 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23635?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17393558#comment-17393558 ] Xintong Song commented on FLINK-23635: --

[jira] [Comment Edited] (FLINK-23635) PrestoS3FileSystemITCase.testConfigKeysForwarding

2021-08-04 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23635?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17393545#comment-17393545 ] Xintong Song edited comment on FLINK-23635 at 8/5/21, 2:23 AM: --- cc

[jira] [Updated] (FLINK-23635) PrestoS3FileSystemITCase.testConfigKeysForwarding

2021-08-04 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23635?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-23635: - Priority: Blocker (was: Major) > PrestoS3FileSystemITCase.testConfigKeysForwarding >

[jira] [Commented] (FLINK-23635) PrestoS3FileSystemITCase.testConfigKeysForwarding

2021-08-04 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23635?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17393557#comment-17393557 ] Xintong Song commented on FLINK-23635: --

[jira] [Commented] (FLINK-23635) PrestoS3FileSystemITCase.testConfigKeysForwarding

2021-08-04 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23635?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17393554#comment-17393554 ] Xintong Song commented on FLINK-23635: --

[jira] [Commented] (FLINK-23635) PrestoS3FileSystemITCase.testConfigKeysForwarding

2021-08-04 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23635?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17393553#comment-17393553 ] Xintong Song commented on FLINK-23635: --

[jira] [Commented] (FLINK-23613) debezium and canal support read medata op and type

2021-08-04 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23613?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17393551#comment-17393551 ] Jark Wu commented on FLINK-23613: - > If I have a changlog stream and want to do some Agg by 'op', I

[GitHub] [flink] beyond1920 commented on a change in pull request #16620: [FLINK-23246][table-planner] Refactor the time indicator materialization

2021-08-04 Thread GitBox
beyond1920 commented on a change in pull request #16620: URL: https://github.com/apache/flink/pull/16620#discussion_r683078506 ## File path: flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/calcite/RelTimeIndicatorConverter.java ## @@ -544,11

[jira] [Comment Edited] (FLINK-23535) The value of option high-availability.cluster-id in flink-conf.yaml is replaced improperly

2021-08-04 Thread tim yu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23535?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17393042#comment-17393042 ] tim yu edited comment on FLINK-23535 at 8/5/21, 2:13 AM: - Hi [~jark], [~yunta],

[GitHub] [flink] hapihu commented on pull request #16670: [FLINK-23581][docs] Change site.download_url to https://flink.apache.…

2021-08-04 Thread GitBox
hapihu commented on pull request #16670: URL: https://github.com/apache/flink/pull/16670#issuecomment-893108772 Hi @zentol ,Would you like to review it for me again. Thank you very much! -- This is an automated message from the Apache Git Service. To respond to the message, please log

[GitHub] [flink] hapihu commented on pull request #16670: [FLINK-23581][docs] Change site.download_url to https://flink.apache.…

2021-08-04 Thread GitBox
hapihu commented on pull request #16670: URL: https://github.com/apache/flink/pull/16670#issuecomment-893108598 > @hapihu I'd like to ask for one more change to this PR. Can you please add a new shortcode (under `layouts/shortcodes`) called `downloads.html` that automatically picks the

[GitHub] [flink] godfreyhe commented on a change in pull request #16620: [FLINK-23246][table-planner] Refactor the time indicator materialization

2021-08-04 Thread GitBox
godfreyhe commented on a change in pull request #16620: URL: https://github.com/apache/flink/pull/16620#discussion_r683076322 ## File path: flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/stream/sql/DeduplicateTest.xml ## @@ -207,7

[jira] [Commented] (FLINK-23635) PrestoS3FileSystemITCase.testConfigKeysForwarding

2021-08-04 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23635?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17393545#comment-17393545 ] Xintong Song commented on FLINK-23635: -- cc [~airblader] Could this relate to FLINK-23487? >

[jira] [Created] (FLINK-23635) PrestoS3FileSystemITCase.testConfigKeysForwarding

2021-08-04 Thread Xintong Song (Jira)
Xintong Song created FLINK-23635: Summary: PrestoS3FileSystemITCase.testConfigKeysForwarding Key: FLINK-23635 URL: https://issues.apache.org/jira/browse/FLINK-23635 Project: Flink Issue

[jira] [Comment Edited] (FLINK-23613) debezium and canal support read medata op and type

2021-08-04 Thread Ward Harris (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23613?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17393544#comment-17393544 ] Ward Harris edited comment on FLINK-23613 at 8/5/21, 1:58 AM: -- 1. the table

[jira] [Commented] (FLINK-23613) debezium and canal support read medata op and type

2021-08-04 Thread Ward Harris (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23613?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17393544#comment-17393544 ] Ward Harris commented on FLINK-23613: - 1. the table the same as online {code:java} create table t1(

[jira] [Comment Edited] (FLINK-23613) debezium and canal support read medata op and type

2021-08-04 Thread Ward Harris (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23613?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17393544#comment-17393544 ] Ward Harris edited comment on FLINK-23613 at 8/5/21, 1:57 AM: -- 1. the table

[GitHub] [flink] flinkbot edited a comment on pull request #16707: [BP-1.13][FLINK-22891][runtime] Using CompletableFuture to sync the scheduling of checkResourceRequirements

2021-08-04 Thread GitBox
flinkbot edited a comment on pull request #16707: URL: https://github.com/apache/flink/pull/16707#issuecomment-892598138 ## CI report: * 7e65102a404e392c28e91823614503feec4d7637 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16599: [FLINK-23479][table-planner] Fix the unstable test cases about json plan

2021-08-04 Thread GitBox
flinkbot edited a comment on pull request #16599: URL: https://github.com/apache/flink/pull/16599#issuecomment-886750468 ## CI report: * 770b177feb77709640e01f6410fbed386daac997 Azure:

[jira] [Commented] (FLINK-23556) SQLClientSchemaRegistryITCase fails with " Subject ... not found"

2021-08-04 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23556?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17393543#comment-17393543 ] Xintong Song commented on FLINK-23556: --

[jira] [Commented] (FLINK-23634) BatchingStateChangeUploaderTest.testDelay fails on azure

2021-08-04 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23634?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17393542#comment-17393542 ] Xintong Song commented on FLINK-23634: -- cc [~roman_khachatryan] >

[jira] [Created] (FLINK-23634) BatchingStateChangeUploaderTest.testDelay fails on azure

2021-08-04 Thread Xintong Song (Jira)
Xintong Song created FLINK-23634: Summary: BatchingStateChangeUploaderTest.testDelay fails on azure Key: FLINK-23634 URL: https://issues.apache.org/jira/browse/FLINK-23634 Project: Flink

[GitHub] [flink] godfreyhe commented on a change in pull request #16620: [FLINK-23246][table-planner] Refactor the time indicator materialization

2021-08-04 Thread GitBox
godfreyhe commented on a change in pull request #16620: URL: https://github.com/apache/flink/pull/16620#discussion_r683071020 ## File path: flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/calcite/RelTimeIndicatorConverter.java ## @@ -544,11

[GitHub] [flink] godfreyhe commented on a change in pull request #16620: [FLINK-23246][table-planner] Refactor the time indicator materialization

2021-08-04 Thread GitBox
godfreyhe commented on a change in pull request #16620: URL: https://github.com/apache/flink/pull/16620#discussion_r683069888 ## File path: flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/calcite/RelTimeIndicatorConverter.java ## @@ -544,11

[GitHub] [flink] mans2singh commented on pull request #16662: [hotfix][connector][jdbc] Corrected exception variable name

2021-08-04 Thread GitBox
mans2singh commented on pull request #16662: URL: https://github.com/apache/flink/pull/16662#issuecomment-893099209 @tisonkun - Can you please review this PR and let me know your feedback ? Thanks -- This is an automated message from the Apache Git Service. To respond to the message,

[jira] [Closed] (FLINK-23529) Add Flink 1.13 MigrationVersion

2021-08-04 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23529?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song closed FLINK-23529. Resolution: Fixed Fixed via - master (1.14): 474366618ce80520783f27c959232f11f8f9a7d0 -

[GitHub] [flink] xintongsong closed pull request #16696: Port FLINK-23529 to 1.13

2021-08-04 Thread GitBox
xintongsong closed pull request #16696: URL: https://github.com/apache/flink/pull/16696 -- 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. To unsubscribe, e-mail:

[GitHub] [flink] xintongsong commented on pull request #16696: Port FLINK-23529 to 1.13

2021-08-04 Thread GitBox
xintongsong commented on pull request #16696: URL: https://github.com/apache/flink/pull/16696#issuecomment-893098621 da94745b1cf6342314e4e9b369f8c37c7132be79 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL

[jira] [Commented] (FLINK-23613) debezium and canal support read medata op and type

2021-08-04 Thread Ward Harris (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23613?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17393539#comment-17393539 ] Ward Harris commented on FLINK-23613: - [~jark] [~zoucao] thanks for your reply, here is what I want

[GitHub] [flink] flinkbot edited a comment on pull request #16707: [BP-1.13][FLINK-22891][runtime] Using CompletableFuture to sync the scheduling of checkResourceRequirements

2021-08-04 Thread GitBox
flinkbot edited a comment on pull request #16707: URL: https://github.com/apache/flink/pull/16707#issuecomment-892598138 ## CI report: * 7e65102a404e392c28e91823614503feec4d7637 Azure:

[GitHub] [flink] KarmaGYZ commented on pull request #16707: [BP-1.13][FLINK-22891][runtime] Using CompletableFuture to sync the scheduling of checkResourceRequirements

2021-08-04 Thread GitBox
KarmaGYZ commented on pull request #16707: URL: https://github.com/apache/flink/pull/16707#issuecomment-893088581 @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] flinkbot edited a comment on pull request #16699: [FLINK-23420][table-runtime] LinkedListSerializer now checks for null elements in the list

2021-08-04 Thread GitBox
flinkbot edited a comment on pull request #16699: URL: https://github.com/apache/flink/pull/16699#issuecomment-892415455 ## CI report: * 2628e78aff84d298c55e52428ab232be78b521a9 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16699: [FLINK-23420][table-runtime] LinkedListSerializer now checks for null elements in the list

2021-08-04 Thread GitBox
flinkbot edited a comment on pull request #16699: URL: https://github.com/apache/flink/pull/16699#issuecomment-892415455 ## CI report: * 2628e78aff84d298c55e52428ab232be78b521a9 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16559: [FLINK-18562] Support for Hadoop ABFS for Azure Datalake Gen2 accounts

2021-08-04 Thread GitBox
flinkbot edited a comment on pull request #16559: URL: https://github.com/apache/flink/pull/16559#issuecomment-884516771 ## CI report: * ed3c016be3eed47b71f31f761f2f1d7fabd186c0 Azure:

[GitHub] [flink] tsreaper commented on pull request #16699: [FLINK-23420][table-runtime] LinkedListSerializer now checks for null elements in the list

2021-08-04 Thread GitBox
tsreaper commented on pull request #16699: URL: https://github.com/apache/flink/pull/16699#issuecomment-893064811 @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] flinkbot edited a comment on pull request #16559: [FLINK-18562] Support for Hadoop ABFS for Azure Datalake Gen2 accounts

2021-08-04 Thread GitBox
flinkbot edited a comment on pull request #16559: URL: https://github.com/apache/flink/pull/16559#issuecomment-884516771 ## CI report: * ed3c016be3eed47b71f31f761f2f1d7fabd186c0 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16716: [FLINK-23631][docs] Fix the link for page zh/docs/dev/dataset/examples

2021-08-04 Thread GitBox
flinkbot edited a comment on pull request #16716: URL: https://github.com/apache/flink/pull/16716#issuecomment-892856220 ## CI report: * 8c87c7fe84db0d9590dc4209ba4cf08ba78d63d9 UNKNOWN * 94a40e7458a9c8cfa1582013a1e79851067b8de0 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16701: [FLINK-23617][datastream] Co-locate sink operators with same parallelism

2021-08-04 Thread GitBox
flinkbot edited a comment on pull request #16701: URL: https://github.com/apache/flink/pull/16701#issuecomment-892491133 ## CI report: * 34884c0567ded09b7413aaeffd8cc4d5819c3bd3 UNKNOWN * a8ac5bff7d0e18110d4bc7821af3667734cf90b7 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16559: [FLINK-18562] Support for Hadoop ABFS for Azure Datalake Gen2 accounts

2021-08-04 Thread GitBox
flinkbot edited a comment on pull request #16559: URL: https://github.com/apache/flink/pull/16559#issuecomment-884516771 ## CI report: * ed3c016be3eed47b71f31f761f2f1d7fabd186c0 Azure:

[GitHub] [flink] srinipunuru commented on a change in pull request #16559: [FLINK-18562] Support for Hadoop ABFS for Azure Datalake Gen2 accounts

2021-08-04 Thread GitBox
srinipunuru commented on a change in pull request #16559: URL: https://github.com/apache/flink/pull/16559#discussion_r683013180 ## File path: flink-filesystems/flink-s3-fs-presto/src/main/resources/META-INF/NOTICE ## @@ -34,14 +34,25 @@ This project bundles the following

[GitHub] [flink] flinkbot edited a comment on pull request #16716: [FLINK-23631][docs] Fix the link for page zh/docs/dev/dataset/examples

2021-08-04 Thread GitBox
flinkbot edited a comment on pull request #16716: URL: https://github.com/apache/flink/pull/16716#issuecomment-892856220 ## CI report: * 8c87c7fe84db0d9590dc4209ba4cf08ba78d63d9 UNKNOWN * ab4bd0c6b334df278465e43aea38f6097e625921 Azure:

[GitHub] [flink] srinipunuru commented on a change in pull request #16559: [FLINK-18562] Support for Hadoop ABFS for Azure Datalake Gen2 accounts

2021-08-04 Thread GitBox
srinipunuru commented on a change in pull request #16559: URL: https://github.com/apache/flink/pull/16559#discussion_r683012825 ## File path: flink-filesystems/flink-azure-fs-hadoop/src/main/java/org/apache/flink/fs/azurefs/AbstractAzureFSFactory.java ## @@ -75,18 +76,27 @@

[GitHub] [flink] flinkbot edited a comment on pull request #16559: [FLINK-18562] Support for Hadoop ABFS for Azure Datalake Gen2 accounts

2021-08-04 Thread GitBox
flinkbot edited a comment on pull request #16559: URL: https://github.com/apache/flink/pull/16559#issuecomment-884516771 ## CI report: * ed3c016be3eed47b71f31f761f2f1d7fabd186c0 Azure:

[jira] [Updated] (FLINK-8478) Add support for time-bounded joins in DataStream API

2021-08-04 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-8478?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-8478: -- Labels: auto-unassigned stale-major (was: auto-unassigned) I am the [Flink Jira

[jira] [Updated] (FLINK-10206) Add hbase sink connector

2021-08-04 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-10206?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-10206: --- Labels: auto-unassigned stale-major (was: auto-unassigned) I am the [Flink Jira

[jira] [Updated] (FLINK-12470) FLIP39: Flink ML pipeline and ML libs

2021-08-04 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-12470?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-12470: --- Labels: auto-unassigned pull-request-available stale-major (was: auto-unassigned

[jira] [Updated] (FLINK-11998) Flink Interactive Programming (Umbrella JIRA)

2021-08-04 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-11998?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-11998: --- Labels: auto-unassigned stale-major (was: auto-unassigned) I am the [Flink Jira

[jira] [Updated] (FLINK-8970) Add more automated end-to-end tests

2021-08-04 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-8970?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-8970: -- Labels: auto-unassigned stale-major (was: auto-unassigned) I am the [Flink Jira

  1   2   3   4   5   6   7   >