[GitHub] [flink] dannycranmer commented on a change in pull request #18930: [FLINK-26398][docs] Adding docs for Kinesis Firehose table api

dannycranmer commented on a change in pull request #18930: URL: https://github.com/apache/flink/pull/18930#discussion_r817431950 ## File path: docs/content/docs/connectors/table/firehose.md ## @@ -0,0 +1,312 @@ +--- +title: Firehose +weight: 5 +type: docs +aliases: +-

[GitHub] [flink] pltbkd commented on pull request #18956: [FLINK-26394] CheckpointCoordinator.isTriggering can not be reset in a particular case.

pltbkd commented on pull request #18956: URL: https://github.com/apache/flink/pull/18956#issuecomment-1056504086 This is a preview for discussion. Please do not merge at present. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to

[GitHub] [flink] dannycranmer commented on a change in pull request #18930: [FLINK-26398][docs] Adding docs for Kinesis Firehose table api

dannycranmer commented on a change in pull request #18930: URL: https://github.com/apache/flink/pull/18930#discussion_r817429690 ## File path: docs/content.zh/docs/connectors/table/firehose.md ## @@ -0,0 +1,312 @@ +--- +title: Firehose +weight: 5 +type: docs +aliases: +-

[jira] [Commented] (FLINK-26393) KafkaITCase.testBrokerFailure fails due to a topic isn't cleaned up properly

