[GitHub] [flink] flinkbot edited a comment on pull request #18388: [FLINK-25530][python][connector/pulsar] Support Pulsar source connector in Python DataStream API.

flinkbot edited a comment on pull request #18388: URL: https://github.com/apache/flink/pull/18388#issuecomment-1015205179 ## CI report: * 0c77d8a8ba1c5e1862d864d459ee2fc5d9d8f589 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[jira] [Created] (FLINK-25712) Merge flink-connector-testing into flink-connector-test-utils

Qingsheng Ren created FLINK-25712: - Summary: Merge flink-connector-testing into flink-connector-test-utils Key: FLINK-25712 URL: https://issues.apache.org/jira/browse/FLINK-25712 Project: Flink

[GitHub] [flink] flinkbot edited a comment on pull request #18137: [FLINK-25287][connector-testing-framework] Refactor interfaces of connector testing framework to support more scenarios

flinkbot edited a comment on pull request #18137: URL: https://github.com/apache/flink/pull/18137#issuecomment-996615034 ## CI report: * 9d442b8d459c111c77d41500bc268eacf312f981 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] xintongsong commented on pull request #15599: [FLINK-11838][flink-gs-fs-hadoop] Create Google Storage file system with recoverable writer support

xintongsong commented on pull request #15599: URL: https://github.com/apache/flink/pull/15599#issuecomment-1017058084 @sap1ens, Thanks for the notice, and sorry that your previous comment was overlooked among the tons of comments. I think you're correct that this should be included in `

[GitHub] [flink] flinkbot edited a comment on pull request #18137: [FLINK-25287][connector-testing-framework] Refactor interfaces of connector testing framework to support more scenarios

flinkbot edited a comment on pull request #18137: URL: https://github.com/apache/flink/pull/18137#issuecomment-996615034 ## CI report: * 9d442b8d459c111c77d41500bc268eacf312f981 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #18137: [FLINK-25287][connector-testing-framework] Refactor interfaces of connector testing framework to support more scenarios

flinkbot edited a comment on pull request #18137: URL: https://github.com/apache/flink/pull/18137#issuecomment-996615034 ## CI report: * 9d442b8d459c111c77d41500bc268eacf312f981 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #18137: [FLINK-25287][connector-testing-framework] Refactor interfaces of connector testing framework to support more scenarios

flinkbot edited a comment on pull request #18137: URL: https://github.com/apache/flink/pull/18137#issuecomment-996615034 ## CI report: * 9d442b8d459c111c77d41500bc268eacf312f981 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Commented] (FLINK-25649) Scheduling jobs fails with org.apache.flink.runtime.jobmanager.scheduler.NoResourceAvailableException

