Dong Lin created FLINK-30533:
Summary: IteratorSourceReaderBase#pollNext() should push records
to ReaderOutput in a while loop
Key: FLINK-30533
URL: https://issues.apache.org/jira/browse/FLINK-30533
Proje
[
https://issues.apache.org/jira/browse/FLINK-30533?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin reassigned FLINK-30533:
Assignee: Dong Lin
> IteratorSourceReaderBase#pollNext() should push records to ReaderOutput in a
[
https://issues.apache.org/jira/browse/FLINK-30502?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17652755#comment-17652755
]
Wencong Liu commented on FLINK-30502:
-
Hello [~douheyu] , thanks for your feedback.
LadyForest commented on code in PR #21566:
URL: https://github.com/apache/flink/pull/21566#discussion_r1058792233
##
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/utils/OperationConverterUtils.java:
##
@@ -89,8 +93,15 @@ public static Operation con
[
https://issues.apache.org/jira/browse/FLINK-29084?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xintong Song closed FLINK-29084.
Resolution: Duplicate
Closing as duplicating FLINK-15358
> Program argument containing # (pound s
[
https://issues.apache.org/jira/browse/FLINK-30364?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17652759#comment-17652759
]
Zhu Zhu commented on FLINK-30364:
-
Close this ticket for now because it's likely to be t
[
https://issues.apache.org/jira/browse/FLINK-30364?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu closed FLINK-30364.
---
Resolution: Not A Problem
> Job failed without exception stack
> --
>
>
[
https://issues.apache.org/jira/browse/FLINK-30131?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17652765#comment-17652765
]
Zhu Zhu commented on FLINK-30131:
-
[~landlord] do you have any updates for this issue?
[
https://issues.apache.org/jira/browse/FLINK-30520?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xintong Song closed FLINK-30520.
Resolution: Duplicate
> Arguments contains with '#' will error split in loadYAMLResource
> ---
[
https://issues.apache.org/jira/browse/FLINK-30520?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17652767#comment-17652767
]
Xintong Song commented on FLINK-30520:
--
[~tanjialiang],
This seems to be duplicati
[
https://issues.apache.org/jira/browse/FLINK-30412?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17652768#comment-17652768
]
Yun Gao commented on FLINK-30412:
-
Hi [~xiaodao] sorry for the late reply, may I have a
Martijn Visser created FLINK-30534:
--
Summary: Discuss / migrate People section to Hugo
Key: FLINK-30534
URL: https://issues.apache.org/jira/browse/FLINK-30534
Project: Flink
Issue Type: Sub-
[
https://issues.apache.org/jira/browse/FLINK-30468?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Gao reassigned FLINK-30468:
---
Assignee: Rui Fan
> The SortOrder of BusyRatio should be descend by default
> -
[
https://issues.apache.org/jira/browse/FLINK-30102?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17652770#comment-17652770
]
Zhu Zhu commented on FLINK-30102:
-
I can see exception below:
{code:java}
2022-11-20T06
[
https://issues.apache.org/jira/browse/FLINK-30102?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu updated FLINK-30102:
Component/s: Runtime / State Backends
> Unstable test
> EventTimeWindowCheckpointingITCase.testPreAggrega
[
https://issues.apache.org/jira/browse/FLINK-29660?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu closed FLINK-29660.
---
Resolution: Won't Fix
In FLINK-30358, the taskmanager IDs of failed tasks are now displayed the
exception p
[
https://issues.apache.org/jira/browse/FLINK-30108?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17652779#comment-17652779
]
Zhu Zhu commented on FLINK-30108:
-
The stuck case is ZooKeeperLeaderElectionConnectionHa
[
https://issues.apache.org/jira/browse/FLINK-30108?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu updated FLINK-30108:
Component/s: Runtime / Coordination
(was: API / Core)
> flink-core module tests exite
qq774724635 opened a new pull request, #21575:
URL: https://github.com/apache/flink/pull/21575
## 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 avoid re-transferring the
wanglijie95 commented on PR #20875:
URL: https://github.com/apache/flink/pull/20875#issuecomment-1367167231
Hi all, what's the current status of this PR? Looks like it's ready to be
merged, but hasn't been merged
--
This is an automated message from the Apache Git Service.
To respond to t
[
https://issues.apache.org/jira/browse/FLINK-30389?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17652781#comment-17652781
]
Wencong Liu commented on FLINK-30389:
-
Hello [~lzljs3620320] , I'm quite interested
flinkbot commented on PR #21575:
URL: https://github.com/apache/flink/pull/21575#issuecomment-1367172796
## CI report:
* 5279153582fc3fd8e3a5680b8563666793c0075a UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-30527?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora reassigned FLINK-30527:
--
Assignee: Gyula Fora
> Last-state suspend followed by flinkVersion change may lead to state l
gaborgsomogyi commented on PR #20875:
URL: https://github.com/apache/flink/pull/20875#issuecomment-1367197412
You see it well...
--
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 comme
[
https://issues.apache.org/jira/browse/FLINK-30533?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin updated FLINK-30533:
-
Component/s: Runtime / Task
> IteratorSourceReaderBase#pollNext() should push records to ReaderOutput in
[
https://issues.apache.org/jira/browse/FLINK-30483?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17652795#comment-17652795
]
Jagadesh Adireddi commented on FLINK-30483:
---
Hi,
I am able to make code change
[
https://issues.apache.org/jira/browse/FLINK-30520?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17652797#comment-17652797
]
tanjialiang commented on FLINK-30520:
-
[~xtsong], thanks for your reply, it is the b
luoyuxia commented on code in PR #21257:
URL: https://github.com/apache/flink/pull/21257#discussion_r1058894608
##
flink-connectors/flink-connector-files/src/main/java/org/apache/flink/connector/file/table/CompactFileUtils.java:
##
@@ -0,0 +1,158 @@
+/*
+ * Licensed to the Apach
lsyldliu commented on code in PR #21563:
URL: https://github.com/apache/flink/pull/21563#discussion_r1058777527
##
flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/plan/rules/FlinkStreamRuleSets.scala:
##
@@ -211,6 +211,29 @@ object FlinkStreamRuleSe
luoyuxia commented on code in PR #21257:
URL: https://github.com/apache/flink/pull/21257#discussion_r1058898389
##
flink-connectors/flink-connector-files/src/main/java/org/apache/flink/connector/file/table/PartitionLoader.java:
##
@@ -148,23 +150,35 @@ private void overwrite(Pat
luoyuxia commented on code in PR #21257:
URL: https://github.com/apache/flink/pull/21257#discussion_r1058899053
##
flink-connectors/flink-connector-files/src/main/java/org/apache/flink/connector/file/table/batch/compact/BatchCompactCoordinator.java:
##
@@ -0,0 +1,155 @@
+/*
+ *
luoyuxia commented on code in PR #21257:
URL: https://github.com/apache/flink/pull/21257#discussion_r1058900263
##
flink-connectors/flink-connector-files/src/main/java/org/apache/flink/connector/file/table/batch/compact/BatchCompactCoordinator.java:
##
@@ -0,0 +1,155 @@
+/*
+ *
luoyuxia commented on code in PR #21257:
URL: https://github.com/apache/flink/pull/21257#discussion_r1058901029
##
flink-connectors/flink-connector-files/src/main/java/org/apache/flink/connector/file/table/batch/compact/BatchCompactOperator.java:
##
@@ -0,0 +1,114 @@
+/*
+ * Lic
[
https://issues.apache.org/jira/browse/FLINK-30533?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin updated FLINK-30533:
-
Description:
Currently, each invocation of IteratorSourceReaderBase#pollNext() push at most
one record
luoyuxia commented on code in PR #21257:
URL: https://github.com/apache/flink/pull/21257#discussion_r1058901588
##
flink-connectors/flink-connector-files/src/main/java/org/apache/flink/connector/file/table/batch/compact/BatchPartitionCommitter.java:
##
@@ -0,0 +1,141 @@
+/*
+ *
lindong28 opened a new pull request, #21576:
URL: https://github.com/apache/flink/pull/21576
## What is the purpose of the change
Improve the performance of Flink programs that reads data from
IteratorSourceReaderBase.
## Brief change log
Updated IteratorSourceReaderBase
lindong28 commented on PR #21576:
URL: https://github.com/apache/flink/pull/21576#issuecomment-1367260609
@gaoyunhaii Would you have time to review this PR?
--
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
[
https://issues.apache.org/jira/browse/FLINK-30533?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-30533:
---
Labels: pull-request-available (was: )
> IteratorSourceReaderBase#pollNext() should push re
flinkbot commented on PR #21576:
URL: https://github.com/apache/flink/pull/21576#issuecomment-1367262465
## CI report:
* 2a19c695367931933b54a858ffd62d55f3978b76 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
luoyuxia commented on PR #21257:
URL: https://github.com/apache/flink/pull/21257#issuecomment-1367265931
@beyond1920 @Aitozi @Tartarus0zm Thanks for you guys reviewing. I have
addressed your comments.
--
This is an automated message from the Apache Git Service.
To respond to the message,
beyond1920 commented on code in PR #21257:
URL: https://github.com/apache/flink/pull/21257#discussion_r1058863360
##
flink-connectors/flink-connector-files/src/main/java/org/apache/flink/connector/file/table/PartitionTempFileManager.java:
##
@@ -75,6 +76,19 @@ public class Parti
luoyuxia commented on code in PR #21257:
URL: https://github.com/apache/flink/pull/21257#discussion_r1058926736
##
flink-connectors/flink-connector-files/src/main/java/org/apache/flink/connector/file/table/batch/compact/BatchCompactOperator.java:
##
@@ -0,0 +1,145 @@
+/*
+ * Lic
luoyuxia commented on code in PR #21257:
URL: https://github.com/apache/flink/pull/21257#discussion_r1058927115
##
flink-connectors/flink-connector-files/src/main/java/org/apache/flink/connector/file/table/PartitionTempFileManager.java:
##
@@ -75,6 +76,19 @@ public class Partiti
fsk119 opened a new pull request, #21577:
URL: https://github.com/apache/flink/pull/21577
## What is the purpose of the change
*Introduce TableChange to represent ALTER TABLE MODIFY syntax.*
## Brief change log
- *Collect table changes during the sql to oper
[
https://issues.apache.org/jira/browse/FLINK-30496?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-30496:
---
Labels: pull-request-available (was: )
> Introduce TableChange to represent MODIFY change
>
flinkbot commented on PR #21577:
URL: https://github.com/apache/flink/pull/21577#issuecomment-1367299309
## CI report:
* d5a2d2426b44a608d76e2c540145c511d53d94fb UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
wanglijie95 closed pull request #21162: [FLINK-29665][runtime] Support flexible
subpartion range division
URL: https://github.com/apache/flink/pull/21162
--
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
[
https://issues.apache.org/jira/browse/FLINK-30528?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora reassigned FLINK-30528:
--
Assignee: Gyula Fora
> Job may be stuck in upgrade loop when last-state fallback is disabled
[
https://issues.apache.org/jira/browse/FLINK-29665?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17652833#comment-17652833
]
Lijie Wang commented on FLINK-29665:
Done via master:
3881e53003adce22fd0a0fbd9a229
[
https://issues.apache.org/jira/browse/FLINK-29665?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lijie Wang closed FLINK-29665.
--
Resolution: Done
> Support flexible subpartition range divisions
> ---
boring-cyborg[bot] commented on PR #9:
URL:
https://github.com/apache/flink-connector-pulsar/pull/9#issuecomment-1367304205
Thanks for opening this pull request! Please check out our contributing
guidelines. (https://flink.apache.org/contributing/how-to-contribute.html)
--
This is an
[
https://issues.apache.org/jira/browse/FLINK-30430?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-30430:
---
Labels: pull-request-available (was: )
> Remove the useless dependencies in flink-connector
[
https://issues.apache.org/jira/browse/FLINK-30093?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17652848#comment-17652848
]
Tomoyuki NAKAMURA commented on FLINK-30093:
---
I am not sure if 1.16 can handle
[
https://issues.apache.org/jira/browse/FLINK-30093?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17652848#comment-17652848
]
Tomoyuki NAKAMURA edited comment on FLINK-30093 at 12/29/22 1:29 PM:
-
[
https://issues.apache.org/jira/browse/FLINK-30093?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17652848#comment-17652848
]
Tomoyuki NAKAMURA edited comment on FLINK-30093 at 12/29/22 1:30 PM:
-
[
https://issues.apache.org/jira/browse/FLINK-30257?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Wencong Liu updated FLINK-30257:
Attachment: image-2022-12-29-21-47-31-606.png
> SqlClientITCase#testMatchRecognize failed
> --
[
https://issues.apache.org/jira/browse/FLINK-30257?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17652852#comment-17652852
]
Wencong Liu commented on FLINK-30257:
-
Hello [~martijnvisser]. In the situation of r
[
https://issues.apache.org/jira/browse/FLINK-30234?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17652854#comment-17652854
]
Wencong Liu commented on FLINK-30234:
-
Hello [~renqs] , I think this is a reasonable
darenwkt commented on code in PR #39:
URL:
https://github.com/apache/flink-connector-aws/pull/39#discussion_r1058982327
##
flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/internals/publisher/fanout/StreamConsumerRegistrar.java:
##
@@ -77,8 +7
darenwkt commented on code in PR #39:
URL:
https://github.com/apache/flink-connector-aws/pull/39#discussion_r1058982468
##
flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/internals/publisher/fanout/StreamConsumerRegistrar.java:
##
@@ -218,7 +
beyond1920 commented on code in PR #21257:
URL: https://github.com/apache/flink/pull/21257#discussion_r1058985398
##
flink-connectors/flink-connector-files/src/main/java/org/apache/flink/connector/file/table/batch/compact/BatchCompactOperator.java:
##
@@ -0,0 +1,145 @@
+/*
+ * L
darenwkt commented on code in PR #39:
URL:
https://github.com/apache/flink-connector-aws/pull/39#discussion_r1058985956
##
flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/proxy/KinesisProxyAsyncV2Interface.java:
##
@@ -0,0 +1,41 @@
+/*
+ * Li
gyfora opened a new pull request, #496:
URL: https://github.com/apache/flink-kubernetes-operator/pull/496
## What is the purpose of the change
The PR adds validation for flinkVersion changes on SUSPENDED application. If
the flinkVersion is changed for an application that was suspended
[
https://issues.apache.org/jira/browse/FLINK-30527?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-30527:
---
Labels: pull-request-available (was: )
> Last-state suspend followed by flinkVersion change
gyfora merged PR #21515:
URL: https://github.com/apache/flink/pull/21515
--
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.apache
[
https://issues.apache.org/jira/browse/FLINK-30429?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora closed FLINK-30429.
--
Fix Version/s: 1.17.0
Resolution: Fixed
merged to master: 259c7a4776af4d9d7f174f871fb2d4145787f
beyond1920 commented on code in PR #21059:
URL: https://github.com/apache/flink/pull/21059#discussion_r1058997349
##
flink-connectors/flink-connector-files/src/main/java/org/apache/flink/connector/file/table/CompactFileUtils.java:
##
@@ -0,0 +1,158 @@
+/*
+ * Licensed to the Apa
beyond1920 commented on code in PR #21257:
URL: https://github.com/apache/flink/pull/21257#discussion_r1058998147
##
flink-connectors/flink-connector-files/src/main/java/org/apache/flink/connector/file/table/batch/compact/CompactFileUtils.java:
##
@@ -0,0 +1,119 @@
+/*
+ * Licen
tisonkun merged PR #9:
URL: https://github.com/apache/flink-connector-pulsar/pull/9
--
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...@f
boring-cyborg[bot] commented on PR #9:
URL:
https://github.com/apache/flink-connector-pulsar/pull/9#issuecomment-1367390477
Awesome work, congrats on your first merged pull request!
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on t
[
https://issues.apache.org/jira/browse/FLINK-30430?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zili Chen closed FLINK-30430.
-
Resolution: Fixed
master via https://github.com/apache/flink-connector-pulsar/pull/9
> Remove the usele
[
https://issues.apache.org/jira/browse/FLINK-30404?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora reassigned FLINK-30404:
--
Assignee: (was: Gyula Fora)
> Do not redeploy taskmanagers on standalone application scal
fsk119 commented on code in PR #21571:
URL: https://github.com/apache/flink/pull/21571#discussion_r1058978409
##
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/operations/AlterSchemaConverter.java:
##
@@ -115,77 +120,135 @@ public Schema applySchema
amirhalatzi opened a new pull request, #4:
URL: https://github.com/apache/flink-connector-opensearch/pull/4
Hi!
During a project we're working on we decided to use Flink over Opensearch
2.3, which seems to have a breaking change of removing the `type` property from
responses.
boring-cyborg[bot] commented on PR #4:
URL:
https://github.com/apache/flink-connector-opensearch/pull/4#issuecomment-1367509656
Thanks for opening this pull request! Please check out our contributing
guidelines. (https://flink.apache.org/contributing/how-to-contribute.html)
--
This i
[
https://issues.apache.org/jira/browse/FLINK-30483?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17652926#comment-17652926
]
Mingliang Liu commented on FLINK-30483:
---
Thanks [~jadireddi] ! I started making ch
[
https://issues.apache.org/jira/browse/FLINK-27571?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17652971#comment-17652971
]
Roman Khachatryan commented on FLINK-27571:
---
Thanks for picking this up [~Yanf
rkhachatryan commented on code in PR #63:
URL: https://github.com/apache/flink-benchmarks/pull/63#discussion_r1059186216
##
update_benchmark_fileds.py:
##
@@ -0,0 +1,56 @@
+#!/usr/bin/env python
+# -*- coding: utf-8 -*-
+##
rkhachatryan closed pull request #55: [FLINK-27571] Parse "lessisbetter" when
detecting regression
URL: https://github.com/apache/flink-benchmarks/pull/55
--
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 g
rkhachatryan commented on PR #55:
URL: https://github.com/apache/flink-benchmarks/pull/55#issuecomment-1367633797
Superseded by #63.
--
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 c
lindong28 commented on PR #21576:
URL: https://github.com/apache/flink/pull/21576#issuecomment-1367668762
@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.
[
https://issues.apache.org/jira/browse/FLINK-30489?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17652982#comment-17652982
]
Yufan Sheng edited comment on FLINK-30489 at 12/30/22 1:03 AM:
---
[
https://issues.apache.org/jira/browse/FLINK-30489?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17652982#comment-17652982
]
Yufan Sheng commented on FLINK-30489:
-
We didn't shade these dependencies because th
JingsongLi opened a new pull request, #448:
URL: https://github.com/apache/flink-table-store/pull/448
Incorrect check between snapshot id and checkpoint id.
--
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
luoyuxia commented on code in PR #21257:
URL: https://github.com/apache/flink/pull/21257#discussion_r1059211343
##
flink-connectors/flink-connector-files/src/main/java/org/apache/flink/connector/file/table/batch/compact/CompactFileUtils.java:
##
@@ -0,0 +1,119 @@
+/*
+ * License
luoyuxia commented on code in PR #21257:
URL: https://github.com/apache/flink/pull/21257#discussion_r1059211343
##
flink-connectors/flink-connector-files/src/main/java/org/apache/flink/connector/file/table/batch/compact/CompactFileUtils.java:
##
@@ -0,0 +1,119 @@
+/*
+ * License
luoyuxia commented on code in PR #21257:
URL: https://github.com/apache/flink/pull/21257#discussion_r1059211731
##
flink-connectors/flink-connector-files/src/main/java/org/apache/flink/connector/file/table/batch/compact/BatchCompactOperator.java:
##
@@ -0,0 +1,145 @@
+/*
+ * Lic
LadyForest commented on code in PR #21571:
URL: https://github.com/apache/flink/pull/21571#discussion_r1059214774
##
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/operations/AlterSchemaConverter.java:
##
@@ -115,77 +120,135 @@ public Schema applySc
JingsongLi merged PR #448:
URL: https://github.com/apache/flink-table-store/pull/448
--
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...@
lsyldliu commented on code in PR #21563:
URL: https://github.com/apache/flink/pull/21563#discussion_r1059217459
##
flink-connectors/flink-connector-hive/src/test/java/org/apache/flink/connectors/hive/HiveTableSourceITCase.java:
##
@@ -447,6 +447,51 @@ public void testProjectionP
fsk119 commented on code in PR #21571:
URL: https://github.com/apache/flink/pull/21571#discussion_r105976
##
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/operations/AlterSchemaConverter.java:
##
@@ -115,77 +120,135 @@ public Schema applySchema
beyond1920 closed pull request #21401: [FLINK-29718][table] Supports hive sum
function by native implementation
URL: https://github.com/apache/flink/pull/21401
--
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
[
https://issues.apache.org/jira/browse/FLINK-29718?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jing Zhang closed FLINK-29718.
--
> Supports hive sum function by native implementation
> --
[
https://issues.apache.org/jira/browse/FLINK-29718?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jing Zhang resolved FLINK-29718.
Assignee: dalongliu
Resolution: Fixed
> Supports hive sum function by native implementation
[
https://issues.apache.org/jira/browse/FLINK-29718?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17652998#comment-17652998
]
Jing Zhang commented on FLINK-29718:
Merged in master: 4c0f5e63775074c87f3a834b22d6c
fsk119 commented on code in PR #21566:
URL: https://github.com/apache/flink/pull/21566#discussion_r1059226965
##
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/utils/OperationConverterUtils.java:
##
@@ -106,13 +117,17 @@ public static Operation conv
[
https://issues.apache.org/jira/browse/FLINK-30531?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin updated FLINK-30531:
-
Description:
Benchmark results show that Flink time to execute simple programs is more than
3X slower t
yangjunhan commented on code in PR #21447:
URL: https://github.com/apache/flink/pull/21447#discussion_r1059229187
##
flink-runtime-web/web-dashboard/src/app/pages/job/overview/flamegraph/job-overview-drawer-flamegraph.component.ts:
##
@@ -100,9 +118,38 @@ export class JobOvervie
yangjunhan commented on PR #21447:
URL: https://github.com/apache/flink/pull/21447#issuecomment-1367708053
Hi, @1996fanrui . Sorry for the late review. I left a few comments to be
improved regarding the last commit (ui). The rest looks good to me :)
--
This is an automated message from th
[
https://issues.apache.org/jira/browse/FLINK-30531?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin updated FLINK-30531:
-
Description:
Benchmark results show that Flink time to execute simple programs is more than
3X slower t
1 - 100 of 126 matches
Mail list logo
