[jira] [Comment Edited] (FLINK-33961) Hybrid Shuffle may hang when exclusive buffers per channel is set to 0

[ https://issues.apache.org/jira/browse/FLINK-33961?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17801669#comment-17801669 ] Weijie Guo edited comment on FLINK-33961 at 1/2/24 6:39 AM: [~Jiang Xin]

[jira] [Comment Edited] (FLINK-33961) Hybrid Shuffle may hang when exclusive buffers per channel is set to 0

[ https://issues.apache.org/jira/browse/FLINK-33961?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17801669#comment-17801669 ] Weijie Guo edited comment on FLINK-33961 at 1/2/24 6:38 AM: [~Jiang Xin]

[jira] [Commented] (FLINK-33961) Hybrid Shuffle may hang when exclusive buffers per channel is set to 0

[ https://issues.apache.org/jira/browse/FLINK-33961?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17801669#comment-17801669 ] Weijie Guo commented on FLINK-33961: Thanks for reporting this. Unfortunately, this issue can be

[jira] [Closed] (FLINK-33857) Expose BulkProcessor.flush via RequestIndexer to allow custom flush logic

[ https://issues.apache.org/jira/browse/FLINK-33857?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo closed FLINK-33857. -- Fix Version/s: elasticsearch-3.1.0 Resolution: Fixed main

[jira] [Closed] (FLINK-33635) Some connectors can not compile in 1.19-SNAPSHOT

[ https://issues.apache.org/jira/browse/FLINK-33635?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo closed FLINK-33635. -- Resolution: Fixed > Some connectors can not compile in 1.19-SNAPSHOT >

[jira] [Commented] (FLINK-33635) Some connectors can not compile in 1.19-SNAPSHOT

[ https://issues.apache.org/jira/browse/FLINK-33635?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17800229#comment-17800229 ] Weijie Guo commented on FLINK-33635: Yep, I have checked the nightly CI of ElasticSearch connector,

[jira] [Commented] (FLINK-32850) [JUnit5 Migration] The io package of flink-runtime module

[ https://issues.apache.org/jira/browse/FLINK-32850?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17799652#comment-17799652 ] Weijie Guo commented on FLINK-32850: master(1.19) via 462708228df253de09e0a002ee0f2bee94e701c5. >

[jira] [Closed] (FLINK-33502) HybridShuffleITCase caused a fatal error

[ https://issues.apache.org/jira/browse/FLINK-33502?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo closed FLINK-33502. -- Resolution: Fixed master(1.19) 593e443cd85962ffa512e26d1a900eccf5f705ca. Feel free to reopen it if

[jira] [Commented] (FLINK-33856) Add metrics to monitor the interaction performance between task and external storage system in the process of checkpoint making

[ https://issues.apache.org/jira/browse/FLINK-33856?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17799272#comment-17799272 ] Weijie Guo commented on FLINK-33856: Yep, it seems feasible. I have assigned this to you. Before you

[jira] [Assigned] (FLINK-33856) Add metrics to monitor the interaction performance between task and external storage system in the process of checkpoint making

[ https://issues.apache.org/jira/browse/FLINK-33856?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo reassigned FLINK-33856: -- Assignee: Jufang He > Add metrics to monitor the interaction performance between task and

[jira] [Comment Edited] (FLINK-33534) PipelineOptions.PARALLELISM_OVERRIDES is not picked up from jar submission request

[ https://issues.apache.org/jira/browse/FLINK-33534?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17798400#comment-17798400 ] Weijie Guo edited comment on FLINK-33534 at 12/20/23 3:55 AM: -- master(1.19)

[jira] [Closed] (FLINK-33534) PipelineOptions.PARALLELISM_OVERRIDES is not picked up from jar submission request

[ https://issues.apache.org/jira/browse/FLINK-33534?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo closed FLINK-33534. -- Fix Version/s: 1.19.0 Resolution: Fixed master(1.19) via

[jira] [Closed] (FLINK-32028) Error handling for the new Elasticsearch sink

[ https://issues.apache.org/jira/browse/FLINK-32028?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo closed FLINK-32028. -- Resolution: Fixed > Error handling for the new Elasticsearch sink >

[jira] [Commented] (FLINK-32028) Error handling for the new Elasticsearch sink

[ https://issues.apache.org/jira/browse/FLINK-32028?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17797103#comment-17797103 ] Weijie Guo commented on FLINK-32028: main via 40774fad0f4ecd1a0d104dcb339e6bb860b0a4bf. > Error

[jira] [Updated] (FLINK-32028) Error handling for the new Elasticsearch sink

[ https://issues.apache.org/jira/browse/FLINK-32028?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-32028: --- Fix Version/s: elasticsearch-3.1.0 > Error handling for the new Elasticsearch sink >

[jira] [Updated] (FLINK-32028) Error handling for the new Elasticsearch sink

[ https://issues.apache.org/jira/browse/FLINK-32028?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-32028: --- Affects Version/s: elasticsearch-3.0.0 (was: 1.16.1) > Error handling

[jira] [Closed] (FLINK-33714) Update documentation about the usage of RuntimeContext#getExecutionConfig

[ https://issues.apache.org/jira/browse/FLINK-33714?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo closed FLINK-33714. -- Resolution: Fixed master(1.19) via 3531998adad20f3904d1421a35a69fef44b2b69f. > Update documentation

[jira] [Updated] (FLINK-33714) Update documentation about the usage of RuntimeContext#getExecutionConfig

[ https://issues.apache.org/jira/browse/FLINK-33714?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-33714: --- Affects Version/s: 1.19.0 > Update documentation about the usage of

[jira] [Updated] (FLINK-33714) Update documentation about the usage of RuntimeContext#getExecutionConfig

[ https://issues.apache.org/jira/browse/FLINK-33714?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-33714: --- Fix Version/s: 1.19.0 > Update documentation about the usage of RuntimeContext#getExecutionConfig >

[jira] [Closed] (FLINK-33502) HybridShuffleITCase caused a fatal error

[ https://issues.apache.org/jira/browse/FLINK-33502?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo closed FLINK-33502. -- > HybridShuffleITCase caused a fatal error > > >

[jira] [Commented] (FLINK-33502) HybridShuffleITCase caused a fatal error

[ https://issues.apache.org/jira/browse/FLINK-33502?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17793578#comment-17793578 ] Weijie Guo commented on FLINK-33502: master(1.19) via 6db32a3374a3fdb34c47039c6240c3845a3e1e30. >

[jira] [Resolved] (FLINK-33502) HybridShuffleITCase caused a fatal error

[ https://issues.apache.org/jira/browse/FLINK-33502?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo resolved FLINK-33502. Resolution: Fixed > HybridShuffleITCase caused a fatal error >

[jira] [Reopened] (FLINK-25857) Add committer metrics to track the status of committables

[ https://issues.apache.org/jira/browse/FLINK-25857?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo reopened FLINK-25857: Re-open this per discuss in mail-list. > Add committer metrics to track the status of committables >

[jira] [Assigned] (FLINK-32028) Error handling for the new Elasticsearch sink

[ https://issues.apache.org/jira/browse/FLINK-32028?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo reassigned FLINK-32028: -- Assignee: Peter Schulz > Error handling for the new Elasticsearch sink >

[jira] [Commented] (FLINK-32028) Error handling for the new Elasticsearch sink

[ https://issues.apache.org/jira/browse/FLINK-32028?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17793492#comment-17793492 ] Weijie Guo commented on FLINK-32028: Thanks for taking this, I will take a look at this PR. > Error

[jira] [Updated] (FLINK-33750) Remove deprecated config options.

[ https://issues.apache.org/jira/browse/FLINK-33750?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-33750: --- Labels: 2.0-related (was: ) > Remove deprecated config options. >

[jira] [Assigned] (FLINK-33750) Remove deprecated config options.

[ https://issues.apache.org/jira/browse/FLINK-33750?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo reassigned FLINK-33750: -- Assignee: Junrui Li > Remove deprecated config options. > -

[jira] [Assigned] (FLINK-33749) Remove deprecated getter method in Configuration.

[ https://issues.apache.org/jira/browse/FLINK-33749?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo reassigned FLINK-33749: -- Assignee: Junrui Li > Remove deprecated getter method in Configuration. >

[jira] [Updated] (FLINK-33749) Remove deprecated getter method in Configuration.

[ https://issues.apache.org/jira/browse/FLINK-33749?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-33749: --- Labels: 2.0-related (was: ) > Remove deprecated getter method in Configuration. >

[jira] [Updated] (FLINK-7957) Add MetricGroup#getLogicalScope

[ https://issues.apache.org/jira/browse/FLINK-7957?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-7957: -- Labels: 2.0-related auto-deprioritized-minor auto-unassigned (was: auto-deprioritized-minor

[jira] [Updated] (FLINK-6053) Gauge should only take subclasses of Number, rather than everything

[ https://issues.apache.org/jira/browse/FLINK-6053?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-6053: -- Labels: 2.0-related pull-request-available (was: pull-request-available) > Gauge should only take

[jira] [Updated] (FLINK-32198) Enforce single maxExceptions query parameter

[ https://issues.apache.org/jira/browse/FLINK-32198?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-32198: --- Labels: 2.0-related pull-request-available (was: pull-request-available) > Enforce single

[jira] [Updated] (FLINK-14350) Introduce dedicated MetricScope

[ https://issues.apache.org/jira/browse/FLINK-14350?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-14350: --- Labels: 2.0-related auto-deprioritized-major auto-deprioritized-minor auto-unassigned

[jira] [Updated] (FLINK-15787) Upgrade REST API response to remove '-' from key names.

[ https://issues.apache.org/jira/browse/FLINK-15787?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-15787: --- Labels: 2.0-related auto-deprioritized-major auto-deprioritized-minor auto-unassigned (was:

[jira] [Updated] (FLINK-32688) Remove deprecated exception history fields

[ https://issues.apache.org/jira/browse/FLINK-32688?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-32688: --- Labels: 2.0-related (was: ) > Remove deprecated exception history fields >

[jira] [Updated] (FLINK-32597) Drop Yarn specific get rest endpoints

[ https://issues.apache.org/jira/browse/FLINK-32597?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-32597: --- Labels: 2.0-related (was: ) > Drop Yarn specific get rest endpoints >

[jira] [Updated] (FLINK-24078) Remove brackets around variables

[ https://issues.apache.org/jira/browse/FLINK-24078?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-24078: --- Labels: 2.0-related (was: ) > Remove brackets around variables >

[jira] [Updated] (FLINK-29863) Properly handle NaN/Infinity in OpenAPI spec

[ https://issues.apache.org/jira/browse/FLINK-29863?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-29863: --- Labels: 2.0-related (was: ) > Properly handle NaN/Infinity in OpenAPI spec >

[jira] [Commented] (FLINK-32684) Renaming AkkaOptions into PekkoOptions

[ https://issues.apache.org/jira/browse/FLINK-32684?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17793156#comment-17793156 ] Weijie Guo commented on FLINK-32684: I'm +1 for introducing {{PekkoOptions}} to deprecate old

[jira] [Updated] (FLINK-32684) Renaming AkkaOptions into PekkoOptions

[ https://issues.apache.org/jira/browse/FLINK-32684?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-32684: --- Labels: 2.0-related (was: ) > Renaming AkkaOptions into PekkoOptions >

[jira] [Updated] (FLINK-33677) Remove flink-conf.yaml from flink dist

[ https://issues.apache.org/jira/browse/FLINK-33677?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-33677: --- Labels: 2.0-related (was: ) > Remove flink-conf.yaml from flink dist >

[jira] [Updated] (FLINK-33678) Remove configuration getters/setters that return/set complex Java objects

[ https://issues.apache.org/jira/browse/FLINK-33678?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-33678: --- Labels: 2.0-related (was: ) > Remove configuration getters/setters that return/set complex Java

[jira] [Updated] (FLINK-32384) Remove deprecated configuration keys which violate YAML spec

[ https://issues.apache.org/jira/browse/FLINK-32384?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-32384: --- Labels: 2.0-related (was: ) > Remove deprecated configuration keys which violate YAML spec >

[jira] [Updated] (FLINK-14068) Use Java's Duration instead of Flink's Time

[ https://issues.apache.org/jira/browse/FLINK-14068?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-14068: --- Labels: 2.0-related (was: ) > Use Java's Duration instead of Flink's Time >

[jira] [Updated] (FLINK-33748) Remove legacy TableSource/TableSink API in 2.0

[ https://issues.apache.org/jira/browse/FLINK-33748?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-33748: --- Description: {{TableSource}} and {{TableSink}} already marked as deprecated in FLINK-19453, and can

[jira] [Updated] (FLINK-33748) Remove legacy TableSource/TableSink API in 2.0

[ https://issues.apache.org/jira/browse/FLINK-33748?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-33748: --- Labels: 2.0-related (was: ) > Remove legacy TableSource/TableSink API in 2.0 >

[jira] [Created] (FLINK-33748) Remove legacy TableSource/TableSink API in 2.0

Weijie Guo created FLINK-33748: -- Summary: Remove legacy TableSource/TableSink API in 2.0 Key: FLINK-33748 URL: https://issues.apache.org/jira/browse/FLINK-33748 Project: Flink Issue Type:

[jira] [Updated] (FLINK-33747) Remove Sink V1 API in 2.0

[ https://issues.apache.org/jira/browse/FLINK-33747?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-33747: --- Description: We have already mark sink v1 related API to `@deprecated` in 1.15. They can be removed

[jira] [Updated] (FLINK-33747) Remove Sink V1 API in 2.0

[ https://issues.apache.org/jira/browse/FLINK-33747?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-33747: --- Fix Version/s: 2.0.0 > Remove Sink V1 API in 2.0 > - > >

[jira] [Created] (FLINK-33747) Remove Sink V1 API in 2.0

Weijie Guo created FLINK-33747: -- Summary: Remove Sink V1 API in 2.0 Key: FLINK-33747 URL: https://issues.apache.org/jira/browse/FLINK-33747 Project: Flink Issue Type: Technical Debt

[jira] [Updated] (FLINK-33747) Remove Sink V1 API in 2.0

[ https://issues.apache.org/jira/browse/FLINK-33747?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-33747: --- Labels: 2.0-related (was: ) > Remove Sink V1 API in 2.0 > - > >

[jira] [Updated] (FLINK-29739) [FLIP-265] Deprecate and remove Scala API support

[ https://issues.apache.org/jira/browse/FLINK-29739?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-29739: --- Labels: 2.0-related (was: ) > [FLIP-265] Deprecate and remove Scala API support >

[jira] [Updated] (FLINK-29740) [FLIP-265] Deprecate all customer-facing Scala APIs

[ https://issues.apache.org/jira/browse/FLINK-29740?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-29740: --- Labels: 2.0-related pull-request-available (was: pull-request-available) > [FLIP-265] Deprecate

[jira] [Commented] (FLINK-33729) Events are getting lost when an exception occurs within a processing function

[ https://issues.apache.org/jira/browse/FLINK-33729?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17792758#comment-17792758 ] Weijie Guo commented on FLINK-33729: Thanks for reporting this! [~Tison] Could you help confirm this

[jira] [Reopened] (FLINK-33502) HybridShuffleITCase caused a fatal error

[ https://issues.apache.org/jira/browse/FLINK-33502?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo reopened FLINK-33502: > HybridShuffleITCase caused a fatal error > > >

[jira] [Updated] (FLINK-33297) FLIP-366: Support standard YAML for FLINK configuration

[ https://issues.apache.org/jira/browse/FLINK-33297?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-33297: --- Labels: 2.0-related pull-request-available (was: pull-request-available) > FLIP-366: Support

[jira] [Updated] (FLINK-33297) FLIP-366: Support standard YAML for FLINK configuration

[ https://issues.apache.org/jira/browse/FLINK-33297?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-33297: --- Fix Version/s: 1.19.0 > FLIP-366: Support standard YAML for FLINK configuration >

[jira] [Updated] (FLINK-23620) Introduce proper YAML parsing to Flink's configuration

[ https://issues.apache.org/jira/browse/FLINK-23620?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-23620: --- Labels: 2.0-related (was: pull-request-available stale-assigned) > Introduce proper YAML parsing

[jira] [Updated] (FLINK-32383) 2.0 Breaking configuration changes

[ https://issues.apache.org/jira/browse/FLINK-32383?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-32383: --- Labels: 2.0-related (was: ) > 2.0 Breaking configuration changes >

[jira] [Updated] (FLINK-4602) Move RocksDB backend to proper package

[ https://issues.apache.org/jira/browse/FLINK-4602?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-4602: -- Labels: 2.0-related auto-unassigned (was: auto-unassigned) > Move RocksDB backend to proper package >

[jira] [Updated] (FLINK-29741) [FLIP-265] Remove all Scala APIs

[ https://issues.apache.org/jira/browse/FLINK-29741?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-29741: --- Labels: 2.0-related (was: ) > [FLIP-265] Remove all Scala APIs >

[jira] [Updated] (FLINK-33669) Update the documentation for RestartStrategy, Checkpoint Storage, and State Backend.

[ https://issues.apache.org/jira/browse/FLINK-33669?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-33669: --- Affects Version/s: 1.19.0 > Update the documentation for RestartStrategy, Checkpoint Storage, and

[jira] [Assigned] (FLINK-33669) Update the documentation for RestartStrategy, Checkpoint Storage, and State Backend.

[ https://issues.apache.org/jira/browse/FLINK-33669?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo reassigned FLINK-33669: -- Assignee: Junrui Li > Update the documentation for RestartStrategy, Checkpoint Storage, and

[jira] [Commented] (FLINK-25857) Add committer metrics to track the status of committables

[ https://issues.apache.org/jira/browse/FLINK-25857?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17789988#comment-17789988 ] Weijie Guo commented on FLINK-25857: [~pvary], Well, sorry, I didn't realize we already had a FLIP

[jira] [Comment Edited] (FLINK-25857) Add committer metrics to track the status of committables

[ https://issues.apache.org/jira/browse/FLINK-25857?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17789356#comment-17789356 ] Weijie Guo edited comment on FLINK-25857 at 11/24/23 7:53 AM: -- Thanks

[jira] [Commented] (FLINK-25857) Add committer metrics to track the status of committables

[ https://issues.apache.org/jira/browse/FLINK-25857?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17789356#comment-17789356 ] Weijie Guo commented on FLINK-25857: Thanks [~pvary] for the quick reply! Yes, In principle, it is

[jira] [Commented] (FLINK-25857) Add committer metrics to track the status of committables

[ https://issues.apache.org/jira/browse/FLINK-25857?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17789304#comment-17789304 ] Weijie Guo commented on FLINK-25857: IIUC, this will cause our external connector sink to be unable

[jira] [Updated] (FLINK-33635) Some connectors can not compile in 1.19-SNAPSHOT

[ https://issues.apache.org/jira/browse/FLINK-33635?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-33635: --- Priority: Blocker (was: Major) > Some connectors can not compile in 1.19-SNAPSHOT >

[jira] [Updated] (FLINK-33635) Some connector can not compile in 1.19-SNAPSHOT

[ https://issues.apache.org/jira/browse/FLINK-33635?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-33635: --- Description: The sink API compatibility was broken in FLINK-25857.

[jira] [Updated] (FLINK-33635) Some connectors can not compile in 1.19-SNAPSHOT

[ https://issues.apache.org/jira/browse/FLINK-33635?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-33635: --- Summary: Some connectors can not compile in 1.19-SNAPSHOT (was: Some connector can not compile in

[jira] [Updated] (FLINK-33635) Some connector can not compile in 1.19-SNAPSHOT

[ https://issues.apache.org/jira/browse/FLINK-33635?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-33635: --- Component/s: Connectors / Common (was: Connectors / ElasticSearch) > Some

[jira] [Updated] (FLINK-33635) Some connector can not compile in 1.19-SNAPSHOT

[ https://issues.apache.org/jira/browse/FLINK-33635?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-33635: --- Summary: Some connector can not compile in 1.19-SNAPSHOT (was: Connector sink can not compile) >

[jira] [Updated] (FLINK-33635) Connector sink can not compile

[ https://issues.apache.org/jira/browse/FLINK-33635?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-33635: --- Summary: Connector sink can not compile (was: ElasticSearch connector main branch can not compile)

[jira] [Created] (FLINK-33635) ElasticSearch connector main branch can not compile

Weijie Guo created FLINK-33635: -- Summary: ElasticSearch connector main branch can not compile Key: FLINK-33635 URL: https://issues.apache.org/jira/browse/FLINK-33635 Project: Flink Issue Type:

[jira] [Closed] (FLINK-33184) HybridShuffleITCase fails with exception in resource cleanup of task Map on AZP

[ https://issues.apache.org/jira/browse/FLINK-33184?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo closed FLINK-33184. -- Resolution: Fixed > HybridShuffleITCase fails with exception in resource cleanup of task Map on >

[jira] [Commented] (FLINK-33184) HybridShuffleITCase fails with exception in resource cleanup of task Map on AZP

[ https://issues.apache.org/jira/browse/FLINK-33184?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17789293#comment-17789293 ] Weijie Guo commented on FLINK-33184: It sees that this code path(i.e. IllegalStateException: Leaking

[jira] [Closed] (FLINK-33370) Simplify validateAndParseHostsString in Elasticsearch connecter's configuration

[ https://issues.apache.org/jira/browse/FLINK-33370?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo closed FLINK-33370. -- Fix Version/s: elasticsearch-3.1.0 Resolution: Fixed main via

[jira] [Closed] (FLINK-33502) HybridShuffleITCase caused a fatal error

[ https://issues.apache.org/jira/browse/FLINK-33502?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo closed FLINK-33502. -- Assignee: Wencong Liu Resolution: Fixed master(1.19) via

[jira] [Updated] (FLINK-33502) HybridShuffleITCase caused a fatal error

[ https://issues.apache.org/jira/browse/FLINK-33502?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-33502: --- Fix Version/s: 1.19.0 > HybridShuffleITCase caused a fatal error >

[jira] [Commented] (FLINK-33582) Update flink-shaded version

[ https://issues.apache.org/jira/browse/FLINK-33582?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17788226#comment-17788226 ] Weijie Guo commented on FLINK-33582: release-1.16 via cef22667ae65fb6fda78f22a05a8ca91540af687. >

[jira] [Closed] (FLINK-33582) Update flink-shaded version

[ https://issues.apache.org/jira/browse/FLINK-33582?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo closed FLINK-33582. -- Resolution: Fixed > Update flink-shaded version > --- > >

[jira] [Updated] (FLINK-33582) Update flink-shaded version

[ https://issues.apache.org/jira/browse/FLINK-33582?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-33582: --- Fix Version/s: 1.17.3 > Update flink-shaded version > --- > >

[jira] [Commented] (FLINK-33445) Translate DataSet migration guideline to Chinese

[ https://issues.apache.org/jira/browse/FLINK-33445?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17785432#comment-17785432 ] Weijie Guo commented on FLINK-33445: master(1.19) via 753f542d175d03f8cb96b44b9afc6b0d3f1453e3. >

[jira] [Resolved] (FLINK-33445) Translate DataSet migration guideline to Chinese

[ https://issues.apache.org/jira/browse/FLINK-33445?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo resolved FLINK-33445. Resolution: Fixed > Translate DataSet migration guideline to Chinese >

[jira] [Closed] (FLINK-33445) Translate DataSet migration guideline to Chinese

[ https://issues.apache.org/jira/browse/FLINK-33445?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo closed FLINK-33445. -- > Translate DataSet migration guideline to Chinese > > >

[jira] [Closed] (FLINK-33493) Elasticsearch connector ElasticsearchWriterITCase test failed

[ https://issues.apache.org/jira/browse/FLINK-33493?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo closed FLINK-33493. -- > Elasticsearch connector ElasticsearchWriterITCase test failed >

[jira] [Resolved] (FLINK-33493) Elasticsearch connector ElasticsearchWriterITCase test failed

[ https://issues.apache.org/jira/browse/FLINK-33493?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo resolved FLINK-33493. Resolution: Fixed > Elasticsearch connector ElasticsearchWriterITCase test failed >

[jira] [Commented] (FLINK-33493) Elasticsearch connector ElasticsearchWriterITCase test failed

[ https://issues.apache.org/jira/browse/FLINK-33493?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17784683#comment-17784683 ] Weijie Guo commented on FLINK-33493: main via 161b615. > Elasticsearch connector

[jira] [Updated] (FLINK-33493) Elasticsearch connector ElasticsearchWriterITCase test failed

[ https://issues.apache.org/jira/browse/FLINK-33493?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-33493: --- Fix Version/s: elasticsearch-3.1.0 > Elasticsearch connector ElasticsearchWriterITCase test failed

[jira] [Assigned] (FLINK-33493) Elasticsearch connector ElasticsearchWriterITCase test failed

[ https://issues.apache.org/jira/browse/FLINK-33493?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo reassigned FLINK-33493: -- Assignee: Yuxin Tan > Elasticsearch connector ElasticsearchWriterITCase test failed >

[jira] [Closed] (FLINK-33323) HybridShuffleITCase fails with produced an uncaught exception in FatalExitExceptionHandler

[ https://issues.apache.org/jira/browse/FLINK-33323?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo closed FLINK-33323. -- Resolution: Fixed master(1.19) via cb3a69c967a978bf8e8bbe287e15113740a2766a. > HybridShuffleITCase

[jira] [Assigned] (FLINK-33323) HybridShuffleITCase fails with produced an uncaught exception in FatalExitExceptionHandler

[ https://issues.apache.org/jira/browse/FLINK-33323?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo reassigned FLINK-33323: -- Assignee: Wencong Liu > HybridShuffleITCase fails with produced an uncaught exception in >

[jira] [Comment Edited] (FLINK-33185) HybridShuffleITCase fails with TimeoutException: Pending slot request timed out in slot pool on AZP

[ https://issues.apache.org/jira/browse/FLINK-33185?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17776626#comment-17776626 ] Weijie Guo edited comment on FLINK-33185 at 10/18/23 12:05 PM: --- master via

[jira] [Closed] (FLINK-33185) HybridShuffleITCase fails with TimeoutException: Pending slot request timed out in slot pool on AZP

[ https://issues.apache.org/jira/browse/FLINK-33185?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo closed FLINK-33185. -- Fix Version/s: 1.19.0 Resolution: Fixed > HybridShuffleITCase fails with TimeoutException:

[jira] [Commented] (FLINK-33185) HybridShuffleITCase fails with TimeoutException: Pending slot request timed out in slot pool on AZP

[ https://issues.apache.org/jira/browse/FLINK-33185?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17776626#comment-17776626 ] Weijie Guo commented on FLINK-33185: master via 166aab3ac4d83b0078496b41483d469158332b91. Feel free

[jira] [Assigned] (FLINK-31262) Move kafka sql connector fat jar test to SmokeKafkaITCase

[ https://issues.apache.org/jira/browse/FLINK-31262?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo reassigned FLINK-31262: -- Assignee: (was: Weijie Guo) > Move kafka sql connector fat jar test to SmokeKafkaITCase

[jira] [Updated] (FLINK-33044) Reduce the frequency of triggering flush for the disk tier of the tiered storage

[ https://issues.apache.org/jira/browse/FLINK-33044?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-33044: --- Fix Version/s: 1.18.0 > Reduce the frequency of triggering flush for the disk tier of the tiered >

[jira] [Closed] (FLINK-33044) Reduce the frequency of triggering flush for the disk tier of the tiered storage

[ https://issues.apache.org/jira/browse/FLINK-33044?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo closed FLINK-33044. -- Resolution: Fixed > Reduce the frequency of triggering flush for the disk tier of the tiered >

[jira] [Comment Edited] (FLINK-33044) Reduce the frequency of triggering flush for the disk tier of the tiered storage

[ https://issues.apache.org/jira/browse/FLINK-33044?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17767089#comment-17767089 ] Weijie Guo edited comment on FLINK-33044 at 9/21/23 2:04 AM: - master(1.19)

[jira] [Updated] (FLINK-33044) Reduce the frequency of triggering flush for the disk tier of the tiered storage

[ https://issues.apache.org/jira/browse/FLINK-33044?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-33044: --- Fix Version/s: 1.19.0 > Reduce the frequency of triggering flush for the disk tier of the tiered >

<    1   2   3   4   5   6   7   8   9   10   >