[GitHub] [flink] flinkbot commented on pull request #12195: [FLINK-17449][sql-parser][table-api-java][table-planner-blink][hive] …

flinkbot commented on pull request #12195: URL: https://github.com/apache/flink/pull/12195#issuecomment-629748103 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] guoweiM commented on pull request #12132: [FLINK-17593][Connectors/FileSystem] Support arbitrary recovery mechanism for PartFileWriter

guoweiM commented on pull request #12132: URL: https://github.com/apache/flink/pull/12132#issuecomment-629748020 HI, @aljoscha @kl0u I resolve all the comments. 1. Change the name of `PartFileFactory` to `BucketWriter`. Change the `PartFileWriter` to `InProgressFileWriter`. 2.

[jira] [Updated] (FLINK-17449) Implement ADD/DROP partitions

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

[GitHub] [flink] lirui-apache opened a new pull request #12195: [FLINK-17449][sql-parser][table-api-java][table-planner-blink][hive] …

lirui-apache opened a new pull request #12195: URL: https://github.com/apache/flink/pull/12195 …Implement ADD/DROP partitions ## What is the purpose of the change To implement ADD/DROP PARTITIONS for Hive dialect. ## Brief change log - Add SqlNodes

[GitHub] [flink] flinkbot edited a comment on pull request #12073: [FLINK-17735][streaming] Add specialized collecting iterator

flinkbot edited a comment on pull request #12073: URL: https://github.com/apache/flink/pull/12073#issuecomment-626524463 ## CI report: * 424d752d1d5e49c752ccd79561ce5cfcd5ea7d1d UNKNOWN * ca26d6edd7772ee46d24b05c01952a10887eb3f7 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12073: [FLINK-17735][streaming] Add specialized collecting iterator

flinkbot edited a comment on pull request #12073: URL: https://github.com/apache/flink/pull/12073#issuecomment-626524463 ## CI report: * 424d752d1d5e49c752ccd79561ce5cfcd5ea7d1d UNKNOWN * ca26d6edd7772ee46d24b05c01952a10887eb3f7 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12194: [FLINK-17764][Examples]Update tips about the default planner when the planner parameter value is not recognized

flinkbot edited a comment on pull request #12194: URL: https://github.com/apache/flink/pull/12194#issuecomment-629741058 ## CI report: * b646f1df4c1dc9797662fac8fe7f54c6a3de4682 Azure:

[GitHub] [flink] TsReaper commented on a change in pull request #12073: [FLINK-17735][streaming] Add specialized collecting iterator

TsReaper commented on a change in pull request #12073: URL: https://github.com/apache/flink/pull/12073#discussion_r426216888 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/collect/CollectResultFetcher.java ## @@ -0,0 +1,343 @@ +/* +

[GitHub] [flink] flinkbot edited a comment on pull request #12193: [FLINK-17759][runtime] Remove unused RestartIndividualStrategy

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

[GitHub] [flink] flinkbot edited a comment on pull request #11725: [FLINK-15670][API] Provide a Kafka Source/Sink pair as KafkaShuffle

flinkbot edited a comment on pull request #11725: URL: https://github.com/apache/flink/pull/11725#issuecomment-613252882 ## CI report: * 066795205734add3b142a92c687c98b25253985e UNKNOWN * 9af69eb96e9a0ddaff4937e9d926feff92439f32 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12029: [FLINK-17451][sql-parser][table-planner-blink][hive] Implement view D…

flinkbot edited a comment on pull request #12029: URL: https://github.com/apache/flink/pull/12029#issuecomment-625673739 ## CI report: * 9405ea4470dc022ffb514f603396fc6bb2582835 UNKNOWN * c1ad4b5d93e10b76fad14269f46fa62e4d771bed Azure:

[GitHub] [flink-web] yangjf2019 commented on a change in pull request #268: [FLINK-13343][docs-zh] Translate "Contribute Code" page into Chinese

yangjf2019 commented on a change in pull request #268: URL: https://github.com/apache/flink-web/pull/268#discussion_r426215899 ## File path: contributing/contribute-code.zh.md ## @@ -136,91 +136,91 @@ Apache Flink is maintained, improved, and extended by code contributions of

[GitHub] [flink-web] yangjf2019 commented on a change in pull request #268: [FLINK-13343][docs-zh] Translate "Contribute Code" page into Chinese

