[GitHub] [flink] flinkbot edited a comment on pull request #16496: [FLINK-23363][table-code-splitter] Java code splitter now supports functions with return statements

flinkbot edited a comment on pull request #16496: URL: https://github.com/apache/flink/pull/16496#issuecomment-880472433 ## CI report: * 2949703f5fc191dac349c1437dd70ce3d8863c64 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16530: [FLINK-23409][runtime] Add logs for FineGrainedSlotManager#checkResou…

flinkbot edited a comment on pull request #16530: URL: https://github.com/apache/flink/pull/16530#issuecomment-882207317 ## CI report: * ed632e41f1fd92b53282164ff9556d99d98061d7 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16525: [hotfix][table-api] Fix typo from Comparision to Comparison

flinkbot edited a comment on pull request #16525: URL: https://github.com/apache/flink/pull/16525#issuecomment-882003167 ## CI report: * 7ecdbf4b8c65b9f74575a18a436a9c9549ba6e47 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16496: [FLINK-23363][table-code-splitter] Java code splitter now supports functions with return statements

flinkbot edited a comment on pull request #16496: URL: https://github.com/apache/flink/pull/16496#issuecomment-880472433 ## CI report: * 2949703f5fc191dac349c1437dd70ce3d8863c64 Azure:

[GitHub] [flink] dianfu commented on a change in pull request #16516: [FLINK-23115][python] Expose new APIs about TableDescriptor in PyFlink

dianfu commented on a change in pull request #16516: URL: https://github.com/apache/flink/pull/16516#discussion_r671985396 ## File path: flink-python/pyflink/table/schema.py ## @@ -0,0 +1,265 @@ +

[jira] [Commented] (FLINK-23420) sql stream mode lag function java.lang.NullPointerException

