[GitHub] [flink] flinkbot edited a comment on pull request #18692: [FLINK-26015] Fixes object store bug

2022-02-10 Thread GitBox
flinkbot edited a comment on pull request #18692: URL: https://github.com/apache/flink/pull/18692#issuecomment-1034131249 ## CI report: * 395d56500dd767fbe64dcd56b6732e02ae4b3d0a Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18707: [FLINK-25995][table-planner] Make implicit assumption of SQL local hash explicit

2022-02-10 Thread GitBox
flinkbot edited a comment on pull request #18707: URL: https://github.com/apache/flink/pull/18707#issuecomment-1034994010 ## CI report: * 7e5e0f5f2aa79f47e79357721719cdcb971e32b3 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18710: [FLINK-26055][table][annotations] Modified CompiledPlan#getFlinkVersion return type to FlinkVersion

2022-02-10 Thread GitBox
flinkbot edited a comment on pull request #18710: URL: https://github.com/apache/flink/pull/18710#issuecomment-1035062536 ## CI report: * b7dc4ee5acd86161c61df1a11adb4df336d39900 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18058: [FLINK-24571][connectors/elasticsearch] Supports a system time function(now() and current_timestamp) in index pattern

2022-02-10 Thread GitBox
flinkbot edited a comment on pull request #18058: URL: https://github.com/apache/flink/pull/18058#issuecomment-988949831 ## CI report: * 93c33001cf55690369281de939bd79bb3727ad9a UNKNOWN * Unknown: [CANCELED](TBD) * 72a2c79d9516622a240993fe4a792a86dbfb59a2 Azure:

[jira] [Updated] (FLINK-26079) Disallow combination of Changelog backend with CLAIM restore mode

