[GitHub] [flink] flinkbot edited a comment on pull request #18013: [FLINK-24227][connectors/kinesis] Kinesis Data Sink Async Client

flinkbot edited a comment on pull request #18013: URL: https://github.com/apache/flink/pull/18013#issuecomment-985991840 ## CI report: * 5eae522382df02cbde9d2543777fee818dfd7558 Azure:

[GitHub] [flink] flinkbot commented on pull request #18045: [FLINK-25091][BP-1.14] Change ORC compression attribute reference error in FileSink docs

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

[GitHub] [flink] flinkbot edited a comment on pull request #18000: [hotfix][connectors/kinesis] Refactored utilities class out into a separate base connector

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

[GitHub] [flink] flinkbot commented on pull request #18046: [FLINK-25091][BP-1.13] Change ORC compression attribute reference error in FileSink docs

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

[GitHub] [flink] flinkbot edited a comment on pull request #18045: [FLINK-25091][BP-1.14] Change ORC compression attribute reference error in FileSink docs

flinkbot edited a comment on pull request #18045: URL: https://github.com/apache/flink/pull/18045#issuecomment-988305971 ## CI report: * 41f12d3d55dd0913cb29938f7183600a5d8bbd57 Azure:

[GitHub] [flink] zhuzhurk commented on a change in pull request #17952: [FLINK-25011][runtime] Introduce vertex parallelism decider and the default implementation.

zhuzhurk commented on a change in pull request #17952: URL: https://github.com/apache/flink/pull/17952#discussion_r764514899 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptivebatch/VertexParallelismDecider.java ## @@ -29,17 +29,8 @@ /**

[GitHub] [flink] flinkbot edited a comment on pull request #17462: [FLINK-23170] Write metadata after materialization

flinkbot edited a comment on pull request #17462: URL: https://github.com/apache/flink/pull/17462#issuecomment-942024789 ## CI report: * 459916eaca61c9210c403ee4f4125cfbf3590fa2 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17988: [FLINK-25010][Connectors/Hive] Speed up hive's createMRSplits by multi thread

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

[GitHub] [flink] flinkbot edited a comment on pull request #18049: [FLINK-24813][table-planner-blink] Improve ImplicitTypeConversionITCase

flinkbot edited a comment on pull request #18049: URL: https://github.com/apache/flink/pull/18049#issuecomment-988465299 ## CI report: * da40e9da154b7273f6db5eb12d65c983636cd1e6 Azure:

[GitHub] [flink] flinkbot commented on pull request #18050: [FLINK-25034][runtime] Support flexible number of subpartitions in IntermediateResultPartition

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

[GitHub] [flink] lincoln-lil commented on a change in pull request #17939: [FLINK-20370][table] part2: introduce 'table.exec.sink.pk-shuffle' option to auto keyby on sink's pk if parallelism are not t

lincoln-lil commented on a change in pull request #17939: URL: https://github.com/apache/flink/pull/17939#discussion_r764528915 ## File path: flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/config/ExecutionConfigOptions.java ## @@ -140,6 +140,25 @@

[GitHub] [flink] flinkbot edited a comment on pull request #14376: [FLINK-18202][PB format] New Format of protobuf

flinkbot edited a comment on pull request #14376: URL: https://github.com/apache/flink/pull/14376#issuecomment-744252765 ## CI report: * a721a9d5f663117a203628547a19b33b23927ac2 UNKNOWN * 8f1051527a46aeba13aadc2db3c5f34d8aff78d2 UNKNOWN *

[GitHub] [flink] flinkbot edited a comment on pull request #14376: [FLINK-18202][PB format] New Format of protobuf

flinkbot edited a comment on pull request #14376: URL: https://github.com/apache/flink/pull/14376#issuecomment-744252765 ## CI report: * a721a9d5f663117a203628547a19b33b23927ac2 UNKNOWN * 8f1051527a46aeba13aadc2db3c5f34d8aff78d2 UNKNOWN *

[GitHub] [flink] MartijnVisser commented on a change in pull request #18026: [FLINK-20188][Connectors/FileSystem,Documentation] Add Documentation …

