[GitHub] [flink] flinkbot commented on pull request #17220: [FLINK-24197] Guard against CLRF being split across chunks

flinkbot commented on pull request #17220: URL: https://github.com/apache/flink/pull/17220#issuecomment-916179140 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-24197) Streaming File Sink end-to-end test fails with : "RestClientException: [File upload failed.]"

[ https://issues.apache.org/jira/browse/FLINK-24197?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-24197: --- Labels: pull-request-available test-stability (was: test-stability) > Streaming File Sink

[jira] [Updated] (FLINK-24197) Streaming File Sink end-to-end test fails with : "RestClientException: [File upload failed.]"

[ https://issues.apache.org/jira/browse/FLINK-24197?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-24197: - Affects Version/s: (was: 1.15.0) 1.14.0 > Streaming File

[jira] [Updated] (FLINK-24197) Streaming File Sink end-to-end test fails with : "RestClientException: [File upload failed.]"

[ https://issues.apache.org/jira/browse/FLINK-24197?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-24197: - Fix Version/s: 1.14.0 > Streaming File Sink end-to-end test fails with :

[GitHub] [flink] zentol opened a new pull request #17220: [FLINK-24197] Guard against CLRF being split across chunks

zentol opened a new pull request #17220: URL: https://github.com/apache/flink/pull/17220 This PR adds a defense mechanism against https://github.com/netty/netty/issues/11668. If the CRLF prefix of a multipart delimiter is split across 2 chunks an exception is thrown because Netty

[jira] [Resolved] (FLINK-24041) [FLIP-171] Generic AsyncSinkBase

[ https://issues.apache.org/jira/browse/FLINK-24041?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer resolved FLINK-24041. --- Resolution: Fixed Rebased and fixed conflict. Tests green, merged. > [FLIP-171] Generic

[GitHub] [flink] dannycranmer merged pull request #17213: [FLINK-24041][connectors] First draft of API, uses FLIP-143: Unified …

dannycranmer merged pull request #17213: URL: https://github.com/apache/flink/pull/17213 -- 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] [Closed] (FLINK-23836) [doc-zh]Translate "/dev/datastream/execution/execution_configuration.md" into Chinese

[ https://issues.apache.org/jira/browse/FLINK-23836?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-23836. --- Fix Version/s: 1.15.0 Resolution: Fixed Fixed in master: ff713a80d8d5adcc0f88e697a544776011bbb1be >

[GitHub] [flink] wuchong merged pull request #16865: [FLINK-23836][doc-zh]Translate "/dev/datastream/execution/execution_c…

wuchong merged pull request #16865: URL: https://github.com/apache/flink/pull/16865 -- 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 #17120: [FLINK-24065][connector] Upgrade the state of TwoPhaseCommitSink to support empty transaction after finished

flinkbot edited a comment on pull request #17120: URL: https://github.com/apache/flink/pull/17120#issuecomment-911597927 ## CI report: * a1289d10f06a9d9b3a387da2f6f00b54f8c2e705 Azure:

[GitHub] [flink] wuchong commented on pull request #16865: [FLINK-23836][doc-zh]Translate "/dev/datastream/execution/execution_c…

wuchong commented on pull request #16865: URL: https://github.com/apache/flink/pull/16865#issuecomment-916160831 Thanks @hapihu @RocMarshal . Merging... -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL

[GitHub] [flink] Airblader commented on pull request #17186: [FLINK-16203][table] Support JSON_OBJECT()

Airblader commented on pull request #17186: URL: https://github.com/apache/flink/pull/17186#issuecomment-916143656 As discussed offline I will investigate if we can reproduce the funky, but admittedly more convenient behavior other implementations expose. -- This is an automated message

[jira] [Updated] (FLINK-23345) Migrate to the next version of Python `requests` when released

[ https://issues.apache.org/jira/browse/FLINK-23345?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-23345: - Fix Version/s: 1.13.3 1.12.6 1.14.0 > Migrate to

[GitHub] [flink] matriv commented on a change in pull request #17217: [FLINK-24186][table-planner] Allow multiple rowtime attributes for collect() and print()

matriv commented on a change in pull request #17217: URL: https://github.com/apache/flink/pull/17217#discussion_r705384003 ## File path: flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/stream/StreamExecSink.java ## @@ -120,13

[jira] [Comment Edited] (FLINK-20195) Jobs endpoint returns duplicated jobs

[ https://issues.apache.org/jira/browse/FLINK-20195?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17412603#comment-17412603 ] Chesnay Schepler edited comment on FLINK-20195 at 9/9/21, 2:14 PM: ---

[jira] [Commented] (FLINK-20195) Jobs endpoint returns duplicated jobs

[ https://issues.apache.org/jira/browse/FLINK-20195?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17412603#comment-17412603 ] Chesnay Schepler commented on FLINK-20195: -- When a job is suspended (or terminates in any other

[GitHub] [flink] flinkbot edited a comment on pull request #17219: [FLINK-23345][python] Limits the version requests to 2.26.0 or above

flinkbot edited a comment on pull request #17219: URL: https://github.com/apache/flink/pull/17219#issuecomment-916103358 ## CI report: * d2830fd4430155ef74ade85f499730f0b3ed31a4 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17218: [FLINK-24184][task] Introduce lock to guard against race conditions around shouldInterruptOnCancel

flinkbot edited a comment on pull request #17218: URL: https://github.com/apache/flink/pull/17218#issuecomment-916076156 ## CI report: * 89c0b8983b03337a4c553e206571cb5e4bb6a5cf UNKNOWN * 1cf23bdcc4bf5c8e529da8cc5fc27d383e39533e Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17217: [FLINK-24186][table-planner] Allow multiple rowtime attributes for collect() and print()

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

[jira] [Created] (FLINK-24232) Archiving of suspended jobs prevents breaks subsequent archive attempts

Chesnay Schepler created FLINK-24232: Summary: Archiving of suspended jobs prevents breaks subsequent archive attempts Key: FLINK-24232 URL: https://issues.apache.org/jira/browse/FLINK-24232

[GitHub] [flink] flinkbot edited a comment on pull request #17200: [FLINK-24161] Fix interplay of stop-with-savepoint w/o drain with final checkpoints

flinkbot edited a comment on pull request #17200: URL: https://github.com/apache/flink/pull/17200#issuecomment-915343275 ## CI report: * 28b02c5ab644885f739ebf7c0b2462b40d6683bf Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17182: [release] Create 1.14 release-notes

flinkbot edited a comment on pull request #17182: URL: https://github.com/apache/flink/pull/17182#issuecomment-914199664 ## CI report: * b797bfedcd5b7fe4877c7fa888cb71860fff01ab Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16988: [FLINK-23458][docs] Added the network buffer documentation along wit…

flinkbot edited a comment on pull request #16988: URL: https://github.com/apache/flink/pull/16988#issuecomment-905730008 ## CI report: * 56620990c0b4f82b487fe8028e9379cc59bc9f08 UNKNOWN * cdd83428958a21df07de304751c0e1d8d75120db Azure:

[jira] [Commented] (FLINK-23345) Migrate to the next version of Python `requests` when released

[ https://issues.apache.org/jira/browse/FLINK-23345?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17412596#comment-17412596 ] Jarek Potiuk commented on FLINK-23345: -- Yeah. Limiting to >= 2.26.0 should be fine! > Migrate to

[jira] [Commented] (FLINK-24197) Streaming File Sink end-to-end test fails with : "RestClientException: [File upload failed.]"

[ https://issues.apache.org/jira/browse/FLINK-24197?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17412586#comment-17412586 ] Chesnay Schepler commented on FLINK-24197: -- Got the confirmation that this is a Netty bug.

[jira] [Created] (FLINK-24231) Buffer debloating microbenchmark for multiply gate

Anton Kalashnikov created FLINK-24231: - Summary: Buffer debloating microbenchmark for multiply gate Key: FLINK-24231 URL: https://issues.apache.org/jira/browse/FLINK-24231 Project: Flink

[GitHub] [flink] flinkbot commented on pull request #17219: [FLINK-23345][python] Limits the version requests to 2.26.0 or above

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

[GitHub] [flink] flinkbot edited a comment on pull request #17218: [FLINK-24184][task] Introduce lock to guard against race conditions around shouldInterruptOnCancel

flinkbot edited a comment on pull request #17218: URL: https://github.com/apache/flink/pull/17218#issuecomment-916076156 ## CI report: * 89c0b8983b03337a4c553e206571cb5e4bb6a5cf UNKNOWN * 1cf23bdcc4bf5c8e529da8cc5fc27d383e39533e UNKNOWN Bot commands The

[GitHub] [flink] flinkbot edited a comment on pull request #17213: [FLINK-24041][connectors] First draft of API, uses FLIP-143: Unified …

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

[GitHub] [flink] flinkbot edited a comment on pull request #17200: [FLINK-24161] Fix interplay of stop-with-savepoint w/o drain with final checkpoints

flinkbot edited a comment on pull request #17200: URL: https://github.com/apache/flink/pull/17200#issuecomment-915343275 ## CI report: * 28b02c5ab644885f739ebf7c0b2462b40d6683bf Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17182: [release] Create 1.14 release-notes

flinkbot edited a comment on pull request #17182: URL: https://github.com/apache/flink/pull/17182#issuecomment-914199664 ## CI report: * 79324344aae0589246a23ace046c7d4e681725cf Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17180: [FLINK-24123][python] Optimize the python operator instances of the same job to share one python environment resources in the same jv

flinkbot edited a comment on pull request #17180: URL: https://github.com/apache/flink/pull/17180#issuecomment-914169654 ## CI report: * 32b10796fbf98d90fe2cd1282aff793179078939 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17133: [Proof of Concept][FLINK-24138] Architectural tests

flinkbot edited a comment on pull request #17133: URL: https://github.com/apache/flink/pull/17133#issuecomment-912323602 ## CI report: * cfb98c4cc708adb38ced719788af16a50625a1c1 UNKNOWN * c5419c736955f9ba9c90af3e25f3bef48edc9c43 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16988: [FLINK-23458][docs] Added the network buffer documentation along wit…

flinkbot edited a comment on pull request #16988: URL: https://github.com/apache/flink/pull/16988#issuecomment-905730008 ## CI report: * 2660dc95b8d0cd03388690df239fdbb098c88758 Azure:

[jira] [Created] (FLINK-24230) Buffer debloating microbenchmark for single gate

Anton Kalashnikov created FLINK-24230: - Summary: Buffer debloating microbenchmark for single gate Key: FLINK-24230 URL: https://issues.apache.org/jira/browse/FLINK-24230 Project: Flink

[GitHub] [flink] twalthr commented on a change in pull request #17186: [FLINK-16203][table] Support JSON_OBJECT()

twalthr commented on a change in pull request #17186: URL: https://github.com/apache/flink/pull/17186#discussion_r705291119 ## File path: docs/data/sql_functions.yml ## @@ -708,6 +708,42 @@ json: -- '[]' JSON_QUERY('{}', 'strict $.invalid' EMPTY ARRAY ON ERROR)

[GitHub] [flink] flinkbot commented on pull request #17218: [FLINK-24184][task] Introduce lock to guard against race conditions around shouldInterruptOnCancel

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

[GitHub] [flink] flinkbot edited a comment on pull request #17216: [FLINK-18880][python] Respect configurations defined in flink-conf.yaml and environment variables when executing in local mode

flinkbot edited a comment on pull request #17216: URL: https://github.com/apache/flink/pull/17216#issuecomment-916047587 ## CI report: * 64d5b847be120bfed01a0da49d2534d55b815624 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17217: [FLINK-24186][table-planner] Allow multiple rowtime attributes for collect() and print()

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

[GitHub] [flink] flinkbot edited a comment on pull request #17200: [FLINK-24161] Fix interplay of stop-with-savepoint w/o drain with final checkpoints

flinkbot edited a comment on pull request #17200: URL: https://github.com/apache/flink/pull/17200#issuecomment-915343275 ## CI report: * 28b02c5ab644885f739ebf7c0b2462b40d6683bf Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17182: [release] Create 1.14 release-notes

flinkbot edited a comment on pull request #17182: URL: https://github.com/apache/flink/pull/17182#issuecomment-914199664 ## CI report: * 79324344aae0589246a23ace046c7d4e681725cf Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17180: [FLINK-24123][python] Optimize the python operator instances of the same job to share one python environment resources in the same jv

flinkbot edited a comment on pull request #17180: URL: https://github.com/apache/flink/pull/17180#issuecomment-914169654 ## CI report: * b2eb0fe23bcfe8680fb28dc1e8a72f64405bd0f1 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17133: [Proof of Concept][FLINK-24138] Architectural tests

flinkbot edited a comment on pull request #17133: URL: https://github.com/apache/flink/pull/17133#issuecomment-912323602 ## CI report: * cfb98c4cc708adb38ced719788af16a50625a1c1 UNKNOWN * c5419c736955f9ba9c90af3e25f3bef48edc9c43 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16988: [FLINK-23458][docs] Added the network buffer documentation along wit…

flinkbot edited a comment on pull request #16988: URL: https://github.com/apache/flink/pull/16988#issuecomment-905730008 ## CI report: * 2660dc95b8d0cd03388690df239fdbb098c88758 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16865: [FLINK-23836][doc-zh]Translate "/dev/datastream/execution/execution_c…

flinkbot edited a comment on pull request #16865: URL: https://github.com/apache/flink/pull/16865#issuecomment-900450716 ## CI report: * 027fdf4bbf0b624b89cee76165b6ad4db50424b3 Azure:

[GitHub] [flink] flinkbot commented on pull request #17219: [FLINK-23345][python] Limits the version requests to 2.26.0 or above

flinkbot commented on pull request #17219: URL: https://github.com/apache/flink/pull/17219#issuecomment-916073387 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-23345) Migrate to the next version of Python `requests` when released

[ https://issues.apache.org/jira/browse/FLINK-23345?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-23345: --- Labels: pull-request-available (was: ) > Migrate to the next version of Python `requests`

[GitHub] [flink] dianfu opened a new pull request #17219: [FLINK-23345][python] Limits the version requests to 2.26.0 or above

dianfu opened a new pull request #17219: URL: https://github.com/apache/flink/pull/17219 ## What is the purpose of the change *This pull request limits the version requests to 2.26.0 or above* ## Verifying this change This change is a trivial rework without any

[GitHub] [flink] dianfu commented on pull request #17219: [FLINK-23345][python] Limits the version requests to 2.26.0 or above

dianfu commented on pull request #17219: URL: https://github.com/apache/flink/pull/17219#issuecomment-916070697 cc @zentol -- 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.

[jira] [Updated] (FLINK-24086) Do not re-register SharedStateRegistry to reduce the recovery time of the job

[ https://issues.apache.org/jira/browse/FLINK-24086?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-24086: - Affects Version/s: (was: 1.14.0) > Do not re-register SharedStateRegistry to reduce

[jira] [Commented] (FLINK-23345) Migrate to the next version of Python `requests` when released

[ https://issues.apache.org/jira/browse/FLINK-23345?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17412558#comment-17412558 ] Chesnay Schepler commented on FLINK-23345: -- That's also fine. > Migrate to the next version of

[jira] [Comment Edited] (FLINK-24086) Do not re-register SharedStateRegistry to reduce the recovery time of the job

[ https://issues.apache.org/jira/browse/FLINK-24086?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17408273#comment-17408273 ] Dawid Wysakowicz edited comment on FLINK-24086 at 9/9/21, 1:00 PM: ---

[jira] [Commented] (FLINK-23316) There's no test for custom PartitionCommitPolicy

[ https://issues.apache.org/jira/browse/FLINK-23316?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17412559#comment-17412559 ] jackwangcs commented on FLINK-23316: Hi [~lirui], I'd like to add some tests for customized

[jira] [Comment Edited] (FLINK-24086) Do not re-register SharedStateRegistry to reduce the recovery time of the job

[ https://issues.apache.org/jira/browse/FLINK-24086?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17408273#comment-17408273 ] Dawid Wysakowicz edited comment on FLINK-24086 at 9/9/21, 1:00 PM: ---

[jira] [Commented] (FLINK-23345) Migrate to the next version of Python `requests` when released

[ https://issues.apache.org/jira/browse/FLINK-23345?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17412557#comment-17412557 ] Dian Fu commented on FLINK-23345: - We can limit the version of requests, e.g. requests >= 2.26.0. Then

[GitHub] [flink] Airblader commented on a change in pull request #17217: [FLINK-24186][table-planner] Allow multiple rowtime attributes for collect() and print()

Airblader commented on a change in pull request #17217: URL: https://github.com/apache/flink/pull/17217#discussion_r705303998 ## File path: flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/stream/StreamExecSink.java ## @@ -120,13

[jira] [Commented] (FLINK-23345) Migrate to the next version of Python `requests` when released

[ https://issues.apache.org/jira/browse/FLINK-23345?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17412555#comment-17412555 ] Chesnay Schepler commented on FLINK-23345: -- If it is truly not used, is there some way to just

[jira] [Commented] (FLINK-23345) Migrate to the next version of Python `requests` when released

[ https://issues.apache.org/jira/browse/FLINK-23345?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17412553#comment-17412553 ] Chesnay Schepler commented on FLINK-23345: -- Imo, whether it is used or not by Flink isn't

[jira] [Reopened] (FLINK-23345) Migrate to the next version of Python `requests` when released

[ https://issues.apache.org/jira/browse/FLINK-23345?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reopened FLINK-23345: -- > Migrate to the next version of Python `requests` when released >

[GitHub] [flink] dawidwys commented on a change in pull request #17200: [FLINK-24161] Fix interplay of stop-with-savepoint w/o drain with final checkpoints

dawidwys commented on a change in pull request #17200: URL: https://github.com/apache/flink/pull/17200#discussion_r705298107 ## File path: .idea/vcs.xml ## @@ -27,7 +11,7 @@ https://cwiki.apache.org/confluence/display/FLINK/$0; /> - +

[jira] [Closed] (FLINK-23345) Migrate to the next version of Python `requests` when released

[ https://issues.apache.org/jira/browse/FLINK-23345?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-23345. --- Resolution: Not A Problem > Migrate to the next version of Python `requests` when released >

[jira] [Comment Edited] (FLINK-23345) Migrate to the next version of Python `requests` when released

[ https://issues.apache.org/jira/browse/FLINK-23345?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17412552#comment-17412552 ] Dian Fu edited comment on FLINK-23345 at 9/9/21, 12:48 PM: --- [~potiuk] Thanks a

[jira] [Commented] (FLINK-23345) Migrate to the next version of Python `requests` when released

[ https://issues.apache.org/jira/browse/FLINK-23345?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17412552#comment-17412552 ] Dian Fu commented on FLINK-23345: - [~potiuk] Thanks a lot for sharing this information. Actually

[jira] [Updated] (FLINK-24229) [FLIP-171] DynamoDB implementation of Async Sink

[ https://issues.apache.org/jira/browse/FLINK-24229?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zichen Liu updated FLINK-24229: --- Description: h2. Motivation *User stories:* As a Flink user, I’d like to use DynamoDB as sink for

[jira] [Created] (FLINK-24229) [FLIP-171] DynamoDB implementation of Async Sink

Zichen Liu created FLINK-24229: -- Summary: [FLIP-171] DynamoDB implementation of Async Sink Key: FLINK-24229 URL: https://issues.apache.org/jira/browse/FLINK-24229 Project: Flink Issue Type: New

[jira] [Updated] (FLINK-24228) [FLIP-171] Firehose implementation of Async Sink

[ https://issues.apache.org/jira/browse/FLINK-24228?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zichen Liu updated FLINK-24228: --- Description: h2. Motivation *User stories:* As a Flink user, I’d like to use Kinesis Firehose as

[GitHub] [flink] Jiayi-Liao commented on a change in pull request #17151: [FLINK-23180] Do not initialize checkpoint base locations when checkp…

Jiayi-Liao commented on a change in pull request #17151: URL: https://github.com/apache/flink/pull/17151#discussion_r705293083 ## File path: flink-tests/src/test/java/org/apache/flink/test/checkpointing/SavepointITCase.java ## @@ -515,6 +517,50 @@ public void

[GitHub] [flink] infoverload commented on a change in pull request #16988: [FLINK-23458][docs] Added the network buffer documentation along wit…

infoverload commented on a change in pull request #16988: URL: https://github.com/apache/flink/pull/16988#discussion_r705292607 ## File path: docs/content/docs/deployment/memory/network_mem_tuning.md ## @@ -0,0 +1,176 @@ +--- +title: "Network Buffer Tuning" +weight: 100 +type:

[jira] [Created] (FLINK-24228) [FLIP-171] Firehose implementation of Async Sink

Zichen Liu created FLINK-24228: -- Summary: [FLIP-171] Firehose implementation of Async Sink Key: FLINK-24228 URL: https://issues.apache.org/jira/browse/FLINK-24228 Project: Flink Issue Type: New

[jira] [Updated] (FLINK-24227) [FLIP-171] KDS implementation of Async Sink

[ https://issues.apache.org/jira/browse/FLINK-24227?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zichen Liu updated FLINK-24227: --- Description: h2. Motivation *User stories:* As a Flink user, I’d like to use Kinesis Data Streams

[jira] [Updated] (FLINK-24227) [FLIP-171] KDS implementation of Async Sink

[ https://issues.apache.org/jira/browse/FLINK-24227?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zichen Liu updated FLINK-24227: --- Description: h2. Motivation *User stories:* As a Flink user, I’d like to use Kinesis Data Streams

[GitHub] [flink] gaoyunhaii commented on pull request #17200: [FLINK-24161] Fix interplay of stop-with-savepoint w/o drain with final checkpoints

gaoyunhaii commented on pull request #17200: URL: https://github.com/apache/flink/pull/17200#issuecomment-916053978 I do the manual check, the savepoint would fail as expected and cause failover, then the job could be finished with stop-with-savepoint normally. -- This is an automated

[jira] [Created] (FLINK-24227) [FLIP-171] KDS implementation of Async Sink

Zichen Liu created FLINK-24227: -- Summary: [FLIP-171] KDS implementation of Async Sink Key: FLINK-24227 URL: https://issues.apache.org/jira/browse/FLINK-24227 Project: Flink Issue Type: New

[jira] [Closed] (FLINK-24213) Java deadlock in QueryableState ClientTest

[ https://issues.apache.org/jira/browse/FLINK-24213?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-24213. Fix Version/s: 1.14.0 Resolution: Fixed master:

[GitHub] [flink] infoverload commented on a change in pull request #16988: [FLINK-23458][docs] Added the network buffer documentation along wit…

infoverload commented on a change in pull request #16988: URL: https://github.com/apache/flink/pull/16988#discussion_r705288377 ## File path: docs/content/docs/deployment/memory/network_mem_tuning.md ## @@ -0,0 +1,176 @@ +--- +title: "Network Buffer Tuning" +weight: 100 +type:

[GitHub] [flink] zentol merged pull request #17212: [FLINK-24213][qs] Use single lock in ServerConnection

zentol merged pull request #17212: URL: https://github.com/apache/flink/pull/17212 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail:

[jira] [Commented] (FLINK-16478) add restApi to modify loglevel

[ https://issues.apache.org/jira/browse/FLINK-16478?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17412549#comment-17412549 ] Kanata Li commented on FLINK-16478: We also have such a demand, but unfortunately we do not have

[GitHub] [flink] gaoyunhaii commented on a change in pull request #17200: [FLINK-24161] Fix interplay of stop-with-savepoint w/o drain with final checkpoints

gaoyunhaii commented on a change in pull request #17200: URL: https://github.com/apache/flink/pull/17200#discussion_r705283949 ## File path: .idea/vcs.xml ## @@ -27,7 +11,7 @@ https://cwiki.apache.org/confluence/display/FLINK/$0; /> -

[GitHub] [flink] matriv commented on a change in pull request #17217: [FLINK-24186][table-planner] Allow multiple rowtime attributes for collect() and print()

matriv commented on a change in pull request #17217: URL: https://github.com/apache/flink/pull/17217#discussion_r705283784 ## File path: flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/stream/StreamExecSink.java ## @@ -120,13

[jira] [Commented] (FLINK-24171) Formatting should be enforced for Flink UI

[ https://issues.apache.org/jira/browse/FLINK-24171?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17412546#comment-17412546 ] Martijn Visser commented on FLINK-24171: [~junhany] Is this something you could also help us out

[GitHub] [flink] twalthr edited a comment on pull request #17217: [FLINK-24186][table-planner] Allow multiple rowtime attributes for collect() and print()

twalthr edited a comment on pull request #17217: URL: https://github.com/apache/flink/pull/17217#issuecomment-916047923 @MartijnVisser the documented query is still correct. I was planning to merge this only to master, so we could revert you change only there. -- This is an automated

[GitHub] [flink] twalthr commented on pull request #17217: [FLINK-24186][table-planner] Allow multiple rowtime attributes for collect() and print()

twalthr commented on pull request #17217: URL: https://github.com/apache/flink/pull/17217#issuecomment-916047923 @MartijnVisser the query is still correct. I was planning to merge this only to master, so we could revert you change only there. -- This is an automated message from the

[GitHub] [flink] flinkbot commented on pull request #17217: [FLINK-24186][table-planner] Allow multiple rowtime attributes for collect() and print()

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

[GitHub] [flink] flinkbot commented on pull request #17216: [FLINK-18880][python] Respect configurations defined in flink-conf.yaml and environment variables when executing in local mode

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

[GitHub] [flink] flinkbot edited a comment on pull request #17189: [FLINK-23528][connectors/kinesis] Improving and reenable FlinkKinesisITCase

flinkbot edited a comment on pull request #17189: URL: https://github.com/apache/flink/pull/17189#issuecomment-914637509 ## CI report: * 8617e38c2c334b489e6c268954877ec0be5c570c Azure:

[jira] [Closed] (FLINK-24137) Python tests fail with "Exception in thread read_grpc_client_inputs"

[ https://issues.apache.org/jira/browse/FLINK-24137?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-24137. --- Resolution: Fixed Fixed in: - master via 7a1b2b39c0f5d7b6651a349db8bcb51cc6c86115 and

[GitHub] [flink] flinkbot commented on pull request #17218: [FLINK-24184][task] Introduce lock to guard against race conditions around shouldInterruptOnCancel

flinkbot commented on pull request #17218: URL: https://github.com/apache/flink/pull/17218#issuecomment-916046450 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-24184) Potential race condition leading to incorrectly issued interruptions

[ https://issues.apache.org/jira/browse/FLINK-24184?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-24184: --- Labels: pull-request-available (was: ) > Potential race condition leading to incorrectly

[GitHub] [flink] dianfu closed pull request #17214: [FLINK-24137][python] Fix the cases that Python boot process exits before Python SDK harness connects to the Java Operator in lookback mode

dianfu closed pull request #17214: URL: https://github.com/apache/flink/pull/17214 -- 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] pnowojski opened a new pull request #17218: [FLINK-24184][task] Introduce lock to guard against race conditions around shouldInterruptOnCancel

pnowojski opened a new pull request #17218: URL: https://github.com/apache/flink/pull/17218 Previously there was a potential race condition in disabling interrupts while closing resources. It used be guarded by a volatile variable, but there might have been a race condition when: 1.

[GitHub] [flink] akalash commented on pull request #16988: [FLINK-23458][docs] Added the network buffer documentation along wit…

akalash commented on pull request #16988: URL: https://github.com/apache/flink/pull/16988#issuecomment-916042807 @infoverload, thanks for the suggestions. I have applied them all. If you have more comments I will wait for them if not, please, approve the PR if it looks good to you. --

[jira] [Commented] (FLINK-23696) RMQSourceTest.testRedeliveredSessionIDsAck fails on azure

[ https://issues.apache.org/jira/browse/FLINK-23696?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17412535#comment-17412535 ] Dian Fu commented on FLINK-23696: -

[jira] [Updated] (FLINK-23696) RMQSourceTest.testRedeliveredSessionIDsAck fails on azure

[ https://issues.apache.org/jira/browse/FLINK-23696?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-23696: Affects Version/s: 1.15.0 1.14.0 > RMQSourceTest.testRedeliveredSessionIDsAck

[GitHub] [flink] dannycranmer commented on a change in pull request #17189: [FLINK-23528][connectors/kinesis] Improving and reenable FlinkKinesisITCase

dannycranmer commented on a change in pull request #17189: URL: https://github.com/apache/flink/pull/17189#discussion_r705274129 ## File path: flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/internals/KinesisDataFetcher.java

[GitHub] [flink] dianfu commented on a change in pull request #17180: [FLINK-24123][python] Optimize the python operator instances of the same job to share one python environment resources in the same

dianfu commented on a change in pull request #17180: URL: https://github.com/apache/flink/pull/17180#discussion_r705265024 ## File path: flink-python/src/main/java/org/apache/flink/python/env/beam/ProcessPythonEnvironmentManager.java ## @@ -430,4 +442,117 @@ private static

[jira] [Updated] (FLINK-23041) Change local alignment timeout back to the global time out

[ https://issues.apache.org/jira/browse/FLINK-23041?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-23041: - Release Note: The semantic of alignmentTimeout configuration has changed the meaning

[jira] [Updated] (FLINK-23041) Change local alignment timeout back to the global time out

[ https://issues.apache.org/jira/browse/FLINK-23041?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-23041: - Release Note: Now it's measured as the time between the start of a checkpoint(on the

[GitHub] [flink] rkhachatryan commented on a change in pull request #16978: [FLINK-23607][state/changelog] Cleanup dependencies

rkhachatryan commented on a change in pull request #16978: URL: https://github.com/apache/flink/pull/16978#discussion_r705267920 ## File path: flink-test-utils-parent/flink-test-utils/pom.xml ## @@ -115,6 +115,14 @@ under the License.

[jira] [Updated] (FLINK-21110) Optimize scheduler performance for large-scale jobs

[ https://issues.apache.org/jira/browse/FLINK-21110?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-21110: - Release Note: The performance of scheduler has been improved to reduce the time of

[jira] [Updated] (FLINK-22540) Remove YAML environment file support in SQL Client

[ https://issues.apache.org/jira/browse/FLINK-22540?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-22540: - Release Note: The sql-client-defaults.yaml YAML file was deprecated in 1.13 release and

<    1   2   3   4   5   >