yangjf2019 commented on a change in pull request #268: URL: https://github.com/apache/flink-web/pull/268#discussion_r426215858 ## File path: contributing/contribute-code.zh.md ## @@ -79,44 +79,44 @@ Apache Flink is maintained, improved, and extended by code contributions of

[GitHub] [flink] flinkbot commented on pull request #12194: [FLINK-17764][Examples]Update tips about the default planner when the planner parameter value is not recognized

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

[GitHub] [flink] flinkbot edited a comment on pull request #12145: [FLINK-17428] [table-planner-blink] supports projection push down on new table source interface in blink planner

flinkbot edited a comment on pull request #12145: URL: https://github.com/apache/flink/pull/12145#issuecomment-628490262 ## CI report: * 3747e17ecf18448088dcb467d8bea240b00f12b6 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12176: [FLINK-17029][jdbc]Introduce a new JDBC connector with new property keys

flinkbot edited a comment on pull request #12176: URL: https://github.com/apache/flink/pull/12176#issuecomment-629283127 ## CI report: * 057d8fa644c9a203a753fe184de8e204ea81918e Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12120: [FLINK-17547] Support unaligned checkpoints for records spilled to files

flinkbot edited a comment on pull request #12120: URL: https://github.com/apache/flink/pull/12120#issuecomment-628150581 ## CI report: * 95c57fc02f0f4c16e685df54b249f2386177126c Azure:

[GitHub] [flink-web] yangjf2019 commented on a change in pull request #268: [FLINK-13343][docs-zh] Translate "Contribute Code" page into Chinese

yangjf2019 commented on a change in pull request #268: URL: https://github.com/apache/flink-web/pull/268#discussion_r426214595 ## File path: contributing/contribute-code.zh.md ## @@ -136,91 +136,91 @@ Apache Flink is maintained, improved, and extended by code contributions of

[GitHub] [flink-web] yangjf2019 commented on a change in pull request #268: [FLINK-13343][docs-zh] Translate "Contribute Code" page into Chinese

yangjf2019 commented on a change in pull request #268: URL: https://github.com/apache/flink-web/pull/268#discussion_r426215133 ## File path: contributing/contribute-code.zh.md ## @@ -136,91 +136,91 @@ Apache Flink is maintained, improved, and extended by code contributions of

[GitHub] [flink-web] yangjf2019 commented on a change in pull request #268: [FLINK-13343][docs-zh] Translate "Contribute Code" page into Chinese

yangjf2019 commented on a change in pull request #268: URL: https://github.com/apache/flink-web/pull/268#discussion_r426215120 ## File path: contributing/contribute-code.zh.md ## @@ -136,91 +136,91 @@ Apache Flink is maintained, improved, and extended by code contributions of

[GitHub] [flink-web] yangjf2019 commented on a change in pull request #268: [FLINK-13343][docs-zh] Translate "Contribute Code" page into Chinese

yangjf2019 commented on a change in pull request #268: URL: https://github.com/apache/flink-web/pull/268#discussion_r426215078 ## File path: contributing/contribute-code.zh.md ## @@ -136,91 +136,91 @@ Apache Flink is maintained, improved, and extended by code contributions of

[GitHub] [flink-web] yangjf2019 commented on a change in pull request #268: [FLINK-13343][docs-zh] Translate "Contribute Code" page into Chinese

yangjf2019 commented on a change in pull request #268: URL: https://github.com/apache/flink-web/pull/268#discussion_r426215097 ## File path: contributing/contribute-code.zh.md ## @@ -136,91 +136,91 @@ Apache Flink is maintained, improved, and extended by code contributions of

[GitHub] [flink-web] yangjf2019 commented on a change in pull request #268: [FLINK-13343][docs-zh] Translate "Contribute Code" page into Chinese

yangjf2019 commented on a change in pull request #268: URL: https://github.com/apache/flink-web/pull/268#discussion_r426215066 ## File path: contributing/contribute-code.zh.md ## @@ -136,91 +136,91 @@ Apache Flink is maintained, improved, and extended by code contributions of

[GitHub] [flink-web] yangjf2019 commented on a change in pull request #268: [FLINK-13343][docs-zh] Translate "Contribute Code" page into Chinese