[ https://issues.apache.org/jira/browse/FLINK-23420?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17383004#comment-17383004 ] Jingsong Lee commented on FLINK-23420: -- [~jark] Thanks for the reminding about state-compatibility.

[GitHub] [flink] flinkbot edited a comment on pull request #16525: [hotfix][table-api] Fix typo from Comparision to Comparison

flinkbot edited a comment on pull request #16525: URL: https://github.com/apache/flink/pull/16525#issuecomment-882003167 ## CI report: * 7ecdbf4b8c65b9f74575a18a436a9c9549ba6e47 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16020: [FLINK-21911][table-api] Add built-in greatest/least functions support #15821

flinkbot edited a comment on pull request #16020: URL: https://github.com/apache/flink/pull/16020#issuecomment-850341406 ## CI report: * 2a105bf903749c7cc6e4cd35e55a948f4b9bf535 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15501: [FLINK-22054][k8s] Using a shared watcher for ConfigMap watching

flinkbot edited a comment on pull request #15501: URL: https://github.com/apache/flink/pull/15501#issuecomment-814722337 ## CI report: * 4d82d3eea5137b32bd38dbaa3340af62906e3cd5 UNKNOWN * 65fc2e6abd18a5b5087e1e318a491202ded69940 UNKNOWN *

[GitHub] [flink] yiduwangkai closed pull request #16517: [FLINK-13400]Remove Hive and Hadoop dependencies from SQL Client

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

[GitHub] [flink] flinkbot edited a comment on pull request #16521: [FLINK-22715][runtime] Implement streaming window assigner tablefunction operator.

flinkbot edited a comment on pull request #16521: URL: https://github.com/apache/flink/pull/16521#issuecomment-881917566 ## CI report: * 8012684f2e1926a04e812579bfa001a82087e0f0 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16465: [FLINK-22910][runtime] Refine ShuffleMaster lifecycle management for pluggable shuffle service framework

flinkbot edited a comment on pull request #16465: URL: https://github.com/apache/flink/pull/16465#issuecomment-878076127 ## CI report: * 952176efe045c811f8648d2e97ad5149eb462975 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16020: [FLINK-21911][table-api] Add built-in greatest/least functions support #15821

flinkbot edited a comment on pull request #16020: URL: https://github.com/apache/flink/pull/16020#issuecomment-850341406 ## CI report: * 2a105bf903749c7cc6e4cd35e55a948f4b9bf535 Azure:

[jira] [Commented] (FLINK-23420) sql stream mode lag function java.lang.NullPointerException

[ https://issues.apache.org/jira/browse/FLINK-23420?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17382986#comment-17382986 ] Jark Wu commented on FLINK-23420: - [~lzljs3620320], usually, it's the responsibility of collection

[jira] [Updated] (FLINK-23420) sql stream mode lag function java.lang.NullPointerException

[ https://issues.apache.org/jira/browse/FLINK-23420?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-23420: - Priority: Critical (was: Major) > sql stream mode lag function java.lang.NullPointerException

[jira] [Updated] (FLINK-23420) sql stream mode lag function java.lang.NullPointerException

[ https://issues.apache.org/jira/browse/FLINK-23420?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-23420: - Component/s: (was: Table SQL / API) Table SQL / Runtime > sql stream mode

[GitHub] [flink] flinkbot edited a comment on pull request #16521: [FLINK-22715][runtime] Implement streaming window assigner tablefunction operator.

flinkbot edited a comment on pull request #16521: URL: https://github.com/apache/flink/pull/16521#issuecomment-881917566 ## CI report: * 8012684f2e1926a04e812579bfa001a82087e0f0 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16530: [FLINK-23409][runtime] Add logs for FineGrainedSlotManager#checkResou…

flinkbot edited a comment on pull request #16530: URL: https://github.com/apache/flink/pull/16530#issuecomment-882207317 ## CI report: * ed632e41f1fd92b53282164ff9556d99d98061d7 Azure:

[jira] [Commented] (FLINK-23420) sql stream mode lag function java.lang.NullPointerException

[ https://issues.apache.org/jira/browse/FLINK-23420?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17382976#comment-17382976 ] Jingsong Lee commented on FLINK-23420: -- LinkedListSerializer is OK, the problem is in

[GitHub] [flink] flinkbot edited a comment on pull request #16465: [FLINK-22910][runtime] Refine ShuffleMaster lifecycle management for pluggable shuffle service framework

flinkbot edited a comment on pull request #16465: URL: https://github.com/apache/flink/pull/16465#issuecomment-878076127 ## CI report: * 952176efe045c811f8648d2e97ad5149eb462975 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16368: ignore

flinkbot edited a comment on pull request #16368: URL: https://github.com/apache/flink/pull/16368#issuecomment-873854539 ## CI report: * 09c5d539521e36f0399c3660f2c676d53c494a73 Azure:

[jira] [Assigned] (FLINK-22672) Some enhancements for pluggable shuffle service framework

[ https://issues.apache.org/jira/browse/FLINK-22672?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu reassigned FLINK-22672: --- Assignee: Jin Xing > Some enhancements for pluggable shuffle service framework >

[GitHub] [flink] flinkbot commented on pull request #16530: [FLINK-23409][runtime] Add logs for FineGrainedSlotManager#checkResou…

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

[GitHub] [flink] flinkbot edited a comment on pull request #16521: [FLINK-22715][runtime] Implement streaming window assigner tablefunction operator.

flinkbot edited a comment on pull request #16521: URL: https://github.com/apache/flink/pull/16521#issuecomment-881917566 ## CI report: * 8012684f2e1926a04e812579bfa001a82087e0f0 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16516: [FLINK-23115][python] Expose new APIs about TableDescriptor in PyFlink

flinkbot edited a comment on pull request #16516: URL: https://github.com/apache/flink/pull/16516#issuecomment-881388489 ## CI report: * d1de6d708b5ff108968142549b0a9074a13834db Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16368: ignore

flinkbot edited a comment on pull request #16368: URL: https://github.com/apache/flink/pull/16368#issuecomment-873854539 ## CI report: * 09c5d539521e36f0399c3660f2c676d53c494a73 Azure:

[jira] [Updated] (FLINK-23420) sql stream mode lag function java.lang.NullPointerException

[ https://issues.apache.org/jira/browse/FLINK-23420?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xiechenling updated FLINK-23420: Description: flink 1.13.1  BlinkPlanner  StreamingMode  EXACTLY_ONCE log {code:java} 2021-07-15

[GitHub] [flink] jinxing64 commented on pull request #16118: [FLINK-22676][coordination] The partition tracker stops tracking internal partitions when TM disconnects

jinxing64 commented on pull request #16118: URL: https://github.com/apache/flink/pull/16118#issuecomment-882204044 Thanks for 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

[jira] [Assigned] (FLINK-23413) Port RelTimeIndicatorConverter from SCALA to JAVA

[ https://issues.apache.org/jira/browse/FLINK-23413?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he reassigned FLINK-23413: -- Assignee: JING ZHANG > Port RelTimeIndicatorConverter from SCALA to JAVA >

[GitHub] [flink] Tartarus0zm commented on pull request #16275: [FLINK-20518][rest] Add decoding characters for MessageQueryParameter

Tartarus0zm commented on pull request #16275: URL: https://github.com/apache/flink/pull/16275#issuecomment-882203724 > > Earlier you said that the requests are encoded 3 times; The UI does it once (does it?), and the RM does it (I assume) once. Any idea where the third one comes from?

[GitHub] [flink] Myasuka commented on a change in pull request #16447: [FLINK-23144][metrics] Add percentiles to checkpoint statistics

Myasuka commented on a change in pull request #16447: URL: https://github.com/apache/flink/pull/16447#discussion_r671960538 ## File path: flink-runtime-web/web-dashboard/src/app/pages/job/checkpoints/job-checkpoints.component.html ## @@ -193,15 +193,74 @@ {{

[GitHub] [flink] beyond1920 commented on pull request #16520: [FLINK-23413][table] Port RelTimeIndicatorConverter from SCALA to JAVA.

beyond1920 commented on pull request #16520: URL: https://github.com/apache/flink/pull/16520#issuecomment-882200385 @godfreyhe @twalthr Please have a look at the pr when you have time. -- This is an automated message from the Apache Git Service. To respond to the message, please log on

[jira] [Commented] (FLINK-23420) sql stream mode lag function java.lang.NullPointerException

[ https://issues.apache.org/jira/browse/FLINK-23420?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17382967#comment-17382967 ] Jark Wu commented on FLINK-23420: - It seems you hard-code to use the internal {{LinkedListSerializer}}

[GitHub] [flink] beyond1920 commented on pull request #16521: [FLINK-22715][runtime] Implement streaming window assigner tablefunction operator.

beyond1920 commented on pull request #16521: URL: https://github.com/apache/flink/pull/16521#issuecomment-882199668 @flinkbot run azure -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the

[jira] [Closed] (FLINK-22676) The partition tracker should support remote shuffle properly

[ https://issues.apache.org/jira/browse/FLINK-22676?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu closed FLINK-22676. --- Resolution: Done Done via 62a342b647fc1eac7f87769be92fda798649d6d4 > The partition tracker should support

[GitHub] [flink] zhuzhurk closed pull request #16118: [FLINK-22676][coordination] The partition tracker stops tracking internal partitions when TM disconnects

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

[GitHub] [flink] flinkbot edited a comment on pull request #16516: [FLINK-23115][python] Expose new APIs about TableDescriptor in PyFlink

flinkbot edited a comment on pull request #16516: URL: https://github.com/apache/flink/pull/16516#issuecomment-881388489 ## CI report: * d1de6d708b5ff108968142549b0a9074a13834db Azure:

[GitHub] [flink] RocMarshal commented on a change in pull request #16316: [FLINK-16090] Translate "Table API" page of "Table API & SQL" into Chinese

RocMarshal commented on a change in pull request #16316: URL: https://github.com/apache/flink/pull/16316#discussion_r671269448 ## File path: docs/content.zh/docs/dev/table/tableApi.md ## @@ -1016,8 +1018,8 @@ result = joined_table.select(joined_table.a, joined_table.b,

[GitHub] [flink] flinkbot commented on pull request #16530: [FLINK-23409][runtime] Add logs for FineGrainedSlotManager#checkResou…

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

[jira] [Updated] (FLINK-23409) CrossITCase fails with "NoResourceAvailableException: Slot request bulk is not fulfillable! Could not allocate the required slot within slot request timeout"

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

[GitHub] [flink] KarmaGYZ opened a new pull request #16530: [FLINK-23409][runtime] Add logs for FineGrainedSlotManager#checkResou…

KarmaGYZ opened a new pull request #16530: URL: https://github.com/apache/flink/pull/16530 …rceRequirements ## What is the purpose of the change *(For example: This pull request makes task deployment go through the blob server, rather than through RPC. That way we

[jira] [Updated] (FLINK-23421) Unify the space handling in RowData CSV parser

[ https://issues.apache.org/jira/browse/FLINK-23421?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-23421: Component/s: Formats (JSON, Avro, Parquet, ORC, SequenceFile) > Unify the space handling in RowData CSV

[jira] [Created] (FLINK-23421) Unify the space handling in RowData CSV parser

Dian Fu created FLINK-23421: --- Summary: Unify the space handling in RowData CSV parser Key: FLINK-23421 URL: https://issues.apache.org/jira/browse/FLINK-23421 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-20928) KafkaSourceReaderTest.testOffsetCommitOnCheckpointComplete:189->pollUntil:270 » Timeout

[ https://issues.apache.org/jira/browse/FLINK-20928?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17382960#comment-17382960 ] Xintong Song commented on FLINK-20928: --

[jira] [Commented] (FLINK-20329) Elasticsearch7DynamicSinkITCase hangs

[ https://issues.apache.org/jira/browse/FLINK-20329?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17382959#comment-17382959 ] Xintong Song commented on FLINK-20329: --

[GitHub] [flink] yljee commented on a change in pull request #16316: [FLINK-16090] Translate "Table API" page of "Table API & SQL" into Chinese

yljee commented on a change in pull request #16316: URL: https://github.com/apache/flink/pull/16316#discussion_r671948261 ## File path: docs/content.zh/docs/dev/table/tableApi.md ## @@ -728,16 +730,16 @@ result =

[jira] [Updated] (FLINK-23420) sql stream mode lag function java.lang.NullPointerException

[ https://issues.apache.org/jira/browse/FLINK-23420?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xiechenling updated FLINK-23420: Description: flink 1.13.1  BlinkPlanner  StreamingMode  EXACTLY_ONCE log {code:java} 2021-07-15

[jira] [Created] (FLINK-23420) sql stream mode lag function java.lang.NullPointerException

xiechenling created FLINK-23420: --- Summary: sql stream mode lag function java.lang.NullPointerException Key: FLINK-23420 URL: https://issues.apache.org/jira/browse/FLINK-23420 Project: Flink

[jira] [Assigned] (FLINK-23409) CrossITCase fails with "NoResourceAvailableException: Slot request bulk is not fulfillable! Could not allocate the required slot within slot request timeout"

[ https://issues.apache.org/jira/browse/FLINK-23409?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song reassigned FLINK-23409: Assignee: Yangze Guo > CrossITCase fails with "NoResourceAvailableException: Slot

[jira] [Commented] (FLINK-23409) CrossITCase fails with "NoResourceAvailableException: Slot request bulk is not fulfillable! Could not allocate the required slot within slot request timeout"

[ https://issues.apache.org/jira/browse/FLINK-23409?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17382958#comment-17382958 ] Xintong Song commented on FLINK-23409: -- This indeed looks like a problem of fine grained resource

[jira] [Commented] (FLINK-23409) CrossITCase fails with "NoResourceAvailableException: Slot request bulk is not fulfillable! Could not allocate the required slot within slot request timeout"

[ https://issues.apache.org/jira/browse/FLINK-23409?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17382956#comment-17382956 ] Yangze Guo commented on FLINK-23409: One possible cause is that something went wrong in calling the

[GitHub] [flink] jinxing64 commented on pull request #16118: [FLINK-22676][coordination] The partition tracker stops tracking internal partitions when TM disconnects

jinxing64 commented on pull request #16118: URL: https://github.com/apache/flink/pull/16118#issuecomment-882183134 Thanks @zhuzhurk for rebasing ~ please ping me to rebase for convenience next time :) -- This is an automated message from the Apache Git Service. To respond to the

[GitHub] [flink] leonardBang commented on a change in pull request #16519: [FLINK-23412][table][docs] - Description improvement of dynamic table sink and full stack example

leonardBang commented on a change in pull request #16519: URL: https://github.com/apache/flink/pull/16519#discussion_r671943009 ## File path: docs/content.zh/docs/dev/table/sourcesSinks.md ## @@ -334,8 +334,8 @@ a reference implementation. In particular, it shows how to -

[GitHub] [flink] fsk119 commented on pull request #16517: [FLINK-13400]Remove Hive and Hadoop dependencies from SQL Client

fsk119 commented on pull request #16517: URL: https://github.com/apache/flink/pull/16517#issuecomment-882176845 Hi, @yiduwangkai. Could you rebase your working branch to the master? There are some irrelevant commits. -- This is an automated message from the Apache Git Service. To

[GitHub] [flink] RollsBean commented on a change in pull request #16478: [FLINK-23228][docs-zh] Translate "Stateful Stream Processing" page into Chinese

RollsBean commented on a change in pull request #16478: URL: https://github.com/apache/flink/pull/16478#discussion_r671934533 ## File path: docs/content.zh/docs/concepts/stateful-stream-processing.md ## @@ -24,342 +24,227 @@ under the License. # 有状态流处理 -## What is State?

[GitHub] [flink] flinkbot edited a comment on pull request #15501: [FLINK-22054][k8s] Using a shared watcher for ConfigMap watching

flinkbot edited a comment on pull request #15501: URL: https://github.com/apache/flink/pull/15501#issuecomment-814722337 ## CI report: * 4d82d3eea5137b32bd38dbaa3340af62906e3cd5 UNKNOWN * 65fc2e6abd18a5b5087e1e318a491202ded69940 UNKNOWN *

[GitHub] [flink] flinkbot edited a comment on pull request #15501: [FLINK-22054][k8s] Using a shared watcher for ConfigMap watching

flinkbot edited a comment on pull request #15501: URL: https://github.com/apache/flink/pull/15501#issuecomment-814722337 ## CI report: * 4d82d3eea5137b32bd38dbaa3340af62906e3cd5 UNKNOWN * 65fc2e6abd18a5b5087e1e318a491202ded69940 UNKNOWN *

[GitHub] [flink] flinkbot edited a comment on pull request #16529: [hotfix][docs][hive] - Minor update to temporal join section

flinkbot edited a comment on pull request #16529: URL: https://github.com/apache/flink/pull/16529#issuecomment-882121220 ## CI report: * 51fab4a0b15ef339422a1c94d1ebfb028eda8775 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16529: [hotfix][docs][hive] - Minor update to temporal join section

flinkbot edited a comment on pull request #16529: URL: https://github.com/apache/flink/pull/16529#issuecomment-882121220 ## CI report: * 51fab4a0b15ef339422a1c94d1ebfb028eda8775 Azure:

[jira] [Commented] (FLINK-22545) JVM crashes when runing OperatorEventSendingCheckpointITCase.testOperatorEventAckLost

[ https://issues.apache.org/jira/browse/FLINK-22545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17382917#comment-17382917 ] Stephan Ewen commented on FLINK-22545: -- The stack trace looks like the executor is creating a

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

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

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

flinkbot commented on pull request #16529: URL: https://github.com/apache/flink/pull/16529#issuecomment-882118591 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] mans2singh opened a new pull request #16529: [hotfix][docs][hive] - Minor update to temporal join section

mans2singh opened a new pull request #16529: URL: https://github.com/apache/flink/pull/16529 ## What is the purpose of the change * Update to temporal join section docs for hive connector ## Brief change log * Update to temporal join section docs for hive connector

[GitHub] [flink] flinkbot edited a comment on pull request #16528: [FLINK-21367][connectors/jdbc] Support Object Reuse in JDBC sink

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

[GitHub] [flink] flinkbot edited a comment on pull request #16118: [FLINK-22676][coordination] The partition tracker stops tracking internal partitions when TM disconnects

flinkbot edited a comment on pull request #16118: URL: https://github.com/apache/flink/pull/16118#issuecomment-857430432 ## CI report: * bff840a95e38a1b9e24025d5eb2f4b5b5d83b5c2 UNKNOWN * 8885f7b99030d44186d1a0062b38e5e8a8bfa631 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15501: [FLINK-22054][k8s] Using a shared watcher for ConfigMap watching

flinkbot edited a comment on pull request #15501: URL: https://github.com/apache/flink/pull/15501#issuecomment-814722337 ## CI report: * 4d82d3eea5137b32bd38dbaa3340af62906e3cd5 UNKNOWN * 65fc2e6abd18a5b5087e1e318a491202ded69940 UNKNOWN *

[GitHub] [flink] hackergin commented on a change in pull request #16478: [FLINK-23228][docs-zh] Translate "Stateful Stream Processing" page into Chinese

hackergin commented on a change in pull request #16478: URL: https://github.com/apache/flink/pull/16478#discussion_r670706854 ## File path: docs/content.zh/docs/concepts/stateful-stream-processing.md ## @@ -24,342 +24,227 @@ under the License. # 有状态流处理 -## What is State?

[GitHub] [flink] flinkbot edited a comment on pull request #16118: [FLINK-22676][coordination] The partition tracker stops tracking internal partitions when TM disconnects

flinkbot edited a comment on pull request #16118: URL: https://github.com/apache/flink/pull/16118#issuecomment-857430432 ## CI report: * bff840a95e38a1b9e24025d5eb2f4b5b5d83b5c2 UNKNOWN * d09945fdf6f4292d87ce867b9b9832e2a71457bd Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16528: [FLINK-21367][connectors/jdbc] Support Object Reuse in JDBC sink

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

[GitHub] [flink] flinkbot edited a comment on pull request #16118: [FLINK-22676][coordination] The partition tracker stops tracking internal partitions when TM disconnects

flinkbot edited a comment on pull request #16118: URL: https://github.com/apache/flink/pull/16118#issuecomment-857430432 ## CI report: * bff840a95e38a1b9e24025d5eb2f4b5b5d83b5c2 UNKNOWN * d09945fdf6f4292d87ce867b9b9832e2a71457bd Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15501: [FLINK-22054][k8s] Using a shared watcher for ConfigMap watching

flinkbot edited a comment on pull request #15501: URL: https://github.com/apache/flink/pull/15501#issuecomment-814722337 ## CI report: * 4d82d3eea5137b32bd38dbaa3340af62906e3cd5 UNKNOWN * 65fc2e6abd18a5b5087e1e318a491202ded69940 UNKNOWN *

[GitHub] [flink] flinkbot commented on pull request #16528: [FLINK-21367][connectors/jdbc] Support Object Reuse in JDBC sink

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

[GitHub] [flink] flinkbot edited a comment on pull request #15501: [FLINK-22054][k8s] Using a shared watcher for ConfigMap watching

flinkbot edited a comment on pull request #15501: URL: https://github.com/apache/flink/pull/15501#issuecomment-814722337 ## CI report: * 4d82d3eea5137b32bd38dbaa3340af62906e3cd5 UNKNOWN * 65fc2e6abd18a5b5087e1e318a491202ded69940 UNKNOWN *

[GitHub] [flink] zhuzhurk commented on pull request #16118: [FLINK-22676][coordination] The partition tracker stops tracking internal partitions when TM disconnects

zhuzhurk commented on pull request #16118: URL: https://github.com/apache/flink/pull/16118#issuecomment-882084717 Rebased onto latest master because the PR base was a bit too old. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to

[jira] [Commented] (FLINK-23136) Make `addSource` method with specific boundedness in `StreamExecutionEnvironment` public

[ https://issues.apache.org/jira/browse/FLINK-23136?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17382861#comment-17382861 ] Eduardo Winpenny Tejedor commented on FLINK-23136: -- This one seems pretty

[jira] [Updated] (FLINK-22676) The partition tracker should support remote shuffle properly

[ https://issues.apache.org/jira/browse/FLINK-22676?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-22676: Affects Version/s: (was: 1.4) 1.14.0 > The partition tracker should support

[jira] [Updated] (FLINK-22676) The partition tracker should support remote shuffle properly

[ https://issues.apache.org/jira/browse/FLINK-22676?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-22676: Fix Version/s: 1.14.0 > The partition tracker should support remote shuffle properly >

[jira] [Assigned] (FLINK-22676) The partition tracker should support remote shuffle properly

[ https://issues.apache.org/jira/browse/FLINK-22676?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu reassigned FLINK-22676: --- Assignee: Jin Xing > The partition tracker should support remote shuffle properly >

[jira] [Updated] (FLINK-22676) The partition tracker should support remote shuffle properly

[ https://issues.apache.org/jira/browse/FLINK-22676?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-22676: Affects Version/s: 1.4 > The partition tracker should support remote shuffle properly >

[GitHub] [flink] flinkbot edited a comment on pull request #16521: [FLINK-22715][runtime] Implement streaming window assigner tablefunction operator.

flinkbot edited a comment on pull request #16521: URL: https://github.com/apache/flink/pull/16521#issuecomment-881917566 ## CI report: * 8012684f2e1926a04e812579bfa001a82087e0f0 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16515: [FLINK-23369][core][docs] Mechanism to document enums used in ConfigOptions

flinkbot edited a comment on pull request #16515: URL: https://github.com/apache/flink/pull/16515#issuecomment-881388403 ## CI report: * 6c47b8eea1556968e903b9c51d9bea4d5732828b UNKNOWN * a1c1dbf9196ce9a2bc5750f98be09bedc9d74e28 UNKNOWN *

[GitHub] [flink] flinkbot edited a comment on pull request #15501: [FLINK-22054][k8s] Using a shared watcher for ConfigMap watching

flinkbot edited a comment on pull request #15501: URL: https://github.com/apache/flink/pull/15501#issuecomment-814722337 ## CI report: * 4d82d3eea5137b32bd38dbaa3340af62906e3cd5 UNKNOWN * 65fc2e6abd18a5b5087e1e318a491202ded69940 UNKNOWN *

[GitHub] [flink] flinkbot commented on pull request #16528: [FLINK-21367][connectors/jdbc] Support Object Reuse in JDBC sink

flinkbot commented on pull request #16528: URL: https://github.com/apache/flink/pull/16528#issuecomment-882082072 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] rkhachatryan commented on pull request #15173: [FLINK-21367][Connectors / JDBC] Support objectReuse in JDBC sink

rkhachatryan commented on pull request #15173: URL: https://github.com/apache/flink/pull/15173#issuecomment-882080147 Hi @Bruschkov, I've implemented the test in #16528 and also added some refactorings (to the existing code). Please let me know if you have any concerns about these PRs.

[GitHub] [flink] rkhachatryan opened a new pull request #16528: [FLINK-21367][connectors/jdbc] Support Object Reuse in JDBC sink

rkhachatryan opened a new pull request #16528: URL: https://github.com/apache/flink/pull/16528 ## What is the purpose of the change Updated version of #15173 which added support for object reuse in JDBC sinks. This version adds: - preliminary refactorings (merging of

[GitHub] [flink] flinkbot edited a comment on pull request #15501: [FLINK-22054][k8s] Using a shared watcher for ConfigMap watching

flinkbot edited a comment on pull request #15501: URL: https://github.com/apache/flink/pull/15501#issuecomment-814722337 ## CI report: * 4d82d3eea5137b32bd38dbaa3340af62906e3cd5 UNKNOWN * 4910bd72167aa111a04ad1604158ddf5933c8eb8 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15501: [FLINK-22054][k8s] Using a shared watcher for ConfigMap watching

flinkbot edited a comment on pull request #15501: URL: https://github.com/apache/flink/pull/15501#issuecomment-814722337 ## CI report: * 4d82d3eea5137b32bd38dbaa3340af62906e3cd5 UNKNOWN * 29789133bd3b1e230b1070800859c398ab176f50 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16527: Fix typo `TAble` -> `Table`

flinkbot edited a comment on pull request #16527: URL: https://github.com/apache/flink/pull/16527#issuecomment-882051041 ## CI report: * b769206cf8cbf8482454af0be135342c7d2cfc64 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15501: [FLINK-22054][k8s] Using a shared watcher for ConfigMap watching

flinkbot edited a comment on pull request #15501: URL: https://github.com/apache/flink/pull/15501#issuecomment-814722337 ## CI report: * 4d82d3eea5137b32bd38dbaa3340af62906e3cd5 UNKNOWN * 29789133bd3b1e230b1070800859c398ab176f50 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15501: [FLINK-22054][k8s] Using a shared watcher for ConfigMap watching

flinkbot edited a comment on pull request #15501: URL: https://github.com/apache/flink/pull/15501#issuecomment-814722337 ## CI report: * 4d82d3eea5137b32bd38dbaa3340af62906e3cd5 UNKNOWN * 29789133bd3b1e230b1070800859c398ab176f50 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16527: Fix typo `TAble` -> `Table`

flinkbot edited a comment on pull request #16527: URL: https://github.com/apache/flink/pull/16527#issuecomment-882051041 ## CI report: * b769206cf8cbf8482454af0be135342c7d2cfc64 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16519: [FLINK-23412][table][docs] - Description improvement of dynamic table sink and full stack example

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

[GitHub] [flink] flinkbot edited a comment on pull request #16521: [FLINK-22715][runtime] Implement streaming window assigner tablefunction operator.

flinkbot edited a comment on pull request #16521: URL: https://github.com/apache/flink/pull/16521#issuecomment-881917566 ## CI report: * ee6204c9efe35c76c6bb59d478090710c1f0108d Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15501: [FLINK-22054][k8s] Using a shared watcher for ConfigMap watching

flinkbot edited a comment on pull request #15501: URL: https://github.com/apache/flink/pull/15501#issuecomment-814722337 ## CI report: * 4d82d3eea5137b32bd38dbaa3340af62906e3cd5 UNKNOWN * 29789133bd3b1e230b1070800859c398ab176f50 Azure:

[GitHub] [flink] flinkbot commented on pull request #16527: Fix typo `TAble` -> `Table`

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

[GitHub] [flink] flinkbot edited a comment on pull request #16521: [FLINK-22715][runtime] Implement streaming window assigner tablefunction operator.

flinkbot edited a comment on pull request #16521: URL: https://github.com/apache/flink/pull/16521#issuecomment-881917566 ## CI report: * ee6204c9efe35c76c6bb59d478090710c1f0108d Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16526: [FLINK-12415][doc-zh]Translate HistoryServer page into Chinese

flinkbot edited a comment on pull request #16526: URL: https://github.com/apache/flink/pull/16526#issuecomment-882041209 ## CI report: * 74612c69463f600f548de6888a046bcae4b50f9f Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16515: [FLINK-23369][core][docs] Mechanism to document enums used in ConfigOptions

flinkbot edited a comment on pull request #16515: URL: https://github.com/apache/flink/pull/16515#issuecomment-881388403 ## CI report: * 6c47b8eea1556968e903b9c51d9bea4d5732828b UNKNOWN * 7991fd26d867a56eac6f1dc5f8ff525e69a39b3b Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16458: [FLINK-22889][tests] Improve logging in JdbcExactlyOnceSinkE2eTest

flinkbot edited a comment on pull request #16458: URL: https://github.com/apache/flink/pull/16458#issuecomment-877915883 ## CI report: * 41ea37275cf5ef44f312fd89c5a014ddfa8160a0 UNKNOWN * 3d984e9cf9cf8989c9784f04fd473845d7cc6c75 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15501: [FLINK-22054][k8s] Using a shared watcher for ConfigMap watching

flinkbot edited a comment on pull request #15501: URL: https://github.com/apache/flink/pull/15501#issuecomment-814722337 ## CI report: * 4d82d3eea5137b32bd38dbaa3340af62906e3cd5 UNKNOWN * 29789133bd3b1e230b1070800859c398ab176f50 Azure:

  1   2   >