[GitHub] [flink] flinkbot commented on pull request #23454: [FLINK-33130]reuse source and sink operator io metrics for task

2023-09-22 Thread via GitHub
flinkbot commented on PR #23454: URL: https://github.com/apache/flink/pull/23454#issuecomment-1732220843 ## CI report: * 9e00500c1f72f6c9e88e90dc389063a6ebfeafa3 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Updated] (FLINK-33130) Don't show the sources and sinks io metrics correctly at flink webui

2023-09-22 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33130?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-33130: --- Labels: pull-request-available (was: ) > Don't show the sources and sinks io metrics correc

[GitHub] [flink] xbthink opened a new pull request, #23454: [FLINK-33130]reuse source and sink operator io metrics for task

2023-09-22 Thread via GitHub
xbthink opened a new pull request, #23454: URL: https://github.com/apache/flink/pull/23454 ## What is the purpose of the change Show sources and sinks io metrics(Bytes/Records) correctly at flink webui. ## Brief change log reuse source and sink operator io met

[jira] [Updated] (FLINK-33130) Don't show the sources and sinks io metrics correctly at flink webui

2023-09-22 Thread xiebin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33130?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xiebin updated FLINK-33130: --- Summary: Don't show the sources and sinks io metrics correctly at flink webui (was: Don't show the sources

[jira] [Updated] (FLINK-33130) Don't show the sources and sinks io metrics in flink webui

2023-09-22 Thread xiebin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33130?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xiebin updated FLINK-33130: --- Description: Now the sources and sinks io metrics(Bytes/Records) is not showed correctly at flink webui。  

[jira] [Updated] (FLINK-33130) Don't show the sources and sinks io metrics in flink webui

2023-09-22 Thread xiebin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33130?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xiebin updated FLINK-33130: --- Description: Now  > Don't show the sources and sinks io metrics in flink webui > ---

[jira] [Updated] (FLINK-33130) Don't show the sources and sinks io metrics in flink webui

2023-09-22 Thread xiebin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33130?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xiebin updated FLINK-33130: --- Priority: Minor (was: Major) > Don't show the sources and sinks io metrics in flink webui > ---

[jira] [Updated] (FLINK-33130) Don't show the sources and sinks io metrics in flink webui

2023-09-22 Thread xiebin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33130?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xiebin updated FLINK-33130: --- Summary: Don't show the sources and sinks io metrics in flink webui (was: Don't show the source and sink io

[jira] [Updated] (FLINK-33130) Don't show the source and sink io metrics in flink webui

2023-09-22 Thread xiebin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33130?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xiebin updated FLINK-33130: --- Summary: Don't show the source and sink io metrics in flink webui (was: Don't show the source and sink io m

[jira] [Updated] (FLINK-33130) Don't show the source and sink io metrics in flinkwebui

2023-09-22 Thread xiebin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33130?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xiebin updated FLINK-33130: --- Summary: Don't show the source and sink io metrics in flinkwebui (was: Source ans Sink) > Don't show the s

[jira] [Created] (FLINK-33130) Source ans Sink

2023-09-22 Thread xiebin (Jira)
xiebin created FLINK-33130: -- Summary: Source ans Sink Key: FLINK-33130 URL: https://issues.apache.org/jira/browse/FLINK-33130 Project: Flink Issue Type: Improvement Reporter: xiebin

[jira] [Commented] (FLINK-33129) Can't create RowDataToAvroConverter for LocalZonedTimestampType logical type

2023-09-22 Thread Zhaoyang Shao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33129?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17768195#comment-17768195 ] Zhaoyang Shao commented on FLINK-33129: --- [~danny0405] can you help take a look? as

[GitHub] [flink-connector-aws] hlteoh37 commented on a diff in pull request #94: [FLINK-33073][Connectors/AWS] Implement end-to-end tests for KinesisS…

2023-09-22 Thread via GitHub
hlteoh37 commented on code in PR #94: URL: https://github.com/apache/flink-connector-aws/pull/94#discussion_r1334871504 ## flink-connector-aws-e2e-tests/flink-connector-aws-kinesis-streams-e2e-tests/src/test/java/org/apache/flink/connector/kinesis/sink/KinesisStreamsSinkITCase.java: ##

[jira] [Updated] (FLINK-31951) Mix schema record source creates corrupt record

