[
https://issues.apache.org/jira/browse/FLINK-30117?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17653268#comment-17653268
]
Wencong Liu commented on FLINK-30117:
-
Thanks [~gaborgsomogyi] . According to the code part, the
flinkbot commented on PR #21579:
URL: https://github.com/apache/flink/pull/21579#issuecomment-1368144511
## CI report:
* 46d9a1842ebe7f2187250e79a3db9bd5bdd24f66 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-30536?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-30536:
---
Labels: pull-request-available (was: )
> Invoke CountingOutput and ChainingOutput as
lindong28 opened a new pull request, #21579:
URL: https://github.com/apache/flink/pull/21579
## What is the purpose of the change
Improve Flink performance by reducing the average depth of the call stack
needed to produce a record.
## Brief change log
- Added interface
nowke commented on PR #487:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/487#issuecomment-1368142154
> I am still a bit torn on this PR. This adds quite a lot of complexity to
the validation with some risks involved. Maybe we should just leave it as it is?
Agreed on
nowke commented on code in PR #487:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/487#discussion_r1059562798
##
flink-kubernetes-operator/src/test/java/org/apache/flink/kubernetes/operator/validation/DefaultValidatorTest.java:
##
@@ -248,13 +252,40 @@ public
[
https://issues.apache.org/jira/browse/FLINK-30488?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-30488:
---
Labels: pull-request-available (was: )
> OpenSearch implementation of Async Sink
>
reta opened a new pull request, #5:
URL: https://github.com/apache/flink-connector-opensearch/pull/5
OpenSearch implementation of Async Sink
(https://cwiki.apache.org/confluence/display/FLINK/FLIP-171%3A+Async+Sink), a
few TODO items:
- [ ] More test cases
- [ ] More sensitive
[
https://issues.apache.org/jira/browse/FLINK-30530?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17653167#comment-17653167
]
Gyula Fora commented on FLINK-30530:
At the end of the day you would still need to create separate
[
https://issues.apache.org/jira/browse/FLINK-30530?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17653159#comment-17653159
]
Arseniy Tashoyan edited comment on FLINK-30530 at 12/30/22 4:43 PM:
[
https://issues.apache.org/jira/browse/FLINK-30530?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17653159#comment-17653159
]
Arseniy Tashoyan commented on FLINK-30530:
--
Hi [~gyfora]
The YAML descriptor contains
[
https://issues.apache.org/jira/browse/FLINK-27246?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17653156#comment-17653156
]
Krzysztof Chmielewski commented on FLINK-27246:
---
Hi [~TsReaper]
I have modified my PR.
I
[
https://issues.apache.org/jira/browse/FLINK-30117?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17653151#comment-17653151
]
Gabor Somogyi commented on FLINK-30117:
---
[~Wencong Liu] Please have a look at the following code
fsk119 commented on PR #21571:
URL: https://github.com/apache/flink/pull/21571#issuecomment-1367973121
Thanks for the update! I add a commit to improve some codes. Please take a
look at the last commit when you are free.
--
This is an automated message from the Apache Git Service.
To
[
https://issues.apache.org/jira/browse/FLINK-30492?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17653146#comment-17653146
]
Martijn Visser commented on FLINK-30492:
[~luoyuxia] I do think it is needed, because the Hive
Dong Lin created FLINK-30536:
Summary: Invoke CountingOutput and ChainingOutput as listeners
Key: FLINK-30536
URL: https://issues.apache.org/jira/browse/FLINK-30536
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-30530?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17653133#comment-17653133
]
Gyula Fora commented on FLINK-30530:
The YAML descriptor too is very application specific so I don't
[
https://issues.apache.org/jira/browse/FLINK-30530?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17653132#comment-17653132
]
Gyula Fora commented on FLINK-30530:
Because flink and log config is probably different for every
[
https://issues.apache.org/jira/browse/FLINK-30530?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora updated FLINK-30530:
---
Affects Version/s: (was: 1.15.2)
> Flink configuration from user-provided ConfigMap
>
LadyForest commented on code in PR #21577:
URL: https://github.com/apache/flink/pull/21577#discussion_r1059352101
##
flink-table/flink-table-common/src/main/java/org/apache/flink/table/catalog/TableChange.java:
##
@@ -94,6 +96,137 @@ static AddWatermark add(WatermarkSpec
kristoffSC commented on PR #21393:
URL: https://github.com/apache/flink/pull/21393#issuecomment-1367883271
@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
[
https://issues.apache.org/jira/browse/FLINK-29607?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora reassigned FLINK-29607:
--
Assignee: Gyula Fora
> Simplify controller flow by introducing FlinkControllerContext
>
LadyForest commented on code in PR #21571:
URL: https://github.com/apache/flink/pull/21571#discussion_r1059269728
##
flink-table/flink-sql-parser/src/main/java/org/apache/flink/sql/parser/ddl/SqlAlterTableDropConstraint.java:
##
@@ -24,25 +24,29 @@
import
1996fanrui commented on PR #21540:
URL: https://github.com/apache/flink/pull/21540#issuecomment-1367867001
Thanks @Myasuka and @yuchen-ecnu 's review.
--
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
[
https://issues.apache.org/jira/browse/FLINK-30492?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17653108#comment-17653108
]
Weijie Guo commented on FLINK-30492:
[~luoyuxia] Yes, I only remove the suffix of
[
https://issues.apache.org/jira/browse/FLINK-30492?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17653102#comment-17653102
]
luoyuxia edited comment on FLINK-30492 at 12/30/22 10:55 AM:
-
If just for
[
https://issues.apache.org/jira/browse/FLINK-30492?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17653102#comment-17653102
]
luoyuxia commented on FLINK-30492:
--
If just for `flink-table-api-java-bridge`, we don't need the scala
[
https://issues.apache.org/jira/browse/FLINK-30492?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17653092#comment-17653092
]
Martijn Visser edited comment on FLINK-30492 at 12/30/22 10:08 AM:
---
[
https://issues.apache.org/jira/browse/FLINK-30492?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17653092#comment-17653092
]
Martijn Visser commented on FLINK-30492:
[~Weijie Guo] See
[
https://issues.apache.org/jira/browse/FLINK-30492?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17653081#comment-17653081
]
Weijie Guo edited comment on FLINK-30492 at 12/30/22 9:36 AM:
--
yunfengzhou-hub commented on code in PR #193:
URL: https://github.com/apache/flink-ml/pull/193#discussion_r105931
##
flink-ml-benchmark/src/test/java/org/apache/flink/ml/benchmark/BenchmarkTest.java:
##
@@ -54,6 +56,33 @@ public void testParseJsonFile() throws Exception {
[
https://issues.apache.org/jira/browse/FLINK-30492?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17653081#comment-17653081
]
Weijie Guo edited comment on FLINK-30492 at 12/30/22 9:31 AM:
--
[
https://issues.apache.org/jira/browse/FLINK-30492?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17653081#comment-17653081
]
Weijie Guo commented on FLINK-30492:
[~martijnvisser] Thanks for the feedback, but I may have some
reswqa commented on PR #21553:
URL: https://github.com/apache/flink/pull/21553#issuecomment-1367810973
@MartijnVisser If I haven't misunderstood your meaning, you mean that the
scala version is still needed as a suffix for the hi connector dependency, but
I only modified the artifactId of
[
https://issues.apache.org/jira/browse/FLINK-30492?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser closed FLINK-30492.
--
Resolution: Invalid
The Hive connector is still tied to the Flink Planner, which requires you
MartijnVisser closed pull request #21553: [FLINK-30492][doc] fix incorrect
dependency artifactId in hive overview.
URL: https://github.com/apache/flink/pull/21553
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL
[
https://issues.apache.org/jira/browse/FLINK-30087?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17653074#comment-17653074
]
Wencong Liu commented on FLINK-30087:
-
Hello [~chesnay] , it the module flink-table-uber named
[
https://issues.apache.org/jira/browse/FLINK-30117?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17653069#comment-17653069
]
Wencong Liu commented on FLINK-30117:
-
Hello [~gaborgsomogyi] , I'm quite interested in this issue,
[
https://issues.apache.org/jira/browse/FLINK-30496?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shengkai Fang reassigned FLINK-30496:
-
Assignee: Shengkai Fang
> Introduce TableChange to represent MODIFY change
>
[
https://issues.apache.org/jira/browse/FLINK-30495?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shengkai Fang closed FLINK-30495.
-
Fix Version/s: 1.17.0
Resolution: Implemented
Merged into master:
fsk119 closed pull request #21566: [FLINK-30495][table-api] Introduce
TableChange to represent ADD change
URL: https://github.com/apache/flink/pull/21566
--
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
yuchen-ecnu commented on PR #21498:
URL: https://github.com/apache/flink/pull/21498#issuecomment-1367782568
Hi @Myasuka @1996fanrui ,
Thanks for the discussion.
As discussed above, I've set the default depth value of the thread dump to
50 and updated the related commit
flinkbot commented on PR #21578:
URL: https://github.com/apache/flink/pull/21578#issuecomment-1367782296
## CI report:
* c14355243995bff7b03a527ed073a2bbaab70ce8 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
Myasuka commented on PR #21406:
URL: https://github.com/apache/flink/pull/21406#issuecomment-1367780705
@rovboyko I created ticket FLINK-30535 to focus on the TTL state benchmarks.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
Yun Tang created FLINK-30535:
Summary: Introduce TTL state based benchmarks
Key: FLINK-30535
URL: https://issues.apache.org/jira/browse/FLINK-30535
Project: Flink
Issue Type: New Feature
lincoln-lil opened a new pull request, #21578:
URL: https://github.com/apache/flink/pull/21578
this is a backport pr for FLINK-28988 to release-1.16
--
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
46 matches
Mail list logo