yangjf2019 commented on a change in pull request #268: URL: https://github.com/apache/flink-web/pull/268#discussion_r426215044 ## File path: contributing/contribute-code.zh.md ## @@ -126,7 +126,7 @@ Apache Flink is maintained, improved, and extended by code contributions of

[GitHub] [flink-web] yangjf2019 commented on a change in pull request #268: [FLINK-13343][docs-zh] Translate "Contribute Code" page into Chinese

yangjf2019 commented on a change in pull request #268: URL: https://github.com/apache/flink-web/pull/268#discussion_r426215023 ## File path: contributing/contribute-code.zh.md ## @@ -136,91 +136,91 @@ Apache Flink is maintained, improved, and extended by code contributions of

[GitHub] [flink] becketqin commented on pull request #12122: [FLINK-15102] Add continuousSource() method to StreamExecutionEnvironment.

becketqin commented on pull request #12122: URL: https://github.com/apache/flink/pull/12122#issuecomment-629739829 Thanks @StephanEwen. Apologies that I somehow missed some of your previous comments... I'll merge the patch with the following changes. 1. `SourceReader`

[GitHub] [flink-web] yangjf2019 commented on a change in pull request #268: [FLINK-13343][docs-zh] Translate "Contribute Code" page into Chinese

yangjf2019 commented on a change in pull request #268: URL: https://github.com/apache/flink-web/pull/268#discussion_r426214595 ## File path: contributing/contribute-code.zh.md ## @@ -136,91 +136,91 @@ Apache Flink is maintained, improved, and extended by code contributions of

[GitHub] [flink] flinkbot commented on pull request #12194: [FLINK-17764][Examples]Update tips about the default planner when the planner parameter value is not recognized

flinkbot commented on pull request #12194: URL: https://github.com/apache/flink/pull/12194#issuecomment-629739324 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 #12192: [FLINK-17758][runtime] Remove unused AdaptedRestartPipelinedRegionStrategyNG

flinkbot edited a comment on pull request #12192: URL: https://github.com/apache/flink/pull/12192#issuecomment-629673624 ## CI report: * 15ca64e3a20101239b30b90064f3b0f35238c828 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12176: [FLINK-17029][jdbc]Introduce a new JDBC connector with new property keys

flinkbot edited a comment on pull request #12176: URL: https://github.com/apache/flink/pull/12176#issuecomment-629283127 ## CI report: * 057d8fa644c9a203a753fe184de8e204ea81918e Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12147: [FLINK-17653] FLIP-126: Unify (and separate) Watermark Assigners

flinkbot edited a comment on pull request #12147: URL: https://github.com/apache/flink/pull/12147#issuecomment-628530122 ## CI report: * 74cd43706dcd385e51e90fb10cb60c4004e5debc UNKNOWN * 45254c90a497b9526cb1c5e891d0a11abfaa03ea Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12145: [FLINK-17428] [table-planner-blink] supports projection push down on new table source interface in blink planner

flinkbot edited a comment on pull request #12145: URL: https://github.com/apache/flink/pull/12145#issuecomment-628490262 ## CI report: * 3747e17ecf18448088dcb467d8bea240b00f12b6 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12029: [FLINK-17451][sql-parser][table-planner-blink][hive] Implement view D…

flinkbot edited a comment on pull request #12029: URL: https://github.com/apache/flink/pull/12029#issuecomment-625673739 ## CI report: * 9405ea4470dc022ffb514f603396fc6bb2582835 UNKNOWN * c1ad4b5d93e10b76fad14269f46fa62e4d771bed Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #11725: [FLINK-15670][API] Provide a Kafka Source/Sink pair as KafkaShuffle

flinkbot edited a comment on pull request #11725: URL: https://github.com/apache/flink/pull/11725#issuecomment-613252882 ## CI report: * 066795205734add3b142a92c687c98b25253985e UNKNOWN * 9af69eb96e9a0ddaff4937e9d926feff92439f32 Azure:

[GitHub] [flink-web] yangjf2019 commented on a change in pull request #268: [FLINK-13343][docs-zh] Translate "Contribute Code" page into Chinese

