[jira] [Closed] (FLINK-25997) FsStateChangelogWriter cannot work well when there is no change appended

[ https://issues.apache.org/jira/browse/FLINK-25997?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan closed FLINK-25997. - Resolution: Duplicate Closing as duplicate of FLINK-25987. > FsStateChangelogWriter

[GitHub] [flink] flinkbot edited a comment on pull request #18738: [FLINK-24745][format][json] Add support for Oracle OGG JSON format parser

flinkbot edited a comment on pull request #18738: URL: https://github.com/apache/flink/pull/18738#issuecomment-1037051889 ## CI report: * e07496c3522be15e47be43c8dae3b17e08745e72 Azure:

[jira] [Resolved] (FLINK-25987) [Changelog] IllegalArgumentException thrown from FsStateChangelogWriter.truncate

[ https://issues.apache.org/jira/browse/FLINK-25987?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan resolved FLINK-25987. --- Resolution: Fixed Merged as 66048d11c1b53b5c6b24cdb20a6d4d3348f87026. >

[GitHub] [flink] rkhachatryan merged pull request #18734: [FLINK-25987][state/changelog] Replace lastSqn with nextSqn()

rkhachatryan merged pull request #18734: URL: https://github.com/apache/flink/pull/18734 -- 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] [Resolved] (FLINK-25785) Update com.h2database:h2 to 2.0.210

[ https://issues.apache.org/jira/browse/FLINK-25785?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan resolved FLINK-25785. --- Fix Version/s: 1.15.0 1.13.6 1.14.4

[jira] [Commented] (FLINK-25785) Update com.h2database:h2 to 2.0.210

[ https://issues.apache.org/jira/browse/FLINK-25785?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17491291#comment-17491291 ] Roman Khachatryan commented on FLINK-25785: --- Unlinked

[GitHub] [flink] flinkbot commented on pull request #18738: [FLINK-24745][format][json] Add support for Oracle OGG JSON format parser

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

[GitHub] [flink] flinkbot commented on pull request #18738: [FLINK-24745][format][json] Add support for Oracle OGG JSON format parser

flinkbot commented on pull request #18738: URL: https://github.com/apache/flink/pull/18738#issuecomment-1037051767 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] [Commented] (FLINK-25785) Update com.h2database:h2 to 2.0.210

[ https://issues.apache.org/jira/browse/FLINK-25785?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17491290#comment-17491290 ] Roman Khachatryan commented on FLINK-25785: --- Merged H2 version fix into 1.13 as

[GitHub] [flink] rkhachatryan merged pull request #18728: [FLINK-25785][BP 1.13][Connectors][JDBC] Upgrade com.h2database:h2 to 2.1.210

rkhachatryan merged pull request #18728: URL: https://github.com/apache/flink/pull/18728 -- 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] luoyuxia opened a new pull request #18738: [FLINK-24745][format][json] Add support for Oracle OGG JSON format parser

luoyuxia opened a new pull request #18738: URL: https://github.com/apache/flink/pull/18738 ## What is the purpose of the change *(For example: This pull request makes task deployment go through the blob server, rather than through RPC. That way we avoid re-transferring them

[GitHub] [flink] wenlong88 commented on a change in pull request #18363: [Flink-25600][table-planner] Support new statement set syntax in sql client and update docs

wenlong88 commented on a change in pull request #18363: URL: https://github.com/apache/flink/pull/18363#discussion_r805129799 ## File path: flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/config/OptimizerConfigOptions.java ## @@ -130,4 +130,12 @@

[GitHub] [flink] wenlong88 commented on pull request #18707: [FLINK-25995][table-planner] Make implicit assumption of SQL local hash explicit

wenlong88 commented on pull request #18707: URL: https://github.com/apache/flink/pull/18707#issuecomment-1037036824 LGTM -- 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] XComp edited a comment on pull request #18644: [FLINK-25974] Makes job cancellation rely on JobResultStore entry

XComp edited a comment on pull request #18644: URL: https://github.com/apache/flink/pull/18644#issuecomment-1034821588 I went through the code once more after you raised valid concerns. I reverted my changes and investigated the cancellation code path for the

[GitHub] [flink] XComp edited a comment on pull request #18644: [FLINK-25974] Makes job cancellation rely on JobResultStore entry

XComp edited a comment on pull request #18644: URL: https://github.com/apache/flink/pull/18644#issuecomment-1034821588 I went through the code once more after you raised valid concerns. I reverted my changes and investigated the cancellation code path for the

[GitHub] [flink] flinkbot edited a comment on pull request #18736: [hotfix][datastream] move the change and restore of env parallelism into the adjusTransformations method.

flinkbot edited a comment on pull request #18736: URL: https://github.com/apache/flink/pull/18736#issuecomment-1036747854 ## CI report: * ba8ff7ae7257614a8987c6cf157c95eba5e9ca32 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: * 1db47ab3b61a44252f62417c4d02f6b81623223a Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18644: [FLINK-25974] Makes job cancellation rely on JobResultStore entry

flinkbot edited a comment on pull request #18644: URL: https://github.com/apache/flink/pull/18644#issuecomment-1031433646 ## CI report: * 7ed59440e909a9344edc481baffc551decbd4e00 UNKNOWN * a5b98c5365961f7628175ea43702af485fe92326 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18681: [FLINK-26032][streaming] check explicit env allowed on StreamExecutionEnvironment own.

flinkbot edited a comment on pull request #18681: URL: https://github.com/apache/flink/pull/18681#issuecomment-1033535247 ## CI report: * 77e43dbd211dc9274041996d5a9d24607dc9f953 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18363: [Flink-25600][table-planner] Support new statement set syntax in sql client and update docs

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

[GitHub] [flink] flinkbot edited a comment on pull request #18735: [FLINK-26079][state/changelog] Disallow recovery from non-changelog checkpoints

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

[GitHub] [flink] flinkbot edited a comment on pull request #18734: [FLINK-25987][state/changelog] Replace lastSqn with nextSqn()

flinkbot edited a comment on pull request #18734: URL: https://github.com/apache/flink/pull/18734#issuecomment-1036367292 ## CI report: * bbb05291cf70850754ee9bc0bfdee618f96d9537 Azure:

[jira] [Updated] (FLINK-26096) Add isolationLevel for JDBC Connector Options

[ https://issues.apache.org/jira/browse/FLINK-26096?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] nyingping updated FLINK-26096: -- Summary: Add isolationLevel for JDBC Connector Options (was: add isolationLevel for jdbc Connector

[jira] [Commented] (FLINK-26096) add isolationLevel for jdbc Connector Options

[ https://issues.apache.org/jira/browse/FLINK-26096?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17491260#comment-17491260 ] nyingping commented on FLINK-26096: --- I would be happy and honored to implement this feature if the

[jira] [Created] (FLINK-26096) add isolationLevel for jdbc Connector Options

nyingping created FLINK-26096: - Summary: add isolationLevel for jdbc Connector Options Key: FLINK-26096 URL: https://issues.apache.org/jira/browse/FLINK-26096 Project: Flink Issue Type:

[GitHub] [flink] flinkbot edited a comment on pull request #18363: [Flink-25600][table-planner] Support new statement set syntax in sql client and update docs

flinkbot edited a comment on pull request #18363: URL: https://github.com/apache/flink/pull/18363#issuecomment-1012985353 ## CI report: * 3df16d53fa873eec61521a77deefa04f42959089 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: * bce8800e3df04e5503e0f6f786d3d7dfa2bacf34 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18363: [Flink-25600][table-planner] Support new statement set syntax in sql client and update docs

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

[GitHub] [flink] wenlong88 commented on pull request #18363: [Flink-25600][table-planner] Support new statement set syntax in sql client and update docs

wenlong88 commented on pull request #18363: URL: https://github.com/apache/flink/pull/18363#issuecomment-1036986225 @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 #18733: [FLINK-26064][connectors/firehose,kinesis] Using own event loop group…

flinkbot edited a comment on pull request #18733: URL: https://github.com/apache/flink/pull/18733#issuecomment-1036367128 ## CI report: * dacff5752d32e487590ae582e94a7e740c1df2d7 UNKNOWN * b16c92d2ca02afc1c52fc3c0383ccc55c7485991 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

flinkbot edited a comment on pull request #18553: URL: https://github.com/apache/flink/pull/18553#issuecomment-1024127153 ## CI report: * eae81dc84402215df5d19aa0687ae2f4a0e376fd UNKNOWN * 128e9b4a394963cb6189259fb3bc9caa23c540f0 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18737: [FLINK-26077][runtime] Support operators send request to Coordinator and return a response

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

[GitHub] [flink] flinkbot commented on pull request #18737: [FLINK-26077][runtime] Support operators send request to Coordinator and return a response

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

[GitHub] [flink] flinkbot commented on pull request #18737: [FLINK-26077][runtime] Support operators send request to Coordinator and return a response

flinkbot commented on pull request #18737: URL: https://github.com/apache/flink/pull/18737#issuecomment-1036981264 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] [Assigned] (FLINK-26077) Support operators send request to Coordinator and return a response

[ https://issues.apache.org/jira/browse/FLINK-26077?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-26077: --- Assignee: Jark Wu > Support operators send request to Coordinator and return a response >

[jira] [Updated] (FLINK-26077) Support operators send request to Coordinator and return a response

[ https://issues.apache.org/jira/browse/FLINK-26077?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-26077: --- Labels: pull-request-available (was: ) > Support operators send request to Coordinator and

[GitHub] [flink] wuchong opened a new pull request #18737: [FLINK-26077][runtime] Support operators send request to Coordinator and return a response

wuchong opened a new pull request #18737: URL: https://github.com/apache/flink/pull/18737 ## What is the purpose of the change Currently, the communitcation between Operator and Coordiator is sigle-way. That means, after Operator sending a message to Coordiator, it can't

[jira] [Commented] (FLINK-25704) Performance regression on 18.01.2022 in batch network benchmarks

[ https://issues.apache.org/jira/browse/FLINK-25704?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17491251#comment-17491251 ] Yingjie Cao commented on FLINK-25704: - Sort-shuffle optimization merged via

[jira] [Closed] (FLINK-25796) Avoid record copy for result partition of sort-shuffle if there are enough buffers for better performance

[ https://issues.apache.org/jira/browse/FLINK-25796?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yingjie Cao closed FLINK-25796. --- Resolution: Fixed > Avoid record copy for result partition of sort-shuffle if there are enough >

[jira] [Closed] (FLINK-24898) Some further improvements of sort-shuffle

[ https://issues.apache.org/jira/browse/FLINK-24898?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yingjie Cao closed FLINK-24898. --- Resolution: Fixed > Some further improvements of sort-shuffle >

[jira] [Commented] (FLINK-25796) Avoid record copy for result partition of sort-shuffle if there are enough buffers for better performance

[ https://issues.apache.org/jira/browse/FLINK-25796?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17491250#comment-17491250 ] Yingjie Cao commented on FLINK-25796: - Merged into master via 

[GitHub] [flink] wsry closed pull request #18505: [FLINK-25796][network] Avoid record copy for result partition of sort-shuffle if there are enough buffers for better performance

wsry closed pull request #18505: URL: https://github.com/apache/flink/pull/18505 -- 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 #18644: [FLINK-25974] Makes job cancellation rely on JobResultStore entry

flinkbot edited a comment on pull request #18644: URL: https://github.com/apache/flink/pull/18644#issuecomment-1031433646 ## CI report: * 7ed59440e909a9344edc481baffc551decbd4e00 UNKNOWN * ee9a80e10042d8265c31b68b91c690f3fe24d6e0 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18733: [FLINK-26064][connectors/firehose,kinesis] Using own event loop group…

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

[GitHub] [flink] flinkbot edited a comment on pull request #18730: [FLINK-25495] The deployment of application-mode support client attach

flinkbot edited a comment on pull request #18730: URL: https://github.com/apache/flink/pull/18730#issuecomment-1036229614 ## CI report: * f5b7683e947187e3fcba74e8c237294a60111327 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18730: [FLINK-25495] The deployment of application-mode support client attach

flinkbot edited a comment on pull request #18730: URL: https://github.com/apache/flink/pull/18730#issuecomment-1036229614 ## CI report: * f5b7683e947187e3fcba74e8c237294a60111327 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18516: [FLINK-25288][tests] add savepoint and metric test cases in source suite of connector testframe

flinkbot edited a comment on pull request #18516: URL: https://github.com/apache/flink/pull/18516#issuecomment-1022021934 ## CI report: * 261b4214f31ad1c55b3cc6247676d8074476d032 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18681: [FLINK-26032][streaming] check explicit env allowed on StreamExecutionEnvironment own.

flinkbot edited a comment on pull request #18681: URL: https://github.com/apache/flink/pull/18681#issuecomment-1033535247 ## CI report: * 77a97fb9e28a3615fff53020ac021328529d2f98 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18644: [FLINK-25974] Makes job cancellation rely on JobResultStore entry

flinkbot edited a comment on pull request #18644: URL: https://github.com/apache/flink/pull/18644#issuecomment-1031433646 ## CI report: * 7ed59440e909a9344edc481baffc551decbd4e00 UNKNOWN * 54d10a9be5e67e3f697158bc186dd6c06359ca32 Azure:

[GitHub] [flink] RocMarshal commented on pull request #18653: [FLINK-25825][connector-jdbc] MySqlCatalogITCase fails on azure

RocMarshal commented on pull request #18653: URL: https://github.com/apache/flink/pull/18653#issuecomment-1036953436 cc @twalthr -- 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] 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: * e931516e1549443b5e90e1b8cc1003cbb37046f5 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18734: [FLINK-25987][state/changelog] Replace lastSqn with nextSqn()

flinkbot edited a comment on pull request #18734: URL: https://github.com/apache/flink/pull/18734#issuecomment-1036367292 ## CI report: * 0915277daafd29915079aa56c84a2b54bbfe5303 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: * e931516e1549443b5e90e1b8cc1003cbb37046f5 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18733: [FLINK-26064][connectors/firehose,kinesis] Using own event loop group…

flinkbot edited a comment on pull request #18733: URL: https://github.com/apache/flink/pull/18733#issuecomment-1036367128 ## CI report: * a118cb8ab6280c8ccbf308b2c985dc6c59a9016f Azure:

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

flinkbot edited a comment on pull request #18708: URL: https://github.com/apache/flink/pull/18708#issuecomment-1035039830 ## CI report: * edc08e92dc532517bfc9eebf2414bf42f5f81b67 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18687: [FLINK-24169][tests] Add TimeBased rolling policy and delete OnStartupTriggeringPolicy

flinkbot edited a comment on pull request #18687: URL: https://github.com/apache/flink/pull/18687#issuecomment-1033868741 ## CI report: * ab574e31a308eb750ef411e0e88f04a64b1c9743 UNKNOWN * 6b7350fda53361fdd105eb884e46871764d36631 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: * 39788f7f4f4305f79b4ce46063532fd0823c418a Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18644: [FLINK-25974] Makes job cancellation rely on JobResultStore entry

flinkbot edited a comment on pull request #18644: URL: https://github.com/apache/flink/pull/18644#issuecomment-1031433646 ## CI report: * 7a240f2d0d30ade90735cdb0d94c4311e176f85d Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18721: [FLINK-24474] Bind Jobmanager and Taskmanager RPC host addresses to localhost by default

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

[GitHub] [flink] flinkbot edited a comment on pull request #18730: [FLINK-25495] The deployment of application-mode support client attach

flinkbot edited a comment on pull request #18730: URL: https://github.com/apache/flink/pull/18730#issuecomment-1036229614 ## CI report: * f5b7683e947187e3fcba74e8c237294a60111327 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: * ad4d3eb214d7cb1fe9f607199c508f8a9a370059 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18724: [FLINK-26090][table] Remove pre FLIP-84 APIs

flinkbot edited a comment on pull request #18724: URL: https://github.com/apache/flink/pull/18724#issuecomment-1036053845 ## CI report: * d7697639228c60476c3524d0bfc9bd3015e22540 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: * 3e53478b4af82a7055018379d3ca938b6d231523 Azure:

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

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

[GitHub] [flink] flinkbot edited a comment on pull request #18648: [FLINK-25845][table] Introduce EXECUTE PLAN

flinkbot edited a comment on pull request #18648: URL: https://github.com/apache/flink/pull/18648#issuecomment-1031569879 ## CI report: * 44ffd07dd20fb9022f9f80c5fba3303c5729ab32 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_r805072225 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/adaptive/AdaptiveSchedulerTest.java ## @@ -969,10 +979,203 @@ public void

[GitHub] [flink] flinkbot edited a comment on pull request #18732: [FLINK-26067] Remove timeout on TestingContender#awaitRevokeLeadershi…

flinkbot edited a comment on pull request #18732: URL: https://github.com/apache/flink/pull/18732#issuecomment-1036250822 ## CI report: * c306ae72be8e2e60dbda427022dc9f8cca8784e6 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18736: [hotfix][datastream] move the change and restore of env parallelism into the adjusTransformations method.

flinkbot edited a comment on pull request #18736: URL: https://github.com/apache/flink/pull/18736#issuecomment-1036747854 ## CI report: * ba8ff7ae7257614a8987c6cf157c95eba5e9ca32 Azure:

[GitHub] [flink] flinkbot commented on pull request #18736: [hotfix][datastream] move the change and restore of env parallelism into the adjusTransformations method.

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

[GitHub] [flink] flinkbot commented on pull request #18736: [hotfix][datastream] move the change and restore of env parallelism into the adjusTransformations method.

flinkbot commented on pull request #18736: URL: https://github.com/apache/flink/pull/18736#issuecomment-1036745598 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] 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_r805065314 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptive/StateWithExecutionGraph.java ## @@ -148,6 +162,33 @@ public

[GitHub] [flink] JingGe opened a new pull request #18736: [hotfix][datastream] move the change and restore of env parallelism into the adjusTransformations method.

JingGe opened a new pull request #18736: URL: https://github.com/apache/flink/pull/18736 ## What is the purpose of the change During the transformations adjustment, we need to keep any potential customized parallelism value. This can be achieved by setting the environment

[GitHub] [flink] flinkbot edited a comment on pull request #18644: [FLINK-25974] Makes job cancellation rely on JobResultStore entry

flinkbot edited a comment on pull request #18644: URL: https://github.com/apache/flink/pull/18644#issuecomment-1031433646 ## CI report: * dccbae13e8249167ecb5330ee231350bd00b8754 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18644: [FLINK-25974] Makes job cancellation rely on JobResultStore entry

flinkbot edited a comment on pull request #18644: URL: https://github.com/apache/flink/pull/18644#issuecomment-1031433646 ## CI report: * dccbae13e8249167ecb5330ee231350bd00b8754 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18133: [FLINK-24718][avro] update AVRO dependency to latest version

flinkbot edited a comment on pull request #18133: URL: https://github.com/apache/flink/pull/18133#issuecomment-995786550 ## CI report: * df4f1ac54636e14a49eff5004b71d1ab4491507d UNKNOWN * c59f85f68f4cf2709e654423a0fbcf647d33bd74 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18644: [FLINK-25974] Makes job cancellation rely on JobResultStore entry

flinkbot edited a comment on pull request #18644: URL: https://github.com/apache/flink/pull/18644#issuecomment-1031433646 ## CI report: * dccbae13e8249167ecb5330ee231350bd00b8754 Azure:

[GitHub] [flink] jvican commented on pull request #12929: [FLINK-18631] [serialization] Serializer for scala sealed trait hierarchies

jvican commented on pull request #12929: URL: https://github.com/apache/flink/pull/12929#issuecomment-1036717894 Hi! Is there any blocker to get this 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

[GitHub] [flink] flinkbot edited a comment on pull request #18726: [FLINK-25983] Add API for configuring maximal watermark drift

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

[GitHub] [flink] flinkbot edited a comment on pull request #18644: [FLINK-25974] Makes job cancellation rely on JobResultStore entry

flinkbot edited a comment on pull request #18644: URL: https://github.com/apache/flink/pull/18644#issuecomment-1031433646 ## CI report: * dccbae13e8249167ecb5330ee231350bd00b8754 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18644: [FLINK-25974] Makes job cancellation rely on JobResultStore entry

flinkbot edited a comment on pull request #18644: URL: https://github.com/apache/flink/pull/18644#issuecomment-1031433646 ## CI report: * dccbae13e8249167ecb5330ee231350bd00b8754 Azure:

[jira] [Updated] (FLINK-15745) KafkaITCase.testKeyValueSupport failure due to assertion error.

[ https://issues.apache.org/jira/browse/FLINK-15745?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-15745: --- Labels: auto-deprioritized-major auto-unassigned stale-assigned test-stability (was:

[GitHub] [flink] flinkbot edited a comment on pull request #18644: [FLINK-25974] Makes job cancellation rely on JobResultStore entry

flinkbot edited a comment on pull request #18644: URL: https://github.com/apache/flink/pull/18644#issuecomment-1031433646 ## CI report: * dccbae13e8249167ecb5330ee231350bd00b8754 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18695: [hotfix][doc] add javadoc for describing ITCASE_USE_MINICLUSTER rule in details

flinkbot edited a comment on pull request #18695: URL: https://github.com/apache/flink/pull/18695#issuecomment-1034296717 ## CI report: * 1a7ff3e846be72fccb022c476f2c33fad914c47b 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: * e931516e1549443b5e90e1b8cc1003cbb37046f5 Azure:

[jira] [Updated] (FLINK-18807) FlinkKafkaProducerITCase.testScaleUpAfterScalingDown failed with "Timeout expired after 60000milliseconds while awaiting EndTxn(COMMIT)"

[ https://issues.apache.org/jira/browse/FLINK-18807?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-18807: --- Labels: auto-deprioritized-major stale-assigned test-stability (was:

[jira] [Updated] (FLINK-17987) KafkaITCase.testStartFromGroupOffsets fails with SchemaException: Error reading field

[ https://issues.apache.org/jira/browse/FLINK-17987?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-17987: --- Labels: auto-deprioritized-critical stale-assigned test-stability (was:

[jira] [Updated] (FLINK-22306) KafkaITCase.testCollectingSchema failed on AZP

[ https://issues.apache.org/jira/browse/FLINK-22306?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-22306: --- Labels: stale-assigned test-stability (was: test-stability) I am the [Flink Jira

[jira] [Updated] (FLINK-18634) FlinkKafkaProducerITCase.testRecoverCommittedTransaction failed with "Timeout expired after 60000milliseconds while awaiting InitProducerId"

[ https://issues.apache.org/jira/browse/FLINK-18634?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-18634: --- Labels: auto-unassigned stale-assigned test-stability (was: auto-unassigned

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

[ https://issues.apache.org/jira/browse/FLINK-20633?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-20633: --- Labels: stale-assigned test-stability (was: test-stability) I am the [Flink Jira

[jira] [Updated] (FLINK-22342) FlinkKafkaProducerITCase fails with producer leak

[ https://issues.apache.org/jira/browse/FLINK-22342?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-22342: --- Labels: stale-assigned test-stability (was: test-stability) I am the [Flink Jira

[GitHub] [flink] flinkbot edited a comment on pull request #18731: [FLINK-26068] Update ZooKeeperStateHandleStore to use an indepotent r…

flinkbot edited a comment on pull request #18731: URL: https://github.com/apache/flink/pull/18731#issuecomment-1036236514 ## CI report: * 0feedb844a877b747a81e56a3bdc24d4b0bc7f09 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: * e931516e1549443b5e90e1b8cc1003cbb37046f5 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18728: [FLINK-25785][BP 1.13][Connectors][JDBC] Upgrade com.h2database:h2 to 2.1.210

flinkbot edited a comment on pull request #18728: URL: https://github.com/apache/flink/pull/18728#issuecomment-1036196232 ## CI report: * 33eb91993e07b02d8b300be586e0ec4cb27e2986 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: * e931516e1549443b5e90e1b8cc1003cbb37046f5 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18681: [FLINK-26032][streaming] check explicit env allowed on StreamExecutionEnvironment own.

flinkbot edited a comment on pull request #18681: URL: https://github.com/apache/flink/pull/18681#issuecomment-1033535247 ## CI report: * 37fc607b370caeb440b6f19774ab55adda1989e6 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18681: [FLINK-26032][streaming] check explicit env allowed on StreamExecutionEnvironment own.

flinkbot edited a comment on pull request #18681: URL: https://github.com/apache/flink/pull/18681#issuecomment-1033535247 ## CI report: * 37fc607b370caeb440b6f19774ab55adda1989e6 Azure:

[GitHub] [flink] rkhachatryan merged pull request #18727: [FLINK-25785][BP 1.14][Connectors][JDBC] Upgrade com.h2database:h2 to 2.1.210

rkhachatryan merged pull request #18727: URL: https://github.com/apache/flink/pull/18727 -- 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 #18695: [hotfix][doc] add javadoc for describing ITCASE_USE_MINICLUSTER rule in details

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

[GitHub] [flink] flinkbot edited a comment on pull request #18695: [hotfix][doc] add javadoc for describing ITCASE_USE_MINICLUSTER rule in details

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

  1   2   3   4   5   6   7   8   >