2023-09-22 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31951?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-31951: --- Labels: fix-provided pull-request-available stale-assigned (was: fix-provided pull-request-

[jira] [Updated] (FLINK-31825) Stopping minikube fails with timeout

2023-09-22 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31825?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-31825: --- Labels: stale-major test-stability (was: test-stability) I am the [Flink Jira Bot|https://g

[jira] [Commented] (FLINK-20767) [FLIP-356] Add nested field support for SupportsFilterPushDown

2023-09-22 Thread Venkata krishnan Sowrirajan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20767?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17768151#comment-17768151 ] Venkata krishnan Sowrirajan commented on FLINK-20767: - [~martijnviss

[jira] [Updated] (FLINK-33128) TestValuesRuntimeFunctions$TestValuesLookupFunction does not call open() on converter

2023-09-22 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33128?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-33128: --- Labels: pull-request-available (was: ) > TestValuesRuntimeFunctions$TestValuesLookupFunctio

[GitHub] [flink] flinkbot commented on pull request #23453: [FLINK-33128] Add converter.open() method call on TestValuesRuntimeFunctions

2023-09-22 Thread via GitHub
flinkbot commented on PR #23453: URL: https://github.com/apache/flink/pull/23453#issuecomment-1731976816 ## CI report: * 0532f0d9989ba0ad9f0952f3b3c59bf4c08bc2ba UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] jgagnon1 opened a new pull request, #23453: [FLINK-33218] Add converter.open() method on TestValuesRuntimeFunctions

2023-09-22 Thread via GitHub
jgagnon1 opened a new pull request, #23453: URL: https://github.com/apache/flink/pull/23453 ## What is the purpose of the change Make sure complex type such as `Array>` get converted property in TestValues connector when doing lookup joins. ## Brief change log - Added a

[jira] [Created] (FLINK-33129) Can't create RowDataToAvroConverter for LocalZonedTimestampType logical type

2023-09-22 Thread Zhaoyang Shao (Jira)
Zhaoyang Shao created FLINK-33129: - Summary: Can't create RowDataToAvroConverter for LocalZonedTimestampType logical type Key: FLINK-33129 URL: https://issues.apache.org/jira/browse/FLINK-33129 Projec

[GitHub] [flink-web] novakov-alexey commented on pull request #670: put more relevant link to the Scala wrapper

2023-09-22 Thread via GitHub
novakov-alexey commented on PR #670: URL: https://github.com/apache/flink-web/pull/670#issuecomment-1731729749 Hi @RyanSkraba, do you know what is blocking this PR to be merged? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub

[GitHub] [flink] flinkbot commented on pull request #23452: [FLINK-32884] [flink-clients] Sending messageHeaders with decorated customHeaders for PyFlink client

2023-09-22 Thread via GitHub
flinkbot commented on PR #23452: URL: https://github.com/apache/flink/pull/23452#issuecomment-1731485499 ## CI report: * 44f8e48e6ca37c2fcd91f52d7b01c2b3d109b038 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Updated] (FLINK-33128) TestValuesRuntimeFunctions$TestValuesLookupFunction does not call open() on converter

2023-09-22 Thread Jerome Gagnon (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33128?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jerome Gagnon updated FLINK-33128: -- Description: When using the TestValues connector with nested Row values relying on BinaryArra

[GitHub] [flink] elkhand opened a new pull request, #23452: [FLINK-32884] [flink-clients] Sending messageHeaders with decorated customHeaders for PyFlink client

2023-09-22 Thread via GitHub
elkhand opened a new pull request, #23452: URL: https://github.com/apache/flink/pull/23452 [FLINK-32884](https://issues.apache.org/jira/browse/FLINK-32884) PyFlink remote execution should support URLs with paths and https scheme ## What is the purpose of the change This PR hand

[jira] [Updated] (FLINK-33128) TestValuesRuntimeFunctions$TestValuesLookupFunction does not call open() on converter

2023-09-22 Thread Jerome Gagnon (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33128?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jerome Gagnon updated FLINK-33128: -- Fix Version/s: (was: 1.16.2) Description: When using the TestValues connector with n

[jira] [Created] (FLINK-33128) TestValuesRuntimeFunctions$TestValuesLookupFunction does not call open() on converter

2023-09-22 Thread Jerome Gagnon (Jira)
Jerome Gagnon created FLINK-33128: - Summary: TestValuesRuntimeFunctions$TestValuesLookupFunction does not call open() on converter Key: FLINK-33128 URL: https://issues.apache.org/jira/browse/FLINK-33128

[jira] [Reopened] (FLINK-32884) PyFlink remote execution should support URLs with paths and https scheme

2023-09-22 Thread Elkhan Dadashov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32884?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Elkhan Dadashov reopened FLINK-32884: - > PyFlink remote execution should support URLs with paths and https scheme > ---

[GitHub] [flink-web] RyanSkraba commented on pull request #671: [hotfix] Minor typos and polish for blog post

2023-09-22 Thread via GitHub
RyanSkraba commented on PR #671: URL: https://github.com/apache/flink-web/pull/671#issuecomment-1731374623 Hello! @elphastori / @dannycranmer Are these proofreading fixes welcome? I don't mind _not_ doing them, but it's not always clear if someone is looking at the PRs! -- This is an a

[jira] [Comment Edited] (FLINK-33018) GCP Pubsub PubSubConsumingTest.testStoppingConnectorWhenDeserializationSchemaIndicatesEndOfStream failed

2023-09-22 Thread Ryan Skraba (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33018?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17767976#comment-17767976 ] Ryan Skraba edited comment on FLINK-33018 at 9/22/23 12:10 PM: ---

[jira] [Commented] (FLINK-33018) GCP Pubsub PubSubConsumingTest.testStoppingConnectorWhenDeserializationSchemaIndicatesEndOfStream failed

2023-09-22 Thread Ryan Skraba (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33018?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17767976#comment-17767976 ] Ryan Skraba commented on FLINK-33018: - Hey [~jjayadeep], would you like to take a lo

[jira] [Resolved] (FLINK-33119) The pojo result returned be procedure should be Row of fields in the pojo instead of the whole pojo object

2023-09-22 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33119?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luoyuxia resolved FLINK-33119. -- Fix Version/s: 1.18.0 1.19.0 Resolution: Fixed > The pojo result returned be

[jira] [Comment Edited] (FLINK-33119) The pojo result returned be procedure should be Row of fields in the pojo instead of the whole pojo object

2023-09-22 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33119?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17767890#comment-17767890 ] luoyuxia edited comment on FLINK-33119 at 9/22/23 11:43 AM:

[GitHub] [flink] luoyuxia merged pull request #23438: [FLINK-33119][table] The pojo result returned be procedure should be Row of fields in the pojo instead of whole pojo object

2023-09-22 Thread via GitHub
luoyuxia merged PR #23438: URL: https://github.com/apache/flink/pull/23438 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: issues-unsubscr...@flink.apac

[jira] [Updated] (FLINK-16987) FLIP-95: Add new table source and sink interfaces

2023-09-22 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16987?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-16987: --- Labels: pull-request-available stale-major (was: pull-request-available) I am the [Flink Ji

[GitHub] [flink] X-czh commented on pull request #23447: [FLINK-31650][metrics][rest] Cleanup terminal subtask attempt metrics to avoid confusion caused by outdated metrics

2023-09-22 Thread via GitHub
X-czh commented on PR #23447: URL: https://github.com/apache/flink/pull/23447#issuecomment-1731133109 I previously thought it fine to completely remove metrics of terminal vertices, as the core I/O metrics displayed on the UI of terminal vertices are actually accessed via the metrics stored

[GitHub] [flink] X-czh commented on pull request #23447: [FLINK-31650][metrics][rest] Cleanup terminal subtask attempt metrics to avoid confusion caused by outdated metrics

2023-09-22 Thread via GitHub
X-czh commented on PR #23447: URL: https://github.com/apache/flink/pull/23447#issuecomment-1731130211 Hi @JunRuiLee, thanks for reviewing. +1 for the need to preserve some non-transient metrics like numRecordsIn and numRecordsOut after vertices reaching terminal state. I'll redesign to remo

[jira] [Commented] (FLINK-23860) Conversion to relational algebra failed to preserve datatypes

2023-09-22 Thread hehuiyuan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23860?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17767927#comment-17767927 ] hehuiyuan commented on FLINK-23860: --- [~jark]   > Conversion to relational algebra fai

[jira] [Commented] (FLINK-23860) Conversion to relational algebra failed to preserve datatypes

2023-09-22 Thread hehuiyuan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23860?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17767926#comment-17767926 ] hehuiyuan commented on FLINK-23860: --- +1 > Conversion to relational algebra failed to

[GitHub] [flink] gaborgsomogyi commented on pull request #23446: [FLINK-32976][runtime] Fix NullPointException when starting flink cluster in standalone mode

2023-09-22 Thread via GitHub
gaborgsomogyi commented on PR #23446: URL: https://github.com/apache/flink/pull/23446#issuecomment-1731055492 I think 1.18 would be enough. -- 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 spe

[jira] [Commented] (FLINK-33052) codespeed and benchmark server is down

2023-09-22 Thread Jing Ge (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17767898#comment-17767898 ] Jing Ge commented on FLINK-33052: - HI [~Zakelly], redirection should be doable. And I th

[jira] [Assigned] (FLINK-20767) [FLIP-356] Add nested field support for SupportsFilterPushDown

2023-09-22 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20767?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser reassigned FLINK-20767: -- Assignee: Venkata krishnan Sowrirajan > [FLIP-356] Add nested field support for Suppo

[jira] [Updated] (FLINK-20767) [FLIP-356] Add nested field support for SupportsFilterPushDown

2023-09-22 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20767?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-20767: --- Summary: [FLIP-356] Add nested field support for SupportsFilterPushDown (was: add nested fi

[jira] [Updated] (FLINK-20767) add nested field support for SupportsFilterPushDown

2023-09-22 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20767?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-20767: --- Parent: (was: FLINK-16987) Issue Type: Improvement (was: Sub-task) > add nested

[GitHub] [flink] JunRuiLee commented on pull request #23447: [FLINK-31650][metrics][rest] Cleanup terminal subtask attempt metrics to avoid confusion caused by outdated metrics

2023-09-22 Thread via GitHub
JunRuiLee commented on PR #23447: URL: https://github.com/apache/flink/pull/23447#issuecomment-1731028477 @X-czh Hi Zhanghao, thanks for your effort. After a quick review of your PR, if I understand correctly, your changes will remove all metrics from the operators in the terminal sta

[jira] [Commented] (FLINK-33119) The pojo result returned be procedure should be Row of fields in the pojo instead of the whole pojo object

2023-09-22 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33119?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17767890#comment-17767890 ] luoyuxia commented on FLINK-33119: -- 1.18: deb07e99560b45033a629afc3f90666ad0a32feb mas

[GitHub] [flink] luoyuxia merged pull request #23450: [FLINK-33119][table] The pojo result returned be procedure should be Row of fields in the pojo instead of whole pojo object

2023-09-22 Thread via GitHub
luoyuxia merged PR #23450: URL: https://github.com/apache/flink/pull/23450 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: issues-unsubscr...@flink.apac

[GitHub] [flink] luoyuxia commented on pull request #23438: [FLINK-33119][table] The pojo result returned be procedure should be Row of fields in the pojo instead of whole pojo object

2023-09-22 Thread via GitHub
luoyuxia commented on PR #23438: URL: https://github.com/apache/flink/pull/23438#issuecomment-1731015760 @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 specific comment.

[GitHub] [flink] flinkbot commented on pull request #23451: [FLINK-32108][test] KubernetesExtension calls assumeThat in @BeforeAll callback which doesn't print the actual failure message

2023-09-22 Thread via GitHub
flinkbot commented on PR #23451: URL: https://github.com/apache/flink/pull/23451#issuecomment-1730983884 ## CI report: * f20a6d84c61a482342d7f338ae3809d1f6d57c15 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Commented] (FLINK-32108) KubernetesExtension calls assumeThat in @BeforeAll callback which doesn't print the actual failure message

2023-09-22 Thread xiang1 yu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32108?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17767885#comment-17767885 ] xiang1 yu commented on FLINK-32108: ---  Hi [Matthias Pohl|https://issues.apache.org/jir

[jira] [Closed] (FLINK-32976) NullPointException when starting flink cluster in standalone mode

2023-09-22 Thread Gabor Somogyi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32976?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi closed FLINK-32976. - > NullPointException when starting flink cluster in standalone mode > --

[jira] [Resolved] (FLINK-32976) NullPointException when starting flink cluster in standalone mode

2023-09-22 Thread Gabor Somogyi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32976?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi resolved FLINK-32976. --- Fix Version/s: 1.19.0 Resolution: Fixed 1fb95c3 on master > NullPointException when

[GitHub] [flink] gaborgsomogyi merged pull request #23446: [FLINK-32976][runtime] Fix NullPointException when starting flink cluster in standalone mode

2023-09-22 Thread via GitHub
gaborgsomogyi merged PR #23446: URL: https://github.com/apache/flink/pull/23446 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: issues-unsubscr...@flink

[GitHub] [flink] victor9309 opened a new pull request, #23451: [FLINK-32108][test] KubernetesExtension calls assumeThat in @BeforeAll callback which doesn't print the actual failure message

2023-09-22 Thread via GitHub
victor9309 opened a new pull request, #23451: URL: https://github.com/apache/flink/pull/23451 ## What is the purpose of the change *KubernetesExtension implements BeforeAllCallback which calls the assumeThat in the @BeforeAll context. assumeThat doesn't work properly in the