yangjf2019 commented on a change in pull request #268: URL: https://github.com/apache/flink-web/pull/268#discussion_r426214472 ## File path: contributing/contribute-code.zh.md ## @@ -136,91 +136,91 @@ Apache Flink is maintained, improved, and extended by code contributions of

[jira] [Updated] (FLINK-17764) Update tips about the default planner when the planner parameter value is not recognized

[ https://issues.apache.org/jira/browse/FLINK-17764?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-17764: --- Labels: pull-request-available (was: ) > Update tips about the default planner when the

[GitHub] [flink] Shih-Wei-Hsu opened a new pull request #12194: [FLINK-17764][Examples]Update tips about the default planner when the planner parameter value is not recognized

Shih-Wei-Hsu opened a new pull request #12194: URL: https://github.com/apache/flink/pull/12194 ## What is the purpose of the change Keep the default planner in the prompt consistent with the code. ## Brief change log Change tips about the default planner to

[GitHub] [flink-web] klion26 commented on a change in pull request #268: [FLINK-13343][docs-zh] Translate "Contribute Code" page into Chinese

klion26 commented on a change in pull request #268: URL: https://github.com/apache/flink-web/pull/268#discussion_r426209811 ## File path: contributing/contribute-code.zh.md ## @@ -126,7 +126,7 @@ Apache Flink is maintained, improved, and extended by code contributions of volu

[jira] [Commented] (FLINK-17762) Postgres Catalog should pass table's primary key to catalogTable

[ https://issues.apache.org/jira/browse/FLINK-17762?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17109299#comment-17109299 ] Jark Wu commented on FLINK-17762: - Btw, this one is blocked by FLINK-17029 > Postgres Catalog should

[GitHub] [flink] flinkbot edited a comment on pull request #11854: [FLINK-17407] Introduce external resource framework

flinkbot edited a comment on pull request #11854: URL: https://github.com/apache/flink/pull/11854#issuecomment-617586491 ## CI report: * bddb0e274da11bbe99d15c6e0bb55e8d8c0e658a UNKNOWN * dc7a9c5c7d1fac82518815b9277809dfb82ddaac UNKNOWN *

[jira] [Commented] (FLINK-17762) Postgres Catalog should pass table's primary key to catalogTable

[ https://issues.apache.org/jira/browse/FLINK-17762?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17109297#comment-17109297 ] Jark Wu commented on FLINK-17762: - Yes. I think we can reuse the implementations. But we may only need

[jira] [Closed] (FLINK-17630) Implement format factory for Avro serialization and deserialization schema

[ https://issues.apache.org/jira/browse/FLINK-17630?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-17630. --- Resolution: Duplicate > Implement format factory for Avro serialization and deserialization schema >

[jira] [Assigned] (FLINK-17757) Implement format factory for Avro serialization and deseriazation schema of RowData type

[ https://issues.apache.org/jira/browse/FLINK-17757?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-17757: --- Assignee: Danny Chen > Implement format factory for Avro serialization and deseriazation schema of

[jira] [Commented] (FLINK-17353) Broken links in Flink docs master

[ https://issues.apache.org/jira/browse/FLINK-17353?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17109295#comment-17109295 ] Jark Wu commented on FLINK-17353: - Assigned to you [~yangyichao] > Broken links in Flink docs master >

[jira] [Assigned] (FLINK-17353) Broken links in Flink docs master

[ https://issues.apache.org/jira/browse/FLINK-17353?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-17353: --- Assignee: Yichao Yang > Broken links in Flink docs master > - > >

[GitHub] [flink] flinkbot edited a comment on pull request #12188: [FLINK-17728] [sql-client] sql client supports parser statements via sql parser

flinkbot edited a comment on pull request #12188: URL: https://github.com/apache/flink/pull/12188#issuecomment-629595773 ## CI report: * 7111bcfcc655d8d6b0ee5f9ff66e80e732f7272e Azure:

[GitHub] [flink] KurtYoung commented on a change in pull request #12145: [FLINK-17428] [table-planner-blink] supports projection push down on new table source interface in blink planner

KurtYoung commented on a change in pull request #12145: URL: https://github.com/apache/flink/pull/12145#discussion_r426211541 ## File path: flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/rules/logical/PushProjectIntoTableSourceScanRule.java

[GitHub] [flink] wuchong commented on pull request #12150: [FLINK-17026][kafka] Introduce a new Kafka connect or with new proper…

wuchong commented on pull request #12150: URL: https://github.com/apache/flink/pull/12150#issuecomment-629734991 Unfortunately, the following case is failed. [ERROR] Kafka011TableITCase>KafkaTableTestBase.testKafkaSourceSink:145 » Execution org...

[GitHub] [flink] KurtYoung commented on a change in pull request #12073: [FLINK-17735][streaming] Add specialized collecting iterator

KurtYoung commented on a change in pull request #12073: URL: https://github.com/apache/flink/pull/12073#discussion_r426208132 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/collect/CollectResultFetcher.java ## @@ -0,0 +1,343 @@ +/* +

[GitHub] [flink] flinkbot edited a comment on pull request #12188: [FLINK-17728] [sql-client] sql client supports parser statements via sql parser

flinkbot edited a comment on pull request #12188: URL: https://github.com/apache/flink/pull/12188#issuecomment-629595773 ## CI report: * 7111bcfcc655d8d6b0ee5f9ff66e80e732f7272e Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12184: [FLINK-17027] Introduce a new Elasticsearch 7 connector with new property keys

flinkbot edited a comment on pull request #12184: URL: https://github.com/apache/flink/pull/12184#issuecomment-629425634 ## CI report: * 80bbdd72c2aeb3c802deef71436882603590d147 UNKNOWN * 25a6ad18a9f957a5f2081e9e9282aa967343987b Azure:

[jira] [Commented] (FLINK-17730) HadoopS3RecoverableWriterITCase.testRecoverAfterMultiplePersistsStateWithMultiPart times out

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

[GitHub] [flink] wuchong commented on a change in pull request #12150: [FLINK-17026][kafka] Introduce a new Kafka connect or with new proper…

wuchong commented on a change in pull request #12150: URL: https://github.com/apache/flink/pull/12150#discussion_r426210338 ## File path: flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaOptions.java ## @@ -0,0

[jira] [Commented] (FLINK-17768) UnalignedCheckpointITCase.shouldPerformUnalignedCheckpointOnLocalAndRemoteChannel is instable

[ https://issues.apache.org/jira/browse/FLINK-17768?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17109281#comment-17109281 ] Dian Fu commented on FLINK-17768: - cc [~AHeise] >

[jira] [Updated] (FLINK-17768) UnalignedCheckpointITCase.shouldPerformUnalignedCheckpointOnLocalAndRemoteChannel is instable

[ https://issues.apache.org/jira/browse/FLINK-17768?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-17768: Fix Version/s: 1.11.0 > UnalignedCheckpointITCase.shouldPerformUnalignedCheckpointOnLocalAndRemoteChannel

[jira] [Updated] (FLINK-17768) UnalignedCheckpointITCase.shouldPerformUnalignedCheckpointOnLocalAndRemoteChannel is instable

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

[jira] [Updated] (FLINK-17768) UnalignedCheckpointITCase.shouldPerformUnalignedCheckpointOnLocalAndRemoteChannel is instable

[ https://issues.apache.org/jira/browse/FLINK-17768?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-17768: Labels: test-stability (was: ) >

[jira] [Created] (FLINK-17768) UnalignedCheckpointITCase.shouldPerformUnalignedCheckpointOnLocalAndRemoteChannel is instable

Dian Fu created FLINK-17768: --- Summary: UnalignedCheckpointITCase.shouldPerformUnalignedCheckpointOnLocalAndRemoteChannel is instable Key: FLINK-17768 URL: https://issues.apache.org/jira/browse/FLINK-17768

[jira] [Created] (FLINK-17767) Tumble and Hop window support offset

hailong wang created FLINK-17767: Summary: Tumble and Hop window support offset Key: FLINK-17767 URL: https://issues.apache.org/jira/browse/FLINK-17767 Project: Flink Issue Type: Improvement

[GitHub] [flink] wuchong commented on a change in pull request #12184: [FLINK-17027] Introduce a new Elasticsearch 7 connector with new property keys

wuchong commented on a change in pull request #12184: URL: https://github.com/apache/flink/pull/12184#discussion_r426209541 ## File path:

[jira] [Assigned] (FLINK-17764) Update tips about the default planner when the planner parameter value is not recognized

[ https://issues.apache.org/jira/browse/FLINK-17764?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu reassigned FLINK-17764: --- Assignee: xushiwei > Update tips about the default planner when the planner parameter value is not

[jira] [Commented] (FLINK-17764) Update tips about the default planner when the planner parameter value is not recognized

[ https://issues.apache.org/jira/browse/FLINK-17764?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17109277#comment-17109277 ] Dian Fu commented on FLINK-17764: - [~xushiwei] Thanks for the contribution. Have assigned the issue to

[jira] [Closed] (FLINK-17448) Implement ALTER TABLE for Hive dialect

[ https://issues.apache.org/jira/browse/FLINK-17448?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-17448. Resolution: Implemented master: 2bbf8ed32a7fc29dd5f0c941f451bd3a7a6d0d1b > Implement ALTER TABLE

[jira] [Assigned] (FLINK-17448) Implement ALTER TABLE for Hive dialect

[ https://issues.apache.org/jira/browse/FLINK-17448?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reassigned FLINK-17448: Assignee: Rui Li > Implement ALTER TABLE for Hive dialect >

[GitHub] [flink] JingsongLi merged pull request #12108: [FLINK-17448][sql-parser][table-api-java][table-planner-blink][hive] Implement table DDLs for Hive dialect part2

JingsongLi merged pull request #12108: URL: https://github.com/apache/flink/pull/12108 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

[GitHub] [flink] klion26 commented on pull request #11722: [FLINK-5763][state backends] Make savepoints self-contained and relocatable

klion26 commented on pull request #11722: URL: https://github.com/apache/flink/pull/11722#issuecomment-629731842 @StephanEwen thanks a lot for the follow-up pr and merging. I learned a lot from the follow-up pr that can be used in future contributions.

[GitHub] [flink] wuchong commented on pull request #12190: [FLINK-17757] Implement format factory for Avro serialization and deseriazation schema of RowData type

wuchong commented on pull request #12190: URL: https://github.com/apache/flink/pull/12190#issuecomment-629731816 @flinkbot run azure This is an automated message from the Apache Git Service. To respond to the message, please

[GitHub] [flink] KurtYoung commented on pull request #12145: [FLINK-17428] [table-planner-blink] supports projection push down on new table source interface in blink planner

KurtYoung commented on pull request #12145: URL: https://github.com/apache/flink/pull/12145#issuecomment-629730714 still has some checkstyle error This is an automated message from the Apache Git Service. To respond to the

[GitHub] [flink] KurtYoung commented on a change in pull request #12029: [FLINK-17451][sql-parser][table-planner-blink][hive] Implement view D…

KurtYoung commented on a change in pull request #12029: URL: https://github.com/apache/flink/pull/12029#discussion_r426207410 ## File path: flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/operations/ddl/AlterTablePropertiesOperation.java ## @@ -26,27

[GitHub] [flink] TsReaper commented on pull request #12073: [FLINK-17735][table] Add specialized collecting iterator to Blink planner

TsReaper commented on pull request #12073: URL: https://github.com/apache/flink/pull/12073#issuecomment-629730294 > Is the description here correct? The classes do not seem to relate to the Blink planner, but are all in the `flink-streaming-java` module. > > I also don't understand

[GitHub] [flink-web] yangjf2019 commented on pull request #268: [FLINK-13343][docs-zh] Translate "Contribute Code" page into Chinese

yangjf2019 commented on pull request #268: URL: https://github.com/apache/flink-web/pull/268#issuecomment-629729435 Hi,@klion26 Thank you for your help, I have completed all the changes, please take a look, thank you! This

[GitHub] [flink-web] yangjf2019 commented on a change in pull request #268: [FLINK-13343][docs-zh] Translate "Contribute Code" page into Chinese

yangjf2019 commented on a change in pull request #268: URL: https://github.com/apache/flink-web/pull/268#discussion_r426206770 ## File path: contributing/contribute-code.zh.md ## @@ -136,91 +136,91 @@ Apache Flink is maintained, improved, and extended by code contributions of

[GitHub] [flink-web] yangjf2019 commented on a change in pull request #268: [FLINK-13343][docs-zh] Translate "Contribute Code" page into Chinese

yangjf2019 commented on a change in pull request #268: URL: https://github.com/apache/flink-web/pull/268#discussion_r426206487 ## File path: contributing/contribute-code.zh.md ## @@ -2,17 +2,17 @@ title: "贡献代码" --- -Apache Flink is maintained, improved, and extended by

[GitHub] [flink] flinkbot edited a comment on pull request #12029: [FLINK-17451][sql-parser][table-planner-blink][hive] Implement view D…

flinkbot edited a comment on pull request #12029: URL: https://github.com/apache/flink/pull/12029#issuecomment-625673739 ## CI report: * 9405ea4470dc022ffb514f603396fc6bb2582835 UNKNOWN * c1ad4b5d93e10b76fad14269f46fa62e4d771bed Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #11920: [FLINK-17408] Introduce GPUDriver and discovery script

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

[GitHub] [flink] KarmaGYZ commented on pull request #11920: [FLINK-17408] Introduce GPUDriver and discovery script

KarmaGYZ commented on pull request #11920: URL: https://github.com/apache/flink/pull/11920#issuecomment-629725321 Thanks for the review @tillrohrmann . I've updated the PR and verified the latest version on a machine that has GPU support.

[GitHub] [flink] KarmaGYZ commented on a change in pull request #11920: [FLINK-17408] Introduce GPUDriver and discovery script

KarmaGYZ commented on a change in pull request #11920: URL: https://github.com/apache/flink/pull/11920#discussion_r426203278 ## File path: flink-dist/src/main/assemblies/opt.xml ## @@ -75,6 +75,28 @@ 0644 + +

[GitHub] [flink] KarmaGYZ commented on a change in pull request #11920: [FLINK-17408] Introduce GPUDriver and discovery script

KarmaGYZ commented on a change in pull request #11920: URL: https://github.com/apache/flink/pull/11920#discussion_r426203278 ## File path: flink-dist/src/main/assemblies/opt.xml ## @@ -75,6 +75,28 @@ 0644 + +

[GitHub] [flink] flinkbot edited a comment on pull request #11920: [FLINK-17408] Introduce GPUDriver and discovery script

flinkbot edited a comment on pull request #11920: URL: https://github.com/apache/flink/pull/11920#issuecomment-619909940 ## CI report: * a06b6bc5d3ff8d57e4610da4fe3ae1ec1f1d0b01 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #11920: [FLINK-17408] Introduce GPUDriver and discovery script

flinkbot edited a comment on pull request #11920: URL: https://github.com/apache/flink/pull/11920#issuecomment-619909940 ## CI report: * a06b6bc5d3ff8d57e4610da4fe3ae1ec1f1d0b01 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #11854: [FLINK-17407] Introduce external resource framework

flinkbot edited a comment on pull request #11854: URL: https://github.com/apache/flink/pull/11854#issuecomment-617586491 ## CI report: * bddb0e274da11bbe99d15c6e0bb55e8d8c0e658a UNKNOWN * dc7a9c5c7d1fac82518815b9277809dfb82ddaac UNKNOWN *

[GitHub] [flink] flinkbot edited a comment on pull request #12172: [FLINK-17656][tests] Migrate docker e2e tests to flink-docker

flinkbot edited a comment on pull request #12172: URL: https://github.com/apache/flink/pull/12172#issuecomment-629230668 ## CI report: * 59d7735635b83251b862eeedef8af62662dd0919 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12186: [FLINK-16383][task] Do not relay notifyCheckpointComplete to closed operators

flinkbot edited a comment on pull request #12186: URL: https://github.com/apache/flink/pull/12186#issuecomment-629492236 ## CI report: * 17deb1ace51d274715027adbeb607feb3958347a Azure:

[GitHub] [flink] senegalo edited a comment on pull request #12056: [FLINK-17502] [flink-connector-rabbitmq] RMQSource refactor

senegalo edited a comment on pull request #12056: URL: https://github.com/apache/flink/pull/12056#issuecomment-629626611 @aljoscha & @austince So i pushed some new changes and let me explain my endeavors for the last 3 hours ! ### My Goal * combine body / correlation id

[jira] [Closed] (FLINK-7267) Add support for lists of hosts to connect

[ https://issues.apache.org/jira/browse/FLINK-7267?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-7267. --- > Add support for lists of hosts to connect > - > >

[jira] [Resolved] (FLINK-7267) Add support for lists of hosts to connect

[ https://issues.apache.org/jira/browse/FLINK-7267?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-7267. - Fix Version/s: 1.11.0 Resolution: Fixed Implemented in 1.11.0 via -

[jira] [Closed] (FLINK-17582) Update quickstarts to use universal Kafka connector

[ https://issues.apache.org/jira/browse/FLINK-17582?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-17582. > Update quickstarts to use universal Kafka connector >

[jira] [Assigned] (FLINK-7267) Add support for lists of hosts to connect

[ https://issues.apache.org/jira/browse/FLINK-7267?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen reassigned FLINK-7267: --- Assignee: Austin Cawley-Edwards > Add support for lists of hosts to connect >

[jira] [Resolved] (FLINK-17582) Update quickstarts to use universal Kafka connector

[ https://issues.apache.org/jira/browse/FLINK-17582?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-17582. -- Resolution: Fixed Fixed in 1.11.0 via - 812d3d13d8c7966d62f40b990470ec468a16c80e > Update

[GitHub] [flink] asfgit closed pull request #12191: [hotfix][flink-core and docs] fix typos

asfgit closed pull request #12191: URL: https://github.com/apache/flink/pull/12191 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to

[GitHub] [flink] asfgit closed pull request #12064: [hotfix][javadocs]java doc error fix

asfgit closed pull request #12064: URL: https://github.com/apache/flink/pull/12064 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to

[GitHub] [flink] asfgit closed pull request #12044: [FLINK-17582][quickstarts] Update quickstarts to use universal Kafka connector

asfgit closed pull request #12044: URL: https://github.com/apache/flink/pull/12044 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to

[GitHub] [flink] asfgit closed pull request #12185: [FLINK-7267][connectors/rabbitmq] Allow overriding RMQ connection setup

asfgit closed pull request #12185: URL: https://github.com/apache/flink/pull/12185 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to

[GitHub] [flink] asfgit closed pull request #12066: [hotfix][runtime] Remove useless local variable in CompletedCheckpointStoreTest3testAddCheckpointMoreThanMaxRetained

asfgit closed pull request #12066: URL: https://github.com/apache/flink/pull/12066 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to

[GitHub] [flink] flinkbot edited a comment on pull request #12186: [FLINK-16383][task] Do not relay notifyCheckpointComplete to closed operators

flinkbot edited a comment on pull request #12186: URL: https://github.com/apache/flink/pull/12186#issuecomment-629492236 ## CI report: * 25f5493bb635b3876ef629cdfb87b3d7a6aa8fff Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12169: [FLINK-17495][metrics][prometheus]Add custom labels on PrometheusReporter like PrometheusPushGatewayReporter's groupingKey

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

[GitHub] [flink] flinkbot edited a comment on pull request #12056: [FLINK-17502] [flink-connector-rabbitmq] RMQSource refactor

flinkbot edited a comment on pull request #12056: URL: https://github.com/apache/flink/pull/12056#issuecomment-626167900 ## CI report: * 850f402a0e81fa0c097a0a883f56e2aa597b8f55 Azure:

[GitHub] [flink] StephanEwen commented on pull request #12122: [FLINK-15102] Add continuousSource() method to StreamExecutionEnvironment.

StephanEwen commented on pull request #12122: URL: https://github.com/apache/flink/pull/12122#issuecomment-629702088 The update looks fine to me. It would be nice to address the comment about the `CoordinatedSourceITCase` (more thorough result checking), otherwise +1 to merge this

[GitHub] [flink] flinkbot edited a comment on pull request #12186: [FLINK-16383][task] Do not relay notifyCheckpointComplete to closed operators

flinkbot edited a comment on pull request #12186: URL: https://github.com/apache/flink/pull/12186#issuecomment-629492236 ## CI report: * 25f5493bb635b3876ef629cdfb87b3d7a6aa8fff Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12184: [FLINK-17027] Introduce a new Elasticsearch 7 connector with new property keys

flinkbot edited a comment on pull request #12184: URL: https://github.com/apache/flink/pull/12184#issuecomment-629425634 ## CI report: * 80bbdd72c2aeb3c802deef71436882603590d147 UNKNOWN * fba63e0698c8c60a04efb10a8914ea548bacc653 Azure:

  1   2   3   4   5   6   >