MartijnVisser commented on a change in pull request #18026: URL: https://github.com/apache/flink/pull/18026#discussion_r764390704 ## File path: docs/content/docs/connectors/datastream/filesystem.md ## @@ -797,3 +797,322 @@ before the job is restarted. This will result in your

[GitHub] [flink] MartijnVisser opened a new pull request #18045: [FLINK-25091][BP-1.14] Change ORC compression attribute reference error in FileSink docs

MartijnVisser opened a new pull request #18045: URL: https://github.com/apache/flink/pull/18045 Backport of https://github.com/apache/flink/pull/17950 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to

[GitHub] [flink] flinkbot edited a comment on pull request #18046: [FLINK-25091][BP-1.13] Change ORC compression attribute reference error in FileSink docs

flinkbot edited a comment on pull request #18046: URL: https://github.com/apache/flink/pull/18046#issuecomment-988306020 ## CI report: * 10a25863bea58a3a4ebd585d257a08ab95aa5886 Azure:

[GitHub] [flink] mans2singh commented on pull request #16529: [hotfix][docs][hive] - Minor update to temporal join section

mans2singh commented on pull request #16529: URL: https://github.com/apache/flink/pull/16529#issuecomment-988364386 @wuchong - Can you please review this minor doc PR ? Thanks for your time. -- This is an automated message from the Apache Git Service. To respond to the message, please

[GitHub] [flink] paul8263 commented on a change in pull request #16108: [FLINK-22821][connector-kafka] FlinkKafkaProducerMigrationTest fails …

paul8263 commented on a change in pull request #16108: URL: https://github.com/apache/flink/pull/16108#discussion_r764473296 ## File path: flink-core/src/main/java/org/apache/flink/util/FileLock.java ## @@ -0,0 +1,110 @@ +/* + * Licensed to the Apache Software Foundation (ASF)

[GitHub] [flink] wuchong merged pull request #16529: [hotfix][docs][hive] - Minor update to temporal join section

wuchong merged pull request #16529: URL: https://github.com/apache/flink/pull/16529 -- 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] JingsongLi commented on a change in pull request #17939: [FLINK-20370][table] part2: introduce 'table.exec.sink.pk-shuffle' option to auto keyby on sink's pk if parallelism are not th

JingsongLi commented on a change in pull request #17939: URL: https://github.com/apache/flink/pull/17939#discussion_r764511517 ## File path: flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/common/CommonExecSink.java ## @@ -232,26

[GitHub] [flink] JingsongLi commented on a change in pull request #17939: [FLINK-20370][table] part2: introduce 'table.exec.sink.pk-shuffle' option to auto keyby on sink's pk if parallelism are not th

JingsongLi commented on a change in pull request #17939: URL: https://github.com/apache/flink/pull/17939#discussion_r764511367 ## File path: flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/common/CommonExecSink.java ## @@ -232,26

[GitHub] [flink] curcur commented on pull request #17462: [FLINK-23170] Write metadata after materialization

curcur commented on pull request #17462: URL: https://github.com/apache/flink/pull/17462#issuecomment-988451245 squash commits. -- 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] JingsongLi commented on a change in pull request #17939: [FLINK-20370][table] part2: introduce 'table.exec.sink.pk-shuffle' option to auto keyby on sink's pk if parallelism are not th

JingsongLi commented on a change in pull request #17939: URL: https://github.com/apache/flink/pull/17939#discussion_r764512993 ## File path: flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/common/CommonExecSink.java ## @@ -232,26

[GitHub] [flink] flinkbot edited a comment on pull request #16108: [FLINK-22821][connector-kafka] FlinkKafkaProducerMigrationTest fails …

flinkbot edited a comment on pull request #16108: URL: https://github.com/apache/flink/pull/16108#issuecomment-856641884 ## CI report: * a696994e8970d98e2f77aa7a4e1db93bb0ecbe53 Azure:

