Vancior commented on code in PR #20040:
URL: https://github.com/apache/flink/pull/20040#discussion_r907051932
##
flink-python/pyflink/fn_execution/coder_impl_slow.py:
##
@@ -834,3 +837,26 @@ def _filter_data_views(self, row):
row[i][spec.field_index] = None
yunfengzhou-hub opened a new pull request, #120:
URL: https://github.com/apache/flink-ml/pull/120
This PR marks Flink ML 2.0's document as outdated, provided that the
document of Flink ML 2.1 is published.
--
This is an automated message from the Apache Git Service.
To respond to the mess
libenchao commented on code in PR #14376:
URL: https://github.com/apache/flink/pull/14376#discussion_r907059256
##
flink-formats/flink-protobuf/src/main/java/org/apache/flink/formats/protobuf/PbCodegenAppender.java:
##
@@ -0,0 +1,58 @@
+/*
+ * Licensed to the Apache Software Fou
wanglijie95 opened a new pull request, #20079:
URL: https://github.com/apache/flink/pull/20079
## What is the purpose of the change
Introduce BlocklistHandler
## Verifying this change
Unit tests.
## Does this pull request potentially affect one of the following par
1996fanrui commented on PR #20075:
URL: https://github.com/apache/flink/pull/20075#issuecomment-1167003999
Hi @pnowojski @akalash , I have submitted the task3 of the overdraft buffer,
that is, disable overdraft buffer for LegacySource. Please help review in your
free time, thanks.
--
Thi
[
https://issues.apache.org/jira/browse/FLINK-28100?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser closed FLINK-28100.
--
Resolution: Not A Problem
Please ask these type of questio
> rocketmq-flink checkpoint
>
[
https://issues.apache.org/jira/browse/FLINK-28100?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17559059#comment-17559059
]
Martijn Visser edited comment on FLINK-28100 at 6/27/22 7:47 AM:
-
[
https://issues.apache.org/jira/browse/FLINK-28143?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-28143:
---
Labels: pull-request-available (was: )
> Introduce BlocklistHandler
> -
[
https://issues.apache.org/jira/browse/FLINK-28205?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser closed FLINK-28205.
--
Resolution: Duplicate
> memory leak in the timing flush of the jdbc-connector
> --
flinkbot commented on PR #20079:
URL: https://github.com/apache/flink/pull/20079#issuecomment-1167007602
## CI report:
* 4e14674d225f6ec980382041d6b4ddde5df3121a UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-28258?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu reassigned FLINK-28258:
---
Assignee: Zhu Zhu
> Introduce ExecutionHistory to host historical executions for each execution
>
yunfengzhou-hub commented on code in PR #118:
URL: https://github.com/apache/flink-ml/pull/118#discussion_r907051827
##
flink-ml-benchmark/src/main/java/org/apache/flink/ml/benchmark/datagenerator/common/ColsWithLabelGenerator.java:
##
@@ -0,0 +1,123 @@
+/*
+ * Licensed to the A
Zhu Zhu created FLINK-28258:
---
Summary: Introduce ExecutionHistory to host historical executions
for each execution vertex
Key: FLINK-28258
URL: https://issues.apache.org/jira/browse/FLINK-28258
Project: Fli
zhuzhurk opened a new pull request, #20080:
URL: https://github.com/apache/flink/pull/20080
…executions for each execution vertex
## What is the purpose of the change
With speculative execution, tracking prior executions in an
EvictingBoundedList does not work. This is because
[
https://issues.apache.org/jira/browse/FLINK-28258?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-28258:
---
Labels: pull-request-available (was: )
> Introduce ExecutionHistory to host historical exec
morhidi commented on code in PR #280:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/280#discussion_r907100122
##
flink-kubernetes-operator/src/main/resources/log4j2.properties:
##
@@ -24,3 +24,6 @@ appender.console.name = ConsoleAppender
appender.console.type =
gyfora commented on PR #187:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/187#issuecomment-1167018800
This can be closed I think, it is included in your other PR
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHu
flinkbot commented on PR #20080:
URL: https://github.com/apache/flink/pull/20080#issuecomment-1167016783
## CI report:
* 8c81b16d2b5efe4a78a455e8ddae83f60289bd73 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
HuangXingBo commented on code in PR #19140:
URL: https://github.com/apache/flink/pull/19140#discussion_r907055031
##
flink-python/pyflink/table/types.py:
##
@@ -2007,6 +1870,15 @@ def _to_java_data_type(data_type: DataType):
fields = [JDataTypes.FIELD(f.name, _to_java_d
mbalassi commented on PR #555:
URL: https://github.com/apache/flink-web/pull/555#issuecomment-1167034458
LGTM, built locally.
--
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.
dianfu commented on code in PR #20029:
URL: https://github.com/apache/flink/pull/20029#discussion_r906937708
##
flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/pattern/Pattern.java:
##
@@ -579,6 +662,21 @@ private void checkIfPreviousPatternGreedy() {
}
gyfora commented on code in PR #280:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/280#discussion_r907108951
##
flink-kubernetes-operator/src/main/resources/log4j2.properties:
##
@@ -24,3 +24,6 @@ appender.console.name = ConsoleAppender
appender.console.type =
Robert Metzger created FLINK-28259:
--
Summary: flink-parquet doesn't compile on M1 mac without rosetta
Key: FLINK-28259
URL: https://issues.apache.org/jira/browse/FLINK-28259
Project: Flink
I
[
https://issues.apache.org/jira/browse/FLINK-28259?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17559068#comment-17559068
]
Robert Metzger commented on FLINK-28259:
Prototc 3.21.2 provides a proper aarch6
gyfora commented on PR #274:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/274#issuecomment-1167041418
If no more comments @Aitozi I will merge this
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
dianfu commented on code in PR #20029:
URL: https://github.com/apache/flink/pull/20029#discussion_r906937708
##
flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/pattern/Pattern.java:
##
@@ -579,6 +662,21 @@ private void checkIfPreviousPatternGreedy() {
}
[
https://issues.apache.org/jira/browse/FLINK-28259?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-28259:
---
Labels: pull-request-available (was: )
> flink-parquet doesn't compile on M1 mac without ro
[
https://issues.apache.org/jira/browse/FLINK-28134?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-28134:
---
Labels: pull-request-available (was: )
> Introduce SpeculativeExecutionVertex
> ---
zhuzhurk opened a new pull request, #20082:
URL: https://github.com/apache/flink/pull/20082
## What is the purpose of the change
SpeculativeExecutionVertex will be used if speculative execution is enabled,
as a replacement of ExecutionVertex to form an ExecutionGraph. The core
differ
Robert Metzger created FLINK-28260:
--
Summary: flink-runtime-web fails to execute "npm ci" on Apple
Silicon (arm64) without rosetta
Key: FLINK-28260
URL: https://issues.apache.org/jira/browse/FLINK-28260
flinkbot commented on PR #20082:
URL: https://github.com/apache/flink/pull/20082#issuecomment-1167059342
## CI report:
* 62367eb46528dffe7d0749f8ade0351bf53e5a16 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
flinkbot commented on PR #20081:
URL: https://github.com/apache/flink/pull/20081#issuecomment-1167047194
## CI report:
* 3e4136848ec91258630c23a52a7cb8a60f2c784b UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
morhidi commented on PR #281:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/281#issuecomment-1167073080
Nice job, @tweise! I was wondering if we could/should make the Reason field
part of the FlinkResourceListener API? If we do so a call control layer could
leverage it and
JackWangCS commented on code in PR #20066:
URL: https://github.com/apache/flink/pull/20066#discussion_r907144799
##
flink-yarn/src/main/java/org/apache/flink/yarn/YarnClusterDescriptor.java:
##
@@ -1294,7 +1294,7 @@ private void removeLocalhostBindHostSetting(
private void
JackWangCS commented on PR #20066:
URL: https://github.com/apache/flink/pull/20066#issuecomment-1167079827
> @JackWangCS not sure where are you w/ the HBase part but plz have a look
how I've changed the API and the manager.
Thanks for the reminder, I think I could wait the Hadoop FS p
HuangXingBo closed pull request #20078: [FLINK-28195][python] Annotate
Python3.6 as deprecated in PyFlink 1.16
URL: https://github.com/apache/flink/pull/20078
--
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-28195?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Huang Xingbo closed FLINK-28195.
Resolution: Done
Merged into master via 459711bfd0efac85761b008031801857f60bf479
> Annotate Pytho
Aitozi commented on code in PR #274:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/274#discussion_r906991319
##
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/reconciler/deployment/AbstractFlinkResourceReconciler.java:
##
@@ -0,0 +1
gyfora merged PR #280:
URL: https://github.com/apache/flink-kubernetes-operator/pull/280
--
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
gyfora commented on code in PR #274:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/274#discussion_r907153684
##
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/reconciler/deployment/AbstractFlinkResourceReconciler.java:
##
@@ -0,0 +1
[
https://issues.apache.org/jira/browse/FLINK-28008?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora closed FLINK-28008.
--
Resolution: Fixed
merged to main 6a4e6a5edb386675fede2790b81e31cdbcb2952c
> Can not get secondary res
[
https://issues.apache.org/jira/browse/FLINK-28237?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17558979#comment-17558979
]
Huang Xingbo edited comment on FLINK-28237 at 6/27/22 9:10 AM:
---
Aitozi commented on code in PR #274:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/274#discussion_r907159561
##
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/reconciler/deployment/AbstractFlinkResourceReconciler.java:
##
@@ -0,0 +1
zhipeng93 merged PR #120:
URL: https://github.com/apache/flink-ml/pull/120
--
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-28148?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17559081#comment-17559081
]
Zichen Liu commented on FLINK-28148:
[~dianfu] [~hxbks2ks] Apologies for the late re
zhipeng93 merged PR #119:
URL: https://github.com/apache/flink-ml/pull/119
--
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
zhoulii commented on code in PR #20080:
URL: https://github.com/apache/flink/pull/20080#discussion_r907160500
##
flink-tests/src/test/java/org/apache/flink/test/runtime/DefaultSchedulerLocalRecoveryITCase.java:
##
@@ -90,7 +90,9 @@ private void
assertNonLocalRecoveredTasksEqual
[
https://issues.apache.org/jira/browse/FLINK-26100?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhipeng Zhang updated FLINK-26100:
--
Issue Type: New Feature (was: Improvement)
> Set up Flink ML Document Website
> -
[
https://issues.apache.org/jira/browse/FLINK-28237?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhipeng Zhang updated FLINK-28237:
--
Parent: FLINK-26265
Issue Type: Sub-task (was: Improvement)
> Improve the flink-ml py
[
https://issues.apache.org/jira/browse/FLINK-28223?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17559082#comment-17559082
]
ConradJam commented on FLINK-28223:
---
Hi,[~matyas] I want to try this ticket,can you as
gaoyunhaii closed pull request #19961: [hotfix][runtime] Cleanup for the
temporary fix of FLINK-13063 which is completely solved by FLINK-16219
URL: https://github.com/apache/flink/pull/19961
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on
[
https://issues.apache.org/jira/browse/FLINK-27979?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17559085#comment-17559085
]
ConradJam commented on FLINK-27979:
---
I think we can define a cluster template and then
leonardBang merged PR #19741:
URL: https://github.com/apache/flink/pull/19741
--
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.a
[
https://issues.apache.org/jira/browse/FLINK-27794?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu resolved FLINK-27794.
Resolution: Fixed
> The primary key obtained from MySQL is incorrect by using MysqlCatalog
> -
yunfengzhou-hub opened a new pull request, #121:
URL: https://github.com/apache/flink-ml/pull/121
This PR is a continuation of #115 . It adds pyflink examples for Flink ML's
algorithms.
This PR also does the following:
- fixes a bug in `IndexToStringModel.java`
- fixes a bug in
[
https://issues.apache.org/jira/browse/FLINK-27794?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17558456#comment-17558456
]
Leonard Xu edited comment on FLINK-27794 at 6/27/22 9:26 AM:
-
[
https://issues.apache.org/jira/browse/FLINK-27794?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu updated FLINK-27794:
---
Fix Version/s: 1.15.2
> The primary key obtained from MySQL is incorrect by using MysqlCatalog
> ---
gyfora commented on code in PR #274:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/274#discussion_r907193815
##
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/reconciler/deployment/AbstractFlinkResourceReconciler.java:
##
@@ -0,0 +1
zhuzhurk commented on code in PR #20072:
URL: https://github.com/apache/flink/pull/20072#discussion_r907158982
##
flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/ExecutionVertex.java:
##
@@ -242,6 +242,10 @@ public Execution getCurrentExecutionAttempt() {
gaborgsomogyi commented on code in PR #20066:
URL: https://github.com/apache/flink/pull/20066#discussion_r907197501
##
flink-yarn/src/main/java/org/apache/flink/yarn/YarnClusterDescriptor.java:
##
@@ -1294,7 +1294,7 @@ private void removeLocalhostBindHostSetting(
private vo
dianfu commented on PR #19945:
URL: https://github.com/apache/flink/pull/19945#issuecomment-1167141994
@pengmide I only reviewed part of the PR as it is very huge and is different
to review. Is it possible to split it into separate PRs to make it easy to
review?
--
This is an automated m
[
https://issues.apache.org/jira/browse/FLINK-28223?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora reassigned FLINK-28223:
--
Assignee: Matyas Orhidi
> Add artifact-fetcher to the pod-template.yaml example
> ---
usamj closed pull request #187: [FLINK-27443] Create standalone mode parameters
and decorators for JM and TMs
URL: https://github.com/apache/flink-kubernetes-operator/pull/187
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and u
[
https://issues.apache.org/jira/browse/FLINK-26051?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17559102#comment-17559102
]
godfrey he commented on FLINK-26051:
[~qingyue] do you have any update?
> one sql h
EnriqueL8 commented on PR #15832:
URL: https://github.com/apache/flink/pull/15832#issuecomment-1167167537
Hey all, just found this amazing PR for fixing an issue that I have been
hitting for quite a long time. I'm running Flink 1.13.2 with Kube HA enabled
and filesystem storage.
I've
swuferhong commented on PR #20009:
URL: https://github.com/apache/flink/pull/20009#issuecomment-1167171931
>
Hi, Now TableTestBase not using juni5, and one of my test class extends
TableTestBase. So I think the best way to upgrade to juni5 should modify
TableTestBase first.
--
T
[
https://issues.apache.org/jira/browse/FLINK-28223?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17559104#comment-17559104
]
Matyas Orhidi commented on FLINK-28223:
---
[~gyfora] can you reassign it to [~Conrad
gyfora merged PR #274:
URL: https://github.com/apache/flink-kubernetes-operator/pull/274
--
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-28223?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora reassigned FLINK-28223:
--
Assignee: ConradJam (was: Matyas Orhidi)
> Add artifact-fetcher to the pod-template.yaml exa
swuferhong commented on code in PR #20008:
URL: https://github.com/apache/flink/pull/20008#discussion_r907230094
##
flink-formats/flink-parquet/src/test/java/org/apache/flink/formats/parquet/ParquetFilesystemStatisticsReportTest.java:
##
@@ -0,0 +1,242 @@
+/*
+ * Licensed to the
[
https://issues.apache.org/jira/browse/FLINK-28180?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora closed FLINK-28180.
--
Resolution: Fixed
merged to main 3a49555e49df780c4efa8ecd4b679c2895766e29
> Unify Application and Ses
[
https://issues.apache.org/jira/browse/FLINK-28150?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shengkai Fang reassigned FLINK-28150:
-
Assignee: Shengkai Fang
> Introduce the hiveserver2 endpoint and factory
>
[
https://issues.apache.org/jira/browse/FLINK-27280?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora closed FLINK-27280.
--
Resolution: Fixed
merged to main db38c3de786d7b9a67cb1c6586b4a53c0f2bdd4f
> Support rollback for sess
[
https://issues.apache.org/jira/browse/FLINK-28150?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shengkai Fang updated FLINK-28150:
--
Component/s: Connectors / Hive
Table SQL / Gateway
> Introduce the hiveserver
[
https://issues.apache.org/jira/browse/FLINK-25735?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17559107#comment-17559107
]
Zichen Liu commented on FLINK-25735:
Hi Sorry for the late response, I have been off
Matyas Orhidi created FLINK-28261:
-
Summary: Consider Using Dependent Resources for Ingress
Key: FLINK-28261
URL: https://issues.apache.org/jira/browse/FLINK-28261
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-25735?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17559121#comment-17559121
]
Zichen Liu commented on FLINK-25735:
Apologies again for the delay. Would [~martijnv
XComp commented on PR #15832:
URL: https://github.com/apache/flink/pull/15832#issuecomment-1167202834
@EnriqueL8 This PR made it into 1.13.1. With you using 1.13.2 I would say
it's a new issue and might be related to what @rmetzger came up with. It's hard
to come up with conclusions right a
[
https://issues.apache.org/jira/browse/FLINK-28161?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xintong Song reassigned FLINK-28161:
Assignee: Wencong Liu
> Introduce the session related API for REST endpoint
> ---
[
https://issues.apache.org/jira/browse/FLINK-27769?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xintong Song reassigned FLINK-27769:
Assignee: Wencong Liu
> Introduce the REST endpoint framework
> -
[
https://issues.apache.org/jira/browse/FLINK-28262?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17559123#comment-17559123
]
simenliuxing commented on FLINK-28262:
--
[~jark] can you take a look at it？
> The s
[
https://issues.apache.org/jira/browse/FLINK-28262?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
simenliuxing updated FLINK-28262:
-
Attachment: (was: image-2022-06-27-19-06-33-267.png)
> The select result does not match the
[
https://issues.apache.org/jira/browse/FLINK-28262?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
simenliuxing updated FLINK-28262:
-
Description:
sql is as follows:
{code:java}
CREATE TABLE source
(
int_one INT,
int_two I
gyfora commented on PR #555:
URL: https://github.com/apache/flink-web/pull/555#issuecomment-1167221631
@mbalassi could you Rebuild the HTML pages and merge this with that please?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub
simenliuxing created FLINK-28262:
Summary: The select result does not match the sink table
Key: FLINK-28262
URL: https://issues.apache.org/jira/browse/FLINK-28262
Project: Flink
Issue Type: I
[
https://issues.apache.org/jira/browse/FLINK-28262?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
simenliuxing updated FLINK-28262:
-
Attachment: image-2022-06-27-19-06-33-267.png
> The select result does not match the sink table
zhuzhurk commented on code in PR #20003:
URL: https://github.com/apache/flink/pull/20003#discussion_r907262950
##
flink-core/src/main/java/org/apache/flink/util/FlinkUserCodeClassLoaders.java:
##
@@ -131,8 +130,8 @@ public static class ParentFirstClassLoader extends
FlinkUserCo
[
https://issues.apache.org/jira/browse/FLINK-24850?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Arseniy Tashoyan updated FLINK-24850:
-
Affects Version/s: 1.15.0
> KafkaSinkBuilder: NullPointerException if bootstrap.servers
wanglijie95 commented on code in PR #20080:
URL: https://github.com/apache/flink/pull/20080#discussion_r907258779
##
flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/ExecutionVertex.java:
##
@@ -270,16 +269,9 @@ public TaskManagerLocation
getCurrentAssignedRe
[
https://issues.apache.org/jira/browse/FLINK-24851?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Arseniy Tashoyan updated FLINK-24851:
-
Affects Version/s: 1.15.0
> KafkaSourceBuilder: auto.offset.reset is ignored
> -
zhuzhurk commented on code in PR #20057:
URL: https://github.com/apache/flink/pull/20057#discussion_r907281806
##
flink-core/src/main/java/org/apache/flink/configuration/ConfigUtils.java:
##
@@ -155,5 +155,23 @@ public static Set>
getAllConfigOptions(Class configOptionsCla
[
https://issues.apache.org/jira/browse/FLINK-25420?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17559129#comment-17559129
]
RocMarshal commented on FLINK-25420:
Hi, [~jingge] [~martijnvisser] .
Would you mind
[
https://issues.apache.org/jira/browse/FLINK-25735?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser reassigned FLINK-25735:
--
Assignee: Zichen Liu
> Chinese Translation - Add documentation for KDS Async Sink
> -
[
https://issues.apache.org/jira/browse/FLINK-25735?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser reassigned FLINK-25735:
--
Assignee: DavidLiu (was: Zichen Liu)
> Chinese Translation - Add documentation for K
[
https://issues.apache.org/jira/browse/FLINK-25420?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17559129#comment-17559129
]
RocMarshal edited comment on FLINK-25420 at 6/27/22 11:35 AM:
[
https://issues.apache.org/jira/browse/FLINK-25420?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17559131#comment-17559131
]
Martijn Visser commented on FLINK-25420:
[~RocMarshal] It should only be the Dev
zhuzhurk commented on code in PR #20080:
URL: https://github.com/apache/flink/pull/20080#discussion_r907288015
##
flink-tests/src/test/java/org/apache/flink/test/runtime/DefaultSchedulerLocalRecoveryITCase.java:
##
@@ -90,7 +90,9 @@ private void
assertNonLocalRecoveredTasksEqua
zhuzhurk commented on code in PR #20080:
URL: https://github.com/apache/flink/pull/20080#discussion_r907288171
##
flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/ExecutionHistory.java:
##
@@ -0,0 +1,94 @@
+/*
+ * Licensed to the Apache Software Foundation (AS
[
https://issues.apache.org/jira/browse/FLINK-25735?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17559132#comment-17559132
]
Martijn Visser commented on FLINK-25735:
I've assigned it to the last person who
[
https://issues.apache.org/jira/browse/FLINK-27770?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17559133#comment-17559133
]
Shengkai Fang commented on FLINK-27770:
---
[~ana4] I have assigned it to you.
> Int
1 - 100 of 283 matches
Mail list logo
