[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: * 28dfa018daa07e9d2e305672a80402eaee1eebaa Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17967: [FLINK-25096][runtime] Fixes empty exception history for JobInitializationException

flinkbot edited a comment on pull request #17967: URL: https://github.com/apache/flink/pull/17967#issuecomment-982775752 ## CI report: * 21197d2de69258102522e7c3decb7ab80e160763 Azure:

[jira] [Comment Edited] (FLINK-25081) When chaining an operator of a side output stream, the num records sent displayed on the dashboard is incorrect

[ https://issues.apache.org/jira/browse/FLINK-25081?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=1745#comment-1745 ] Guo Weijie edited comment on FLINK-25081 at 12/7/21, 7:58 AM: -- cc

[jira] [Updated] (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:all-tabpanel ] Martijn Visser updated FLINK-20370: --- Fix Version/s: 1.14.1 > Result is wrong when sink primary key is not the same with query >

[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=17454447#comment-17454447 ] Martijn Visser commented on FLINK-20370: Given the impact, I think it makes sense to wait with

[jira] [Commented] (FLINK-25081) When chaining an operator of a side output stream, the num records sent displayed on the dashboard is incorrect

[ https://issues.apache.org/jira/browse/FLINK-25081?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=1745#comment-1745 ] Guo Weijie commented on FLINK-25081: cc [~siranen]  > When chaining an operator of a side output

[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: * 28dfa018daa07e9d2e305672a80402eaee1eebaa Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17967: [FLINK-25096][runtime] Fixes empty exception history for JobInitializationException

flinkbot edited a comment on pull request #17967: URL: https://github.com/apache/flink/pull/17967#issuecomment-982775752 ## CI report: * 21197d2de69258102522e7c3decb7ab80e160763 Azure:

[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: * 28dfa018daa07e9d2e305672a80402eaee1eebaa Azure:

[GitHub] [flink] dawidwys commented on a change in pull request #17968: [FLINK-23532] Unify stop-with-savepoint without and with drain

dawidwys commented on a change in pull request #17968: URL: https://github.com/apache/flink/pull/17968#discussion_r763716735 ## File path: flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/SourceStreamTaskTest.java ## @@ -577,45 +518,6 @@ public void

[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: * 28dfa018daa07e9d2e305672a80402eaee1eebaa Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17967: [FLINK-25096][runtime] Fixes empty exception history for JobInitializationException

flinkbot edited a comment on pull request #17967: URL: https://github.com/apache/flink/pull/17967#issuecomment-982775752 ## CI report: * 21197d2de69258102522e7c3decb7ab80e160763 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17919: [FLINK-24419][table-planner] Trim to precision when casting to BINARY/VARBINARY

flinkbot edited a comment on pull request #17919: URL: https://github.com/apache/flink/pull/17919#issuecomment-979659835 ## CI report: * 45b754770668f8aa332b5d0d35bc0cbde4cb4706 Azure:

[GitHub] [flink-web] XComp commented on pull request #485: [FLINK-25096] Adds pointer to custom Assert implementations in flink-test-utils-junit

XComp commented on pull request #485: URL: https://github.com/apache/flink-web/pull/485#issuecomment-987658160 I'm closing this PR again since the `FlinkAssertions` are, probably, only temporarily necessary considering the efforts in [assertj-core's PR

[GitHub] [flink-web] XComp closed pull request #485: [FLINK-25096] Adds pointer to custom Assert implementations in flink-test-utils-junit

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

[jira] [Commented] (FLINK-24614) Add array,map,row types support for parquet vectorized reader

[ https://issues.apache.org/jira/browse/FLINK-24614?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17454439#comment-17454439 ] sujun commented on FLINK-24614: --- [~lzljs3620320]  No problem. > Add array,map,row types support for

[GitHub] [flink] dawidwys commented on a change in pull request #17968: [FLINK-23532] Unify stop-with-savepoint without and with drain

dawidwys commented on a change in pull request #17968: URL: https://github.com/apache/flink/pull/17968#discussion_r763708144 ## File path: flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/SynchronousCheckpointTest.java ## @@ -76,24 +75,6 @@ public

[GitHub] [flink] flinkbot edited a comment on pull request #17967: [FLINK-25096][runtime] Fixes empty exception history for JobInitializationException

flinkbot edited a comment on pull request #17967: URL: https://github.com/apache/flink/pull/17967#issuecomment-982775752 ## CI report: * 21197d2de69258102522e7c3decb7ab80e160763 Azure:

[jira] [Updated] (FLINK-24614) Add array,map,row types support for parquet vectorized reader

[ https://issues.apache.org/jira/browse/FLINK-24614?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sujun updated FLINK-24614: -- Attachment: (was: image-2021-12-07-15-47-58-585.png) > Add array,map,row types support for parquet

[jira] [Updated] (FLINK-24614) Add array,map,row types support for parquet vectorized reader

[ https://issues.apache.org/jira/browse/FLINK-24614?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sujun updated FLINK-24614: -- Attachment: (was: image-2021-12-07-12-09-15-405.png) > Add array,map,row types support for parquet

[jira] [Updated] (FLINK-24614) Add array,map,row types support for parquet vectorized reader

[ https://issues.apache.org/jira/browse/FLINK-24614?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sujun updated FLINK-24614: -- Attachment: image-2021-12-07-15-47-58-585.png > Add array,map,row types support for parquet vectorized reader

[GitHub] [flink] flinkbot edited a comment on pull request #17967: [FLINK-25096][runtime] Fixes empty exception history for JobInitializationException

flinkbot edited a comment on pull request #17967: URL: https://github.com/apache/flink/pull/17967#issuecomment-982775752 ## CI report: * 21197d2de69258102522e7c3decb7ab80e160763 Azure:

[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: * 28dfa018daa07e9d2e305672a80402eaee1eebaa Azure:

[GitHub] [flink] coralzu commented on pull request #15676: [FLINK-22178][csv] Support ignore-first-line option in new csv format

coralzu commented on pull request #15676: URL: https://github.com/apache/flink/pull/15676#issuecomment-987654708 I have encountered this problem. Can this parameter be accepted? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to

[GitHub] [flink] dawidwys commented on a change in pull request #17968: [FLINK-23532] Unify stop-with-savepoint without and with drain

dawidwys commented on a change in pull request #17968: URL: https://github.com/apache/flink/pull/17968#discussion_r763713610 ## File path: flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/SourceTaskTerminationTest.java ## @@ -118,9 +120,6 @@ private

[jira] [Commented] (FLINK-24614) Add array,map,row types support for parquet vectorized reader

[ https://issues.apache.org/jira/browse/FLINK-24614?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17454433#comment-17454433 ] Jingsong Lee commented on FLINK-24614: -- Hi [~sujun1020] I am currently quite busy, do not have time

[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: * 28dfa018daa07e9d2e305672a80402eaee1eebaa Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17967: [FLINK-25096][runtime] Fixes empty exception history for JobInitializationException

flinkbot edited a comment on pull request #17967: URL: https://github.com/apache/flink/pull/17967#issuecomment-982775752 ## CI report: * 21197d2de69258102522e7c3decb7ab80e160763 Azure:

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

lindong28 commented on a change in pull request #24: URL: https://github.com/apache/flink-ml/pull/24#discussion_r763682700 ## File path: flink-ml-core/src/main/java/org/apache/flink/ml/linalg/DenseMatrix.java ## @@ -0,0 +1,47 @@ +package org.apache.flink.ml.linalg; + +import

[GitHub] [flink] flinkbot edited a comment on pull request #18034: [FLINK-25204][Docs] Fix Spell one more as in the DataStream interval join docs

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

[GitHub] [flink] gaoyunhaii commented on a change in pull request #17968: [FLINK-23532] Unify stop-with-savepoint without and with drain

gaoyunhaii commented on a change in pull request #17968: URL: https://github.com/apache/flink/pull/17968#discussion_r763710210 ## File path: flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/SourceTaskTerminationTest.java ## @@ -118,9 +120,6 @@

[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: * 28dfa018daa07e9d2e305672a80402eaee1eebaa Azure:

[GitHub] [flink] dawidwys commented on a change in pull request #17968: [FLINK-23532] Unify stop-with-savepoint without and with drain

dawidwys commented on a change in pull request #17968: URL: https://github.com/apache/flink/pull/17968#discussion_r763709489 ## File path: flink-tests/src/test/java/org/apache/flink/runtime/jobmaster/JobMasterStopWithSavepointITCase.java ## @@ -99,31 +94,6 @@ private

[jira] [Commented] (FLINK-25171) When the DDL statement was executed, the column names of the Derived Columns were not validated

[ https://issues.apache.org/jira/browse/FLINK-25171?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17454432#comment-17454432 ] Wenlong Lyu commented on FLINK-25171: - I think it is good to not allow duplicated column name in

[GitHub] [flink] dawidwys commented on a change in pull request #17968: [FLINK-23532] Unify stop-with-savepoint without and with drain

dawidwys commented on a change in pull request #17968: URL: https://github.com/apache/flink/pull/17968#discussion_r763709489 ## File path: flink-tests/src/test/java/org/apache/flink/runtime/jobmaster/JobMasterStopWithSavepointITCase.java ## @@ -99,31 +94,6 @@ private

[GitHub] [flink] dawidwys commented on a change in pull request #17968: [FLINK-23532] Unify stop-with-savepoint without and with drain

dawidwys commented on a change in pull request #17968: URL: https://github.com/apache/flink/pull/17968#discussion_r763705063 ## File path: flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/SourceStreamTaskTest.java ## @@ -528,27 +490,6 @@ public void

[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: * 28dfa018daa07e9d2e305672a80402eaee1eebaa Azure:

[GitHub] [flink] flinkbot commented on pull request #18034: [FLINK-25204][Docs] Fix Spell one more as in the DataStream interval join docs

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

[GitHub] [flink] flinkbot commented on pull request #18034: [FLINK-25204][Docs] Fix Spell one more as in the DataStream interval join docs

flinkbot commented on pull request #18034: URL: https://github.com/apache/flink/pull/18034#issuecomment-987649094 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] dawidwys commented on a change in pull request #17968: [FLINK-23532] Unify stop-with-savepoint without and with drain

dawidwys commented on a change in pull request #17968: URL: https://github.com/apache/flink/pull/17968#discussion_r763708144 ## File path: flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/SynchronousCheckpointTest.java ## @@ -76,24 +75,6 @@ public

[jira] [Updated] (FLINK-25204) Spell one more as in the DataStream interval join docs

[ https://issues.apache.org/jira/browse/FLINK-25204?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-25204: --- Labels: pull-request-available (was: ) > Spell one more as in the DataStream interval join

[GitHub] [flink] Tartarus0zm commented on pull request #18034: [FLINK-25204][Docs] Fix Spell one more as in the DataStream interval join docs

Tartarus0zm commented on pull request #18034: URL: https://github.com/apache/flink/pull/18034#issuecomment-987648228 @beyond1920 please take a look, if you have time, thanks -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub

[GitHub] [flink] Tartarus0zm opened a new pull request #18034: [FLINK-25204][Docs] Fix Spell one more as in the DataStream interval join docs

Tartarus0zm opened a new pull request #18034: URL: https://github.com/apache/flink/pull/18034 ## What is the purpose of the change Fix Spell one more as in the DataStream interval join docs ## Brief change log * Remove extra words ## Verifying this change

[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: * 28dfa018daa07e9d2e305672a80402eaee1eebaa Azure:

[GitHub] [flink] dawidwys commented on a change in pull request #17968: [FLINK-23532] Unify stop-with-savepoint without and with drain

dawidwys commented on a change in pull request #17968: URL: https://github.com/apache/flink/pull/17968#discussion_r763706426 ## File path: flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/StreamTaskFinalCheckpointsTest.java ## @@ -483,130 +496,6 @@

[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: * 28dfa018daa07e9d2e305672a80402eaee1eebaa Azure:

[GitHub] [flink] dawidwys commented on a change in pull request #17968: [FLINK-23532] Unify stop-with-savepoint without and with drain

dawidwys commented on a change in pull request #17968: URL: https://github.com/apache/flink/pull/17968#discussion_r763706684 ## File path: flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/StreamTaskFinalCheckpointsTest.java ## @@ -483,130 +496,6 @@

[GitHub] [flink] flinkbot edited a comment on pull request #17958: FLINK-25029: Hadoop Caller Context Setting in Flink

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

[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: * 28dfa018daa07e9d2e305672a80402eaee1eebaa Azure:

[jira] [Created] (FLINK-25205) Optimize SinkUpsertMaterializer

Jingsong Lee created FLINK-25205: Summary: Optimize SinkUpsertMaterializer Key: FLINK-25205 URL: https://issues.apache.org/jira/browse/FLINK-25205 Project: Flink Issue Type: Improvement

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

wenlong88 commented on pull request #18017: URL: https://github.com/apache/flink/pull/18017#issuecomment-987645905 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] KarmaGYZ commented on pull request #18007: [FLINK-25085][runtime] Add a scheduled thread pool in Endpoint and close it when the endpoint is stopped

KarmaGYZ commented on pull request #18007: URL: https://github.com/apache/flink/pull/18007#issuecomment-987644800 Thanks for the reply, @zjureel . It seems we all agree that, in the end, the `MainThreadExecutor#schedule` will be replaced. Also, I don't think one should use

[GitHub] [flink] dawidwys commented on a change in pull request #17968: [FLINK-23532] Unify stop-with-savepoint without and with drain

dawidwys commented on a change in pull request #17968: URL: https://github.com/apache/flink/pull/17968#discussion_r763703873 ## File path: flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/SourceStreamTaskTest.java ## @@ -113,39 +108,6 @@ */

[GitHub] [flink] flinkbot edited a comment on pull request #18033: [FLINK-25141][connector/elasticsearch] add sink parallelism option

flinkbot edited a comment on pull request #18033: URL: https://github.com/apache/flink/pull/18033#issuecomment-987520681 ## CI report: * efc9b32bee87ef64369b1e1ca1605ab1f3cc48e0 Azure:

[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: * 28dfa018daa07e9d2e305672a80402eaee1eebaa Azure:

[jira] [Commented] (FLINK-25204) Spell one more as in the DataStream interval join docs

[ https://issues.apache.org/jira/browse/FLINK-25204?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17454424#comment-17454424 ] tartarus commented on FLINK-25204: -- [~jark] Please assign to me , thanks > Spell one more as in the

[GitHub] [flink] unigeorge closed pull request #17585: [hotfix][docs] Modify wrong variable names in doc demo code

unigeorge closed pull request #17585: URL: https://github.com/apache/flink/pull/17585 -- 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] unigeorge removed a comment on pull request #17585: [hotfix][docs] Modify wrong variable names in doc demo code

unigeorge removed a comment on pull request #17585: URL: https://github.com/apache/flink/pull/17585#issuecomment-962769793 @dianfu Can you review it for me? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL

[jira] [Created] (FLINK-25204) Spell one more as in the DataStream interval join docs

tartarus created FLINK-25204: Summary: Spell one more as in the DataStream interval join docs Key: FLINK-25204 URL: https://issues.apache.org/jira/browse/FLINK-25204 Project: Flink Issue Type:

[GitHub] [flink] dawidwys commented on a change in pull request #17968: [FLINK-23532] Unify stop-with-savepoint without and with drain

dawidwys commented on a change in pull request #17968: URL: https://github.com/apache/flink/pull/17968#discussion_r763702447 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/SourceOperator.java ## @@ -52,6 +52,7 @@ import

[GitHub] [flink] flinkbot edited a comment on pull request #18032: [FLINK-25190] Actively report the number of TaskManagers that have not yet been registered with JobManager

flinkbot edited a comment on pull request #18032: URL: https://github.com/apache/flink/pull/18032#issuecomment-987494910 ## CI report: * 78bc26400605d1f3e8662f3d7eabbe426c72eb9d Azure:

[GitHub] [flink] rmetzger commented on a change in pull request #17996: [FLINK-23230] Fix protoc dependency for Apple Silicon / m1 support

rmetzger commented on a change in pull request #17996: URL: https://github.com/apache/flink/pull/17996#discussion_r763687125 ## File path: flink-formats/flink-parquet/pom.xml ## @@ -131,8 +131,17 @@ under the License. org.apache.hadoop

[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: * 11561c01f7d5f1f92c2fb98db39ee5db34c7afab Azure:

[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: * 11561c01f7d5f1f92c2fb98db39ee5db34c7afab Azure:

[jira] [Commented] (FLINK-24957) show `host:port` information in `subtasks` tab

[ https://issues.apache.org/jira/browse/FLINK-24957?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17454411#comment-17454411 ] Xianxun Ye commented on FLINK-24957: cc [~chesnay]  could you assign this ticket to me ? > show

[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: * 11561c01f7d5f1f92c2fb98db39ee5db34c7afab Azure:

[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: * 11561c01f7d5f1f92c2fb98db39ee5db34c7afab Azure:

[jira] [Updated] (FLINK-22071) LookupTableSource.LookupRuntimeProvider customizes parallelism

[ https://issues.apache.org/jira/browse/FLINK-22071?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ada Wong updated FLINK-22071: - Priority: Major (was: Minor) > LookupTableSource.LookupRuntimeProvider customizes parallelism >

[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: * 11561c01f7d5f1f92c2fb98db39ee5db34c7afab Azure:

[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: * 11561c01f7d5f1f92c2fb98db39ee5db34c7afab Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18033: [FLINK-25141][connector/elasticsearch] add sink parallelism option

flinkbot edited a comment on pull request #18033: URL: https://github.com/apache/flink/pull/18033#issuecomment-987520681 ## CI report: * efc9b32bee87ef64369b1e1ca1605ab1f3cc48e0 Azure:

[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: * 11561c01f7d5f1f92c2fb98db39ee5db34c7afab Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18033: [FLINK-25141][connector/elasticsearch] add sink parallelism option

flinkbot edited a comment on pull request #18033: URL: https://github.com/apache/flink/pull/18033#issuecomment-987520681 ## CI report: * efc9b32bee87ef64369b1e1ca1605ab1f3cc48e0 Azure:

[jira] [Commented] (FLINK-24947) Support host network for native K8s integration

[ https://issues.apache.org/jira/browse/FLINK-24947?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17454403#comment-17454403 ] liuzhuo commented on FLINK-24947: - [~wangyang0918] Sorry for the busy work recently, I am working hard

[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: * 11561c01f7d5f1f92c2fb98db39ee5db34c7afab Azure:

[jira] [Updated] (FLINK-24947) Support host network for native K8s integration

[ https://issues.apache.org/jira/browse/FLINK-24947?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] liuzhuo updated FLINK-24947: Attachment: image-2021-12-07-14-30-42-156.png > Support host network for native K8s integration >

[jira] [Updated] (FLINK-24947) Support host network for native K8s integration

[ https://issues.apache.org/jira/browse/FLINK-24947?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] liuzhuo updated FLINK-24947: Attachment: (was: image-2021-12-07-14-30-42-156.png) > Support host network for native K8s

[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: * 11561c01f7d5f1f92c2fb98db39ee5db34c7afab Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18007: [FLINK-25085][runtime] Add a scheduled thread pool in Endpoint and close it when the endpoint is stopped

flinkbot edited a comment on pull request #18007: URL: https://github.com/apache/flink/pull/18007#issuecomment-985453331 ## CI report: * f118d2bdf22d4a661807d4f6e511ad43201058fb Azure:

[jira] [Closed] (FLINK-25072) Introduce description for operator

[ https://issues.apache.org/jira/browse/FLINK-25072?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao closed FLINK-25072. --- Resolution: Fixed > Introduce description for operator > -- > >

[jira] [Commented] (FLINK-25072) Introduce description for operator

[ https://issues.apache.org/jira/browse/FLINK-25072?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17454397#comment-17454397 ] Yun Gao commented on FLINK-25072: - Merge on master via fda6bf6d13831dcef8f405803674404ca4be5586 >

[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: * 11561c01f7d5f1f92c2fb98db39ee5db34c7afab Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18007: [FLINK-25085][runtime] Add a scheduled thread pool in Endpoint and close it when the endpoint is stopped

flinkbot edited a comment on pull request #18007: URL: https://github.com/apache/flink/pull/18007#issuecomment-985453331 ## CI report: * f118d2bdf22d4a661807d4f6e511ad43201058fb Azure:

[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: * 11561c01f7d5f1f92c2fb98db39ee5db34c7afab Azure:

[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: * 11561c01f7d5f1f92c2fb98db39ee5db34c7afab Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17654: [FLINK-24614][Connectors/PARQUET] Add Complex types support for parquet reader

flinkbot edited a comment on pull request #17654: URL: https://github.com/apache/flink/pull/17654#issuecomment-958713350 ## CI report: * f5c785fd3c60fcacebcaeedbaa8fb6522c641762 Azure:

[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: * 11561c01f7d5f1f92c2fb98db39ee5db34c7afab Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17654: [FLINK-24614][Connectors/PARQUET] Add Complex types support for parquet reader

flinkbot edited a comment on pull request #17654: URL: https://github.com/apache/flink/pull/17654#issuecomment-958713350 ## CI report: * f5c785fd3c60fcacebcaeedbaa8fb6522c641762 Azure:

[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: * 11561c01f7d5f1f92c2fb98db39ee5db34c7afab Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17958: FLINK-25029: Hadoop Caller Context Setting in Flink

flinkbot edited a comment on pull request #17958: URL: https://github.com/apache/flink/pull/17958#issuecomment-982461620 ## CI report: * cc4e67df76861ef65f7d9ba4b6fde75f85a091e8 Azure:

[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: * 11561c01f7d5f1f92c2fb98db39ee5db34c7afab Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17958: FLINK-25029: Hadoop Caller Context Setting in Flink

flinkbot edited a comment on pull request #17958: URL: https://github.com/apache/flink/pull/17958#issuecomment-982461620 ## CI report: * cc4e67df76861ef65f7d9ba4b6fde75f85a091e8 Azure:

[GitHub] [flink] zjureel edited a comment on pull request #18007: [FLINK-25085][runtime] Add a scheduled thread pool in Endpoint and close it when the endpoint is stopped

zjureel edited a comment on pull request #18007: URL: https://github.com/apache/flink/pull/18007#issuecomment-987597330 @KarmaGYZ Thank you for your comments. I think it's a good question about `ScheduledMainThreadExecutor` and `MainThreadExecutor`. I create `ScheduledMainThreadExecutor`

[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: * 11561c01f7d5f1f92c2fb98db39ee5db34c7afab Azure:

[GitHub] [flink] gaoyunhaii closed pull request #17924: [FLINK-25072][streaming] Introduce description on Transformation and …

gaoyunhaii closed pull request #17924: URL: https://github.com/apache/flink/pull/17924 -- 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] zjureel edited a comment on pull request #18007: [FLINK-25085][runtime] Add a scheduled thread pool in Endpoint and close it when the endpoint is stopped

zjureel edited a comment on pull request #18007: URL: https://github.com/apache/flink/pull/18007#issuecomment-987597330 @KarmaGYZ Thank you for your comments. I think it's a good question about `ScheduledMainThreadExecutor` and `MainThreadExecutor`. I create `ScheduledMainThreadExecutor`

[GitHub] [flink] zjureel commented on pull request #18007: [FLINK-25085][runtime] Add a scheduled thread pool in Endpoint and close it when the endpoint is stopped

zjureel commented on pull request #18007: URL: https://github.com/apache/flink/pull/18007#issuecomment-987597330 @KarmaGYZ Thank you for your comments. I think it's a good question about `ScheduledMainThreadExecutor` and `MainThreadExecutor`. I create `ScheduledMainThreadExecutor` here

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

liufangqi removed a comment on pull request #17958: URL: https://github.com/apache/flink/pull/17958#issuecomment-987524606 > Test failures show that your Hadoop configuraiton hack is not enough to properly detect if Hadoop is on CP or not. @zentol do we better options? @AHeise

[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: * 11561c01f7d5f1f92c2fb98db39ee5db34c7afab Azure:

[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: * 11561c01f7d5f1f92c2fb98db39ee5db34c7afab Azure:

  1   2   3   4   5   6   7   8   9   10   >