[ https://issues.apache.org/jira/browse/FLINK-26393?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17499947#comment-17499947 ] Yun Gao commented on FLINK-26393: -

[jira] [Commented] (FLINK-26314) StreamingCompactingFileSinkITCase.testFileSink failed on azure

[ https://issues.apache.org/jira/browse/FLINK-26314?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17499946#comment-17499946 ] Yun Gao commented on FLINK-26314: -

[jira] [Created] (FLINK-26445) Unified Sink cannot restore committer state

Fabian Paul created FLINK-26445: --- Summary: Unified Sink cannot restore committer state Key: FLINK-26445 URL: https://issues.apache.org/jira/browse/FLINK-26445 Project: Flink Issue Type: Bug

[GitHub] [flink] flinkbot edited a comment on pull request #18944: [FLINK-26430][FLINK-26429][runtime-web] Bump Karma and follow-redirects to address security findings

flinkbot edited a comment on pull request #18944: URL: https://github.com/apache/flink/pull/18944#issuecomment-1055498759 ## CI report: * f2dfe92d769bdbba5ca9407f35bed8505ae71cd3 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18794: [hotfix] Refactor the name of builder method

flinkbot edited a comment on pull request #18794: URL: https://github.com/apache/flink/pull/18794#issuecomment-1041190242 ## CI report: * b072ee3f9f3c53575e97a437fc3d9693c451ad74 Azure:

[GitHub] [flink] HuangXingBo commented on a change in pull request #18954: [FLINK-20633][python] Add retry times to download avro

HuangXingBo commented on a change in pull request #18954: URL: https://github.com/apache/flink/pull/18954#discussion_r817426524 ## File path: flink-python/pyflink/pyflink_gateway_server.py ## @@ -290,7 +291,23 @@ def launch_gateway_server_process(env, args): classpath

[jira] [Commented] (FLINK-26417) Async Sink can violate At Least Once processing during checkpointing

[ https://issues.apache.org/jira/browse/FLINK-26417?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17499944#comment-17499944 ] Danny Cranmer commented on FLINK-26417: --- Resolving as not a problem. Was a false alarm since sink

[jira] [Updated] (FLINK-26417) Async Sink can violate At Least Once processing during checkpointing

[ https://issues.apache.org/jira/browse/FLINK-26417?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer updated FLINK-26417: -- Fix Version/s: (was: 1.15.0) > Async Sink can violate At Least Once processing during

[jira] [Updated] (FLINK-26417) Async Sink can violate At Least Once processing during checkpointing

[ https://issues.apache.org/jira/browse/FLINK-26417?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer updated FLINK-26417: -- Priority: Not a Priority (was: Blocker) > Async Sink can violate At Least Once processing

[jira] [Resolved] (FLINK-26417) Async Sink can violate At Least Once processing during checkpointing

[ https://issues.apache.org/jira/browse/FLINK-26417?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer resolved FLINK-26417. --- Resolution: Not A Problem > Async Sink can violate At Least Once processing during

[GitHub] [flink] dannycranmer closed pull request #18945: [FLINK-26417][connector/base] Add failed Inflight requests in async writer snapshot state

dannycranmer closed pull request #18945: URL: https://github.com/apache/flink/pull/18945 -- 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] dannycranmer commented on pull request #18945: [FLINK-26417][connector/base] Add failed Inflight requests in async writer snapshot state

dannycranmer commented on pull request #18945: URL: https://github.com/apache/flink/pull/18945#issuecomment-1056487230 We discovered this PR is not required since Sink will wait for in-flight requests to complete before triggering snapshot method. -- This is an automated message from

[GitHub] [flink] dannycranmer commented on a change in pull request #18945: [FLINK-26417][connector/base] Add failed Inflight requests in async writer snapshot state

dannycranmer commented on a change in pull request #18945: URL: https://github.com/apache/flink/pull/18945#discussion_r817424567 ## File path: flink-connectors/flink-connector-base/src/main/java/org/apache/flink/connector/base/sink/writer/AsyncSinkWriter.java ## @@ -51,7

[jira] [Assigned] (FLINK-26387) KafkaSourceLegacyITCase.testBrokerFailure hang on azure

[ https://issues.apache.org/jira/browse/FLINK-26387?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Paul reassigned FLINK-26387: --- Assignee: Alexander Preuss (was: Fabian Paul) > KafkaSourceLegacyITCase.testBrokerFailure

[jira] [Commented] (FLINK-26393) KafkaITCase.testBrokerFailure fails due to a topic isn't cleaned up properly

[ https://issues.apache.org/jira/browse/FLINK-26393?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17499942#comment-17499942 ] Yun Gao commented on FLINK-26393: -

[GitHub] [flink] dannycranmer commented on a change in pull request #18945: [FLINK-26417][connector/base] Add failed Inflight requests in async writer snapshot state

dannycranmer commented on a change in pull request #18945: URL: https://github.com/apache/flink/pull/18945#discussion_r817423453 ## File path: flink-connectors/flink-connector-base/src/main/java/org/apache/flink/connector/base/sink/writer/AsyncSinkWriter.java ## @@ -51,7

[jira] [Commented] (FLINK-26393) KafkaITCase.testBrokerFailure fails due to a topic isn't cleaned up properly

[ https://issues.apache.org/jira/browse/FLINK-26393?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17499940#comment-17499940 ] Yun Gao commented on FLINK-26393: -

[jira] [Comment Edited] (FLINK-26387) KafkaSourceLegacyITCase.testBrokerFailure hang on azure

[ https://issues.apache.org/jira/browse/FLINK-26387?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17499937#comment-17499937 ] Yun Gao edited comment on FLINK-26387 at 3/2/22, 7:45 AM: --

[jira] [Commented] (FLINK-26393) KafkaITCase.testBrokerFailure fails due to a topic isn't cleaned up properly

[ https://issues.apache.org/jira/browse/FLINK-26393?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17499941#comment-17499941 ] Yun Gao commented on FLINK-26393: -

[jira] [Commented] (FLINK-26444) Window allocator supporting pyflink datastream API

[ https://issues.apache.org/jira/browse/FLINK-26444?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17499938#comment-17499938 ] Juntao Hu commented on FLINK-26444: --- [~cun8cun8] are you working on this? > Window allocator

[jira] [Commented] (FLINK-26387) KafkaSourceLegacyITCase.testBrokerFailure hang on azure

[ https://issues.apache.org/jira/browse/FLINK-26387?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17499937#comment-17499937 ] Yun Gao commented on FLINK-26387: -

[GitHub] [flink] flinkbot edited a comment on pull request #18655: [FLINK-25799] [docs] Translate table/filesystem.md page into Chinese.

flinkbot edited a comment on pull request #18655: URL: https://github.com/apache/flink/pull/18655#issuecomment-1032265310 ## CI report: * ea083dee7aacf256ca0642ddbcf8c624211d6426 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18655: [FLINK-25799] [docs] Translate table/filesystem.md page into Chinese.

flinkbot edited a comment on pull request #18655: URL: https://github.com/apache/flink/pull/18655#issuecomment-1032265310 ## CI report: * 887bb5fe33f3fcd33b5cbf82594b6978fadf55fa Azure:

[GitHub] [flink] shouweikun commented on pull request #18199: [FLINK-25183][table] Optimize changelog normalize for the managed table upse…

shouweikun commented on pull request #18199: URL: https://github.com/apache/flink/pull/18199#issuecomment-1056468031 @jjrrzxc Hi, I'm afraid that this pr can not work on your problem. Actually `StreamPhysicalWindowAggregate` only does consume **Insert-only** records for now.

[GitHub] [flink] SteNicholas commented on a change in pull request #18954: [FLINK-20633][python] Add retry times to download avro

SteNicholas commented on a change in pull request #18954: URL: https://github.com/apache/flink/pull/18954#discussion_r817417527 ## File path: flink-python/pyflink/pyflink_gateway_server.py ## @@ -290,7 +291,23 @@ def launch_gateway_server_process(env, args): classpath

[jira] [Updated] (FLINK-26437) Cannot discover a connector using option: 'connector'='jdbc'

[ https://issues.apache.org/jira/browse/FLINK-26437?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-26437: --- Environment: (was: PROD,DEV) > Cannot discover a connector using option:

[jira] [Created] (FLINK-26444) Window allocator supporting pyflink datastream API

zhangjingcun created FLINK-26444: Summary: Window allocator supporting pyflink datastream API Key: FLINK-26444 URL: https://issues.apache.org/jira/browse/FLINK-26444 Project: Flink Issue

[jira] [Closed] (FLINK-22441) In Flink v1.11.3 contains netty(version:3.10.6) netty(version:4.1.60) . There are many vulnerabilities, like CVE-2021-21409 etc. please confirm these version and fix. thx

[ https://issues.apache.org/jira/browse/FLINK-22441?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser closed FLINK-22441. -- Resolution: Won't Fix This has been resolved for Flink 1.14 and newer versions, but can't be

[jira] [Updated] (FLINK-26438) expat critical vulnerabilities CVE-2021-45960

[ https://issues.apache.org/jira/browse/FLINK-26438?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-26438: --- Priority: Major (was: Critical) > expat critical vulnerabilities CVE-2021-45960 >

[GitHub] [flink] flinkbot edited a comment on pull request #18838: [FLINK-26177][Connector/pulsar] Use testcontainer pulsar runtime instead o…

flinkbot edited a comment on pull request #18838: URL: https://github.com/apache/flink/pull/18838#issuecomment-1044141081 ## CI report: * 86716e0aca7328bb8affdde3ea95f933849934e7 Azure:

[jira] [Updated] (FLINK-26443) Add a benchmark framework for flinkml

[ https://issues.apache.org/jira/browse/FLINK-26443?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-26443: --- Labels: pull-request-available (was: ) > Add a benchmark framework for flinkml >

[GitHub] [flink-ml] zhipeng93 opened a new pull request #69: [FLINK-26443] Add benchmark framework for Flink ML

zhipeng93 opened a new pull request #69: URL: https://github.com/apache/flink-ml/pull/69 ## What is the purpose of the change - Add a benchmark framework for Flink ML in flink-ml-tests. ## Brief change log - Adds a benchmark framework for Flink ML. - Adds KMeansBenchmark and

[GitHub] [flink] flinkbot edited a comment on pull request #18944: [FLINK-26430][FLINK-26429][runtime-web] Bump Karma and follow-redirects to address security findings

flinkbot edited a comment on pull request #18944: URL: https://github.com/apache/flink/pull/18944#issuecomment-1055498759 ## CI report: * f2dfe92d769bdbba5ca9407f35bed8505ae71cd3 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18838: [FLINK-26177][Connector/pulsar] Use testcontainer pulsar runtime instead o…

flinkbot edited a comment on pull request #18838: URL: https://github.com/apache/flink/pull/18838#issuecomment-1044141081 ## CI report: * 86716e0aca7328bb8affdde3ea95f933849934e7 Azure:

[jira] [Closed] (FLINK-26427) Streaming File Sink Uploading Smaller Versions Of The Same Part File To S3 (Race Condition)

[ https://issues.apache.org/jira/browse/FLINK-26427?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser closed FLINK-26427. -- Resolution: Resolved Thanks for confirming that [~johnboy84] - Closing this ticket >

[GitHub] [flink] flinkbot edited a comment on pull request #18944: [FLINK-26430][FLINK-26429][runtime-web] Bump Karma and follow-redirects to address security findings

flinkbot edited a comment on pull request #18944: URL: https://github.com/apache/flink/pull/18944#issuecomment-1055498759 ## CI report: * f2dfe92d769bdbba5ca9407f35bed8505ae71cd3 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18838: [FLINK-26177][Connector/pulsar] Use testcontainer pulsar runtime instead o…

flinkbot edited a comment on pull request #18838: URL: https://github.com/apache/flink/pull/18838#issuecomment-1044141081 ## CI report: * 86716e0aca7328bb8affdde3ea95f933849934e7 Azure:

[GitHub] [flink] bgeng777 commented on a change in pull request #18739: [FLINK-26030][yarn] Set FLINK_LIB_DIR to 'lib' under working dir in YARN containers

bgeng777 commented on a change in pull request #18739: URL: https://github.com/apache/flink/pull/18739#discussion_r817405111 ## File path: flink-yarn/src/test/java/org/apache/flink/yarn/YarnClusterDescriptorTest.java ## @@ -854,6 +855,25 @@ public void

[GitHub] [flink] MartijnVisser commented on pull request #18944: [FLINK-26430][FLINK-26429][runtime-web] Bump Karma and follow-redirects to address security findings

MartijnVisser commented on pull request #18944: URL: https://github.com/apache/flink/pull/18944#issuecomment-1056427149 @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] HuangXingBo commented on a change in pull request #18954: [FLINK-20633][python] Add retry times to download avro

HuangXingBo commented on a change in pull request #18954: URL: https://github.com/apache/flink/pull/18954#discussion_r817402319 ## File path: flink-python/pyflink/pyflink_gateway_server.py ## @@ -290,7 +291,23 @@ def launch_gateway_server_process(env, args): classpath

[GitHub] [flink] flinkbot edited a comment on pull request #18739: [FLINK-26030][yarn] Set FLINK_LIB_DIR to 'lib' under working dir in YARN containers

flinkbot edited a comment on pull request #18739: URL: https://github.com/apache/flink/pull/18739#issuecomment-1037747523 ## CI report: * 070f67c5a96eef7252b15f5f8299be16c623ef09 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18953: [FLINK-26387][connectors/kafka] Fix KafkaSourceLegacyITCase.testBrokerFailure

flinkbot edited a comment on pull request #18953: URL: https://github.com/apache/flink/pull/18953#issuecomment-1055680614 ## CI report: * 85d792c57d22424b880c400a43ccdd93728fce88 Azure:

[jira] [Created] (FLINK-26443) Add a benchmark framework for flinkml

Zhipeng Zhang created FLINK-26443: - Summary: Add a benchmark framework for flinkml Key: FLINK-26443 URL: https://issues.apache.org/jira/browse/FLINK-26443 Project: Flink Issue Type: New

[GitHub] [flink] flinkbot edited a comment on pull request #18739: [FLINK-26030][yarn] Set FLINK_LIB_DIR to 'lib' under working dir in YARN containers

flinkbot edited a comment on pull request #18739: URL: https://github.com/apache/flink/pull/18739#issuecomment-1037747523 ## CI report: * 070f67c5a96eef7252b15f5f8299be16c623ef09 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18953: [FLINK-26387][connectors/kafka] Fix KafkaSourceLegacyITCase.testBrokerFailure

flinkbot edited a comment on pull request #18953: URL: https://github.com/apache/flink/pull/18953#issuecomment-1055680614 ## CI report: * 85d792c57d22424b880c400a43ccdd93728fce88 Azure:

[jira] [Closed] (FLINK-26442) Allow ManifestFile to write a list of ManifestFileMeta into multiple files if too many.

[ https://issues.apache.org/jira/browse/FLINK-26442?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-26442. Fix Version/s: table-store-0.1.0 Assignee: Caizhi Weng Resolution: Fixed master:

[GitHub] [flink-table-store] JingsongLi merged pull request #29: [FLINK-26442] Allow ManifestFile to write a list of ManifestFileMeta into multiple files if too many

JingsongLi merged pull request #29: URL: https://github.com/apache/flink-table-store/pull/29 -- 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 #18739: [FLINK-26030][yarn] Set FLINK_LIB_DIR to 'lib' under working dir in YARN containers

flinkbot edited a comment on pull request #18739: URL: https://github.com/apache/flink/pull/18739#issuecomment-1037747523 ## CI report: * 070f67c5a96eef7252b15f5f8299be16c623ef09 Azure:

[jira] [Commented] (FLINK-26191) Incorrect license in Elasticsearch connectors

[ https://issues.apache.org/jira/browse/FLINK-26191?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17499911#comment-17499911 ] Yun Gao commented on FLINK-26191: - Got that, thanks [~alexanderpreuss] for the fixing~ > Incorrect

[jira] [Commented] (FLINK-25243) Fabric8FlinkKubeClientITCase.testCheckAndUpdateConfigMapConcurrently

[ https://issues.apache.org/jira/browse/FLINK-25243?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17499910#comment-17499910 ] Yun Gao commented on FLINK-25243: - Merged on master via 152ad4fc14920372076c0004793c179141ae10c7. If the

[GitHub] [flink] gaoyunhaii closed pull request #18891: [FLINK-25243][k8s] Increase the k8s transactional operation max retries in the integration tests

gaoyunhaii closed pull request #18891: URL: https://github.com/apache/flink/pull/18891 -- 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 #18955: [FLINK-26440] CompactorOperatorStateHandler can not work with unaligned checkpoint.

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

[GitHub] [flink] flinkbot edited a comment on pull request #18739: [FLINK-26030][yarn] Set FLINK_LIB_DIR to 'lib' under working dir in YARN containers

flinkbot edited a comment on pull request #18739: URL: https://github.com/apache/flink/pull/18739#issuecomment-1037747523 ## CI report: * 070f67c5a96eef7252b15f5f8299be16c623ef09 Azure:

[GitHub] [flink] wangyang0918 commented on a change in pull request #18739: [FLINK-26030][yarn] Set FLINK_LIB_DIR to 'lib' under working dir in YARN containers

wangyang0918 commented on a change in pull request #18739: URL: https://github.com/apache/flink/pull/18739#discussion_r817387290 ## File path: flink-yarn/src/test/java/org/apache/flink/yarn/YarnClusterDescriptorTest.java ## @@ -854,6 +855,25 @@ public void

[GitHub] [flink] flinkbot edited a comment on pull request #18955: [FLINK-26440] CompactorOperatorStateHandler can not work with unaligned checkpoint.

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

[GitHub] [flink] flinkbot edited a comment on pull request #18938: [FLINK-26403] SinkWriter should emit all the pending committables on endOfInput

flinkbot edited a comment on pull request #18938: URL: https://github.com/apache/flink/pull/18938#issuecomment-1055248048 ## CI report: * 7232540fbd51c09b4a0f660aa6d614ed9bc20348 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18739: [FLINK-26030][yarn] Set FLINK_LIB_DIR to 'lib' under working dir in YARN containers

flinkbot edited a comment on pull request #18739: URL: https://github.com/apache/flink/pull/18739#issuecomment-1037747523 ## CI report: * 070f67c5a96eef7252b15f5f8299be16c623ef09 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18938: [FLINK-26403] SinkWriter should emit all the pending committables on endOfInput

flinkbot edited a comment on pull request #18938: URL: https://github.com/apache/flink/pull/18938#issuecomment-1055248048 ## CI report: * 7232540fbd51c09b4a0f660aa6d614ed9bc20348 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18739: [FLINK-26030][yarn] Set FLINK_LIB_DIR to 'lib' under working dir in YARN containers

flinkbot edited a comment on pull request #18739: URL: https://github.com/apache/flink/pull/18739#issuecomment-1037747523 ## CI report: * 070f67c5a96eef7252b15f5f8299be16c623ef09 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18739: [FLINK-26030][yarn] Set FLINK_LIB_DIR to 'lib' under working dir in YARN containers

flinkbot edited a comment on pull request #18739: URL: https://github.com/apache/flink/pull/18739#issuecomment-1037747523 ## CI report: * 070f67c5a96eef7252b15f5f8299be16c623ef09 Azure:

[GitHub] [flink] SteNicholas commented on a change in pull request #18954: [FLINK-20633][python] Add retry times to download avro

SteNicholas commented on a change in pull request #18954: URL: https://github.com/apache/flink/pull/18954#discussion_r817378104 ## File path: flink-python/pyflink/pyflink_gateway_server.py ## @@ -290,7 +291,23 @@ def launch_gateway_server_process(env, args): classpath

[GitHub] [flink] flinkbot edited a comment on pull request #18739: [FLINK-26030][yarn] Set FLINK_LIB_DIR to 'lib' under working dir in YARN containers

flinkbot edited a comment on pull request #18739: URL: https://github.com/apache/flink/pull/18739#issuecomment-1037747523 ## CI report: * 070f67c5a96eef7252b15f5f8299be16c623ef09 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18739: [FLINK-26030][yarn] Set FLINK_LIB_DIR to 'lib' under working dir in YARN containers

flinkbot edited a comment on pull request #18739: URL: https://github.com/apache/flink/pull/18739#issuecomment-1037747523 ## CI report: * 070f67c5a96eef7252b15f5f8299be16c623ef09 Azure:

[GitHub] [flink] HuangXingBo commented on a change in pull request #18954: [FLINK-20633][python] Add retry times to download avro

HuangXingBo commented on a change in pull request #18954: URL: https://github.com/apache/flink/pull/18954#discussion_r817374755 ## File path: flink-python/pyflink/pyflink_gateway_server.py ## @@ -290,7 +291,23 @@ def launch_gateway_server_process(env, args): classpath

[jira] [Commented] (FLINK-26422) Update Chinese documentation with the new TablePipeline docs

[ https://issues.apache.org/jira/browse/FLINK-26422?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17499898#comment-17499898 ] zoucao commented on FLINK-26422: Hi [~slinkydeveloper], I'm willing to fix it, could you assign the

[GitHub] [flink] flinkbot edited a comment on pull request #18739: [FLINK-26030][yarn] Set FLINK_LIB_DIR to 'lib' under working dir in YARN containers

flinkbot edited a comment on pull request #18739: URL: https://github.com/apache/flink/pull/18739#issuecomment-1037747523 ## CI report: * 89b8ca850e24457d3e5c09c4ffa6b6ffd0dff6a3 Azure:

[GitHub] [flink-table-store] JingsongLi commented on a change in pull request #29: [FLINK-26442] Allow ManifestFile to write a list of ManifestFileMeta into multiple files if too many

JingsongLi commented on a change in pull request #29: URL: https://github.com/apache/flink-table-store/pull/29#discussion_r817368776 ## File path: flink-table-store-core/src/main/java/org/apache/flink/table/store/file/utils/RollingFile.java ## @@ -0,0 +1,129 @@ +/* + *

[GitHub] [flink] flinkbot edited a comment on pull request #18840: [FLINK-25528][state-processor-api] state processor api do not support increment checkpoint

flinkbot edited a comment on pull request #18840: URL: https://github.com/apache/flink/pull/18840#issuecomment-1044222572 ## CI report: * 2cb596515665f8a5712d5d5f48d95e85ebf3ce4e Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18739: [FLINK-26030][yarn] Set FLINK_LIB_DIR to 'lib' under working dir in YARN containers

flinkbot edited a comment on pull request #18739: URL: https://github.com/apache/flink/pull/18739#issuecomment-1037747523 ## CI report: * 89b8ca850e24457d3e5c09c4ffa6b6ffd0dff6a3 Azure:

[jira] [Updated] (FLINK-26442) Allow ManifestFile to write a list of ManifestFileMeta into multiple files if too many.

[ https://issues.apache.org/jira/browse/FLINK-26442?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-26442: --- Labels: pull-request-available (was: ) > Allow ManifestFile to write a list of

[GitHub] [flink-table-store] tsreaper opened a new pull request #29: [FLINK-26442] Allow ManifestFile to write a list of ManifestFileMeta into multiple files if too many

tsreaper opened a new pull request #29: URL: https://github.com/apache/flink-table-store/pull/29 Currently `ManifestFile#write` will only produce a single file no matter how large the given `ManifestFileMeta` list is. However batch jobs are likely to produce a lot of changes hence the

[GitHub] [flink] flinkbot edited a comment on pull request #18840: [FLINK-25528][state-processor-api] state processor api do not support increment checkpoint

flinkbot edited a comment on pull request #18840: URL: https://github.com/apache/flink/pull/18840#issuecomment-1044222572 ## CI report: * 2cb596515665f8a5712d5d5f48d95e85ebf3ce4e Azure:

[jira] [Created] (FLINK-26442) Allow ManifestFile to write a list of ManifestFileMeta into multiple files if too many.

Caizhi Weng created FLINK-26442: --- Summary: Allow ManifestFile to write a list of ManifestFileMeta into multiple files if too many. Key: FLINK-26442 URL: https://issues.apache.org/jira/browse/FLINK-26442

[GitHub] [flink] flinkbot edited a comment on pull request #18739: [FLINK-26030][yarn] Set FLINK_LIB_DIR to 'lib' under working dir in YARN containers

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

[GitHub] [flink] Myasuka commented on a change in pull request #18931: [FLINK-26396][state/changelog] Fail upload if last attempt times out

Myasuka commented on a change in pull request #18931: URL: https://github.com/apache/flink/pull/18931#discussion_r817347164 ## File path: flink-dstl/flink-dstl-dfs/src/main/java/org/apache/flink/changelog/fs/RetryingExecutor.java ## @@ -102,35 +129,48 @@ public void close()

[GitHub] [flink] Myasuka commented on a change in pull request #18931: [FLINK-26396][state/changelog] Fail upload if last attempt times out

Myasuka commented on a change in pull request #18931: URL: https://github.com/apache/flink/pull/18931#discussion_r817353818 ## File path: flink-dstl/flink-dstl-dfs/src/main/java/org/apache/flink/changelog/fs/RetryingExecutor.java ## @@ -172,16 +225,19 @@ private RetriableTask

[GitHub] [flink] Myasuka commented on a change in pull request #18931: [FLINK-26396][state/changelog] Fail upload if last attempt times out

Myasuka commented on a change in pull request #18931: URL: https://github.com/apache/flink/pull/18931#discussion_r817353277 ## File path: flink-dstl/flink-dstl-dfs/src/main/java/org/apache/flink/changelog/fs/RetryingExecutor.java ## @@ -151,18 +193,29 @@ public void run() {

[GitHub] [flink] SteNicholas commented on a change in pull request #18954: [FLINK-20633][python] Add retry times to download avro

SteNicholas commented on a change in pull request #18954: URL: https://github.com/apache/flink/pull/18954#discussion_r817353198 ## File path: flink-python/pyflink/pyflink_gateway_server.py ## @@ -290,7 +291,23 @@ def launch_gateway_server_process(env, args): classpath

[GitHub] [flink] Myasuka commented on a change in pull request #18931: [FLINK-26396][state/changelog] Fail upload if last attempt times out

Myasuka commented on a change in pull request #18931: URL: https://github.com/apache/flink/pull/18931#discussion_r817341846 ## File path: flink-dstl/flink-dstl-dfs/src/main/java/org/apache/flink/changelog/fs/RetryingExecutor.java ## @@ -151,18 +193,29 @@ public void run() {

[jira] [Commented] (FLINK-26345) Observer should detect flink job even if deployment status is empty

[ https://issues.apache.org/jira/browse/FLINK-26345?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17499891#comment-17499891 ] Nicholas Jiang commented on FLINK-26345: [~t...@apache.org], are you working for this ticket? If

[jira] [Commented] (FLINK-26367) Move sanity check in FlinkService#cancelJob to DefaultDeploymentValidator

[ https://issues.apache.org/jira/browse/FLINK-26367?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17499890#comment-17499890 ] Yang Wang commented on FLINK-26367: --- [~nicholasjiang] Thanks for your contribution. > Move sanity

[jira] [Closed] (FLINK-26367) Move sanity check in FlinkService#cancelJob to DefaultDeploymentValidator

[ https://issues.apache.org/jira/browse/FLINK-26367?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yang Wang closed FLINK-26367. - Resolution: Fixed Fixed via: main:11944da080373834f26c726895f3b90b1d24b46c > Move sanity check in

[GitHub] [flink] Myasuka commented on a change in pull request #18931: [FLINK-26396][state/changelog] Fail upload if last attempt times out

Myasuka commented on a change in pull request #18931: URL: https://github.com/apache/flink/pull/18931#discussion_r817347164 ## File path: flink-dstl/flink-dstl-dfs/src/main/java/org/apache/flink/changelog/fs/RetryingExecutor.java ## @@ -102,35 +129,48 @@ public void close()

[GitHub] [flink] flinkbot edited a comment on pull request #18957: Window allocator supporting pyflink datastream API

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

[GitHub] [flink] flinkbot commented on pull request #18957: Window allocator supporting pyflink datastream API

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

[GitHub] [flink] cun8cun8 opened a new pull request #18957: Window allocator supporting pyflink datastream API

cun8cun8 opened a new pull request #18957: URL: https://github.com/apache/flink/pull/18957 ## 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] flinkbot edited a comment on pull request #18956: [FLINK-26394] CheckpointCoordinator.isTriggering can not be reset in a particular case.

flinkbot edited a comment on pull request #18956: URL: https://github.com/apache/flink/pull/18956#issuecomment-1056194247 ## CI report: * 9256843f24defd169d04c7347ac2457a33aa7dc1 Azure:

[GitHub] [flink] Myasuka commented on a change in pull request #18931: [FLINK-26396][state/changelog] Fail upload if last attempt times out

Myasuka commented on a change in pull request #18931: URL: https://github.com/apache/flink/pull/18931#discussion_r817341846 ## File path: flink-dstl/flink-dstl-dfs/src/main/java/org/apache/flink/changelog/fs/RetryingExecutor.java ## @@ -151,18 +193,29 @@ public void run() {

[GitHub] [flink] flinkbot commented on pull request #18956: [FLINK-26394] CheckpointCoordinator.isTriggering can not be reset in a particular case.

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

[jira] [Updated] (FLINK-26394) CheckpointCoordinator.isTriggering can not be reset if a checkpoint expires while the checkpointCoordinator task is queuing in the SourceCoordinator executor.

[ https://issues.apache.org/jira/browse/FLINK-26394?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-26394: --- Labels: pull-request-available (was: ) > CheckpointCoordinator.isTriggering can not be

[GitHub] [flink] pltbkd opened a new pull request #18956: [FLINK-26394] CheckpointCoordinator.isTriggering can not be reset in a particular case.

pltbkd opened a new pull request #18956: URL: https://github.com/apache/flink/pull/18956 ## What is the purpose of the change CheckpointCoordinator.isTriggering can not be reset if a checkpoint expires while the checkpointCoordinator task is queuing in the SourceCoordinator

[GitHub] [flink] RocMarshal commented on pull request #18655: [FLINK-25799] [docs] Translate table/filesystem.md page into Chinese.

RocMarshal commented on pull request #18655: URL: https://github.com/apache/flink/pull/18655#issuecomment-1056189314 IMO,it would be better if you squish the multi commits in thr pr into one commit. -- This is an automated message from the Apache Git Service. To respond to the message,

[jira] [Created] (FLINK-26441) Overwrite commit kind should not be APPEND

Jingsong Lee created FLINK-26441: Summary: Overwrite commit kind should not be APPEND Key: FLINK-26441 URL: https://issues.apache.org/jira/browse/FLINK-26441 Project: Flink Issue Type:

[jira] [Commented] (FLINK-25256) Savepoints do not work with ExternallyInducedSources

[ https://issues.apache.org/jira/browse/FLINK-25256?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17499879#comment-17499879 ] Brian Zhou commented on FLINK-25256: Yes, this interface is now used in the both the legacy reader

[GitHub] [flink] flinkbot commented on pull request #18955: [FLINK-26440] CompactorOperatorStateHandler can not work with unaligned checkpoint.

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

[GitHub] [flink] flinkbot edited a comment on pull request #18955: [FLINK-26440] CompactorOperatorStateHandler can not work with unaligned checkpoint.

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

[GitHub] [flink] flinkbot edited a comment on pull request #18935: [FLINK-26347][rpc] Using system classloader in deserialization of Rem…

flinkbot edited a comment on pull request #18935: URL: https://github.com/apache/flink/pull/18935#issuecomment-1055078593 ## CI report: * d5ac33b72f6446d08a3593663720f425a0321d39 Azure:

  1   2   3   4   5   6   >