[
https://issues.apache.org/jira/browse/FLINK-26033?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17489327#comment-17489327
]
Martijn Visser commented on FLINK-26033:
[~renqs] What are your thoughts on this?
> In
flinkbot commented on pull request #18676:
URL: https://github.com/apache/flink/pull/18676#issuecomment-1033442314
## CI report:
* dad0e032399b3b422d20e018161c0030ca84d08e UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot
[
https://issues.apache.org/jira/browse/FLINK-18356?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17489321#comment-17489321
]
Yun Gao commented on FLINK-18356:
-
Hi [~dmvk]~ do we have already had jira issue for the aws thread
flinkbot commented on pull request #18677:
URL: https://github.com/apache/flink/pull/18677#issuecomment-1033455918
--
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
flinkbot edited a comment on pull request #18676:
URL: https://github.com/apache/flink/pull/18676#issuecomment-1033442314
## CI report:
* dad0e032399b3b422d20e018161c0030ca84d08e Azure:
flinkbot edited a comment on pull request #18675:
URL: https://github.com/apache/flink/pull/18675#issuecomment-1033442210
## CI report:
* d13e6f599e562fb155120cbc60f9a4a983356f2e Azure:
[
https://issues.apache.org/jira/browse/FLINK-26036?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17489320#comment-17489320
]
Yun Gao commented on FLINK-26036:
-
flinkbot edited a comment on pull request #18531:
URL: https://github.com/apache/flink/pull/18531#issuecomment-1022985542
## CI report:
* 2952a6c6af10494f1ad1f30c18ac3cbc39693330 Azure:
flinkbot edited a comment on pull request #18434:
URL: https://github.com/apache/flink/pull/18434#issuecomment-1018078894
## CI report:
* 9cb1fddc375c0b7583b529ebd83faa0ee700a983 Azure:
Yun Gao created FLINK-26040:
---
Summary: PrometheusReporterEndToEndITCase hang on azure pipeline
Key: FLINK-26040
URL: https://issues.apache.org/jira/browse/FLINK-26040
Project: Flink
Issue Type:
Han created FLINK-26039:
---
Summary: Incorrect value getter in map unnest table function
Key: FLINK-26039
URL: https://issues.apache.org/jira/browse/FLINK-26039
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-26032?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-26032:
---
Labels: pull-request-available (was: )
> log job info in the ContextEnvironment
>
[
https://issues.apache.org/jira/browse/FLINK-26036?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17489317#comment-17489317
]
Yun Gao commented on FLINK-26036:
-
Perhaps cc [~trohrmann]~
>
JingGe opened a new pull request #18677:
URL: https://github.com/apache/flink/pull/18677
## What is the purpose of the change
Add log info for ContextEnvironment.
## Brief change log
- Add log info of job submission
- Add log info of job execution result
[
https://issues.apache.org/jira/browse/FLINK-26038?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yufan Sheng updated FLINK-26038:
Description: A delayed message is a type of message that would be sent to
the consumer after
[
https://issues.apache.org/jira/browse/FLINK-25233?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17489316#comment-17489316
]
Yun Gao commented on FLINK-25233:
-
[
https://issues.apache.org/jira/browse/FLINK-26038?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yufan Sheng updated FLINK-26038:
Summary: Support delay message on PulsarSink (was: Support delay message
on Pulsar sink)
>
[
https://issues.apache.org/jira/browse/FLINK-26036?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17489315#comment-17489315
]
Yangze Guo commented on FLINK-26036:
KarmaGYZ commented on pull request #18434:
URL: https://github.com/apache/flink/pull/18434#issuecomment-1033442692
@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
flinkbot commented on pull request #18676:
URL: https://github.com/apache/flink/pull/18676#issuecomment-1033442771
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
flinkbot commented on pull request #18675:
URL: https://github.com/apache/flink/pull/18675#issuecomment-1033442795
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
[
https://issues.apache.org/jira/browse/FLINK-25940?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17489314#comment-17489314
]
Yun Gao commented on FLINK-25940:
-
Yufan Sheng created FLINK-26038:
---
Summary: Support delay message on Pulsar sink
Key: FLINK-26038
URL: https://issues.apache.org/jira/browse/FLINK-26038
Project: Flink
Issue Type: Sub-task
flinkbot commented on pull request #18675:
URL: https://github.com/apache/flink/pull/18675#issuecomment-1033442210
## CI report:
* d13e6f599e562fb155120cbc60f9a4a983356f2e UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot
flinkbot edited a comment on pull request #18672:
URL: https://github.com/apache/flink/pull/18672#issuecomment-1033272608
## CI report:
* 154cd56e0f3298e2190cffe947e2f283f5c7d2ec Azure:
[
https://issues.apache.org/jira/browse/FLINK-26036?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17489312#comment-17489312
]
Yun Gao commented on FLINK-26036:
-
flinkbot edited a comment on pull request #18531:
URL: https://github.com/apache/flink/pull/18531#issuecomment-1022985542
## CI report:
* 2952a6c6af10494f1ad1f30c18ac3cbc39693330 Azure:
[
https://issues.apache.org/jira/browse/FLINK-25825?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17489311#comment-17489311
]
Yun Gao commented on FLINK-25825:
-
[
https://issues.apache.org/jira/browse/FLINK-26036?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17489310#comment-17489310
]
Yun Gao commented on FLINK-26036:
-
[
https://issues.apache.org/jira/browse/FLINK-25937?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17489308#comment-17489308
]
Yun Gao commented on FLINK-25937:
-
SQL Client end-to-end test:
[
https://issues.apache.org/jira/browse/FLINK-26036?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Gao updated FLINK-26036:
Priority: Critical (was: Major)
>
Yun Gao created FLINK-26037:
---
Summary: TaskManagerRunnerTest JVM crash with exit code 239
Key: FLINK-26037
URL: https://issues.apache.org/jira/browse/FLINK-26037
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-26035?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-26035:
---
Labels: pull-request-available (was: )
> Rework loader-bundle into separate module
>
[
https://issues.apache.org/jira/browse/FLINK-25491?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-25491:
---
Labels: pull-request-available (was: )
> Code generation: init method exceeds 64 KB when
zentol opened a new pull request #18676:
URL: https://github.com/apache/flink/pull/18676
The flink-table-planner currently creates 2 artifacts. 1 jar containing the
planner and various dependencies for the cases where the planner is used
directly, and another jar that additionally
tsreaper opened a new pull request #18675:
URL: https://github.com/apache/flink/pull/18675
## What is the purpose of the change
Although we've introduced a dedicated code splitter module in FLINK-23007
there are still some corner cases. For example, current code splitter cannot
Yun Gao created FLINK-26036:
---
Summary:
LocalRecoveryITCase.testRecoverLocallyFromProcessCrashWithWorkingDirectory
timeout on azure
Key: FLINK-26036
URL: https://issues.apache.org/jira/browse/FLINK-26036
Chesnay Schepler created FLINK-26035:
Summary: Rework loader-bundle into separate module
Key: FLINK-26035
URL: https://issues.apache.org/jira/browse/FLINK-26035
Project: Flink
Issue
flinkbot edited a comment on pull request #18603:
URL: https://github.com/apache/flink/pull/18603#issuecomment-1027853740
## CI report:
* 8b6adf5e05234f15048390cae6f97355d286944d Azure:
flinkbot edited a comment on pull request #18531:
URL: https://github.com/apache/flink/pull/18531#issuecomment-1022985542
## CI report:
* 2952a6c6af10494f1ad1f30c18ac3cbc39693330 Azure:
[
https://issues.apache.org/jira/browse/FLINK-26027?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser reassigned FLINK-26027:
--
Assignee: Yufei Zhang
> Add FLIP-33 metrics to new PulsarSink
>
[
https://issues.apache.org/jira/browse/FLINK-26028?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser reassigned FLINK-26028:
--
Assignee: Yufei Zhang
> Write documentation for new PulsarSink
>
[
https://issues.apache.org/jira/browse/FLINK-26027?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser reassigned FLINK-26027:
--
Assignee: (was: Yufei Gu)
> Add FLIP-33 metrics to new PulsarSink
>
[
https://issues.apache.org/jira/browse/FLINK-26022?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser reassigned FLINK-26022:
--
Assignee: Yufan Sheng
> Implement at-least-once and exactly-once Pulsar Sink
>
[
https://issues.apache.org/jira/browse/FLINK-26027?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser reassigned FLINK-26027:
--
Assignee: Yufei Gu
> Add FLIP-33 metrics to new PulsarSink
>
[
https://issues.apache.org/jira/browse/FLINK-26025?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser reassigned FLINK-26025:
--
Assignee: Yufan Sheng
> Replace MockPulsar with new Pulsar test tools based on
[
https://issues.apache.org/jira/browse/FLINK-26024?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser reassigned FLINK-26024:
--
Assignee: Yufan Sheng
> Create a PulsarSerializationSchema for better records
[
https://issues.apache.org/jira/browse/FLINK-26026?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser reassigned FLINK-26026:
--
Assignee: Yufan Sheng
> Test FLIP-191 PulsarSink
>
>
>
[
https://issues.apache.org/jira/browse/FLINK-26023?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser reassigned FLINK-26023:
--
Assignee: Yufan Sheng
> Create a Pulsar sink config model for matching
flinkbot edited a comment on pull request #18658:
URL: https://github.com/apache/flink/pull/18658#issuecomment-1032365173
## CI report:
* 753ba1b6b5423fd899393f243ac7ab35587aa91c Azure:
[
https://issues.apache.org/jira/browse/FLINK-26021?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser reassigned FLINK-26021:
--
Assignee: Yufan Sheng
> Pulsar topic deduplicated in both sink and source connector
[
https://issues.apache.org/jira/browse/FLINK-26030?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17489303#comment-17489303
]
Yang Wang commented on FLINK-26030:
---
{{ClusterEntrypointUtils#tryFindUserLibDirectory}} will return a
[
https://issues.apache.org/jira/browse/FLINK-26020?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser reassigned FLINK-26020:
--
Assignee: Yufan Sheng
> Unified Pulsar Connector config model
>
flinkbot edited a comment on pull request #18531:
URL: https://github.com/apache/flink/pull/18531#issuecomment-1022985542
## CI report:
* 2952a6c6af10494f1ad1f30c18ac3cbc39693330 Azure:
flinkbot edited a comment on pull request #18360:
URL: https://github.com/apache/flink/pull/18360#issuecomment-1012981724
## CI report:
* c6b8f500af6adadfa82d1ee404e18c6ec78ece04 Azure:
gaoyunhaii commented on pull request #18642:
URL: https://github.com/apache/flink/pull/18642#issuecomment-1033434323
Thanks @pltbkd for the updating! LGTM.
For the fix I think it could be put as a hot fix in a separate commit in
this PR. I'll change it when merging.
--
This is
flinkbot edited a comment on pull request #18658:
URL: https://github.com/apache/flink/pull/18658#issuecomment-1032365173
## CI report:
* 753ba1b6b5423fd899393f243ac7ab35587aa91c Azure:
flinkbot edited a comment on pull request #18657:
URL: https://github.com/apache/flink/pull/18657#issuecomment-1032365045
## CI report:
* c3a56aca00474d59d326645d489dc5fccb67f2ad Azure:
flinkbot edited a comment on pull request #18531:
URL: https://github.com/apache/flink/pull/18531#issuecomment-1022985542
## CI report:
* 2952a6c6af10494f1ad1f30c18ac3cbc39693330 Azure:
flinkbot edited a comment on pull request #18531:
URL: https://github.com/apache/flink/pull/18531#issuecomment-1022985542
## CI report:
* 2952a6c6af10494f1ad1f30c18ac3cbc39693330 Azure:
flinkbot edited a comment on pull request #18669:
URL: https://github.com/apache/flink/pull/18669#issuecomment-1033040800
## CI report:
* d025b76c02f35a4c6e56311a7dfed49b5d0dc9d6 Azure:
flinkbot edited a comment on pull request #18531:
URL: https://github.com/apache/flink/pull/18531#issuecomment-1022985542
## CI report:
* 2952a6c6af10494f1ad1f30c18ac3cbc39693330 Azure:
flinkbot edited a comment on pull request #17452:
URL: https://github.com/apache/flink/pull/17452#issuecomment-940136217
## CI report:
* 68b185ec99cc4db97323f2b5b09b4d17e09ac80d Azure:
Aiden Gong created FLINK-26034:
--
Summary: Add maven wapper for flink
Key: FLINK-26034
URL: https://issues.apache.org/jira/browse/FLINK-26034
Project: Flink
Issue Type: Improvement
flinkbot edited a comment on pull request #18669:
URL: https://github.com/apache/flink/pull/18669#issuecomment-1033040800
## CI report:
* d025b76c02f35a4c6e56311a7dfed49b5d0dc9d6 Azure:
flinkbot edited a comment on pull request #18603:
URL: https://github.com/apache/flink/pull/18603#issuecomment-1027853740
## CI report:
* 9c269c64ad7e0cb3e24dbaf1b9e5da3d5df5a6cd Azure:
flinkbot edited a comment on pull request #18531:
URL: https://github.com/apache/flink/pull/18531#issuecomment-1022985542
## CI report:
* 2952a6c6af10494f1ad1f30c18ac3cbc39693330 Azure:
flinkbot edited a comment on pull request #17452:
URL: https://github.com/apache/flink/pull/17452#issuecomment-940136217
## CI report:
* 68b185ec99cc4db97323f2b5b09b4d17e09ac80d Azure:
[
https://issues.apache.org/jira/browse/FLINK-26033?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17489298#comment-17489298
]
shizhengchao commented on FLINK-26033:
--
[~jark] [~libenchao] Can you check this question?
> In
[
https://issues.apache.org/jira/browse/FLINK-25992?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17489297#comment-17489297
]
Liu commented on FLINK-25992:
-
[~roman] I am afraid that the reason is still uncertain from the log. From
flinkbot edited a comment on pull request #18603:
URL: https://github.com/apache/flink/pull/18603#issuecomment-1027853740
## CI report:
* 9c269c64ad7e0cb3e24dbaf1b9e5da3d5df5a6cd Azure:
flinkbot edited a comment on pull request #18669:
URL: https://github.com/apache/flink/pull/18669#issuecomment-1033040800
## CI report:
* d025b76c02f35a4c6e56311a7dfed49b5d0dc9d6 Azure:
flinkbot edited a comment on pull request #18531:
URL: https://github.com/apache/flink/pull/18531#issuecomment-1022985542
## CI report:
* 2952a6c6af10494f1ad1f30c18ac3cbc39693330 Azure:
shizhengchao created FLINK-26033:
Summary: In KafkaConnector, when 'sink.partitioner' is configured
as 'round-robin', it does not take effect
Key: FLINK-26033
URL:
flinkbot commented on pull request #18674:
URL: https://github.com/apache/flink/pull/18674#issuecomment-1033419841
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
vahmed-hamdy commented on pull request #18669:
URL: https://github.com/apache/flink/pull/18669#issuecomment-1033419382
@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
flinkbot edited a comment on pull request #18531:
URL: https://github.com/apache/flink/pull/18531#issuecomment-1022985542
## CI report:
* 2952a6c6af10494f1ad1f30c18ac3cbc39693330 Azure:
imaffe commented on pull request #18674:
URL: https://github.com/apache/flink/pull/18674#issuecomment-1033418753
Close because the target fork is wrong. Sorry for any inconvenience
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
flinkbot edited a comment on pull request #18220:
URL: https://github.com/apache/flink/pull/18220#issuecomment-1001978981
## CI report:
* 8dc3a423728c27a335cd6f2f393ef79fb801e9c7 Azure:
imaffe closed pull request #18674:
URL: https://github.com/apache/flink/pull/18674
--
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:
bgeng777 commented on a change in pull request #18531:
URL: https://github.com/apache/flink/pull/18531#discussion_r802321843
##
File path:
flink-yarn/src/test/java/org/apache/flink/yarn/YarnClusterDescriptorTest.java
##
@@ -699,6 +701,32 @@ public void
imaffe commented on a change in pull request #18674:
URL: https://github.com/apache/flink/pull/18674#discussion_r802321257
##
File path:
flink-connectors/flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/sink/writer/PulsarWriter.java
##
@@ -143,11 +152,15
flinkbot edited a comment on pull request #18531:
URL: https://github.com/apache/flink/pull/18531#issuecomment-1022985542
## CI report:
* 2952a6c6af10494f1ad1f30c18ac3cbc39693330 Azure:
imaffe opened a new pull request #18674:
URL: https://github.com/apache/flink/pull/18674
Since the sink code is still evolving, for now I create this PR for
temporary discussion purposes. Will create new PR to flink repo after the major
code is merged.
1. Test code
I think the
Jing Ge created FLINK-26032:
---
Summary: log job info in the ContextEnvironment
Key: FLINK-26032
URL: https://issues.apache.org/jira/browse/FLINK-26032
Project: Flink
Issue Type: Improvement
flinkbot edited a comment on pull request #18531:
URL: https://github.com/apache/flink/pull/18531#issuecomment-1022985542
## CI report:
* 2952a6c6af10494f1ad1f30c18ac3cbc39693330 Azure:
bgeng777 commented on a change in pull request #18531:
URL: https://github.com/apache/flink/pull/18531#discussion_r802311817
##
File path:
flink-yarn/src/test/java/org/apache/flink/yarn/YarnClusterDescriptorTest.java
##
@@ -699,6 +701,32 @@ public void
flinkbot edited a comment on pull request #18531:
URL: https://github.com/apache/flink/pull/18531#issuecomment-1022985542
## CI report:
* 2952a6c6af10494f1ad1f30c18ac3cbc39693330 Azure:
tsreaper commented on pull request #18657:
URL: https://github.com/apache/flink/pull/18657#issuecomment-1033411514
Azure passes in
https://dev.azure.com/tsreaper96/Flink/_build/results?buildId=324=results
--
This is an automated message from the Apache Git Service.
To respond to the
flinkbot edited a comment on pull request #18531:
URL: https://github.com/apache/flink/pull/18531#issuecomment-1022985542
## CI report:
* 2952a6c6af10494f1ad1f30c18ac3cbc39693330 Azure:
flinkbot edited a comment on pull request #18531:
URL: https://github.com/apache/flink/pull/18531#issuecomment-1022985542
## CI report:
* 2952a6c6af10494f1ad1f30c18ac3cbc39693330 Azure:
flinkbot edited a comment on pull request #18671:
URL: https://github.com/apache/flink/pull/18671#issuecomment-1033207374
## CI report:
* 97226580a6e71c78492c3ae2bf48cccf84e2a81c Azure:
flinkbot edited a comment on pull request #18531:
URL: https://github.com/apache/flink/pull/18531#issuecomment-1022985542
## CI report:
* 2952a6c6af10494f1ad1f30c18ac3cbc39693330 Azure:
bgeng777 commented on a change in pull request #18531:
URL: https://github.com/apache/flink/pull/18531#discussion_r802311817
##
File path:
flink-yarn/src/test/java/org/apache/flink/yarn/YarnClusterDescriptorTest.java
##
@@ -699,6 +701,32 @@ public void
Caizhi Weng created FLINK-26031:
---
Summary: Support projection pushdown on keys and values in sst
file readers
Key: FLINK-26031
URL: https://issues.apache.org/jira/browse/FLINK-26031
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-24439?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17489279#comment-17489279
]
Jiangjie Qin commented on FLINK-24439:
--
[~pnowojski] This effectively introduces a cross-operator
tsreaper opened a new pull request #18:
URL: https://github.com/apache/flink-table-store/pull/18
Projection pushdown is an optimization for sources. With this optimization,
we can avoid reading useless columns and thus improve performance.
This PR is waiting for #16 and #17 .
--
flinkbot edited a comment on pull request #18669:
URL: https://github.com/apache/flink/pull/18669#issuecomment-1033040800
## CI report:
* d025b76c02f35a4c6e56311a7dfed49b5d0dc9d6 Azure:
flinkbot edited a comment on pull request #18669:
URL: https://github.com/apache/flink/pull/18669#issuecomment-1033040800
## CI report:
* d025b76c02f35a4c6e56311a7dfed49b5d0dc9d6 Azure:
[
https://issues.apache.org/jira/browse/FLINK-24607?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jiangjie Qin updated FLINK-24607:
-
Fix Version/s: 1.15.0
1.13.6
1.14.4
> SourceCoordinator
1 - 100 of 887 matches
Mail list logo
