[
https://issues.apache.org/jira/browse/FLINK-28318?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17560855#comment-17560855
]
Martijn Visser commented on FLINK-28318:
Can you please provide more information
[
https://issues.apache.org/jira/browse/FLINK-28309?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-28309:
---
Labels: pull-request-available (was: )
> Introduce metrics of the duration that a task stay
[
https://issues.apache.org/jira/browse/FLINK-16419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17560854#comment-17560854
]
Martijn Visser commented on FLINK-16419:
[~YordanPavlov] Did that also resolve t
KarmaGYZ opened a new pull request, #20111:
URL: https://github.com/apache/flink/pull/20111
…ys in each status
## What is the purpose of the change
Introduce metrics of the duration that a task stays in each status
## Verifying this change
This change a
[
https://issues.apache.org/jira/browse/FLINK-27487?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17560852#comment-17560852
]
Arseniy Tashoyan commented on FLINK-27487:
--
Hi [~fpaul]
Should we apply the sam
flinkbot commented on PR #20110:
URL: https://github.com/apache/flink/pull/20110#issuecomment-1170830747
## CI report:
* f0c66904276f5fb8e149b7af07b658d430107c51 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-28244?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee closed FLINK-28244.
Resolution: Fixed
master: 83a321fa116f9dc520d7ea936ce6103e1cb45869
> Introduce changelog file for
JingsongLi merged PR #178:
URL: https://github.com/apache/flink-table-store/pull/178
--
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...@
[
https://issues.apache.org/jira/browse/FLINK-28282?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee closed FLINK-28282.
Resolution: Fixed
master: 910b8f3e2bcbb4883b6b3794c01858a8097d0d65
> Planner free in flink-table-
[
https://issues.apache.org/jira/browse/FLINK-28292?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee closed FLINK-28292.
Resolution: Fixed
master: c8c3cd1d93012d6eba6a7f7639435d489e0cffd8
> Get rid of BulkReaderFormatF
[
https://issues.apache.org/jira/browse/FLINK-28300?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17560849#comment-17560849
]
Maksim Aniskov commented on FLINK-28300:
https://github.com/apache/flink-kuberne
JingsongLi merged PR #179:
URL: https://github.com/apache/flink-table-store/pull/179
--
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...@
JingsongLi merged PR #180:
URL: https://github.com/apache/flink-table-store/pull/180
--
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...@
yutao created FLINK-28318:
-
Summary: table idle state ttl configure does not have check when
window size bigger then table state ttl
Key: FLINK-28318
URL: https://issues.apache.org/jira/browse/FLINK-28318
P
luoyuxia created FLINK-28317:
Summary: Throw unsupport exception when RexSubQuery contains
LogicalUnion and correlate variables
Key: FLINK-28317
URL: https://issues.apache.org/jira/browse/FLINK-28317
Proj
MaksimAniskov opened a new pull request, #286:
URL: https://github.com/apache/flink-kubernetes-operator/pull/286
Fixes FLINK-28300
--
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 com
MartijnVisser commented on PR #20003:
URL: https://github.com/apache/flink/pull/20003#issuecomment-1170827097
@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 comm
[
https://issues.apache.org/jira/browse/FLINK-28308?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-28308:
---
Labels: pull-request-available (was: )
> Introduce accumulated time metrics that a running
KarmaGYZ opened a new pull request, #20110:
URL: https://github.com/apache/flink/pull/20110
## What is the purpose of the change
Introduce metrics of the accumulated time that a running task is busy / idle
/ back-pressured
## Verifying this change
This change add
[
https://issues.apache.org/jira/browse/FLINK-28314?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yangze Guo reassigned FLINK-28314:
--
Assignee: Junhan Yang
> [UI] Introduce "Cluster Environment" tab under history server
> -
[
https://issues.apache.org/jira/browse/FLINK-28315?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yangze Guo reassigned FLINK-28315:
--
Assignee: Junhan Yang
> [UI] Introduce aggregate stats in tables of the subtasks and taskmana
[
https://issues.apache.org/jira/browse/FLINK-28316?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yangze Guo reassigned FLINK-28316:
--
Assignee: Junhan Yang
> [UI] add external taskmanager log links in the vertex drawer under hi
Junhan Yang created FLINK-28316:
---
Summary: [UI] add external taskmanager log links in the vertex
drawer under history server
Key: FLINK-28316
URL: https://issues.apache.org/jira/browse/FLINK-28316
Proje
[
https://issues.apache.org/jira/browse/FLINK-28314?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Junhan Yang updated FLINK-28314:
Summary: [UI] Introduce "Cluster Environment" tab under history server
(was: Introduce "Cluster E
Junhan Yang created FLINK-28315:
---
Summary: [UI] Introduce aggregate stats in tables of the subtasks
and taskmanagers
Key: FLINK-28315
URL: https://issues.apache.org/jira/browse/FLINK-28315
Project: Flin
Junhan Yang created FLINK-28314:
---
Summary: Introduce "Cluster Environment" tab under history server
Web UI
Key: FLINK-28314
URL: https://issues.apache.org/jira/browse/FLINK-28314
Project: Flink
fsk119 commented on PR #20063:
URL: https://github.com/apache/flink/pull/20063#issuecomment-1170817245
@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-28312?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yangze Guo reassigned FLINK-28312:
--
Assignee: Yangze Guo
> Introduce REST APIs for log URL retrieval
> --
fsk119 commented on code in PR #18920:
URL: https://github.com/apache/flink/pull/18920#discussion_r910647254
##
flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/planner/delegation/hive/copy/HiveParserBaseSemanticAnalyzer.java:
##
@@ -1862,6 +1867,65 @@
Yangze Guo created FLINK-28313:
--
Summary: Add history server flag to DashboardConfiguration
Key: FLINK-28313
URL: https://issues.apache.org/jira/browse/FLINK-28313
Project: Flink
Issue Type: Sub
zhuzhurk commented on code in PR #20082:
URL: https://github.com/apache/flink/pull/20082#discussion_r910645522
##
flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/ArchivedSpeculativeExecutionVertex.java:
##
@@ -0,0 +1,52 @@
+/*
+ * Licensed to the Apache Softw
Yangze Guo created FLINK-28312:
--
Summary: Introduce REST APIs for log URL retrieval
Key: FLINK-28312
URL: https://issues.apache.org/jira/browse/FLINK-28312
Project: Flink
Issue Type: Sub-task
Yangze Guo created FLINK-28311:
--
Summary: Introduce REST APIs for the environmental information
Key: FLINK-28311
URL: https://issues.apache.org/jira/browse/FLINK-28311
Project: Flink
Issue Type:
Yangze Guo created FLINK-28310:
--
Summary: Introduce aggregating task metrics
Key: FLINK-28310
URL: https://issues.apache.org/jira/browse/FLINK-28310
Project: Flink
Issue Type: Sub-task
zhuzhurk commented on code in PR #20082:
URL: https://github.com/apache/flink/pull/20082#discussion_r910644339
##
flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/SpeculativeExecutionVertex.java:
##
@@ -0,0 +1,284 @@
+/*
+ * Licensed to the Apache Software Fou
[
https://issues.apache.org/jira/browse/FLINK-28308?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yangze Guo updated FLINK-28308:
---
Component/s: Runtime / Metrics
> Introduce accumulated time metrics that a running task is busy / id
Yangze Guo created FLINK-28309:
--
Summary: Introduce metrics of the duration that a task stays in
each status
Key: FLINK-28309
URL: https://issues.apache.org/jira/browse/FLINK-28309
Project: Flink
Yangze Guo created FLINK-28308:
--
Summary: Introduce accumulated time metrics that a running task is
busy / idle / back-pressured
Key: FLINK-28308
URL: https://issues.apache.org/jira/browse/FLINK-28308
Pr
Yangze Guo created FLINK-28307:
--
Summary: FLIP-241: Completed Jobs Information Enhancement
Key: FLINK-28307
URL: https://issues.apache.org/jira/browse/FLINK-28307
Project: Flink
Issue Type: New
zhuzhurk commented on code in PR #20082:
URL: https://github.com/apache/flink/pull/20082#discussion_r910640053
##
flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/SpeculativeExecutionVertex.java:
##
@@ -0,0 +1,284 @@
+/*
+ * Licensed to the Apache Software Fou
zhuzhurk commented on code in PR #20082:
URL: https://github.com/apache/flink/pull/20082#discussion_r910639908
##
flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/SpeculativeExecutionVertex.java:
##
@@ -0,0 +1,284 @@
+/*
+ * Licensed to the Apache Software Fou
zhuzhurk commented on code in PR #20082:
URL: https://github.com/apache/flink/pull/20082#discussion_r910639243
##
flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/ExecutionVertex.java:
##
@@ -241,32 +254,36 @@ public Execution getCurrentExecutionAttempt() {
SteNicholas commented on PR #268:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/268#issuecomment-1170791818
@gyfora, @morhidi, thanks for your suggestions. I will address above
comments today.
--
This is an automated message from the Apache Git Service.
To respond to the
[
https://issues.apache.org/jira/browse/FLINK-28289?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee updated FLINK-28289:
-
Priority: Minor (was: Major)
> Introduce Spark2 Reader for table store
> --
SteNicholas commented on PR #104:
URL:
https://github.com/apache/flink-table-store/pull/104#issuecomment-1170787052
@JingsongLi, I have addressed above comments and the failure of the
UTCase/ITCase isn't related to this change. PTAL.
--
This is an automated message from the Apache Git Se
JingsongLi commented on code in PR #182:
URL: https://github.com/apache/flink-table-store/pull/182#discussion_r910597345
##
flink-table-store-core/src/main/java/org/apache/flink/table/store/file/mergetree/compact/KeyValueCompactManager.java:
##
@@ -0,0 +1,108 @@
+/*
+ * Licensed
JingsongLi commented on PR #180:
URL:
https://github.com/apache/flink-table-store/pull/180#issuecomment-1170748014
> With this change we cannot support formats which are already supported by
Flink. We'll need built-in parquet format support.
Yes, we should do more for parquet support
[
https://issues.apache.org/jira/browse/FLINK-28276?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17560815#comment-17560815
]
luoyuxia edited comment on FLINK-28276 at 6/30/22 4:25 AM:
---
It
[
https://issues.apache.org/jira/browse/FLINK-28276?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17560815#comment-17560815
]
luoyuxia edited comment on FLINK-28276 at 6/30/22 4:25 AM:
---
It
[
https://issues.apache.org/jira/browse/FLINK-28276?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17560815#comment-17560815
]
luoyuxia edited comment on FLINK-28276 at 6/30/22 4:24 AM:
---
It
[
https://issues.apache.org/jira/browse/FLINK-28276?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17560815#comment-17560815
]
luoyuxia edited comment on FLINK-28276 at 6/30/22 4:24 AM:
---
It
[
https://issues.apache.org/jira/browse/FLINK-28276?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17560815#comment-17560815
]
luoyuxia commented on FLINK-28276:
--
It's about iceberg sdk. I'm not familar with it. An
zoltar9264 commented on code in PR #20093:
URL: https://github.com/apache/flink/pull/20093#discussion_r910588233
##
flink-dstl/flink-dstl-dfs/src/main/java/org/apache/flink/changelog/fs/StateChangeFsUploader.java:
##
@@ -83,14 +88,15 @@ public StateChangeFsUploader(
}
zoltar9264 commented on code in PR #20093:
URL: https://github.com/apache/flink/pull/20093#discussion_r910588233
##
flink-dstl/flink-dstl-dfs/src/main/java/org/apache/flink/changelog/fs/StateChangeFsUploader.java:
##
@@ -83,14 +88,15 @@ public StateChangeFsUploader(
}
[
https://issues.apache.org/jira/browse/FLINK-26718?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
luoyuxia resolved FLINK-26718.
--
Resolution: Not A Problem
[~kunghsu] I think we can close this issue. Feel free to open it again if yo
zoltar9264 commented on code in PR #20093:
URL: https://github.com/apache/flink/pull/20093#discussion_r910587799
##
flink-dstl/flink-dstl-dfs/src/main/java/org/apache/flink/changelog/fs/StateChangeFsUploader.java:
##
@@ -83,14 +88,15 @@ public StateChangeFsUploader(
}
[
https://issues.apache.org/jira/browse/FLINK-28208?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17560811#comment-17560811
]
luoyuxia commented on FLINK-28208:
--
[~Jiangang] Thanks for reporting it. I think the ma
flinkbot commented on PR #20109:
URL: https://github.com/apache/flink/pull/20109#issuecomment-1170731187
## CI report:
* fe2dbd0daff1122d642652399532fc01d10caea2 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
zoltar9264 commented on code in PR #20093:
URL: https://github.com/apache/flink/pull/20093#discussion_r910585869
##
flink-dstl/flink-dstl-dfs/src/main/java/org/apache/flink/changelog/fs/StateChangeFsUploader.java:
##
@@ -54,6 +55,8 @@
public class StateChangeFsUploader implemen
zhuzhurk commented on code in PR #20082:
URL: https://github.com/apache/flink/pull/20082#discussion_r910585733
##
flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/SpeculativeExecutionJobVertex.java:
##
@@ -0,0 +1,67 @@
+/*
+ * Licensed to the Apache Software F
[
https://issues.apache.org/jira/browse/FLINK-24871?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
luoyuxia resolved FLINK-24871.
--
Resolution: Resolved
> Flink SQL hive reports IndexOutOfBoundsException when using trim in where
> cl
zhuzhurk commented on code in PR #20082:
URL: https://github.com/apache/flink/pull/20082#discussion_r910584438
##
flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/SpeculativeExecutionJobVertex.java:
##
@@ -0,0 +1,67 @@
+/*
+ * Licensed to the Apache Software F
[
https://issues.apache.org/jira/browse/FLINK-28306?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-28306:
---
Labels: pull-request-available (was: )
> Support get table statistic for Hive partition tab
luoyuxia opened a new pull request, #20109:
URL: https://github.com/apache/flink/pull/20109
## What is the purpose of the change
To support get table statistic for Hive partition table
## Brief change log
- When it's hive partition table, list all the statistic in p
[
https://issues.apache.org/jira/browse/FLINK-25727?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
luoyuxia resolved FLINK-25727.
--
Resolution: Fixed
> Flink SQL convert constant string to char type which cause hive udtf
> json_tuple
LadyForest commented on code in PR #183:
URL: https://github.com/apache/flink-table-store/pull/183#discussion_r910581992
##
flink-table-store-connector/src/main/java/org/apache/flink/table/store/connector/sink/StoreWriteOperator.java:
##
@@ -0,0 +1,236 @@
+/*
+ * Licensed to the
[
https://issues.apache.org/jira/browse/FLINK-28276?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17560806#comment-17560806
]
wei edited comment on FLINK-28276 at 6/30/22 3:47 AM:
--
Thanks! I th
LadyForest commented on code in PR #183:
URL: https://github.com/apache/flink-table-store/pull/183#discussion_r910579852
##
flink-table-store-connector/src/main/java/org/apache/flink/table/store/connector/sink/StoreWriteOperator.java:
##
@@ -0,0 +1,236 @@
+/*
+ * Licensed to the
[
https://issues.apache.org/jira/browse/FLINK-28276?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17560806#comment-17560806
]
wei commented on FLINK-28276:
-
Thanks! I think this is the cause of the problem. I create ta
zhuzhurk commented on code in PR #20082:
URL: https://github.com/apache/flink/pull/20082#discussion_r910576592
##
flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/ExecutionVertex.java:
##
@@ -336,57 +357,56 @@ public void resetForNewExecution() {
}
wangyang0918 commented on code in PR #20056:
URL: https://github.com/apache/flink/pull/20056#discussion_r910575170
##
flink-kubernetes/src/main/java/org/apache/flink/kubernetes/kubeclient/decorators/InitTaskManagerDecorator.java:
##
@@ -149,7 +153,16 @@ private Container decorat
[
https://issues.apache.org/jira/browse/FLINK-27597?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
luoyuxia updated FLINK-27597:
-
Summary: Support get column statistic for Hive paritioned table (was: Get
statistic for Hive paritioned
luoyuxia created FLINK-28306:
Summary: Support get table statistic for Hive partition table
Key: FLINK-28306
URL: https://issues.apache.org/jira/browse/FLINK-28306
Project: Flink
Issue Type: Sub-
zhuzhurk commented on code in PR #20056:
URL: https://github.com/apache/flink/pull/20056#discussion_r910569216
##
flink-kubernetes/src/test/java/org/apache/flink/kubernetes/kubeclient/decorators/InitTaskManagerDecoratorTest.java:
##
@@ -179,11 +179,24 @@ void testMainContainerPo
wanglijie95 commented on code in PR #20056:
URL: https://github.com/apache/flink/pull/20056#discussion_r910568148
##
flink-core/src/main/java/org/apache/flink/configuration/TaskManagerOptionsInternal.java:
##
@@ -32,4 +32,15 @@ public class TaskManagerOptionsInternal {
[
https://issues.apache.org/jira/browse/FLINK-28276?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17560802#comment-17560802
]
luoyuxia commented on FLINK-28276:
--
The picture isn't completed so that I can't see the
[
https://issues.apache.org/jira/browse/FLINK-28276?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17560802#comment-17560802
]
luoyuxia edited comment on FLINK-28276 at 6/30/22 3:12 AM:
---
Th
wanglijie95 commented on code in PR #20056:
URL: https://github.com/apache/flink/pull/20056#discussion_r910566431
##
flink-kubernetes/src/main/java/org/apache/flink/kubernetes/kubeclient/decorators/InitTaskManagerDecorator.java:
##
@@ -149,7 +153,16 @@ private Container decorate
6591812 commented on PR #20072:
URL: https://github.com/apache/flink/pull/20072#issuecomment-1170700134
@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 #20108:
URL: https://github.com/apache/flink/pull/20108#issuecomment-1170696790
## CI report:
* 4aa7acbc536b1c168b0de658664e4e4e0c1343c0 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
pltbkd opened a new pull request, #20108:
URL: https://github.com/apache/flink/pull/20108
## What is the purpose of the change
There's a bug that NetworkBufferPool#getRequestedSegmentsUsage may throw
ArithmeticException if the pool is initialized without any buffers. It may
cause oth
[
https://issues.apache.org/jira/browse/FLINK-28240?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-28240:
---
Labels: pull-request-available (was: )
> NettyShuffleMetricFactory#RequestedMemoryUsageMetr
zhuzhurk commented on code in PR #20056:
URL: https://github.com/apache/flink/pull/20056#discussion_r910559720
##
flink-core/src/main/java/org/apache/flink/configuration/TaskManagerOptionsInternal.java:
##
@@ -32,4 +32,15 @@ public class TaskManagerOptionsInternal {
tsreaper commented on code in PR #178:
URL: https://github.com/apache/flink-table-store/pull/178#discussion_r910559342
##
flink-table-store-core/src/main/java/org/apache/flink/table/store/file/data/DataFileWriter.java:
##
@@ -105,32 +106,60 @@ public DataFilePathFactory pathFact
tsreaper commented on code in PR #179:
URL: https://github.com/apache/flink-table-store/pull/179#discussion_r910558828
##
flink-table-store-codegen/src/main/scala/org.apache.flink.table.store.codegen/ExprCodeGenerator.scala:
##
@@ -0,0 +1,171 @@
+/*
+
tsreaper commented on code in PR #180:
URL: https://github.com/apache/flink-table-store/pull/180#discussion_r910557571
##
flink-table-store-format/src/main/java/org/apache/flink/table/store/format/avro/AvroFileFormat.java:
##
@@ -19,31 +19,161 @@
package org.apache.flink.table.
LadyForest commented on code in PR #183:
URL: https://github.com/apache/flink-table-store/pull/183#discussion_r910558149
##
flink-table-store-kafka/src/main/java/org/apache/flink/table/store/kafka/KafkaSinkFunction.java:
##
@@ -0,0 +1,76 @@
+/*
+ * Licensed to the Apache Softwar
wangyang0918 commented on code in PR #20056:
URL: https://github.com/apache/flink/pull/20056#discussion_r910557934
##
flink-kubernetes/src/main/java/org/apache/flink/kubernetes/kubeclient/decorators/InitTaskManagerDecorator.java:
##
@@ -149,7 +153,16 @@ private Container decorat
zhuzhurk commented on code in PR #20056:
URL: https://github.com/apache/flink/pull/20056#discussion_r910557929
##
flink-core/src/main/java/org/apache/flink/configuration/TaskManagerOptionsInternal.java:
##
@@ -32,4 +32,15 @@ public class TaskManagerOptionsInternal {
[
https://issues.apache.org/jira/browse/FLINK-28033?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17560796#comment-17560796
]
YeAble commented on FLINK-28033:
hi [~Weijie Guo] , i find this problem when in `over wi
lindong28 merged PR #124:
URL: https://github.com/apache/flink-ml/pull/124
--
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
lindong28 commented on PR #124:
URL: https://github.com/apache/flink-ml/pull/124#issuecomment-1170686163
Thanks for the PR. LGTM.
--
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 comm
[
https://issues.apache.org/jira/browse/FLINK-20392?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17560793#comment-17560793
]
Yang Wang commented on FLINK-20392:
---
Thanks [~martijnvisser] for adding the K8s relate
[
https://issues.apache.org/jira/browse/FLINK-28276?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17560792#comment-17560792
]
wei commented on FLINK-28276:
-
I didn't specify the input format when creating the table, so
[
https://issues.apache.org/jira/browse/FLINK-28276?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
wei updated FLINK-28276:
Attachment: image-2022-06-30-10-36-17-075.png
> org.apache.flink.connectors.hive.FlinkHiveException: Unable to ins
lindong28 merged PR #123:
URL: https://github.com/apache/flink-ml/pull/123
--
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-27586?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Huang Xingbo resolved FLINK-27586.
--
Assignee: Juntao Hu
Resolution: Done
Merged into master via dfdf7afb047d1b8af581883bf208
[
https://issues.apache.org/jira/browse/FLINK-27586?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Huang Xingbo updated FLINK-27586:
-
Affects Version/s: 1.16.0
(was: 1.15.0)
> Support non-keyed co-broadc
[
https://issues.apache.org/jira/browse/FLINK-26051?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17560786#comment-17560786
]
godfrey he commented on FLINK-26051:
[~qingyue] Thanks for the investigation, assign
HuangXingBo closed pull request #19878: [FLINK-27586][python] Support non-keyed
co-broadcast processing
URL: https://github.com/apache/flink/pull/19878
--
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 t
1 - 100 of 314 matches
Mail list logo
