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`
[
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
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
[
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
[
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。
[
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
> ---
[
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
> ---
[
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
[
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
[
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
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
[
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
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:
##
[
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-
[
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
[
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
[
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
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`
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
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
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
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`
[
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
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
[
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
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
[
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
> ---
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
[
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:
---
[
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
[
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
[
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:
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
[
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
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
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
[
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
[
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
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
[
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
[
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
[
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
[
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
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
[
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
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
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.
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`
[
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
[
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
> --
[
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
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
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
53 matches
Mail list logo