2022-02-10 Thread Roman Khachatryan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26079?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan updated FLINK-26079: -- Summary: Disallow combination of Changelog backend with CLAIM restore mode (was:

[jira] [Commented] (FLINK-25872) Restoring from non-changelog checkpoint with changelog state-backend enabled in CLAIM mode discards state in use

2022-02-10 Thread Roman Khachatryan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25872?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17490522#comment-17490522 ] Roman Khachatryan commented on FLINK-25872: --- I've created FLINK-26079 for disabling support

[jira] [Created] (FLINK-26079) Disallow combination of Changelog backend and CLAIM restore mode

2022-02-10 Thread Roman Khachatryan (Jira)
Roman Khachatryan created FLINK-26079: - Summary: Disallow combination of Changelog backend and CLAIM restore mode Key: FLINK-26079 URL: https://issues.apache.org/jira/browse/FLINK-26079 Project:

[GitHub] [flink] flinkbot edited a comment on pull request #18664: [FLINK-25907][runtime][security] Add pluggable delegation token manager

2022-02-10 Thread GitBox
flinkbot edited a comment on pull request #18664: URL: https://github.com/apache/flink/pull/18664#issuecomment-1032585099 ## CI report: * 01046c38b403a797e9228a434d194144e6eed82b Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18701: [FLINK-26071][table-api-java][table-planner] Now Planner#compilePlan fails if the plan cannot be serialized

2022-02-10 Thread GitBox
flinkbot edited a comment on pull request #18701: URL: https://github.com/apache/flink/pull/18701#issuecomment-1034766277 ## CI report: * c2b74e16dc3528608d017847c2f9856cbabf227e Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18664: [FLINK-25907][runtime][security] Add pluggable delegation token manager

2022-02-10 Thread GitBox
flinkbot edited a comment on pull request #18664: URL: https://github.com/apache/flink/pull/18664#issuecomment-1032585099 ## CI report: * 01046c38b403a797e9228a434d194144e6eed82b Azure:

[GitHub] [flink] gaborgsomogyi commented on pull request #18664: [FLINK-25907][runtime][security] Add pluggable delegation token manager

2022-02-10 Thread GitBox
gaborgsomogyi commented on pull request #18664: URL: https://github.com/apache/flink/pull/18664#issuecomment-1035515856 @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 #18667: [FLINK-25990][table] Expose uid generator for DataStream/Transformation providers

2022-02-10 Thread GitBox
flinkbot edited a comment on pull request #18667: URL: https://github.com/apache/flink/pull/18667#issuecomment-1032823071 ## CI report: * ca7a596b31ce7e89969dcf7bf58b9a7cdea38310 Azure:

[GitHub] [flink] XComp commented on a change in pull request #18692: [FLINK-26015] Fixes object store bug

2022-02-10 Thread GitBox
XComp commented on a change in pull request #18692: URL: https://github.com/apache/flink/pull/18692#discussion_r804103917 ## File path: flink-filesystems/flink-s3-fs-presto/src/test/java/org/apache/flink/fs/s3presto/MinioTestContainer.java ## @@ -0,0 +1,146 @@ +/* + *

[GitHub] [flink] flinkbot edited a comment on pull request #18709: [FLINK-26076] Fix ArchUnit violations in Source(Sink)MetricsITCase

2022-02-10 Thread GitBox
flinkbot edited a comment on pull request #18709: URL: https://github.com/apache/flink/pull/18709#issuecomment-1035050631 ## CI report: * 17f2ffbe7f9a8dd9315e7ee8c1cc3acad30728bc Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18696: [hotfix][docs] project config pages

2022-02-10 Thread GitBox
flinkbot edited a comment on pull request #18696: URL: https://github.com/apache/flink/pull/18696#issuecomment-1034481691 ## CI report: * ccb88999c20036553d971851cdc0c38670fb102a Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18706: [FLINK-26072][Connectors][NiFi] Mark NiFi Source and Sink as deprecated

2022-02-10 Thread GitBox
flinkbot edited a comment on pull request #18706: URL: https://github.com/apache/flink/pull/18706#issuecomment-1034953890 ## CI report: * 12773467f6c3eebf4dcd2befcb0bb323c706b6c7 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18603: [FLINK-25610][connector/firehose] Adding table api base for kinesis firehose

2022-02-10 Thread GitBox
flinkbot edited a comment on pull request #18603: URL: https://github.com/apache/flink/pull/18603#issuecomment-1027853740 ## CI report: * 2dd554c9e2fc7ed8e66821805190b4e2ae9c7ebf Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18153: [FLINK-25568][connectors/elasticsearch] Add Elasticsearch 7 Source

2022-02-10 Thread GitBox
flinkbot edited a comment on pull request #18153: URL: https://github.com/apache/flink/pull/18153#issuecomment-997756404 ## CI report: * aab3087762ad1405ff910b1573f7307317a3ccd4 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18689: [FLINK-21439][runtime] Exception history adaptive scheduler

2022-02-10 Thread GitBox
flinkbot edited a comment on pull request #18689: URL: https://github.com/apache/flink/pull/18689#issuecomment-1033918208 ## CI report: * 9568936fd04ca5bea92dc58e578a266c04eaf35a Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16584: [FLINK-22781][table-planner-blink] Fix bug that when implements the L…

2022-02-10 Thread GitBox
flinkbot edited a comment on pull request #16584: URL: https://github.com/apache/flink/pull/16584#issuecomment-885710999 ## CI report: * 597398ed8010c365dda03ccd590dce85e36eb7a8 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18694: [FLINK-26062][state/changelog] Replace poll() with remove() for PQ states

2022-02-10 Thread GitBox
flinkbot edited a comment on pull request #18694: URL: https://github.com/apache/flink/pull/18694#issuecomment-1034158633 ## CI report: * 7d30f95525f934e440c834cd032ca06cfabf98a7 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18705: [FLINK-26073][Connectors][Twitter] Remove Twitter connector

2022-02-10 Thread GitBox
flinkbot edited a comment on pull request #18705: URL: https://github.com/apache/flink/pull/18705#issuecomment-1034936625 ## CI report: * b303ba40b73e934b6f113fd8875c0725f1256913 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18669: [FLINK-25943][connector/common] Add buffered requests to snapshot state in AsyncSyncWriter.

2022-02-10 Thread GitBox
flinkbot edited a comment on pull request #18669: URL: https://github.com/apache/flink/pull/18669#issuecomment-1033040800 ## CI report: * f7b2480909019bf786dcc9d58680be202458e2c4 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18553: [FLINK-25846][FLINK-25848] Async Sink does not gracefully shutdown on Cancel, KDS Sink does not fast fail when invalid configuration

2022-02-10 Thread GitBox
flinkbot edited a comment on pull request #18553: URL: https://github.com/apache/flink/pull/18553#issuecomment-1024127153 ## CI report: * eae81dc84402215df5d19aa0687ae2f4a0e376fd UNKNOWN * Unknown: [CANCELED](TBD) * 35eed39d242dc7745b7fe09f15e56ee553eb3204 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18702: [FLINK-24441][source] Block SourceOperator when watermarks are out of alignment

2022-02-10 Thread GitBox
flinkbot edited a comment on pull request #18702: URL: https://github.com/apache/flink/pull/18702#issuecomment-1034842544 ## CI report: * 065960d2962be7fc5df6098a93cab9e94df7b6ff Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18553: [FLINK-25846][FLINK-25848] Async Sink does not gracefully shutdown on Cancel, KDS Sink does not fast fail when invalid configuration

2022-02-10 Thread GitBox
flinkbot edited a comment on pull request #18553: URL: https://github.com/apache/flink/pull/18553#issuecomment-1024127153 ## CI report: * eae81dc84402215df5d19aa0687ae2f4a0e376fd UNKNOWN * Unknown: [CANCELED](TBD) * 35eed39d242dc7745b7fe09f15e56ee553eb3204 UNKNOWN

[GitHub] [flink] flinkbot edited a comment on pull request #18692: [FLINK-26015] Fixes object store bug

2022-02-10 Thread GitBox
flinkbot edited a comment on pull request #18692: URL: https://github.com/apache/flink/pull/18692#issuecomment-1034131249 ## CI report: * b20d5b2c72912bd1d97cd61d3c38da95c52700a8 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18553: [FLINK-25846][FLINK-25848] Async Sink does not gracefully shutdown on Cancel, KDS Sink does not fast fail when invalid configuration

2022-02-10 Thread GitBox
flinkbot edited a comment on pull request #18553: URL: https://github.com/apache/flink/pull/18553#issuecomment-1024127153 ## CI report: * eae81dc84402215df5d19aa0687ae2f4a0e376fd UNKNOWN * Unknown: [CANCELED](TBD) Bot commands The @flinkbot bot supports the

[jira] [Commented] (FLINK-26036) LocalRecoveryITCase.testRecoverLocallyFromProcessCrashWithWorkingDirectory timeout on azure

2022-02-10 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26036?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17490470#comment-17490470 ] Piotr Nowojski commented on FLINK-26036:

[GitHub] [flink] flinkbot edited a comment on pull request #18707: [FLINK-25995][table-planner] Make implicit assumption of SQL local hash explicit

2022-02-10 Thread GitBox
flinkbot edited a comment on pull request #18707: URL: https://github.com/apache/flink/pull/18707#issuecomment-1034994010 ## CI report: * 5e2128cc02aa0cfdb9b074edd5b0cab02c3daed6 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18637: [FLINK-25433][runtime] Adds retry mechanism to DefaultResourceCleaner

2022-02-10 Thread GitBox
flinkbot edited a comment on pull request #18637: URL: https://github.com/apache/flink/pull/18637#issuecomment-1030235273 ## CI report: * 7a1f59c89cc282433be0c496e30275f004be7a89 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18553: [FLINK-25846][FLINK-25848] Async Sink does not gracefully shutdown on Cancel, KDS Sink does not fast fail when invalid configuration

2022-02-10 Thread GitBox
flinkbot edited a comment on pull request #18553: URL: https://github.com/apache/flink/pull/18553#issuecomment-1024127153 ## CI report: * eae81dc84402215df5d19aa0687ae2f4a0e376fd UNKNOWN * Unknown: [CANCELED](TBD) * 35eed39d242dc7745b7fe09f15e56ee553eb3204 UNKNOWN

[GitHub] [flink] flinkbot edited a comment on pull request #18553: [FLINK-25846][FLINK-25848] Async Sink does not gracefully shutdown on Cancel, KDS Sink does not fast fail when invalid configuration

2022-02-10 Thread GitBox
flinkbot edited a comment on pull request #18553: URL: https://github.com/apache/flink/pull/18553#issuecomment-1024127153 ## CI report: * eae81dc84402215df5d19aa0687ae2f4a0e376fd UNKNOWN * Unknown: [CANCELED](TBD) Bot commands The @flinkbot bot supports the

[GitHub] [flink] dmvk commented on pull request #18553: [FLINK-25846][FLINK-25848] Async Sink does not gracefully shutdown on Cancel, KDS Sink does not fast fail when invalid configuration supplied

2022-02-10 Thread GitBox
dmvk commented on pull request #18553: URL: https://github.com/apache/flink/pull/18553#issuecomment-1035379576 Here is the code I've used during debugging, it could provide some more context for understanding the issue better. https://gist.github.com/dmvk/6f3fbf5a6432becd076a9f7989ab8bdd

[GitHub] [flink] flinkbot edited a comment on pull request #18693: [FLINK-25987][state/changelog] Make lastAppendedSqn optional

2022-02-10 Thread GitBox
flinkbot edited a comment on pull request #18693: URL: https://github.com/apache/flink/pull/18693#issuecomment-1034140883 ## CI report: * b34ba68d832332d79137cfe1ff45cd1efae38e41 Azure:

[GitHub] [flink] dmvk commented on pull request #18553: [FLINK-25846][FLINK-25848] Async Sink does not gracefully shutdown on Cancel, KDS Sink does not fast fail when invalid configuration supplied

2022-02-10 Thread GitBox
dmvk commented on pull request #18553: URL: https://github.com/apache/flink/pull/18553#issuecomment-1035377072 This issue is also present in other modules that are using the AWS HTTP client. -- This is an automated message from the Apache Git Service. To respond to the message, please

[GitHub] [flink] flinkbot edited a comment on pull request #18686: [FLINK-25977][connectors/kinesis] Closing http & sdk clients in sink …

2022-02-10 Thread GitBox
flinkbot edited a comment on pull request #18686: URL: https://github.com/apache/flink/pull/18686#issuecomment-1033839484 ## CI report: * Unknown: [CANCELED](TBD) * 00da3d82453c8977bf69fc5843f1cba9c39ac5a8 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18553: [FLINK-25846][FLINK-25848] Async Sink does not gracefully shutdown on Cancel, KDS Sink does not fast fail when invalid configuration

2022-02-10 Thread GitBox
flinkbot edited a comment on pull request #18553: URL: https://github.com/apache/flink/pull/18553#issuecomment-1024127153 ## CI report: * eae81dc84402215df5d19aa0687ae2f4a0e376fd UNKNOWN * Unknown: [CANCELED](TBD) * 35eed39d242dc7745b7fe09f15e56ee553eb3204 UNKNOWN

[jira] [Commented] (FLINK-26064) KinesisFirehoseSinkITCase IllegalStateException: Trying to access closed classloader

2022-02-10 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-26064?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17490456#comment-17490456 ] David Morávek commented on FLINK-26064: --- There is actually not a problem with reusing http

[GitHub] [flink] dmvk commented on pull request #18553: [FLINK-25846][FLINK-25848] Async Sink does not gracefully shutdown on Cancel, KDS Sink does not fast fail when invalid configuration supplied

2022-02-10 Thread GitBox
dmvk commented on pull request #18553: URL: https://github.com/apache/flink/pull/18553#issuecomment-1035369952 So there is actually not a problem with reusing clients, it just makes the root cause more visible for some reason. The actual problem is that if the underlying netty event

[GitHub] [flink] flinkbot edited a comment on pull request #18686: [FLINK-25977][connectors/kinesis] Closing http & sdk clients in sink …

2022-02-10 Thread GitBox
flinkbot edited a comment on pull request #18686: URL: https://github.com/apache/flink/pull/18686#issuecomment-1033839484 ## CI report: * Unknown: [CANCELED](TBD) * 00da3d82453c8977bf69fc5843f1cba9c39ac5a8 Azure:

[GitHub] [flink] CrynetLogistics commented on pull request #18553: [FLINK-25846][FLINK-25848] Async Sink does not gracefully shutdown on Cancel, KDS Sink does not fast fail when invalid configuration

2022-02-10 Thread GitBox
CrynetLogistics commented on pull request #18553: URL: https://github.com/apache/flink/pull/18553#issuecomment-1035367682 @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 #18553: [FLINK-25846][FLINK-25848] Async Sink does not gracefully shutdown on Cancel, KDS Sink does not fast fail when invalid configuration

2022-02-10 Thread GitBox
flinkbot edited a comment on pull request #18553: URL: https://github.com/apache/flink/pull/18553#issuecomment-1024127153 ## CI report: * eae81dc84402215df5d19aa0687ae2f4a0e376fd UNKNOWN * 2ae4a03cd24f6ea6e6231e278a90fd1cb7840319 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18706: [FLINK-26072][Connectors][NiFi] Mark NiFi Source and Sink as deprecated

2022-02-10 Thread GitBox
flinkbot edited a comment on pull request #18706: URL: https://github.com/apache/flink/pull/18706#issuecomment-1034953890 ## CI report: * f104642af11fced6f110afd39424871efa89ae9f Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18701: [FLINK-26071][table-api-java][table-planner] Now Planner#compilePlan fails if the plan cannot be serialized

2022-02-10 Thread GitBox
flinkbot edited a comment on pull request #18701: URL: https://github.com/apache/flink/pull/18701#issuecomment-1034766277 ## CI report: * c2e56d970d3d0e19d4534ca60f98d21b9d0764d1 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18686: [FLINK-25977][connectors/kinesis] Closing http & sdk clients in sink …

2022-02-10 Thread GitBox
flinkbot edited a comment on pull request #18686: URL: https://github.com/apache/flink/pull/18686#issuecomment-1033839484 ## CI report: * Unknown: [CANCELED](TBD) * 00da3d82453c8977bf69fc5843f1cba9c39ac5a8 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18553: [FLINK-25846][FLINK-25848] Async Sink does not gracefully shutdown on Cancel, KDS Sink does not fast fail when invalid configuration

2022-02-10 Thread GitBox
flinkbot edited a comment on pull request #18553: URL: https://github.com/apache/flink/pull/18553#issuecomment-1024127153 ## CI report: * eae81dc84402215df5d19aa0687ae2f4a0e376fd UNKNOWN * 2ae4a03cd24f6ea6e6231e278a90fd1cb7840319 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18686: [FLINK-25977][connectors/kinesis] Closing http & sdk clients in sink …

2022-02-10 Thread GitBox
flinkbot edited a comment on pull request #18686: URL: https://github.com/apache/flink/pull/18686#issuecomment-1033839484 ## CI report: * Unknown: [CANCELED](TBD) * 00da3d82453c8977bf69fc5843f1cba9c39ac5a8 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18553: [FLINK-25846][FLINK-25848] Async Sink does not gracefully shutdown on Cancel, KDS Sink does not fast fail when invalid configuration

2022-02-10 Thread GitBox
flinkbot edited a comment on pull request #18553: URL: https://github.com/apache/flink/pull/18553#issuecomment-1024127153 ## CI report: * eae81dc84402215df5d19aa0687ae2f4a0e376fd UNKNOWN * 2ae4a03cd24f6ea6e6231e278a90fd1cb7840319 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18686: [FLINK-25977][connectors/kinesis] Closing http & sdk clients in sink …

2022-02-10 Thread GitBox
flinkbot edited a comment on pull request #18686: URL: https://github.com/apache/flink/pull/18686#issuecomment-1033839484 ## CI report: * Unknown: [CANCELED](TBD) * 00da3d82453c8977bf69fc5843f1cba9c39ac5a8 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18624: [FLINK-25388][table-planner] Add consumedOptions to ExecNodeMetadata

2022-02-10 Thread GitBox
flinkbot edited a comment on pull request #18624: URL: https://github.com/apache/flink/pull/18624#issuecomment-1029176049 ## CI report: * 135b18a48b23afa0a28cde1ff570304bd0326101 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18553: [FLINK-25846][FLINK-25848] Async Sink does not gracefully shutdown on Cancel, KDS Sink does not fast fail when invalid configuration

2022-02-10 Thread GitBox
flinkbot edited a comment on pull request #18553: URL: https://github.com/apache/flink/pull/18553#issuecomment-1024127153 ## CI report: * eae81dc84402215df5d19aa0687ae2f4a0e376fd UNKNOWN * 2ae4a03cd24f6ea6e6231e278a90fd1cb7840319 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18686: [FLINK-25977][connectors/kinesis] Closing http & sdk clients in sink …

2022-02-10 Thread GitBox
flinkbot edited a comment on pull request #18686: URL: https://github.com/apache/flink/pull/18686#issuecomment-1033839484 ## CI report: * Unknown: [CANCELED](TBD) * 00da3d82453c8977bf69fc5843f1cba9c39ac5a8 Azure:

[jira] [Updated] (FLINK-26078) Initial Kubernetes Operator Prototype contribution

2022-02-10 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26078?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora updated FLINK-26078: --- Component/s: Deployment / Kubernetes > Initial Kubernetes Operator Prototype contribution >

[GitHub] [flink] flinkbot edited a comment on pull request #18553: [FLINK-25846][FLINK-25848] Async Sink does not gracefully shutdown on Cancel, KDS Sink does not fast fail when invalid configuration

2022-02-10 Thread GitBox
flinkbot edited a comment on pull request #18553: URL: https://github.com/apache/flink/pull/18553#issuecomment-1024127153 ## CI report: * eae81dc84402215df5d19aa0687ae2f4a0e376fd UNKNOWN * 2ae4a03cd24f6ea6e6231e278a90fd1cb7840319 Azure:

[jira] [Created] (FLINK-26078) Initial Kubernetes Operator Prototype contribution

2022-02-10 Thread Gyula Fora (Jira)
Gyula Fora created FLINK-26078: -- Summary: Initial Kubernetes Operator Prototype contribution Key: FLINK-26078 URL: https://issues.apache.org/jira/browse/FLINK-26078 Project: Flink Issue Type:

[GitHub] [flink] flinkbot edited a comment on pull request #18686: [FLINK-25977][connectors/kinesis] Closing http & sdk clients in sink …

2022-02-10 Thread GitBox
flinkbot edited a comment on pull request #18686: URL: https://github.com/apache/flink/pull/18686#issuecomment-1033839484 ## CI report: * Unknown: [CANCELED](TBD) * 00da3d82453c8977bf69fc5843f1cba9c39ac5a8 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18603: [FLINK-25610][connector/firehose] Adding table api base for kinesis firehose

2022-02-10 Thread GitBox
flinkbot edited a comment on pull request #18603: URL: https://github.com/apache/flink/pull/18603#issuecomment-1027853740 ## CI report: * 212445d147cbd0174d8735b651c242d2cceb7570 Azure:

[GitHub] [flink] CrynetLogistics commented on pull request #18553: [FLINK-25846][FLINK-25848] Async Sink does not gracefully shutdown on Cancel, KDS Sink does not fast fail when invalid configuration

2022-02-10 Thread GitBox
CrynetLogistics commented on pull request #18553: URL: https://github.com/apache/flink/pull/18553#issuecomment-1035325183 || @dannycranmer || Why did you split out to separate HTTP clients? I will revert to the previous, where it is using a single http client. Please continue

[jira] [Closed] (FLINK-25998) Flink akka runs into NoClassDefFoundError on shutdown

2022-02-10 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25998?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger closed FLINK-25998. -- Resolution: Won't Fix > Flink akka runs into NoClassDefFoundError on shutdown >

[jira] [Updated] (FLINK-25998) Flink akka runs into NoClassDefFoundError on shutdown

2022-02-10 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25998?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-25998: --- Priority: Minor (was: Major) > Flink akka runs into NoClassDefFoundError on shutdown >

[jira] [Commented] (FLINK-25998) Flink akka runs into NoClassDefFoundError on shutdown

2022-02-10 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17490431#comment-17490431 ] Robert Metzger commented on FLINK-25998: Okay, I see. I'm closing the ticket for now. > Flink

[GitHub] [flink] flinkbot edited a comment on pull request #18686: [FLINK-25977][connectors/kinesis] Closing http & sdk clients in sink …

2022-02-10 Thread GitBox
flinkbot edited a comment on pull request #18686: URL: https://github.com/apache/flink/pull/18686#issuecomment-1033839484 ## CI report: * Unknown: [CANCELED](TBD) * 00da3d82453c8977bf69fc5843f1cba9c39ac5a8 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18603: [FLINK-25610][connector/firehose] Adding table api base for kinesis firehose

2022-02-10 Thread GitBox
flinkbot edited a comment on pull request #18603: URL: https://github.com/apache/flink/pull/18603#issuecomment-1027853740 ## CI report: * 212445d147cbd0174d8735b651c242d2cceb7570 Azure:

[GitHub] [flink] CrynetLogistics commented on pull request #18686: [FLINK-25977][connectors/kinesis] Closing http & sdk clients in sink …

2022-02-10 Thread GitBox
CrynetLogistics commented on pull request #18686: URL: https://github.com/apache/flink/pull/18686#issuecomment-1035314761 @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] CrynetLogistics commented on pull request #18686: [FLINK-25977][connectors/kinesis] Closing http & sdk clients in sink …

2022-02-10 Thread GitBox
CrynetLogistics commented on pull request #18686: URL: https://github.com/apache/flink/pull/18686#issuecomment-1035314558 Changes complete. -- 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 #18704: [FLINK-26054][table-planner][build] Add enforcer rule to disable direct dependency on table planner

2022-02-10 Thread GitBox
flinkbot edited a comment on pull request #18704: URL: https://github.com/apache/flink/pull/18704#issuecomment-1034913098 ## CI report: * 06af5845ff7cb107455d48cdca7c5ed0bd04a286 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18701: [FLINK-26071][table-api-java][table-planner] Now Planner#compilePlan fails if the plan cannot be serialized

2022-02-10 Thread GitBox
flinkbot edited a comment on pull request #18701: URL: https://github.com/apache/flink/pull/18701#issuecomment-1034766277 ## CI report: * c2e56d970d3d0e19d4534ca60f98d21b9d0764d1 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18686: [FLINK-25977][connectors/kinesis] Closing http & sdk clients in sink …

2022-02-10 Thread GitBox
flinkbot edited a comment on pull request #18686: URL: https://github.com/apache/flink/pull/18686#issuecomment-1033839484 ## CI report: * Unknown: [CANCELED](TBD) * 00da3d82453c8977bf69fc5843f1cba9c39ac5a8 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18603: [FLINK-25610][connector/firehose] Adding table api base for kinesis firehose

2022-02-10 Thread GitBox
flinkbot edited a comment on pull request #18603: URL: https://github.com/apache/flink/pull/18603#issuecomment-1027853740 ## CI report: * 212445d147cbd0174d8735b651c242d2cceb7570 Azure:

[GitHub] [flink] CrynetLogistics commented on a change in pull request #18686: [FLINK-25977][connectors/kinesis] Closing http & sdk clients in sink …

2022-02-10 Thread GitBox
CrynetLogistics commented on a change in pull request #18686: URL: https://github.com/apache/flink/pull/18686#discussion_r803994172 ## File path:

[GitHub] [flink] CrynetLogistics commented on pull request #18686: [FLINK-25977][connectors/kinesis] Closing http & sdk clients in sink …

2022-02-10 Thread GitBox
CrynetLogistics commented on pull request #18686: URL: https://github.com/apache/flink/pull/18686#issuecomment-1035305726 -- 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] CrynetLogistics commented on a change in pull request #18686: [FLINK-25977][connectors/kinesis] Closing http & sdk clients in sink …

2022-02-10 Thread GitBox
CrynetLogistics commented on a change in pull request #18686: URL: https://github.com/apache/flink/pull/18686#discussion_r803991788 ## File path:

[GitHub] [flink] flinkbot edited a comment on pull request #18701: [FLINK-26071][table-api-java][table-planner] Now Planner#compilePlan fails if the plan cannot be serialized

2022-02-10 Thread GitBox
flinkbot edited a comment on pull request #18701: URL: https://github.com/apache/flink/pull/18701#issuecomment-1034766277 ## CI report: * c2e56d970d3d0e19d4534ca60f98d21b9d0764d1 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18686: [FLINK-25977][connectors/kinesis] Closing http & sdk clients in sink …

2022-02-10 Thread GitBox
flinkbot edited a comment on pull request #18686: URL: https://github.com/apache/flink/pull/18686#issuecomment-1033839484 ## CI report: * Unknown: [CANCELED](TBD) * 00da3d82453c8977bf69fc5843f1cba9c39ac5a8 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18603: [FLINK-25610][connector/firehose] Adding table api base for kinesis firehose

2022-02-10 Thread GitBox
flinkbot edited a comment on pull request #18603: URL: https://github.com/apache/flink/pull/18603#issuecomment-1027853740 ## CI report: * 212445d147cbd0174d8735b651c242d2cceb7570 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18153: [FLINK-25568][connectors/elasticsearch] Add Elasticsearch 7 Source

2022-02-10 Thread GitBox
flinkbot edited a comment on pull request #18153: URL: https://github.com/apache/flink/pull/18153#issuecomment-997756404 ## CI report: * cb936e98d7be5f4898c3c087dd28d6c2a907304b Azure:

[GitHub] [flink] CrynetLogistics commented on pull request #18686: [FLINK-25977][connectors/kinesis] Closing http & sdk clients in sink …

2022-02-10 Thread GitBox
CrynetLogistics commented on pull request #18686: URL: https://github.com/apache/flink/pull/18686#issuecomment-1035289356 -- 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 #18653: [FLINK-25825][connector-jdbc] MySqlCatalogITCase fails on azure

2022-02-10 Thread GitBox
flinkbot edited a comment on pull request #18653: URL: https://github.com/apache/flink/pull/18653#issuecomment-1032212433 ## CI report: * 1c96c6553cd12da3d699383ec26353315864871a Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18603: [FLINK-25610][connector/firehose] Adding table api base for kinesis firehose

2022-02-10 Thread GitBox
flinkbot edited a comment on pull request #18603: URL: https://github.com/apache/flink/pull/18603#issuecomment-1027853740 ## CI report: * 212445d147cbd0174d8735b651c242d2cceb7570 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18708: Flink 25610 firehose connector backup

2022-02-10 Thread GitBox
flinkbot edited a comment on pull request #18708: URL: https://github.com/apache/flink/pull/18708#issuecomment-1035039830 ## CI report: * 6e752a3332dd1b2f7b256f54d6aa662f8bacc4ba Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18686: [FLINK-25977][connectors/kinesis] Closing http & sdk clients in sink …

2022-02-10 Thread GitBox
flinkbot edited a comment on pull request #18686: URL: https://github.com/apache/flink/pull/18686#issuecomment-1033839484 ## CI report: * f68e30a5f1f5ab294acc51f0b3417d09829f423e Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18603: [FLINK-25610][connector/firehose] Adding table api base for kinesis firehose

2022-02-10 Thread GitBox
flinkbot edited a comment on pull request #18603: URL: https://github.com/apache/flink/pull/18603#issuecomment-1027853740 ## CI report: * 212445d147cbd0174d8735b651c242d2cceb7570 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18686: [FLINK-25977][connectors/kinesis] Closing http & sdk clients in sink …

2022-02-10 Thread GitBox
flinkbot edited a comment on pull request #18686: URL: https://github.com/apache/flink/pull/18686#issuecomment-1033839484 ## CI report: * f68e30a5f1f5ab294acc51f0b3417d09829f423e Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18603: [FLINK-25610][connector/firehose] Adding table api base for kinesis firehose

2022-02-10 Thread GitBox
flinkbot edited a comment on pull request #18603: URL: https://github.com/apache/flink/pull/18603#issuecomment-1027853740 ## CI report: * 212445d147cbd0174d8735b651c242d2cceb7570 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18693: [FLINK-25987][state/changelog] Make lastAppendedSqn optional

2022-02-10 Thread GitBox
flinkbot edited a comment on pull request #18693: URL: https://github.com/apache/flink/pull/18693#issuecomment-1034140883 ## CI report: * 3e33bf10866f986c2778b5ed8f9fb183aadeb11d Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18603: [FLINK-25610][connector/firehose] Adding table api base for kinesis firehose

2022-02-10 Thread GitBox
flinkbot edited a comment on pull request #18603: URL: https://github.com/apache/flink/pull/18603#issuecomment-1027853740 ## CI report: * 212445d147cbd0174d8735b651c242d2cceb7570 Azure:

[GitHub] [flink] rkhachatryan commented on a change in pull request #18391: [FLINK-25478][chaneglog] Correct the state register logic of ChangelogStateBackendHandle

2022-02-10 Thread GitBox
rkhachatryan commented on a change in pull request #18391: URL: https://github.com/apache/flink/pull/18391#discussion_r803954550 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/metadata/MetadataV2V3SerializerBase.java ## @@ -415,7 +440,7 @@

[GitHub] [flink] flinkbot edited a comment on pull request #18603: [FLINK-25610][connector/firehose] Adding table api base for kinesis firehose

2022-02-10 Thread GitBox
flinkbot edited a comment on pull request #18603: URL: https://github.com/apache/flink/pull/18603#issuecomment-1027853740 ## CI report: * 212445d147cbd0174d8735b651c242d2cceb7570 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18669: [FLINK-25943][connector/common] Add buffered requests to snapshot state in AsyncSyncWriter.

2022-02-10 Thread GitBox
flinkbot edited a comment on pull request #18669: URL: https://github.com/apache/flink/pull/18669#issuecomment-1033040800 ## CI report: * 0821dc818041b4be18d1327b9f5d5ca18deff594 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18603: [FLINK-25610][connector/firehose] Adding table api base for kinesis firehose

2022-02-10 Thread GitBox
flinkbot edited a comment on pull request #18603: URL: https://github.com/apache/flink/pull/18603#issuecomment-1027853740 ## CI report: * 212445d147cbd0174d8735b651c242d2cceb7570 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18701: [FLINK-26071][table-api-java][table-planner] Now Planner#compilePlan fails if the plan cannot be serialized

2022-02-10 Thread GitBox
flinkbot edited a comment on pull request #18701: URL: https://github.com/apache/flink/pull/18701#issuecomment-1034766277 ## CI report: * e001ada7d0947721903b47ce861fe0ac846ea2db Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18686: [FLINK-25977][connectors/kinesis] Closing http & sdk clients in sink …

2022-02-10 Thread GitBox
flinkbot edited a comment on pull request #18686: URL: https://github.com/apache/flink/pull/18686#issuecomment-1033839484 ## CI report: * f68e30a5f1f5ab294acc51f0b3417d09829f423e Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18603: [FLINK-25610][connector/firehose] Adding table api base for kinesis firehose

2022-02-10 Thread GitBox
flinkbot edited a comment on pull request #18603: URL: https://github.com/apache/flink/pull/18603#issuecomment-1027853740 ## CI report: * 212445d147cbd0174d8735b651c242d2cceb7570 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18603: [FLINK-25610][connector/firehose] Adding table api base for kinesis firehose

2022-02-10 Thread GitBox
flinkbot edited a comment on pull request #18603: URL: https://github.com/apache/flink/pull/18603#issuecomment-1027853740 ## CI report: * 212445d147cbd0174d8735b651c242d2cceb7570 Azure:

[GitHub] [flink] CrynetLogistics commented on a change in pull request #18553: [FLINK-25846][FLINK-25848] Async Sink does not gracefully shutdown on Cancel, KDS Sink does not fast fail when invalid co

2022-02-10 Thread GitBox
CrynetLogistics commented on a change in pull request #18553: URL: https://github.com/apache/flink/pull/18553#discussion_r803916593 ## File path:

[GitHub] [flink] flinkbot edited a comment on pull request #18692: [FLINK-26015] Fixes object store bug

2022-02-10 Thread GitBox
flinkbot edited a comment on pull request #18692: URL: https://github.com/apache/flink/pull/18692#issuecomment-1034131249 ## CI report: * 7645e2a83b9789816399536fbf369dc65eafcbf7 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18689: [FLINK-21439][runtime] Exception history adaptive scheduler

2022-02-10 Thread GitBox
flinkbot edited a comment on pull request #18689: URL: https://github.com/apache/flink/pull/18689#issuecomment-1033918208 ## CI report: * 45c9c7931377fa16988a1a25985c028907047274 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18702: [FLINK-24441][source] Block SourceOperator when watermarks are out of alignment

2022-02-10 Thread GitBox
flinkbot edited a comment on pull request #18702: URL: https://github.com/apache/flink/pull/18702#issuecomment-1034842544 ## CI report: * f730132ffa59826d88df89d4bd6ac1e5c93639d3 Azure:

[jira] [Commented] (FLINK-26064) KinesisFirehoseSinkITCase IllegalStateException: Trying to access closed classloader

2022-02-10 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26064?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17490388#comment-17490388 ] Matthias Pohl commented on FLINK-26064: --- This test is temporarily disabled on {{master}}:

<    1   2   3   4   5   6   7   8   9   10   >