[ https://issues.apache.org/jira/browse/FLINK-25649?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17479064#comment-17479064 ] Zhu Zhu commented on FLINK-25649: - You can also send the logs to me (reed...@gmail.com).

[GitHub] [flink] flinkbot edited a comment on pull request #18137: [FLINK-25287][connector-testing-framework] Refactor interfaces of connector testing framework to support more scenarios

flinkbot edited a comment on pull request #18137: URL: https://github.com/apache/flink/pull/18137#issuecomment-996615034 ## CI report: * 9d442b8d459c111c77d41500bc268eacf312f981 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #18137: [FLINK-25287][connector-testing-framework] Refactor interfaces of connector testing framework to support more scenarios

flinkbot edited a comment on pull request #18137: URL: https://github.com/apache/flink/pull/18137#issuecomment-996615034 ## CI report: * 9d442b8d459c111c77d41500bc268eacf312f981 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] tsreaper opened a new pull request #18404: [FLINK-25681][table-planner] Remove failure test in CodeSplitITCase to avoid deep exception stack

tsreaper opened a new pull request #18404: URL: https://github.com/apache/flink/pull/18404 ## What is the purpose of the change FLINK-18356 aims to enforce memory limits for Docker containers, however failure tests in `CodeSplitITCase` will produce deep exception stack which may exc

[jira] [Updated] (FLINK-25681) CodeSplitITCase produces large stacktraces and potentially out of memory errors

[ https://issues.apache.org/jira/browse/FLINK-25681?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-25681: --- Labels: pull-request-available (was: ) > CodeSplitITCase produces large stacktraces and pot

[GitHub] [flink] flinkbot edited a comment on pull request #18137: [FLINK-25287][connector-testing-framework] Refactor interfaces of connector testing framework to support more scenarios

flinkbot edited a comment on pull request #18137: URL: https://github.com/apache/flink/pull/18137#issuecomment-996615034 ## CI report: * 9d442b8d459c111c77d41500bc268eacf312f981 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot commented on pull request #18404: [FLINK-25681][table-planner] Remove failure test in CodeSplitITCase to avoid deep exception stack

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

[GitHub] [flink] flinkbot commented on pull request #18404: [FLINK-25681][table-planner] Remove failure test in CodeSplitITCase to avoid deep exception stack

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

[GitHub] [flink-table-store] tsreaper commented on a change in pull request #12: [FLINK-25689] Introduce atomic commit

tsreaper commented on a change in pull request #12: URL: https://github.com/apache/flink-table-store/pull/12#discussion_r788307495 ## File path: flink-table-store-core/src/main/java/org/apache/flink/table/store/file/operation/FileStoreCommitImpl.java ## @@ -0,0 +1,376 @@ +/* +

[GitHub] [flink-table-store] tsreaper commented on a change in pull request #12: [FLINK-25689] Introduce atomic commit

tsreaper commented on a change in pull request #12: URL: https://github.com/apache/flink-table-store/pull/12#discussion_r788308005 ## File path: flink-table-store-core/src/main/java/org/apache/flink/table/store/file/utils/FileStorePathFactory.java ## @@ -96,6 +108,31 @@ public

[GitHub] [flink] flinkbot edited a comment on pull request #18137: [FLINK-25287][connector-testing-framework] Refactor interfaces of connector testing framework to support more scenarios

flinkbot edited a comment on pull request #18137: URL: https://github.com/apache/flink/pull/18137#issuecomment-996615034 ## CI report: * 9d442b8d459c111c77d41500bc268eacf312f981 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Resolved] (FLINK-24210) Window related serailizer should not return 0 as its serialized length

[ https://issues.apache.org/jira/browse/FLINK-24210?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang resolved FLINK-24210. -- Resolution: Fixed Merged in master: 573d2b038f8fd5dc1177733ee3087c5b6c847fa4 > Window related seraili

[GitHub] [flink-table-store] tsreaper commented on a change in pull request #12: [FLINK-25689] Introduce atomic commit

tsreaper commented on a change in pull request #12: URL: https://github.com/apache/flink-table-store/pull/12#discussion_r788308364 ## File path: flink-table-store-core/src/main/java/org/apache/flink/table/store/file/utils/FileStorePathFactory.java ## @@ -96,6 +108,31 @@ public

[GitHub] [flink] Myasuka closed pull request #17720: [FLINK-24210][serializer] Return the correct serialized length for wi…

Myasuka closed pull request #17720: URL: https://github.com/apache/flink/pull/17720 -- 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: issues-unsubsc

[GitHub] [flink] flinkbot edited a comment on pull request #18404: [FLINK-25681][table-planner] Remove failure test in CodeSplitITCase to avoid deep exception stack

flinkbot edited a comment on pull request #18404: URL: https://github.com/apache/flink/pull/18404#issuecomment-1017066728 ## CI report: * 511330acce13b111458ea01a6182ab2749d1d1a6 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[jira] [Updated] (FLINK-24210) Window related serailizer should not return 0 as its serialized length

[ https://issues.apache.org/jira/browse/FLINK-24210?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang updated FLINK-24210: - Fix Version/s: 1.15.0 > Window related serailizer should not return 0 as its serialized length > ---

[GitHub] [flink] flinkbot edited a comment on pull request #18137: [FLINK-25287][connector-testing-framework] Refactor interfaces of connector testing framework to support more scenarios

flinkbot edited a comment on pull request #18137: URL: https://github.com/apache/flink/pull/18137#issuecomment-996615034 ## CI report: * 9d442b8d459c111c77d41500bc268eacf312f981 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink-table-store] tsreaper commented on a change in pull request #12: [FLINK-25689] Introduce atomic commit

tsreaper commented on a change in pull request #12: URL: https://github.com/apache/flink-table-store/pull/12#discussion_r788309671 ## File path: flink-table-store-core/src/main/java/org/apache/flink/table/store/file/manifest/ManifestFileMeta.java ## @@ -118,4 +121,94 @@ public

[GitHub] [flink] paul8263 opened a new pull request #18405: [FLINK-25683][streaming-java] wrong result if table transfrom to Data…

paul8263 opened a new pull request #18405: URL: https://github.com/apache/flink/pull/18405 …Stream then window process in batch mode ## What is the purpose of the change Changed AbstractStreamOperator by extending BoundedMultiInput and set the key to a designed value when the

[jira] [Updated] (FLINK-25683) wrong result if table transfrom to DataStream then window process in batch mode

[ https://issues.apache.org/jira/browse/FLINK-25683?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-25683: --- Labels: pull-request-available (was: ) > wrong result if table transfrom to DataStream then

[GitHub] [flink] flinkbot edited a comment on pull request #18137: [FLINK-25287][connector-testing-framework] Refactor interfaces of connector testing framework to support more scenarios

flinkbot edited a comment on pull request #18137: URL: https://github.com/apache/flink/pull/18137#issuecomment-996615034 ## CI report: * 9d442b8d459c111c77d41500bc268eacf312f981 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot commented on pull request #18405: [FLINK-25683][streaming-java] wrong result if table transfrom to Data…

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

[GitHub] [flink] flinkbot commented on pull request #18405: [FLINK-25683][streaming-java] wrong result if table transfrom to Data…

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

[GitHub] [flink] flinkbot edited a comment on pull request #18137: [FLINK-25287][connector-testing-framework] Refactor interfaces of connector testing framework to support more scenarios

flinkbot edited a comment on pull request #18137: URL: https://github.com/apache/flink/pull/18137#issuecomment-996615034 ## CI report: * 9d442b8d459c111c77d41500bc268eacf312f981 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #18405: [FLINK-25683][streaming-java] wrong result if table transfrom to Data…

flinkbot edited a comment on pull request #18405: URL: https://github.com/apache/flink/pull/18405#issuecomment-1017071379 ## CI report: * 6229193f6adeedd62e7d5f0dcee9e6098e49ed9e Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink-table-store] tsreaper commented on a change in pull request #12: [FLINK-25689] Introduce atomic commit

tsreaper commented on a change in pull request #12: URL: https://github.com/apache/flink-table-store/pull/12#discussion_r788312849 ## File path: flink-table-store-core/src/main/java/org/apache/flink/table/store/file/Snapshot.java ## @@ -0,0 +1,132 @@ +/* + * Licensed to the Ap

[GitHub] [flink-table-store] tsreaper commented on a change in pull request #12: [FLINK-25689] Introduce atomic commit

tsreaper commented on a change in pull request #12: URL: https://github.com/apache/flink-table-store/pull/12#discussion_r788313592 ## File path: flink-table-store-core/src/main/java/org/apache/flink/table/store/file/Snapshot.java ## @@ -0,0 +1,132 @@ +/* + * Licensed to the Ap

[GitHub] [flink] RocMarshal removed a comment on pull request #17560: [FLINK-22315][table] Support ADD column/constraint/watermark for ALTER TABLE statement.

RocMarshal removed a comment on pull request #17560: URL: https://github.com/apache/flink/pull/17560#issuecomment-1013809780 Hi, @wuchong Could you help me to review this PR? Thanks. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to

[GitHub] [flink] flinkbot edited a comment on pull request #18137: [FLINK-25287][connector-testing-framework] Refactor interfaces of connector testing framework to support more scenarios

flinkbot edited a comment on pull request #18137: URL: https://github.com/apache/flink/pull/18137#issuecomment-996615034 ## CI report: * 9d442b8d459c111c77d41500bc268eacf312f981 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Commented] (FLINK-25705) Translate "Metric Reporters" page of "Deployment" in to Chinese

[ https://issues.apache.org/jira/browse/FLINK-25705?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17479074#comment-17479074 ] ChengKai Yang commented on FLINK-25705: --- Hi,[~jark] ,I want to work on this,can yo

[GitHub] [flink-table-store] tsreaper commented on a change in pull request #12: [FLINK-25689] Introduce atomic commit

tsreaper commented on a change in pull request #12: URL: https://github.com/apache/flink-table-store/pull/12#discussion_r788315085 ## File path: flink-table-store-core/src/main/java/org/apache/flink/table/store/file/manifest/ManifestFileMeta.java ## @@ -118,4 +121,94 @@ public

[GitHub] [flink-table-store] JingsongLi merged pull request #10: [FLINK-25680] Introduce Table Store Flink Sink

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

[jira] [Closed] (FLINK-25680) Introduce Table Store Flink Sink

[ https://issues.apache.org/jira/browse/FLINK-25680?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-25680. Resolution: Fixed master: beaf4adb2b3aae44df3334c4a562a927afefd160 > Introduce Table Store Flink

[jira] [Updated] (FLINK-25686) Support Pulsar Schema evolution in Pulsar Connector

[ https://issues.apache.org/jira/browse/FLINK-25686?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-25686: --- Labels: Pulsar pull-request-available (was: Pulsar) > Support Pulsar Schema evolution in Pu

[GitHub] [flink] imaffe opened a new pull request #18406: [FLINK-25686][pulsar]: add schema evolution support for pulsar source connector

imaffe opened a new pull request #18406: URL: https://github.com/apache/flink/pull/18406 ## Contribution Checklist - Make sure that the pull request corresponds to a [JIRA issue](https://issues.apache.org/jira/projects/FLINK/issues). Exceptions are made for typos in JavaDoc or

[GitHub] [flink] flinkbot commented on pull request #18406: [FLINK-25686][pulsar]: add schema evolution support for pulsar source connector

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

[GitHub] [flink] flinkbot commented on pull request #18406: [FLINK-25686][pulsar]: add schema evolution support for pulsar source connector

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

[GitHub] [flink] flinkbot edited a comment on pull request #18406: [FLINK-25686][pulsar]: add schema evolution support for pulsar source connector

flinkbot edited a comment on pull request #18406: URL: https://github.com/apache/flink/pull/18406#issuecomment-1017085273 ## CI report: * 2d7b3a0ff347eaf6a97622fa4cc9a318c793a51d Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink-ml] weibozhao opened a new pull request #56: [FLINK-25616] Add Transformer for VectorAssembler in FlinkML

weibozhao opened a new pull request #56: URL: https://github.com/apache/flink-ml/pull/56 ## What is the purpose of the change Add Transformer for VectorAssembler in FlinkML. ## Brief change log Add VectorAssembler. ## Does this pull request potentially affect one of the f

[jira] [Updated] (FLINK-25616) Support VectorAssembler in FlinkML

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

[GitHub] [flink] ruanhang1993 commented on a change in pull request #17601: [FLINK-24697][flink-connectors-kafka] add auto.offset.reset configuration for group-offsets startup mode

ruanhang1993 commented on a change in pull request #17601: URL: https://github.com/apache/flink/pull/17601#discussion_r788329906 ## File path: flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaDynamicSource.java ## @@ -

[GitHub] [flink] imaffe commented on a change in pull request #18406: [FLINK-25686][pulsar]: add schema evolution support for pulsar source connector

imaffe commented on a change in pull request #18406: URL: https://github.com/apache/flink/pull/18406#discussion_r788330029 ## File path: flink-connectors/flink-connector-pulsar/src/test/java/org/apache/flink/connector/pulsar/source/reader/deserializer/PulsarDeserializationSchemaTest.j

[GitHub] [flink] flinkbot edited a comment on pull request #17601: [FLINK-24697][flink-connectors-kafka] add auto.offset.reset configuration for group-offsets startup mode

flinkbot edited a comment on pull request #17601: URL: https://github.com/apache/flink/pull/17601#issuecomment-954546978 ## CI report: * 7667bd94a9d0af29b443a1b07f6e7077f5b9cce6 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #17601: [FLINK-24697][flink-connectors-kafka] add auto.offset.reset configuration for group-offsets startup mode

flinkbot edited a comment on pull request #17601: URL: https://github.com/apache/flink/pull/17601#issuecomment-954546978 ## CI report: * 7667bd94a9d0af29b443a1b07f6e7077f5b9cce6 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #18394: [FLINK-25520][Table SQL/API] Implement "ALTER TABLE ... COMPACT" SQL

flinkbot edited a comment on pull request #18394: URL: https://github.com/apache/flink/pull/18394#issuecomment-1015323011 ## CI report: * 9e19879e4b7b6fc0304cb5c36bbb972721e97c6d Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #18394: [FLINK-25520][Table SQL/API] Implement "ALTER TABLE ... COMPACT" SQL

flinkbot edited a comment on pull request #18394: URL: https://github.com/apache/flink/pull/18394#issuecomment-1015323011 ## CI report: * 9e19879e4b7b6fc0304cb5c36bbb972721e97c6d Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] LadyForest edited a comment on pull request #18394: [FLINK-25520][Table SQL/API] Implement "ALTER TABLE ... COMPACT" SQL

LadyForest edited a comment on pull request #18394: URL: https://github.com/apache/flink/pull/18394#issuecomment-1016159041 > I just feel, the testing classes are too complicated, can we simplify them? We only need to test what we need, there is no need to have very strong features.

[GitHub] [flink] LadyForest commented on pull request #18394: [FLINK-25520][Table SQL/API] Implement "ALTER TABLE ... COMPACT" SQL

LadyForest commented on pull request #18394: URL: https://github.com/apache/flink/pull/18394#issuecomment-1017100828 Hi, @JingsongLi thanks for your review. I've addressed your comments, please take a look when you're available, thanks :) -- This is an automated message from the Apache

[GitHub] [flink] wsry closed pull request #18365: [FLINK-22643][network] Reuse tpc connections between taskmanagers

wsry closed pull request #18365: URL: https://github.com/apache/flink/pull/18365 -- 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: issues-unsubscr..

[GitHub] [flink] wsry commented on pull request #18365: [FLINK-22643][network] Reuse tpc connections between taskmanagers

wsry commented on pull request #18365: URL: https://github.com/apache/flink/pull/18365#issuecomment-1017101035 Merged. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To u

[jira] [Updated] (FLINK-25669) Support register operator coordinators for newly initialized ExecutionJobVertex.

[ https://issues.apache.org/jira/browse/FLINK-25669?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lijie Wang updated FLINK-25669: --- Description: For dynamic graphs, the operator coordinators of execution job vertices should also be

[jira] [Updated] (FLINK-25669) Support register operator coordinators for newly initialized ExecutionJobVertex.

[ https://issues.apache.org/jira/browse/FLINK-25669?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lijie Wang updated FLINK-25669: --- Description: For dynamic graphs, the operator coordinators of execution job vertices should also be

[jira] [Commented] (FLINK-22643) Too many TCP connections among TaskManagers for large scale jobs

[ https://issues.apache.org/jira/browse/FLINK-22643?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17479091#comment-17479091 ] Yingjie Cao commented on FLINK-22643: - Fix via 23c1637b7d35135936f8abffdaaa937576006

[jira] [Closed] (FLINK-22643) Too many TCP connections among TaskManagers for large scale jobs

[ https://issues.apache.org/jira/browse/FLINK-22643?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yingjie Cao closed FLINK-22643. --- Resolution: Fixed > Too many TCP connections among TaskManagers for large scale jobs > -

[jira] [Updated] (FLINK-22643) Too many TCP connections among TaskManagers for large scale jobs

[ https://issues.apache.org/jira/browse/FLINK-22643?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yingjie Cao updated FLINK-22643: Fix Version/s: 1.15.0 > Too many TCP connections among TaskManagers for large scale jobs > ---

[GitHub] [flink] zhuzhurk commented on pull request #18102: [FLINK-25033][runtime] Let some scheduler components updatable

zhuzhurk commented on pull request #18102: URL: https://github.com/apache/flink/pull/18102#issuecomment-1017105507 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 above to go to the specific comment.

[GitHub] [flink] wanglijie95 opened a new pull request #18407: [FLINK-25669][runtime] Support register operator coordinators for newly initialized ExecutionJobVertex

wanglijie95 opened a new pull request #18407: URL: https://github.com/apache/flink/pull/18407 ## What is the purpose of the change For dynamic graphs, the operator coordinators of execution job vertices should also be registered and started lazily. We need to support register operator

[jira] [Updated] (FLINK-25669) Support register operator coordinators for newly initialized ExecutionJobVertex.

[ https://issues.apache.org/jira/browse/FLINK-25669?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-25669: --- Labels: pull-request-available (was: ) > Support register operator coordinators for newly i

[GitHub] [flink] flinkbot commented on pull request #18407: [FLINK-25669][runtime] Support register operator coordinators for newly initialized ExecutionJobVertex

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

[GitHub] [flink-ml] weibozhao commented on pull request #54: [FLINK-25552] Add Estimator and Transformer for MinMaxScaler in FlinkML

weibozhao commented on pull request #54: URL: https://github.com/apache/flink-ml/pull/54#issuecomment-1017107333 @zhipeng93 @lindong28 @gaoyunhaii Can you help review this PR? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub a

[GitHub] [flink-ml] weibozhao commented on pull request #56: [FLINK-25616] Add Transformer for VectorAssembler in FlinkML

weibozhao commented on pull request #56: URL: https://github.com/apache/flink-ml/pull/56#issuecomment-1017107566 @zhipeng93 @lindong28 @gaoyunhaii Can you help review this PR? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHu

[GitHub] [flink] flinkbot commented on pull request #18407: [FLINK-25669][runtime] Support register operator coordinators for newly initialized ExecutionJobVertex

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

[jira] [Comment Edited] (FLINK-25649) Scheduling jobs fails with org.apache.flink.runtime.jobmanager.scheduler.NoResourceAvailableException

[ https://issues.apache.org/jira/browse/FLINK-25649?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17479064#comment-17479064 ] Zhu Zhu edited comment on FLINK-25649 at 1/20/22, 4:25 AM: --- Yo

[GitHub] [flink] flinkbot edited a comment on pull request #18407: [FLINK-25669][runtime] Support register operator coordinators for newly initialized ExecutionJobVertex

flinkbot edited a comment on pull request #18407: URL: https://github.com/apache/flink/pull/18407#issuecomment-1017107067 ## CI report: * 1716622b272f2141ee4c29cf978265d8de00fa1b Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] zhuzhurk closed pull request #18102: [FLINK-25033][runtime] Let some scheduler components updatable

zhuzhurk closed pull request #18102: URL: https://github.com/apache/flink/pull/18102 -- 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: issues-unsubs

[jira] [Closed] (FLINK-25033) Let some scheduler components updatable

[ https://issues.apache.org/jira/browse/FLINK-25033?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu closed FLINK-25033. --- Fix Version/s: 1.15.0 Resolution: Done master/release-1.15: 82b07035719ac25c9256a1f273019410ee3ca4e7

[jira] [Created] (FLINK-25713) Support VectorNormalize in FlinkML

weibo zhao created FLINK-25713: -- Summary: Support VectorNormalize in FlinkML Key: FLINK-25713 URL: https://issues.apache.org/jira/browse/FLINK-25713 Project: Flink Issue Type: New Feature

[GitHub] [flink] sap1ens commented on pull request #15599: [FLINK-11838][flink-gs-fs-hadoop] Create Google Storage file system with recoverable writer support

sap1ens commented on pull request #15599: URL: https://github.com/apache/flink/pull/15599#issuecomment-1017116084 Thank you 👍 -- 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 commen

[GitHub] [flink] flinkbot edited a comment on pull request #18406: [FLINK-25686][pulsar]: add schema evolution support for pulsar source connector

flinkbot edited a comment on pull request #18406: URL: https://github.com/apache/flink/pull/18406#issuecomment-1017085273 ## CI report: * 2d7b3a0ff347eaf6a97622fa4cc9a318c793a51d Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] lmagic233 commented on pull request #18331: [FLINK-25614][table/runtime] Let LocalWindowAggregate be chained with upstream

lmagic233 commented on pull request #18331: URL: https://github.com/apache/flink/pull/18331#issuecomment-1017118469 Seems good to go. @wenlong88 @beyond1920 Please check and merge. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to Git

[GitHub] [flink] flinkbot edited a comment on pull request #18406: [FLINK-25686][pulsar]: add schema evolution support for pulsar source connector

flinkbot edited a comment on pull request #18406: URL: https://github.com/apache/flink/pull/18406#issuecomment-1017085273 ## CI report: * 2d7b3a0ff347eaf6a97622fa4cc9a318c793a51d Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink-ml] lindong28 commented on pull request #56: [FLINK-25616] Add Transformer for VectorAssembler in FlinkML

lindong28 commented on pull request #56: URL: https://github.com/apache/flink-ml/pull/56#issuecomment-1017123440 Before we continue to more and more algorithm, what's our plan to making sure these algorithm's implementation could meet our performance target? -- This is an automated messa

[GitHub] [flink-ml] lindong28 commented on pull request #54: [FLINK-25552] Add Estimator and Transformer for MinMaxScaler in FlinkML

lindong28 commented on pull request #54: URL: https://github.com/apache/flink-ml/pull/54#issuecomment-1017123834 Thanks for the PR. Before we continue to more and more algorithm, what's our plan to making sure these algorithm's implementation could meet our performance target? I am

[GitHub] [flink-ml] lindong28 edited a comment on pull request #56: [FLINK-25616] Add Transformer for VectorAssembler in FlinkML

lindong28 edited a comment on pull request #56: URL: https://github.com/apache/flink-ml/pull/56#issuecomment-1017123440 Thanks for the PR. Before we continue to more and more algorithm, what's our plan to making sure these algorithm's implementation could meet our performance target?

[GitHub] [flink] JingsongLi commented on a change in pull request #18394: [FLINK-25520][Table SQL/API] Implement "ALTER TABLE ... COMPACT" SQL

JingsongLi commented on a change in pull request #18394: URL: https://github.com/apache/flink/pull/18394#discussion_r788353676 ## File path: flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/operations/SourceQueryOperation.java ## @@ -39,9 +39,16 @@ public

[GitHub] [flink] JingsongLi commented on a change in pull request #18394: [FLINK-25520][Table SQL/API] Implement "ALTER TABLE ... COMPACT" SQL

JingsongLi commented on a change in pull request #18394: URL: https://github.com/apache/flink/pull/18394#discussion_r788353796 ## File path: flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/operations/SourceQueryOperation.java ## @@ -58,6 +65,7 @@ public S

[GitHub] [flink] JingsongLi commented on a change in pull request #18394: [FLINK-25520][Table SQL/API] Implement "ALTER TABLE ... COMPACT" SQL

JingsongLi commented on a change in pull request #18394: URL: https://github.com/apache/flink/pull/18394#discussion_r788355454 ## File path: flink-table/flink-table-planner/src/test/resources/META-INF/services/org.apache.flink.table.factories.Factory ## @@ -13,8 +13,8 @@ # Se

[GitHub] [flink] JingsongLi commented on a change in pull request #18394: [FLINK-25520][Table SQL/API] Implement "ALTER TABLE ... COMPACT" SQL

JingsongLi commented on a change in pull request #18394: URL: https://github.com/apache/flink/pull/18394#discussion_r788355740 ## File path: flink-formats/flink-orc/pom.xml ## @@ -145,6 +145,19 @@ under the License. test test-jar

[GitHub] [flink-ml] lindong28 edited a comment on pull request #54: [FLINK-25552] Add Estimator and Transformer for MinMaxScaler in FlinkML

lindong28 edited a comment on pull request #54: URL: https://github.com/apache/flink-ml/pull/54#issuecomment-1017123834 Thanks for the PR. Before we continue to more and more algorithm, what's our plan to make sure these algorithm's implementation could meet our performance target? I

[GitHub] [flink-ml] lindong28 edited a comment on pull request #56: [FLINK-25616] Add Transformer for VectorAssembler in FlinkML

lindong28 edited a comment on pull request #56: URL: https://github.com/apache/flink-ml/pull/56#issuecomment-1017123440 Thanks for the PR. Before we continue to more and more algorithm, what's our plan to make sure these algorithm's implementation could meet our performance target? I

[GitHub] [flink] JingsongLi commented on a change in pull request #18394: [FLINK-25520][Table SQL/API] Implement "ALTER TABLE ... COMPACT" SQL

JingsongLi commented on a change in pull request #18394: URL: https://github.com/apache/flink/pull/18394#discussion_r788356281 ## File path: flink-table/flink-table-common/src/test/java/org/apache/flink/table/connector/sink/TestManagedCommittable.java ## @@ -0,0 +1,81 @@ +/* +

[GitHub] [flink] JingsongLi commented on a change in pull request #18394: [FLINK-25520][Table SQL/API] Implement "ALTER TABLE ... COMPACT" SQL

JingsongLi commented on a change in pull request #18394: URL: https://github.com/apache/flink/pull/18394#discussion_r788356617 ## File path: flink-table/flink-table-common/src/test/java/org/apache/flink/table/connector/source/TestManagedFileSourceSplitSerializer.java ## @@ -0,

[GitHub] [flink] JingsongLi commented on a change in pull request #18394: [FLINK-25520][Table SQL/API] Implement "ALTER TABLE ... COMPACT" SQL

JingsongLi commented on a change in pull request #18394: URL: https://github.com/apache/flink/pull/18394#discussion_r788356728 ## File path: flink-table/flink-table-common/src/test/java/org/apache/flink/table/connector/source/TestManagedIterableSourceSplit.java ## @@ -0,0 +1,9

[GitHub] [flink] JingsongLi commented on a change in pull request #18394: [FLINK-25520][Table SQL/API] Implement "ALTER TABLE ... COMPACT" SQL

JingsongLi commented on a change in pull request #18394: URL: https://github.com/apache/flink/pull/18394#discussion_r788357203 ## File path: flink-table/flink-table-common/src/test/java/org/apache/flink/table/connector/source/TestManagedTableSource.java ## @@ -0,0 +1,69 @@ +/*

[GitHub] [flink] JingsongLi commented on a change in pull request #18394: [FLINK-25520][Table SQL/API] Implement "ALTER TABLE ... COMPACT" SQL

JingsongLi commented on a change in pull request #18394: URL: https://github.com/apache/flink/pull/18394#discussion_r788357601 ## File path: flink-table/flink-table-common/src/test/java/org/apache/flink/table/factories/TestManagedTableFactory.java ## @@ -175,37 +191,153 @@ pri

[GitHub] [flink] SteNicholas opened a new pull request #18408: [FLINK-24865][cep] Support MATCH_RECOGNIZE in Batch mode

SteNicholas opened a new pull request #18408: URL: https://github.com/apache/flink/pull/18408 ## What is the purpose of the change *`MATCH_RECOGNIZE` only works currently in Streaming mode. It should also be supported in Batch mode.* ## Brief change log - *`FlinkBatch

[GitHub] [flink] xintongsong opened a new pull request #18409: [hotfix][dist] Fix that flink-gs-fs-hadoop not included in flink-dist

xintongsong opened a new pull request #18409: URL: https://github.com/apache/flink/pull/18409 See [this discussion](https://github.com/apache/flink/pull/15599#issuecomment-1017039938) for the details. -- This is an automated message from the Apache Git Service. To respond to the message

[jira] [Updated] (FLINK-24865) Support MATCH_RECOGNIZE in Batch mode

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

[GitHub] [flink] flinkbot commented on pull request #18408: [FLINK-24865][cep] Support MATCH_RECOGNIZE in Batch mode

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

[GitHub] [flink] flinkbot edited a comment on pull request #18324: [FLINK-25557][checkpoint] Introduce incremental/full checkpoint size stats

flinkbot edited a comment on pull request #18324: URL: https://github.com/apache/flink/pull/18324#issuecomment-1009752905 ## CI report: * ce08a46add96553021558f2af3ecebc74a93e4e4 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot commented on pull request #18408: [FLINK-24865][cep] Support MATCH_RECOGNIZE in Batch mode

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

[GitHub] [flink] flinkbot commented on pull request #18409: [hotfix][dist] Fix that flink-gs-fs-hadoop not included in flink-dist

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

[GitHub] [flink] flinkbot commented on pull request #18409: [hotfix][dist] Fix that flink-gs-fs-hadoop not included in flink-dist

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

<    1   2   3   4   5   6   >