[GitHub] [flink] paul8263 commented on a change in pull request #16108: [FLINK-22821][connector-kafka] FlinkKafkaProducerMigrationTest fails …

paul8263 commented on a change in pull request #16108: URL: https://github.com/apache/flink/pull/16108#discussion_r764519555 ## File path: flink-core/src/main/java/org/apache/flink/util/FileLock.java ## @@ -0,0 +1,110 @@ +/* + * Licensed to the Apache Software Foundation (ASF)

[GitHub] [flink] wanglijie95 opened a new pull request #18050: [FLINK-25034][runtime] Support flexible number of subpartitions in IntermediateResultPartition

wanglijie95 opened a new pull request #18050: URL: https://github.com/apache/flink/pull/18050 ## What is the purpose of the change Support flexible number of subpartitions in IntermediateResultPartition. When the consumer parallelism is decided, number of subpartitions should be

[GitHub] [flink] zhuzhurk commented on a change in pull request #17952: [FLINK-25011][runtime] Introduce vertex parallelism decider and the default implementation.

zhuzhurk commented on a change in pull request #17952: URL: https://github.com/apache/flink/pull/17952#discussion_r764522054 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/adaptivebatch/DefaultVertexParallelismDeciderTest.java ## @@ -82,32 +96,32

[GitHub] [flink] lincoln-lil commented on a change in pull request #17939: [FLINK-20370][table] part2: introduce 'table.exec.sink.pk-shuffle' option to auto keyby on sink's pk if parallelism are not t

lincoln-lil commented on a change in pull request #17939: URL: https://github.com/apache/flink/pull/17939#discussion_r764527157 ## File path: flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/config/ExecutionConfigOptions.java ## @@ -140,6 +140,25 @@

[GitHub] [flink] flinkbot edited a comment on pull request #14376: [FLINK-18202][PB format] New Format of protobuf

flinkbot edited a comment on pull request #14376: URL: https://github.com/apache/flink/pull/14376#issuecomment-744252765 ## CI report: * a721a9d5f663117a203628547a19b33b23927ac2 UNKNOWN * 8f1051527a46aeba13aadc2db3c5f34d8aff78d2 UNKNOWN *

[GitHub] [flink] lincoln-lil commented on pull request #17939: [FLINK-20370][table] part2: introduce 'table.exec.sink.pk-shuffle' option to auto keyby on sink's pk if parallelism are not the same for

lincoln-lil commented on pull request #17939: URL: https://github.com/apache/flink/pull/17939#issuecomment-988482409 Thanks for your review! @JingsongLi I've address your comments and update the pr. -- This is an automated message from the Apache Git Service. To respond to the

[GitHub] [flink] flinkbot edited a comment on pull request #17948: [FLINK-24227][connectors/kinesis] Added Kinesis Data Streams Sink

flinkbot edited a comment on pull request #17948: URL: https://github.com/apache/flink/pull/17948#issuecomment-982001952 ## CI report: * b61cc73060fc93ccc68376aab31c9c652bd71179 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17999: [hotfix][connectors/opensearch] Refactored to base aws sink to allow for opensearch sink

flinkbot edited a comment on pull request #17999: URL: https://github.com/apache/flink/pull/17999#issuecomment-984912238 ## CI report: * 138a3651e871784d59572175c15adfafd7e5003a Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17998: [hotfix][connectors] Added to HTTP use very Versioning parameter to Kinesis Client

flinkbot edited a comment on pull request #17998: URL: https://github.com/apache/flink/pull/17998#issuecomment-984912161 ## CI report: * 63a67878ddeb061233f293539c8015bdcda861d4 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17997: [hotfix][connectors] Kinesalite Container very very rarely fails with ContainerLaunchException

flinkbot edited a comment on pull request #17997: URL: https://github.com/apache/flink/pull/17997#issuecomment-984912079 ## CI report: * ec35d8ff23f06f7c74421bb28575f57d564be47f Azure:

[GitHub] [flink-shaded] zentol merged pull request #106: [FLINK-25018][zk] Upgrade Curator to 5.2.0

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

[jira] [Updated] (FLINK-25019) Remove misleading comment regarding flink-shaded-netty re-use

