[GitHub] [flink] dmvk 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 configuration

dmvk commented on a change in pull request #18553: URL: https://github.com/apache/flink/pull/18553#discussion_r803913325 ## File path: flink-connectors/flink-connector-aws-kinesis-firehose/src/test/java/org/apache/flink/connector/firehose/sink/KinesisFirehoseSinkITCase.java

[GitHub] [flink] XComp merged pull request #18712: [FLINK-26064] Temporarily disable KinesisFirehoseSinkITCase.

XComp merged pull request #18712: URL: https://github.com/apache/flink/pull/18712 -- 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] [Updated] (FLINK-25898) Add README.md to flink-statefun/statefun-sdk-js

[ https://issues.apache.org/jira/browse/FLINK-25898?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-25898: --- Labels: pull-request-available (was: ) > Add README.md to flink-statefun/statefun-sdk-js >

[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

CrynetLogistics commented on a change in pull request #18553: URL: https://github.com/apache/flink/pull/18553#discussion_r803912203 ## File path:

[GitHub] [flink-statefun] tillrohrmann opened a new pull request #301: [FLINK-25898] Add README.md to statefun-sdk-js

tillrohrmann opened a new pull request #301: URL: https://github.com/apache/flink-statefun/pull/301 This commit adds an README.md to statefun-sdk-js. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to

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

flinkbot edited a comment on pull request #18706: URL: https://github.com/apache/flink/pull/18706#issuecomment-1034953890 ## CI report: * bf78620ba038d62e133c9ef66eb39e0e2313561f Azure:

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

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

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 #18664: [FLINK-25907][runtime][security] Add pluggable delegation token manager

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

[GitHub] [flink] dmvk 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 configuration

dmvk commented on a change in pull request #18553: URL: https://github.com/apache/flink/pull/18553#discussion_r803907568 ## File path: flink-connectors/flink-connector-aws-kinesis-firehose/src/test/java/org/apache/flink/connector/firehose/sink/KinesisFirehoseSinkITCase.java

[GitHub] [flink] flinkbot edited a comment on pull request #18712: [FLINK-26064] Temporarily disable KinesisFirehoseSinkITCase.

flinkbot edited a comment on pull request #18712: URL: https://github.com/apache/flink/pull/18712#issuecomment-1035165485 ## CI report: * 8204576083202af4b2708d1eb5491f24aa6fd5ea Azure:

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

flinkbot edited a comment on pull request #18702: URL: https://github.com/apache/flink/pull/18702#issuecomment-1034842544 ## CI report: * 1c798c2c84e8285f7a7784038583a194bc42b3ea Azure:

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

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

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

[GitHub] [flink] CrynetLogistics commented on pull request #18712: [FLINK-26064] Temporarily disable KinesisFirehoseSinkITCase.

CrynetLogistics commented on pull request #18712: URL: https://github.com/apache/flink/pull/18712#issuecomment-1035167876 I have demonstrated on my local machine that https://github.com/apache/flink/pull/18553 fixes the classloader issues. ThreadLocals / ServiceLoader has been

[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

CrynetLogistics commented on a change in pull request #18553: URL: https://github.com/apache/flink/pull/18553#discussion_r803892402 ## File path:

[GitHub] [flink] flinkbot commented on pull request #18712: [FLINK-26064] Temporarily disable KinesisFirehoseSinkITCase.

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

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

flinkbot edited a comment on pull request #18702: URL: https://github.com/apache/flink/pull/18702#issuecomment-1034842544 ## CI report: * 1c798c2c84e8285f7a7784038583a194bc42b3ea Azure:

[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

flinkbot edited a comment on pull request #18704: URL: https://github.com/apache/flink/pull/18704#issuecomment-1034913098 ## CI report: * 385d41344c4a95ddc7041b05ff2c622d9de2c6ce Azure:

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

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

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 commented on pull request #18712: [FLINK-26064] Temporarily disable KinesisFirehoseSinkITCase.

flinkbot commented on pull request #18712: URL: https://github.com/apache/flink/pull/18712#issuecomment-1035161107 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-26064) KinesisFirehoseSinkITCase IllegalStateException: Trying to access closed classloader

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

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

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

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

[GitHub] [flink] dmvk opened a new pull request #18712: [FLINK-26064] Temporarily disable KinesisFirehoseSinkITCase.

dmvk opened a new pull request #18712: URL: https://github.com/apache/flink/pull/18712 Disabling the test until the underlying issues are resolved. It seems to be some combination of ThreadLocals / ServiceLoader / Classloading issues deep down in AWS SDK, so it might take some time to

[jira] [Assigned] (FLINK-25898) Add README.md to flink-statefun/statefun-sdk-js

[ https://issues.apache.org/jira/browse/FLINK-25898?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-25898: - Assignee: Till Rohrmann > Add README.md to flink-statefun/statefun-sdk-js >

[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

CrynetLogistics commented on a change in pull request #18553: URL: https://github.com/apache/flink/pull/18553#discussion_r803884132 ## File path:

[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

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] 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

CrynetLogistics commented on a change in pull request #18553: URL: https://github.com/apache/flink/pull/18553#discussion_r803882048 ## File path:

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

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

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

[GitHub] [flink] metaswirl commented on a change in pull request #18689: [FLINK-21439][runtime] Exception history adaptive scheduler

metaswirl commented on a change in pull request #18689: URL: https://github.com/apache/flink/pull/18689#discussion_r80383 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptive/Executing.java ## @@ -80,49 +89,53 @@ public void cancel() {

[jira] [Closed] (FLINK-26034) Add maven wrapper for flink

[ https://issues.apache.org/jira/browse/FLINK-26034?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-26034. - Resolution: Fixed Fixed via cc5616d1f1a3566f8a4dbb7a016251cf0f34b47a > Add maven wrapper for

[GitHub] [flink] tillrohrmann closed pull request #18697: [FLINK-26034][Build System]Add maven wrapper for flink

tillrohrmann closed pull request #18697: URL: https://github.com/apache/flink/pull/18697 -- 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 #18711: [FLINK-26036] Don't execute TaskExecutor.freeSlotInternal if not running

flinkbot edited a comment on pull request #18711: URL: https://github.com/apache/flink/pull/18711#issuecomment-1035135369 ## CI report: * eb69cc009a564d0fce6087eb0447d98c5021bc43 Azure:

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

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 #18603: [FLINK-25610][connector/firehose] Adding table api base for kinesis firehose

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

[GitHub] [flink] zch93 commented on pull request #18687: [FLINK-24169][tests] Add TimeBased rolling policy and delete OnStartupTriggeringPolicy

zch93 commented on pull request #18687: URL: https://github.com/apache/flink/pull/18687#issuecomment-1035139263 Hey guys! Sorry for the late info, but it seems this pr is not ok yet, there is something minor what should be also set (the pattern should contains date), so let me push my

[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

flinkbot edited a comment on pull request #18058: URL: https://github.com/apache/flink/pull/18058#issuecomment-988949831 ## CI report: * 93c33001cf55690369281de939bd79bb3727ad9a UNKNOWN * 5c5c6cc4aa76981978d7015e494fe74f7a8c283b Azure:

[GitHub] [flink] flinkbot commented on pull request #18711: [FLINK-26036] Don't execute TaskExecutor.freeSlotInternal if not running

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

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

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 commented on pull request #18711: [FLINK-26036] Don't execute TaskExecutor.freeSlotInternal if not running

flinkbot commented on pull request #18711: URL: https://github.com/apache/flink/pull/18711#issuecomment-1035133828 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 edited a comment on pull request #18678: [FLINK-24474] Default rest.bind-address to localhost in flink-conf.yaml

flinkbot edited a comment on pull request #18678: URL: https://github.com/apache/flink/pull/18678#issuecomment-1033466685 ## CI report: * 4a7745e66e11fb024ded1dcdc37dcaa61691face 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

flinkbot edited a comment on pull request #18058: URL: https://github.com/apache/flink/pull/18058#issuecomment-988949831 ## CI report: * 93c33001cf55690369281de939bd79bb3727ad9a UNKNOWN * 5c5c6cc4aa76981978d7015e494fe74f7a8c283b Azure:

[GitHub] [flink] vahmed-hamdy commented on a change in pull request #18603: [FLINK-25610][connector/firehose] Adding table api base for kinesis firehose

vahmed-hamdy commented on a change in pull request #18603: URL: https://github.com/apache/flink/pull/18603#discussion_r803864907 ## File path: flink-connectors/flink-connector-aws-kinesis-firehose/src/main/java/org/apache/flink/connector/firehose/table/KinesisFirehoseDynamicSink.java

[GitHub] [flink] tillrohrmann commented on pull request #18697: [FLINK-26034][Build System]Add maven wrapper for flink

tillrohrmann commented on pull request #18697: URL: https://github.com/apache/flink/pull/18697#issuecomment-1035130271 Thanks for the clarification @GOODBOY008 and the review @RyanSkraba. -- This is an automated message from the Apache Git Service. To respond to the message, please log

[GitHub] [flink] tillrohrmann opened a new pull request #18711: [FLINK-26036] Don't execute TaskExecutor.freeSlotInternal if not running

tillrohrmann opened a new pull request #18711: URL: https://github.com/apache/flink/pull/18711 This commit prevents the execution of TaskExecutor.freeSlotInternal if the TaskExecutor is shutting down. This will preserve the slot allocation information when shutting down. -- This

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

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 #18153: [FLINK-25568][connectors/elasticsearch] Add Elasticsearch 7 Source

flinkbot edited a comment on pull request #18153: URL: https://github.com/apache/flink/pull/18153#issuecomment-997756404 ## CI report: * 7cecfb69874b3e340b01232bc780eab2e3a43765 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

flinkbot edited a comment on pull request #18058: URL: https://github.com/apache/flink/pull/18058#issuecomment-988949831 ## CI report: * 93c33001cf55690369281de939bd79bb3727ad9a UNKNOWN * 5c5c6cc4aa76981978d7015e494fe74f7a8c283b Azure:

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

CrynetLogistics commented on pull request #18686: URL: https://github.com/apache/flink/pull/18686#issuecomment-1035120233 https://github.com/apache/flink/pull/18686#discussion_r803843297 Yes. Since we do not need to worry about backwards compatibility of the test code, I will rename

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

[ https://issues.apache.org/jira/browse/FLINK-26036?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17490351#comment-17490351 ] Till Rohrmann commented on FLINK-26036: --- I think the solution is to move the {{isRunning()}} check

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

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

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

[ https://issues.apache.org/jira/browse/FLINK-26036?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17490349#comment-17490349 ] Till Rohrmann commented on FLINK-26036: --- The problem seems to be the following: When shutting down

[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

flinkbot edited a comment on pull request #18058: URL: https://github.com/apache/flink/pull/18058#issuecomment-988949831 ## CI report: * 93c33001cf55690369281de939bd79bb3727ad9a UNKNOWN * 5c5c6cc4aa76981978d7015e494fe74f7a8c283b Azure:

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

flinkbot edited a comment on pull request #18706: URL: https://github.com/apache/flink/pull/18706#issuecomment-1034953890 ## CI report: * bf78620ba038d62e133c9ef66eb39e0e2313561f Azure:

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

flinkbot edited a comment on pull request #18702: URL: https://github.com/apache/flink/pull/18702#issuecomment-1034842544 ## CI report: * 1c798c2c84e8285f7a7784038583a194bc42b3ea Azure:

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

dannycranmer commented on a change in pull request #18686: URL: https://github.com/apache/flink/pull/18686#discussion_r803844878 ## File path:

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

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 #18058: [FLINK-24571][connectors/elasticsearch] Supports a system time function(now() and current_timestamp) in index pattern

flinkbot edited a comment on pull request #18058: URL: https://github.com/apache/flink/pull/18058#issuecomment-988949831 ## CI report: * 93c33001cf55690369281de939bd79bb3727ad9a UNKNOWN * 5c5c6cc4aa76981978d7015e494fe74f7a8c283b Azure:

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

flinkbot edited a comment on pull request #18705: URL: https://github.com/apache/flink/pull/18705#issuecomment-1034936625 ## CI report: * 0559b7a557c7e34f4564c4280ae0b9d2977b42da Azure:

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

flinkbot edited a comment on pull request #18702: URL: https://github.com/apache/flink/pull/18702#issuecomment-1034842544 ## CI report: * 1c798c2c84e8285f7a7784038583a194bc42b3ea Azure:

[GitHub] [flink] metaswirl commented on a change in pull request #18689: [FLINK-21439][runtime] Exception history adaptive scheduler

metaswirl commented on a change in pull request #18689: URL: https://github.com/apache/flink/pull/18689#discussion_r80383 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptive/Executing.java ## @@ -80,49 +89,53 @@ public void cancel() {

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

flinkbot edited a comment on pull request #18706: URL: https://github.com/apache/flink/pull/18706#issuecomment-1034953890 ## CI report: * bf78620ba038d62e133c9ef66eb39e0e2313561f Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18697: [FLINK-26034][Build System]Add maven wrapper for flink

flinkbot edited a comment on pull request #18697: URL: https://github.com/apache/flink/pull/18697#issuecomment-1034510296 ## CI report: * 3cd445e29262a008208a97ce6e2cf80e33f37ba5 Azure:

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

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 #18692: [FLINK-26015] Fixes object store bug

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

[GitHub] [flink] dannycranmer commented on a change in pull request #18603: [FLINK-25610][connector/firehose] Adding table api base for kinesis firehose

dannycranmer commented on a change in pull request #18603: URL: https://github.com/apache/flink/pull/18603#discussion_r803835349 ## File path: flink-connectors/flink-sql-connector-aws-kinesis-firehose/src/main/resources/META-INF/NOTICE ## @@ -0,0 +1,53 @@

[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

flinkbot edited a comment on pull request #18058: URL: https://github.com/apache/flink/pull/18058#issuecomment-988949831 ## CI report: * 93c33001cf55690369281de939bd79bb3727ad9a UNKNOWN * 5c5c6cc4aa76981978d7015e494fe74f7a8c283b Azure:

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

flinkbot edited a comment on pull request #18706: URL: https://github.com/apache/flink/pull/18706#issuecomment-1034953890 ## CI report: * bf78620ba038d62e133c9ef66eb39e0e2313561f Azure:

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

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

[GitHub] [flink] dannycranmer commented on a change in pull request #18603: [FLINK-25610][connector/firehose] Adding table api base for kinesis firehose

dannycranmer commented on a change in pull request #18603: URL: https://github.com/apache/flink/pull/18603#discussion_r803825913 ## File path:

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

flinkbot edited a comment on pull request #18669: URL: https://github.com/apache/flink/pull/18669#issuecomment-1033040800 ## CI report: * b35192da26215222b167cdffbb9f45091fb4c559 Azure:

[GitHub] [flink] dmvk commented on a change in pull request #18689: [FLINK-21439][runtime] Exception history adaptive scheduler

dmvk commented on a change in pull request #18689: URL: https://github.com/apache/flink/pull/18689#discussion_r803829190 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/DefaultExecutionGraph.java ## @@ -1576,4 +1576,15 @@ public

[GitHub] [flink] dmvk commented on a change in pull request #18689: [FLINK-21439][runtime] Exception history adaptive scheduler

dmvk commented on a change in pull request #18689: URL: https://github.com/apache/flink/pull/18689#discussion_r803828457 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/DefaultExecutionGraph.java ## @@ -1576,4 +1576,15 @@ public

[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

flinkbot edited a comment on pull request #18058: URL: https://github.com/apache/flink/pull/18058#issuecomment-988949831 ## CI report: * 93c33001cf55690369281de939bd79bb3727ad9a UNKNOWN * 5c5c6cc4aa76981978d7015e494fe74f7a8c283b Azure:

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

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 #18703: [FLINK-25870][table] Introduce ContextResolvedFunction similar to ContextResolvedTable

flinkbot edited a comment on pull request #18703: URL: https://github.com/apache/flink/pull/18703#issuecomment-1034899976 ## CI report: * 2014ead9cb14bdaafabf8afbd7c54cc277f9a7e0 Azure:

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

flinkbot edited a comment on pull request #18706: URL: https://github.com/apache/flink/pull/18706#issuecomment-1034953890 ## CI report: * bf78620ba038d62e133c9ef66eb39e0e2313561f Azure:

[GitHub] [flink] dmvk 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 configuration

dmvk commented on a change in pull request #18553: URL: https://github.com/apache/flink/pull/18553#discussion_r803821085 ## File path: flink-connectors/flink-connector-aws-kinesis-firehose/src/test/java/org/apache/flink/connector/firehose/sink/KinesisFirehoseSinkITCase.java

[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

flinkbot edited a comment on pull request #18058: URL: https://github.com/apache/flink/pull/18058#issuecomment-988949831 ## CI report: * 93c33001cf55690369281de939bd79bb3727ad9a UNKNOWN * 5c5c6cc4aa76981978d7015e494fe74f7a8c283b Azure:

[GitHub] [flink-statefun] galenwarren commented on pull request #300: [FLINK-25933][statefun] Add support for the async HTTP transport in request-reply function builder

galenwarren commented on pull request #300: URL: https://github.com/apache/flink-statefun/pull/300#issuecomment-1035077693 @igalshilman Thanks! -- 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

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

hackergin commented on pull request #18058: URL: https://github.com/apache/flink/pull/18058#issuecomment-1035076328 @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 #18710: [FLINK-26055][table][annotations] Modified CompiledPlan#getFlinkVersion return type to FlinkVersion

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 #18707: [FLINK-25995][table-planner] Make implicit assumption of SQL local hash explicit

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 #18706: [FLINK-26072][Connectors][NiFi] Mark NiFi Source and Sink as deprecated

flinkbot edited a comment on pull request #18706: URL: https://github.com/apache/flink/pull/18706#issuecomment-1034953890 ## CI report: * bf78620ba038d62e133c9ef66eb39e0e2313561f 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

flinkbot edited a comment on pull request #18701: URL: https://github.com/apache/flink/pull/18701#issuecomment-1034766277 ## CI report: * a3fdc9763094051769e040d5211db40196fe493c Azure:

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

flinkbot edited a comment on pull request #18702: URL: https://github.com/apache/flink/pull/18702#issuecomment-1034842544 ## CI report: * 1c798c2c84e8285f7a7784038583a194bc42b3ea Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18688: [FLINK-26060][table-planner] Remove persisted plan feature support for Python UDFs

flinkbot edited a comment on pull request #18688: URL: https://github.com/apache/flink/pull/18688#issuecomment-1033917965 ## CI report: * a1e93a73c296c113f974f93e44262d156f4ff102 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

flinkbot edited a comment on pull request #18058: URL: https://github.com/apache/flink/pull/18058#issuecomment-988949831 ## CI report: * 93c33001cf55690369281de939bd79bb3727ad9a UNKNOWN * 107f4c437fb8f4af9a8dd143a2c3e68e72b66ceb Azure:

[jira] [Assigned] (FLINK-26075) Persist per-ExecNode configuration

[ https://issues.apache.org/jira/browse/FLINK-26075?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Marios Trivyzas reassigned FLINK-26075: --- Assignee: Marios Trivyzas > Persist per-ExecNode configuration >

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

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

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

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 #18706: [FLINK-26072][Connectors][NiFi] Mark NiFi Source and Sink as deprecated

flinkbot edited a comment on pull request #18706: URL: https://github.com/apache/flink/pull/18706#issuecomment-1034953890 ## CI report: * bf78620ba038d62e133c9ef66eb39e0e2313561f Azure:

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

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 #18702: [FLINK-24441][source] Block SourceOperator when watermarks are out of alignment

flinkbot edited a comment on pull request #18702: URL: https://github.com/apache/flink/pull/18702#issuecomment-1034842544 ## CI report: * 1c798c2c84e8285f7a7784038583a194bc42b3ea 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

flinkbot edited a comment on pull request #18701: URL: https://github.com/apache/flink/pull/18701#issuecomment-1034766277 ## CI report: * a3fdc9763094051769e040d5211db40196fe493c Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18670: [FLINK-25999] Deprecate Per-Job Mode

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

[GitHub] [flink] flinkbot edited a comment on pull request #18667: [FLINK-25990][table] Expose uid generator for DataStream/Transformation providers

flinkbot edited a comment on pull request #18667: URL: https://github.com/apache/flink/pull/18667#issuecomment-1032823071 ## CI report: * 4af7f825a1bcbed0a6fda02c9445d9288a175e30 Azure:

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