[
https://issues.apache.org/jira/browse/FLINK-17049?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther closed FLINK-17049.
Fix Version/s: 1.12.0
Resolution: Fixed
Fixed in 1.12.0: 04141fd750173bcb8772e2e88802eeb686
[
https://issues.apache.org/jira/browse/FLINK-18890?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther reassigned FLINK-18890:
Assignee: Timo Walther
> Update AsyncTableFunctions to the new type system
>
[
https://issues.apache.org/jira/browse/FLINK-20208?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17234844#comment-17234844
]
Alexander Trushev commented on FLINK-20208:
---
Hello [~gaoyunhaii].
The second
rkhachatryan commented on a change in pull request #14052:
URL: https://github.com/apache/flink/pull/14052#discussion_r526307486
##
File path:
flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/consumer/RemoteInputChannelTest.java
##
@@ -1125,70 +1127,13
rkhachatryan commented on a change in pull request #14052:
URL: https://github.com/apache/flink/pull/14052#discussion_r526309425
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/RemoteInputChannel.java
##
@@ -98,14 +100,11 @@
rkhachatryan commented on pull request #14052:
URL: https://github.com/apache/flink/pull/14052#issuecomment-729858897
Thanks for reviewing @AHeise.
I've addressed your feedback, please take a look.
This is an automated mes
flinkbot edited a comment on pull request #14052:
URL: https://github.com/apache/flink/pull/14052#issuecomment-726216034
## CI report:
* 14e0929bf9cebd4db7c60c5928d71e631fb4ad47 UNKNOWN
* 4965e2e5cb1a2baebdb7e2f516df106a4a3f523f Azure:
[SUCCESS](https://dev.azure.com/apache-fl
flinkbot edited a comment on pull request #14068:
URL: https://github.com/apache/flink/pull/14068#issuecomment-726851708
## CI report:
* deefe94f7e88be11ad13c0a54dc526cc01fd9783 Azure:
[CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul
flinkbot edited a comment on pull request #14119:
URL: https://github.com/apache/flink/pull/14119#issuecomment-729643745
## CI report:
* 7e3e4a36e74746f22867587fbc589a94cfb1fb81 Azure:
[SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot edited a comment on pull request #14068:
URL: https://github.com/apache/flink/pull/14068#issuecomment-726851708
## CI report:
* deefe94f7e88be11ad13c0a54dc526cc01fd9783 Azure:
[CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul
flinkbot edited a comment on pull request #14120:
URL: https://github.com/apache/flink/pull/14120#issuecomment-729644511
## CI report:
* 7a0700585dc56e463bea46e46d85937562202717 Azure:
[SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot edited a comment on pull request #14052:
URL: https://github.com/apache/flink/pull/14052#issuecomment-726216034
## CI report:
* 14e0929bf9cebd4db7c60c5928d71e631fb4ad47 UNKNOWN
* 4965e2e5cb1a2baebdb7e2f516df106a4a3f523f Azure:
[SUCCESS](https://dev.azure.com/apache-fl
Benoît Paris created FLINK-20226:
Summary: Temporal Table Functions cannot be created with a view
reference
Key: FLINK-20226
URL: https://issues.apache.org/jira/browse/FLINK-20226
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-20226?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Benoît Paris updated FLINK-20226:
-
Description:
Temporal Table Functions fail to be created if the history side `Table` is
obtaine
sjwiesman commented on a change in pull request #14114:
URL: https://github.com/apache/flink/pull/14114#discussion_r526363456
##
File path: docs/dev/datastream_execution_mode.md
##
@@ -0,0 +1,246 @@
+---
+title: "Execution Mode (Batch/Streaming)"
+nav-id: datastream_execution_m
flinkbot edited a comment on pull request #13291:
URL: https://github.com/apache/flink/pull/13291#issuecomment-684180034
## CI report:
* 6ac74e1786b1e621009e89fe30ea5242c0e0c9d3 Azure:
[SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot edited a comment on pull request #14068:
URL: https://github.com/apache/flink/pull/14068#issuecomment-726851708
## CI report:
* 0df8a43230ab135903b5af9261c72b33daa52404 Azure:
[CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul
flinkbot edited a comment on pull request #14122:
URL: https://github.com/apache/flink/pull/14122#issuecomment-729690073
## CI report:
* 2e983422fb5c6e22b76cd2e59d67907e6ff97e9d Azure:
[SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot edited a comment on pull request #14121:
URL: https://github.com/apache/flink/pull/14121#issuecomment-729677642
## CI report:
* d015071071cc426c82961f748cbc06b2191d26a1 Azure:
[SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot edited a comment on pull request #13998:
URL: https://github.com/apache/flink/pull/13998#issuecomment-724001789
## CI report:
* 98fb6be3e33813d21dff02dfc527bef97c06c1b9 Azure:
[SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot edited a comment on pull request #14123:
URL: https://github.com/apache/flink/pull/14123#issuecomment-729713112
## CI report:
* 608956b4e60768a5218e235ce41c224a157ce962 Azure:
[SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
John Mathews created FLINK-20227:
Summary: Kafka transaction IDs exceeding limit
Key: FLINK-20227
URL: https://issues.apache.org/jira/browse/FLINK-20227
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-20227?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Mathews updated FLINK-20227:
-
Description:
Flink uses the task name to generate the transactionId for the kafka producers.
Se
[
https://issues.apache.org/jira/browse/FLINK-20227?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Mathews updated FLINK-20227:
-
Description:
Flink uses the task name to generate the transactionId for the kafka producers.
Se
flinkbot edited a comment on pull request #14068:
URL: https://github.com/apache/flink/pull/14068#issuecomment-726851708
## CI report:
* 0ce46be8b552e937db8fb1c193efe43c8ff1e477 Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot edited a comment on pull request #14052:
URL: https://github.com/apache/flink/pull/14052#issuecomment-726216034
## CI report:
* 14e0929bf9cebd4db7c60c5928d71e631fb4ad47 UNKNOWN
* a24deacbf6d88b856faba8add3a470e425451f7b Azure:
[SUCCESS](https://dev.azure.com/apache-fl
liqi316 created FLINK-20228:
---
Summary: ESsink accur thread blocked
Key: FLINK-20228
URL: https://issues.apache.org/jira/browse/FLINK-20228
Project: Flink
Issue Type: Bug
Components: API /
[
https://issues.apache.org/jira/browse/FLINK-20228?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
liqi316 updated FLINK-20228:
Description:
java.lang.Thread.State: BLOCKED (on object monitor)
at
org.apache.flink.streaming.runtime.t
[
https://issues.apache.org/jira/browse/FLINK-20228?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
liqi316 updated FLINK-20228:
Description:
I will write the data to es(es version is 5.6.8. and flink use
flink-connector-elasticsearch
[
https://issues.apache.org/jira/browse/FLINK-20228?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
liqi316 updated FLINK-20228:
Component/s: (was: API / Core)
Connectors / ElasticSearch
> ESsink accur thread block
zhouyongjin created FLINK-20229:
---
Summary: duplicate "for" security-kerberos doc
Key: FLINK-20229
URL: https://issues.apache.org/jira/browse/FLINK-20229
Project: Flink
Issue Type: Improvement
YongjinZhou opened a new pull request #14124:
URL: https://github.com/apache/flink/pull/14124
## What is the purpose of the change
remove ducplicate 'for'
[
https://issues.apache.org/jira/browse/FLINK-20229?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-20229:
---
Labels: pull-request-available (was: )
> duplicate "for" security-kerberos doc
> --
flinkbot commented on pull request #14124:
URL: https://github.com/apache/flink/pull/14124#issuecomment-730065209
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 pro
[
https://issues.apache.org/jira/browse/FLINK-17827?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17235100#comment-17235100
]
Thomas Thornton commented on FLINK-17827:
-
Hi, [~chesnay], I want to gain consen
[
https://issues.apache.org/jira/browse/FLINK-20190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17235101#comment-17235101
]
GaryGao commented on FLINK-20190:
-
Hi, [~aljoscha]，[~rmetzger]，would you please spare so
flinkbot edited a comment on pull request #14068:
URL: https://github.com/apache/flink/pull/14068#issuecomment-726851708
## CI report:
* 0ce46be8b552e937db8fb1c193efe43c8ff1e477 Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
[
https://issues.apache.org/jira/browse/FLINK-19687?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17235107#comment-17235107
]
xiaozilong commented on FLINK-19687:
[~jark] Thanks~
> Support to get execution pla
flinkbot edited a comment on pull request #14099:
URL: https://github.com/apache/flink/pull/14099#issuecomment-728904723
## CI report:
* 14881fe955909c3b715720a66d1b41b78fe98a36 Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot commented on pull request #14124:
URL: https://github.com/apache/flink/pull/14124#issuecomment-730073761
## CI report:
* ba1a5763fe0ecf2635e970d14d930bee75ac9265 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot r
[
https://issues.apache.org/jira/browse/FLINK-20218?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu updated FLINK-20218:
Affects Version/s: (was: 1.10.2)
1.10.3
> AttributeError: module 'urllib' has n
[
https://issues.apache.org/jira/browse/FLINK-20218?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17235109#comment-17235109
]
Huang Xingbo commented on FLINK-20218:
--
The reason for the problem through investig
liu created FLINK-20230:
---
Summary: PARTITIONED TABLE, INSERT INTO EMPTY VALUES, THROW
FileNotFoundException
Key: FLINK-20230
URL: https://issues.apache.org/jira/browse/FLINK-20230
Project: Flink
Issu
[
https://issues.apache.org/jira/browse/FLINK-20230?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
liu updated FLINK-20230:
Environment:
TABLE DDL:
CREATE TABLE IF NOT EXISTS test1 (
uid string,
truename string,
dt string
)
ROW FORM
[
https://issues.apache.org/jira/browse/FLINK-20230?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
liu updated FLINK-20230:
Description:
if table has PARTITIONED, USE SQL "INSERT INTO VALUES", WHEN THE VALUES IS
NULL, AND IT WILL THROW F
wuchong merged pull request #13900:
URL: https://github.com/apache/flink/pull/13900
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
[
https://issues.apache.org/jira/browse/FLINK-19949?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu closed FLINK-19949.
---
Resolution: Fixed
Fixed in master (1.12.0):
- afb239e311aad2a8237e8be001a12d8af102e2b2
- 8b2d0ace9b56f2639
JingsongLi merged pull request #13998:
URL: https://github.com/apache/flink/pull/13998
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-20062?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee closed FLINK-20062.
Assignee: Rui Li
Resolution: Fixed
master (1.12): cd833c2584810102723c49e6f0c5eb3b3f79311f
[
https://issues.apache.org/jira/browse/FLINK-19940?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Caizhi Weng updated FLINK-19940:
Attachment: multi-web-ui.png
> Task names on web UI should change when an operator chain is chaine
HuangXingBo opened a new pull request #14125:
URL: https://github.com/apache/flink/pull/14125
## What is the purpose of the change
*This pull request will import `urllib.parse` before importing `apache-beam`*
## Brief change log
- *import `urllib.parse` before impo
flinkbot edited a comment on pull request #14068:
URL: https://github.com/apache/flink/pull/14068#issuecomment-726851708
## CI report:
* 0ce46be8b552e937db8fb1c193efe43c8ff1e477 Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot edited a comment on pull request #14099:
URL: https://github.com/apache/flink/pull/14099#issuecomment-728904723
## CI report:
* 14881fe955909c3b715720a66d1b41b78fe98a36 Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot edited a comment on pull request #14124:
URL: https://github.com/apache/flink/pull/14124#issuecomment-730073761
## CI report:
* ba1a5763fe0ecf2635e970d14d930bee75ac9265 Azure:
[PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
[
https://issues.apache.org/jira/browse/FLINK-20218?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-20218:
---
Labels: pull-request-available (was: )
> AttributeError: module 'urllib' has no attribute '
flinkbot commented on pull request #14125:
URL: https://github.com/apache/flink/pull/14125#issuecomment-730084932
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 pro
[
https://issues.apache.org/jira/browse/FLINK-20062?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17235127#comment-17235127
]
Rui Li commented on FLINK-20062:
Thanks [~lzljs3620320] for merging the PR. I think the
[
https://issues.apache.org/jira/browse/FLINK-19940?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17235129#comment-17235129
]
Caizhi Weng commented on FLINK-19940:
-
[~roman_khachatryan] This is what is currentl
[
https://issues.apache.org/jira/browse/FLINK-20221?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xintong Song updated FLINK-20221:
-
Fix Version/s: 1.11.3
1.10.3
1.12.0
> DelimitedInputFormat
[
https://issues.apache.org/jira/browse/FLINK-20218?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17235132#comment-17235132
]
Dian Fu commented on FLINK-20218:
-
[~hxbks2ks] Thanks a lot for the investigation. +1 to
[
https://issues.apache.org/jira/browse/FLINK-20218?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17235132#comment-17235132
]
Dian Fu edited comment on FLINK-20218 at 11/19/20, 2:36 AM:
[
https://issues.apache.org/jira/browse/FLINK-20218?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu reassigned FLINK-20218:
---
Assignee: Huang Xingbo
> AttributeError: module 'urllib' has no attribute 'parse'
> ---
[
https://issues.apache.org/jira/browse/FLINK-20221?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17235133#comment-17235133
]
Xintong Song commented on FLINK-20221:
--
[~gyfora], thanks for reporting the issue.
godfreyhe commented on a change in pull request #13291:
URL: https://github.com/apache/flink/pull/13291#discussion_r526553328
##
File path:
flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/rules/logical/CorrelateSortToRankRule.scala
##
@
flinkbot commented on pull request #14125:
URL: https://github.com/apache/flink/pull/14125#issuecomment-730091045
## CI report:
* 8affa1758f97c6ff6a02e0fe9f815556820d864f UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot r
flinkbot edited a comment on pull request #14125:
URL: https://github.com/apache/flink/pull/14125#issuecomment-730091045
## CI report:
* 8affa1758f97c6ff6a02e0fe9f815556820d864f Travis:
[PENDING](https://travis-ci.com/github/flink-ci/flink/builds/202621275)
Bot comman
Junning Liang created FLINK-20231:
-
Summary: Sql UDTF subplan reuse on correlate
Key: FLINK-20231
URL: https://issues.apache.org/jira/browse/FLINK-20231
Project: Flink
Issue Type: Improvement
flinkbot edited a comment on pull request #14124:
URL: https://github.com/apache/flink/pull/14124#issuecomment-730073761
## CI report:
* ba1a5763fe0ecf2635e970d14d930bee75ac9265 Azure:
[SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
dianfu merged pull request #14125:
URL: https://github.com/apache/flink/pull/14125
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 t
[
https://issues.apache.org/jira/browse/FLINK-20218?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu closed FLINK-20218.
---
Resolution: Fixed
Fixed in release-1.10 via 2fbef47bed73d3847fd88a292802551fcef64050
> AttributeError: modu
wuchong commented on pull request #14105:
URL: https://github.com/apache/flink/pull/14105#issuecomment-730109204
Thanks @godfreyhe , this is another issue and has been tracked by
FLINK-20186. I think Timo has already been working on this.
Will merge this PR then.
wuchong merged pull request #14105:
URL: https://github.com/apache/flink/pull/14105
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
[
https://issues.apache.org/jira/browse/FLINK-20187?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu closed FLINK-20187.
---
Resolution: Fixed
Fixed in master (1.12.0): b4d885dc9cfc28d7a6cb2f58925cf072dc916b0b
> FactoryUtil#createTa
[
https://issues.apache.org/jira/browse/FLINK-20231?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu updated FLINK-20231:
Component/s: Table SQL / Planner
> Sql UDTF subplan reuse on correlate
> -
[
https://issues.apache.org/jira/browse/FLINK-20231?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17235157#comment-17235157
]
Jark Wu commented on FLINK-20231:
-
How do you execute these two INSERT INTO statement? D
flinkbot edited a comment on pull request #14099:
URL: https://github.com/apache/flink/pull/14099#issuecomment-728904723
## CI report:
* 58186e803854f0131df6eece718be8f64adc559d Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
[
https://issues.apache.org/jira/browse/FLINK-20231?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17235159#comment-17235159
]
Junning Liang commented on FLINK-20231:
---
[~jark] i used StreamTable to execute the
[
https://issues.apache.org/jira/browse/FLINK-20208?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alexander Trushev updated FLINK-20208:
--
Description:
Assume a job has StreamingFileSink with OnCheckpointRollingPolicy
In the
guoweiM commented on pull request #14120:
URL: https://github.com/apache/flink/pull/14120#issuecomment-730115130
Thanks @SteNicholas for opening this pr. In general the pr is good to me. I
just have some minor comments.
1. Provide more precise filtering. Currently it is fine that we
Myasuka commented on a change in pull request #43:
URL: https://github.com/apache/flink-docker/pull/43#discussion_r526583917
##
File path: docker-entrypoint.sh
##
@@ -93,21 +94,41 @@ prepare_job_manager_start() {
envsubst < "${CONF_FILE}" > "${CONF_FILE}.tmp" && mv "${CONF
[
https://issues.apache.org/jira/browse/FLINK-16585?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17235170#comment-17235170
]
Shengkai Fang commented on FLINK-16585:
---
I have reproduced the bug in release-1.10
[
https://issues.apache.org/jira/browse/FLINK-16585?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shengkai Fang closed FLINK-16585.
-
Resolution: Fixed
> Table program cannot be compiled.Cannot determine simple type name "com"
> -
[
https://issues.apache.org/jira/browse/FLINK-20230?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu updated FLINK-20230:
Component/s: (was: API / DataStream)
(was: API / DataSet)
Table S
[
https://issues.apache.org/jira/browse/FLINK-20230?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu updated FLINK-20230:
Fix Version/s: 1.12.0
> PARTITIONED TABLE, INSERT INTO EMPTY VALUES, THROW FileNotFoundException
> --
caozhen1937 opened a new pull request #14126:
URL: https://github.com/apache/flink/pull/14126
## What is the purpose of the change
Translate page 'upsert-kafka Connector' into Chinese.
## Brief change log
*docs/dev/table/connectors/upsert-kafka.zh.md*
*docs/de
[
https://issues.apache.org/jira/browse/FLINK-20204?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-20204:
---
Labels: pull-request-available (was: )
> Translate page 'upsert-kafka Connector' into Chine
flinkbot commented on pull request #14126:
URL: https://github.com/apache/flink/pull/14126#issuecomment-730126658
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 pro
flinkbot commented on pull request #14126:
URL: https://github.com/apache/flink/pull/14126#issuecomment-730132466
## CI report:
* 338b02c0b3c6a220ebba45f2b0553bb4bce8863e UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot r
[
https://issues.apache.org/jira/browse/FLINK-20137?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu updated FLINK-20137:
Description: Currently, the timestamp of the element isn't handled
correctly and will be dropped after by
[
https://issues.apache.org/jira/browse/FLINK-20137?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu updated FLINK-20137:
Summary: Handle the timestamp of element properly in Python DataStream API
(was: User cannot obtain the t
flinkbot edited a comment on pull request #14126:
URL: https://github.com/apache/flink/pull/14126#issuecomment-730132466
## CI report:
* 338b02c0b3c6a220ebba45f2b0553bb4bce8863e Azure:
[PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
Dian Fu created FLINK-20232:
---
Summary: Handle object reuse properly in the operators of Python
DataStream API
Key: FLINK-20232
URL: https://issues.apache.org/jira/browse/FLINK-20232
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-20231?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17235180#comment-17235180
]
Jark Wu commented on FLINK-20231:
-
[~Akihito Liang] could you share a full example which
[
https://issues.apache.org/jira/browse/FLINK-20231?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17235182#comment-17235182
]
Jark Wu commented on FLINK-20231:
-
I see, I think this is a known issue because the dige
[
https://issues.apache.org/jira/browse/FLINK-16585?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu updated FLINK-16585:
Fix Version/s: (was: 1.11.4)
(was: 1.10.3)
(was: 1.12.0)
wuchong commented on pull request #14126:
URL: https://github.com/apache/flink/pull/14126#issuecomment-730144107
cc @fsk119 , could you help to review this?
This is an automated message from the Apache Git Service.
To respond
dianfu closed pull request #14068:
URL: https://github.com/apache/flink/pull/14068
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 t
[
https://issues.apache.org/jira/browse/FLINK-20137?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-20137:
---
Labels: pull-request-available (was: )
> Handle the timestamp of element properly in Python
[
https://issues.apache.org/jira/browse/FLINK-20137?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu closed FLINK-20137.
---
Resolution: Fixed
Fixed in master(1.12.0) via 492965cb09f3be7432c88194920a0e54a340af02
> Handle the timesta
[
https://issues.apache.org/jira/browse/FLINK-20232?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu updated FLINK-20232:
Description: Currently, it doesn't consider object reuse in
PythonTimestampsAndWatermarksOperator. We shou
301 - 400 of 434 matches
Mail list logo