[ https://issues.apache.org/jira/browse/FLINK-25019?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-25019: - Issue Type: Technical Debt (was: Bug) > Remove misleading comment regarding

[jira] [Closed] (FLINK-25019) Remove misleading comment regarding flink-shaded-netty re-use

[ https://issues.apache.org/jira/browse/FLINK-25019?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-25019. Resolution: Fixed shaded-master: a118856dd92c2d5de30d0bce83fa6795d522ca5f > Remove

[jira] [Closed] (FLINK-22113) UniqueKey constraint is lost with multiple sources join in SQL

[ https://issues.apache.org/jira/browse/FLINK-22113?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he closed FLINK-22113. -- Resolution: Fixed Fixed in 1.15.0: ac957ae07a49ab88ad46a14c6ea0d4891d5437d7 1.14.1:

[GitHub] [flink] flinkbot edited a comment on pull request #17988: [FLINK-25010][Connectors/Hive] Speed up hive's createMRSplits by multi thread

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

[GitHub] [flink] lincoln-lil commented on a change in pull request #17939: [FLINK-20370][table] part2: introduce 'table.exec.sink.pk-shuffle' option to auto keyby on sink's pk if parallelism are not t

lincoln-lil commented on a change in pull request #17939: URL: https://github.com/apache/flink/pull/17939#discussion_r764519877 ## File path: flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/common/CommonExecSink.java ## @@ -232,26

[GitHub] [flink] zhuzhurk commented on a change in pull request #17952: [FLINK-25011][runtime] Introduce vertex parallelism decider and the default implementation.

zhuzhurk commented on a change in pull request #17952: URL: https://github.com/apache/flink/pull/17952#discussion_r764519958 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptivebatch/BlockingResultInfo.java ## @@ -0,0 +1,42 @@ +/* + * Licensed

[GitHub] [flink] xuyangzhong opened a new pull request #18049: [FLINK-24813][table-planner-blink] Improve ImplicitTypeConversionITCase

xuyangzhong opened a new pull request #18049: URL: https://github.com/apache/flink/pull/18049 ## What is the purpose of the change delete the test file ImplicitTypeConversionITCase and union them into the ImplicitConversionEqualsFunctionITCase to have the same code style with

[GitHub] [flink] flinkbot edited a comment on pull request #18050: [FLINK-25034][runtime] Support flexible number of subpartitions in IntermediateResultPartition

flinkbot edited a comment on pull request #18050: URL: https://github.com/apache/flink/pull/18050#issuecomment-988466514 ## CI report: * 5e36ba1eacf427ca4665de18b6f71253fb53f0e8 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14376: [FLINK-18202][PB format] New Format of protobuf

flinkbot edited a comment on pull request #14376: URL: https://github.com/apache/flink/pull/14376#issuecomment-744252765 ## CI report: * a721a9d5f663117a203628547a19b33b23927ac2 UNKNOWN * 8f1051527a46aeba13aadc2db3c5f34d8aff78d2 UNKNOWN *

[GitHub] [flink] flinkbot edited a comment on pull request #14376: [FLINK-18202][PB format] New Format of protobuf

flinkbot edited a comment on pull request #14376: URL: https://github.com/apache/flink/pull/14376#issuecomment-744252765 ## CI report: * a721a9d5f663117a203628547a19b33b23927ac2 UNKNOWN * 8f1051527a46aeba13aadc2db3c5f34d8aff78d2 UNKNOWN *

[GitHub] [flink] MartijnVisser opened a new pull request #18047: [FLINK-25091][BP-1.12] Change ORC compression attribute reference error in FileSink docs

MartijnVisser opened a new pull request #18047: URL: https://github.com/apache/flink/pull/18047 Backport of #17950 -- 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

[GitHub] [flink] MartijnVisser opened a new pull request #18046: [FLINK-25091][BP-1.13] Change ORC compression attribute reference error in FileSink docs

MartijnVisser opened a new pull request #18046: URL: https://github.com/apache/flink/pull/18046 Backport of #17950 -- 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

[GitHub] [flink] flinkbot edited a comment on pull request #18047: [FLINK-25091][BP-1.12] Change ORC compression attribute reference error in FileSink docs

flinkbot edited a comment on pull request #18047: URL: https://github.com/apache/flink/pull/18047#issuecomment-988307641 ## CI report: * 398959c9088e71b867c3d3cc08dff48db67df244 Azure:

[GitHub] [flink] liufangqi commented on pull request #17958: FLINK-25029: Hadoop Caller Context Setting in Flink

liufangqi commented on pull request #17958: URL: https://github.com/apache/flink/pull/17958#issuecomment-988365115 @AHeise Hi, maybe there is a time difference of more than ten hours between us. It is difficult to form continuous communication. When are you free? I can wait for you to

[GitHub] [flink] paul8263 commented on a change in pull request #16108: [FLINK-22821][connector-kafka] FlinkKafkaProducerMigrationTest fails …

paul8263 commented on a change in pull request #16108: URL: https://github.com/apache/flink/pull/16108#discussion_r764472462 ## File path: flink-core/src/main/java/org/apache/flink/util/FileLock.java ## @@ -0,0 +1,110 @@ +/* + * Licensed to the Apache Software Foundation (ASF)

[jira] [Commented] (FLINK-25021) Source/Sink for Azure Data Explorer (ADX)

[ https://issues.apache.org/jira/browse/FLINK-25021?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17454912#comment-17454912 ] Xue Wang commented on FLINK-25021: -- [~MartijnVisser] No problem, Flink has a very active ML which

[jira] [Commented] (FLINK-20370) Result is wrong when sink primary key is not the same with query

[ https://issues.apache.org/jira/browse/FLINK-20370?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17454921#comment-17454921 ] lincoln lee commented on FLINK-20370: - I've created the cherry pick:

[GitHub] [flink] flinkbot commented on pull request #18048: [FLINK-20370][table] part1: Fix wrong results when sink primary key is not the same with query result's changelog upsert key

flinkbot commented on pull request #18048: URL: https://github.com/apache/flink/pull/18048#issuecomment-988411123 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the

[GitHub] [flink] flinkbot edited a comment on pull request #18048: [FLINK-20370][table] part1: Fix wrong results when sink primary key is not the same with query result's changelog upsert key

flinkbot edited a comment on pull request #18048: URL: https://github.com/apache/flink/pull/18048#issuecomment-988409163 ## CI report: * 03c879c08980eedf2bba6b46a6e5eeb0a0df31b8 Azure:

[jira] [Commented] (FLINK-25210) PulsarSource(Un)OrderedE2ECase is brokern

[ https://issues.apache.org/jira/browse/FLINK-25210?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17454923#comment-17454923 ] Yufei Zhang commented on FLINK-25210: - To reproduce/fix this, I guess I should use FLINK-25159's

[jira] [Commented] (FLINK-25159) Streamline E2E surefire configuration setup

[ https://issues.apache.org/jira/browse/FLINK-25159?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17454926#comment-17454926 ] Yufei Zhang commented on FLINK-25159: - Would you mind share the link to the currently in-progress

[GitHub] [flink] flinkbot edited a comment on pull request #16582: [FLINK-21504][checkpoint] Introduce notification of subsumed checkpoint

flinkbot edited a comment on pull request #16582: URL: https://github.com/apache/flink/pull/16582#issuecomment-885598535 ## CI report: * 1168b48d412c2ac15da72d06bcdff90c2120f2c8 Azure:

[GitHub] [flink] Myracle commented on pull request #16957: [FLINK-23937][Documentation] Fix PQ comment in KeyGroupPartitionedPriorityQueue

Myracle commented on pull request #16957: URL: https://github.com/apache/flink/pull/16957#issuecomment-988443866 @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] JingsongLi commented on a change in pull request #17939: [FLINK-20370][table] part2: introduce 'table.exec.sink.pk-shuffle' option to auto keyby on sink's pk if parallelism are not th

JingsongLi commented on a change in pull request #17939: URL: https://github.com/apache/flink/pull/17939#discussion_r764511041 ## File path: flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/common/CommonExecSink.java ## @@ -232,26

[GitHub] [flink] flinkbot edited a comment on pull request #17988: [FLINK-25010][Connectors/Hive] Speed up hive's createMRSplits by multi thread

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

[GitHub] [flink] flinkbot edited a comment on pull request #16108: [FLINK-22821][connector-kafka] FlinkKafkaProducerMigrationTest fails …

flinkbot edited a comment on pull request #16108: URL: https://github.com/apache/flink/pull/16108#issuecomment-856641884 ## CI report: * a696994e8970d98e2f77aa7a4e1db93bb0ecbe53 Azure:

[GitHub] [flink] lincoln-lil commented on a change in pull request #17939: [FLINK-20370][table] part2: introduce 'table.exec.sink.pk-shuffle' option to auto keyby on sink's pk if parallelism are not t

lincoln-lil commented on a change in pull request #17939: URL: https://github.com/apache/flink/pull/17939#discussion_r764522531 ## File path: flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/common/CommonExecSink.java ## @@ -232,26

[jira] [Updated] (FLINK-25034) Support flexible number of subpartitions in IntermediateResultPartition

[ https://issues.apache.org/jira/browse/FLINK-25034?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-25034: --- Labels: pull-request-available (was: ) > Support flexible number of subpartitions in

[GitHub] [flink] flinkbot commented on pull request #18049: [FLINK-24813][table-planner-blink] Improve ImplicitTypeConversionITCase

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

[GitHub] [flink] flinkbot edited a comment on pull request #14376: [FLINK-18202][PB format] New Format of protobuf

flinkbot edited a comment on pull request #14376: URL: https://github.com/apache/flink/pull/14376#issuecomment-744252765 ## CI report: * a721a9d5f663117a203628547a19b33b23927ac2 UNKNOWN * 8f1051527a46aeba13aadc2db3c5f34d8aff78d2 UNKNOWN *

[GitHub] [flink] flinkbot edited a comment on pull request #17939: [FLINK-20370][table] part2: introduce 'table.exec.sink.pk-shuffle' option to auto keyby on sink's pk if parallelism are not the same

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

[jira] [Updated] (FLINK-18540) Unnecessary retract messages when setIdleStateRetentionTime before converting dynamic table to retract stream

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

[jira] [Updated] (FLINK-18496) Anchors are not generated based on ZH characters

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

[jira] [Updated] (FLINK-18409) The FilterJoinRule.FILTER_ON_JOIN optimizer rule cause 'Join With a Temporal Table' not working properly

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

[jira] [Updated] (FLINK-18508) Dynamic source supports statistics and parallelism report

[ https://issues.apache.org/jira/browse/FLINK-18508?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-18508: --- Labels: auto-deprioritized-major pull-request-available stale-minor (was:

[jira] [Updated] (FLINK-18308) KafkaProducerTestBase->Kafka011ProducerExactlyOnceITCase. testExactlyOnceCustomOperator hangs in Azure

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

[jira] [Updated] (FLINK-6098) Cassandra sink freezes after write error

[ https://issues.apache.org/jira/browse/FLINK-6098?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-6098: -- Labels: auto-deprioritized-major stale-minor (was: auto-deprioritized-major) I am the [Flink

[jira] [Updated] (FLINK-9541) Add robots.txt and sitemap.xml to Flink website

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

[jira] [Updated] (FLINK-9469) Add tests that cover PatternStream#flatSelect

[ https://issues.apache.org/jira/browse/FLINK-9469?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-9469: -- Labels: auto-deprioritized-major auto-deprioritized-minor pull-request-available (was:

[jira] [Updated] (FLINK-18366) Track E2E test durations centrally

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

[jira] [Updated] (FLINK-6082) Support window definition for SQL Queries based on WHERE clause with time condition

[ https://issues.apache.org/jira/browse/FLINK-6082?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-6082: -- Labels: auto-deprioritized-major stale-minor (was: auto-deprioritized-major) I am the [Flink

[jira] [Updated] (FLINK-18274) document example error

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

[GitHub] [flink] lincoln-lil opened a new pull request #18048: [FLINK-20370][table] part1: Fix wrong results when sink primary key is not the same with query result's changelog upsert key

lincoln-lil opened a new pull request #18048: URL: https://github.com/apache/flink/pull/18048 This is a cherry pick for FLINK-20370 part1. ## Brief change log update the logic of `FlinkChangelogModeInferenceProgram` and `StreamPhysicalSink` ## Verifying this change

[GitHub] [flink] flinkbot commented on pull request #18048: [FLINK-20370][table] part1: Fix wrong results when sink primary key is not the same with query result's changelog upsert key

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

[jira] [Commented] (FLINK-24939) Support 'SHOW CREATE CATALOG' syntax

[ https://issues.apache.org/jira/browse/FLINK-24939?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17454935#comment-17454935 ] Yubin Li commented on FLINK-24939: -- Hi [~jark] , surely, it should be very cautious to add functions to

[GitHub] [flink] JingsongLi commented on a change in pull request #17939: [FLINK-20370][table] part2: introduce 'table.exec.sink.pk-shuffle' option to auto keyby on sink's pk if parallelism are not th

JingsongLi commented on a change in pull request #17939: URL: https://github.com/apache/flink/pull/17939#discussion_r764511680 ## File path: flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/config/ExecutionConfigOptions.java ## @@ -140,6 +140,25 @@

[GitHub] [flink] flinkbot edited a comment on pull request #17462: [FLINK-23170] Write metadata after materialization

flinkbot edited a comment on pull request #17462: URL: https://github.com/apache/flink/pull/17462#issuecomment-942024789 ## CI report: * 459916eaca61c9210c403ee4f4125cfbf3590fa2 Azure:

[GitHub] [flink] flinkbot commented on pull request #18049: [FLINK-24813][table-planner-blink] Improve ImplicitTypeConversionITCase

flinkbot commented on pull request #18049: URL: https://github.com/apache/flink/pull/18049#issuecomment-988465918 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the

[GitHub] [flink] flinkbot commented on pull request #18050: [FLINK-25034][runtime] Support flexible number of subpartitions in IntermediateResultPartition

flinkbot commented on pull request #18050: URL: https://github.com/apache/flink/pull/18050#issuecomment-988465904 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] zhuzhurk commented on a change in pull request #17952: [FLINK-25011][runtime] Introduce vertex parallelism decider and the default implementation.

zhuzhurk commented on a change in pull request #17952: URL: https://github.com/apache/flink/pull/17952#discussion_r764522853 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/adaptivebatch/DefaultVertexParallelismDeciderTest.java ## @@ -58,22 +72,22

[GitHub] [flink] zhuzhurk commented on a change in pull request #17952: [FLINK-25011][runtime] Introduce vertex parallelism decider and the default implementation.

zhuzhurk commented on a change in pull request #17952: URL: https://github.com/apache/flink/pull/17952#discussion_r764522853 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/adaptivebatch/DefaultVertexParallelismDeciderTest.java ## @@ -58,22 +72,22

[GitHub] [flink] flinkbot edited a comment on pull request #14376: [FLINK-18202][PB format] New Format of protobuf

flinkbot edited a comment on pull request #14376: URL: https://github.com/apache/flink/pull/14376#issuecomment-744252765 ## CI report: * a721a9d5f663117a203628547a19b33b23927ac2 UNKNOWN * 8f1051527a46aeba13aadc2db3c5f34d8aff78d2 UNKNOWN *

[GitHub] [flink] maosuhan commented on pull request #14376: [FLINK-18202][PB format] New Format of protobuf

maosuhan commented on pull request #14376: URL: https://github.com/apache/flink/pull/14376#issuecomment-988473669 @MyLanPangzi I have updated the code to adaptively convert between enum of protobuf and numeric/string type of flink and also unit tests are added. Since codegen in java is

[jira] [Commented] (FLINK-25021) Source/Sink for Azure Data Explorer (ADX)

[ https://issues.apache.org/jira/browse/FLINK-25021?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17454860#comment-17454860 ] Martijn Visser commented on FLINK-25021: [~xwang51] Sorry for the late reply. 1. For Async

[GitHub] [flink] flinkbot edited a comment on pull request #17968: [FLINK-23532] Unify stop-with-savepoint without and with drain

flinkbot edited a comment on pull request #17968: URL: https://github.com/apache/flink/pull/17968#issuecomment-982779420 ## CI report: * f6b4bbefc02b81397c7a9147a329bf490826058c Azure:

[GitHub] [flink] flinkbot commented on pull request #18047: [FLINK-25091][BP-1.12] Change ORC compression attribute reference error in FileSink docs

flinkbot commented on pull request #18047: URL: https://github.com/apache/flink/pull/18047#issuecomment-988307525 -- 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

[GitHub] [flink] flinkbot edited a comment on pull request #18045: [FLINK-25091][BP-1.14] Change ORC compression attribute reference error in FileSink docs

flinkbot edited a comment on pull request #18045: URL: https://github.com/apache/flink/pull/18045#issuecomment-988305971 ## CI report: * 41f12d3d55dd0913cb29938f7183600a5d8bbd57 Azure:

[GitHub] [flink] flinkbot commented on pull request #18046: [FLINK-25091][BP-1.13] Change ORC compression attribute reference error in FileSink docs

flinkbot commented on pull request #18046: URL: https://github.com/apache/flink/pull/18046#issuecomment-988307542 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the

[GitHub] [flink] flinkbot edited a comment on pull request #18046: [FLINK-25091][BP-1.13] Change ORC compression attribute reference error in FileSink docs

flinkbot edited a comment on pull request #18046: URL: https://github.com/apache/flink/pull/18046#issuecomment-988306020 ## CI report: * 10a25863bea58a3a4ebd585d257a08ab95aa5886 Azure:

[GitHub] [flink] flinkbot commented on pull request #18045: [FLINK-25091][BP-1.14] Change ORC compression attribute reference error in FileSink docs

flinkbot commented on pull request #18045: URL: https://github.com/apache/flink/pull/18045#issuecomment-988307563 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-ml] zhipeng93 commented on a change in pull request #28: [Flink-24556] Add Estimator and Transformer for logistic regression

zhipeng93 commented on a change in pull request #28: URL: https://github.com/apache/flink-ml/pull/28#discussion_r764491505 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/classification/linear/LogisticRegressionModel.java ## @@ -0,0 +1,185 @@ +/* + * Licensed to

[GitHub] [flink-ml] zhipeng93 commented on a change in pull request #28: [Flink-24556] Add Estimator and Transformer for logistic regression

zhipeng93 commented on a change in pull request #28: URL: https://github.com/apache/flink-ml/pull/28#discussion_r762762819 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/classification/linear/LogisticRegressionModel.java ## @@ -0,0 +1,185 @@ +/* + * Licensed to

[GitHub] [flink-ml] weibozhao commented on a change in pull request #24: [Flink 24557] - Add knn algorithm to flink-ml

weibozhao commented on a change in pull request #24: URL: https://github.com/apache/flink-ml/pull/24#discussion_r764497065 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/classification/knn/Knn.java ## @@ -0,0 +1,217 @@ +package

[GitHub] [flink] jelly-1203 commented on pull request #18017: [FLINK-25171] Validation of duplicate fields in derived tables

jelly-1203 commented on pull request #18017: URL: https://github.com/apache/flink/pull/18017#issuecomment-988440826 > Thanks for the contribution, @jelly-1203 , you may need to add some test on the change. By the way, you can do some clean up on description of pr. The template is a

[GitHub] [flink] godfreyhe closed pull request #18040: [FLINK-22113][table-planner] Implement column uniqueness checking for TableSourceTable

godfreyhe closed pull request #18040: URL: https://github.com/apache/flink/pull/18040 -- 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:

  1   2   3   4   5   6   7   8   >