[
https://issues.apache.org/jira/browse/FLINK-21093?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
godfrey he reassigned FLINK-21093:
--
Assignee: godfrey he
> Support StreamExecTableSource json serialization/deserialization
> ---
godfrey he created FLINK-21093:
--
Summary: Support StreamExecTableSource json
serialization/deserialization
Key: FLINK-21093
URL: https://issues.apache.org/jira/browse/FLINK-21093
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-21092?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
godfrey he reassigned FLINK-21092:
--
Assignee: godfrey he
> Introduce getJsonPlan, explainJsonPlan and executeJsonPlan in
> Tabl
godfrey he created FLINK-21092:
--
Summary: Introduce getJsonPlan, explainJsonPlan and
executeJsonPlan in TableEnvironmentInternal
Key: FLINK-21092
URL: https://issues.apache.org/jira/browse/FLINK-21092
P
godfrey he created FLINK-21091:
--
Summary: Support ExecNode json serialization/deserialization
Key: FLINK-21091
URL: https://issues.apache.org/jira/browse/FLINK-21091
Project: Flink
Issue Type: N
flinkbot edited a comment on pull request #14727:
URL: https://github.com/apache/flink/pull/14727#issuecomment-765189922
## CI report:
* 276c75f4fae477228e15f3f60278107859128fb6 Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
AHeise commented on a change in pull request #14721:
URL: https://github.com/apache/flink/pull/14721#discussion_r562439086
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/logger/NetworkActionsLogger.java
##
@@ -18,51 +18,89 @@
package org.apach
flinkbot edited a comment on pull request #14726:
URL: https://github.com/apache/flink/pull/14726#issuecomment-765189766
## CI report:
* 8b36c8a39b5485807f2b3cc50d24d39608294313 Azure:
[PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
AHeise commented on a change in pull request #14721:
URL: https://github.com/apache/flink/pull/14721#discussion_r562438971
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/logger/NetworkActionsLogger.java
##
@@ -18,51 +18,89 @@
package org.apach
fsk119 commented on pull request #14679:
URL: https://github.com/apache/flink/pull/14679#issuecomment-765201423
Thanks for your tips. I think I have already resolved your concerns.
This is an automated message from the Apache
flinkbot commented on pull request #14727:
URL: https://github.com/apache/flink/pull/14727#issuecomment-765189922
## CI report:
* 276c75f4fae477228e15f3f60278107859128fb6 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot r
flinkbot commented on pull request #14726:
URL: https://github.com/apache/flink/pull/14726#issuecomment-765189766
## CI report:
* 8b36c8a39b5485807f2b3cc50d24d39608294313 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot r
flinkbot edited a comment on pull request #14678:
URL: https://github.com/apache/flink/pull/14678#issuecomment-761905721
## CI report:
* cade20e85b29ca63c51383dca04976c1d9801042 UNKNOWN
* a4c68763883ef4f3c411fa606d0907ef334a6e76 Azure:
[FAILURE](https://dev.azure.com/apache-fl
shouweikun commented on pull request #14727:
URL: https://github.com/apache/flink/pull/14727#issuecomment-765184186
@flinkbot run azure
This is an automated message from the Apache Git Service.
To respond to the message, plea
flinkbot commented on pull request #14726:
URL: https://github.com/apache/flink/pull/14726#issuecomment-765180726
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 #14727:
URL: https://github.com/apache/flink/pull/14727#issuecomment-765180709
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 edited a comment on pull request #14678:
URL: https://github.com/apache/flink/pull/14678#issuecomment-761905721
## CI report:
* cade20e85b29ca63c51383dca04976c1d9801042 UNKNOWN
* e32796821c485c583a2b10b55d3f8b780971d357 Azure:
[FAILURE](https://dev.azure.com/apache-fl
[
https://issues.apache.org/jira/browse/FLINK-20935?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17269941#comment-17269941
]
yuemeng commented on FLINK-20935:
-
[~trohrmann], i had updated the pr, can u review it.
rmetzger commented on pull request #13602:
URL: https://github.com/apache/flink/pull/13602#issuecomment-765179789
I see, thanks for the update
This is an automated message from the Apache Git Service.
To respond to the messag
shouweikun opened a new pull request #14727:
URL: https://github.com/apache/flink/pull/14727
…uration to FileSystem connector
## What is the purpose of the change
give user access to configuring the sink parallelism of FileSystem.
## Brief change log
- add SI
[
https://issues.apache.org/jira/browse/FLINK-21026?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-21026:
---
Labels: pull-request-available (was: )
> Align column list specification with Hive in INSER
docete opened a new pull request #14726:
URL: https://github.com/apache/flink/pull/14726
…x with hive in INSERT statement
## What is the purpose of the change
HIVE-9481 allows column list specification in INSERT statement in Hive. And
the column list specification appears afte
[
https://issues.apache.org/jira/browse/FLINK-20977?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17269939#comment-17269939
]
Jun Zhang commented on FLINK-20977:
---
I found that USE CATALOG `mod` has the same pr
shouweikun commented on pull request #14007:
URL: https://github.com/apache/flink/pull/14007#issuecomment-765178244
A new Pr will be open instead of this pr
This is an automated message from the Apache Git Service.
To respond
shouweikun closed pull request #14007:
URL: https://github.com/apache/flink/pull/14007
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
becketqin commented on a change in pull request #14711:
URL: https://github.com/apache/flink/pull/14711#discussion_r562419345
##
File path:
flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/KafkaSourceEnumerator.java
##
@@
flinkbot edited a comment on pull request #14678:
URL: https://github.com/apache/flink/pull/14678#issuecomment-761905721
## CI report:
* cade20e85b29ca63c51383dca04976c1d9801042 UNKNOWN
* e32796821c485c583a2b10b55d3f8b780971d357 Azure:
[FAILURE](https://dev.azure.com/apache-fl
wuchong merged pull request #14723:
URL: https://github.com/apache/flink/pull/14723
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
becketqin commented on a change in pull request #14531:
URL: https://github.com/apache/flink/pull/14531#discussion_r562412668
##
File path:
flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/KafkaSourceBuilder.java
##
@@ -396,6 +396,11
wuchong merged pull request #14693:
URL: https://github.com/apache/flink/pull/14693
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
becketqin commented on pull request #13602:
URL: https://github.com/apache/flink/pull/13602#issuecomment-765169416
@rmetzger The PR was suspended to give priority to other features at that
point. We need to resume the work here. @Sxnan it looks that the patch has
conflict with the master n
flinkbot edited a comment on pull request #13912:
URL: https://github.com/apache/flink/pull/13912#issuecomment-721398037
This is an automated message from the Apache Git Service.
To respond to the message, please log on to Git
tzulitai closed pull request #191:
URL: https://github.com/apache/flink-statefun/pull/191
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
flinkbot commented on pull request #14713:
URL: https://github.com/apache/flink/pull/14713#issuecomment-764465565
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and
flinkbot edited a comment on pull request #14717:
URL: https://github.com/apache/flink/pull/14717#issuecomment-764599651
This is an automated message from the Apache Git Service.
To respond to the message, please log on to Git
flinkbot edited a comment on pull request #14699:
URL: https://github.com/apache/flink/pull/14699#issuecomment-763287840
This is an automated message from the Apache Git Service.
To respond to the message, please log on to Git
flinkbot edited a comment on pull request #14718:
URL: https://github.com/apache/flink/pull/14718#issuecomment-764610054
This is an automated message from the Apache Git Service.
To respond to the message, please log on to Git
LadyForest commented on a change in pull request #14687:
URL: https://github.com/apache/flink/pull/14687#discussion_r56238
##
File path:
flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/optimize/program/FlinkBatchProgram.scala
##
@@
tzulitai closed pull request #192:
URL: https://github.com/apache/flink-statefun/pull/192
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
flinkbot edited a comment on pull request #14692:
URL: https://github.com/apache/flink/pull/14692#issuecomment-762669595
This is an automated message from the Apache Git Service.
To respond to the message, please log on to Git
flinkbot edited a comment on pull request #13787:
URL: https://github.com/apache/flink/pull/13787#issuecomment-716285196
This is an automated message from the Apache Git Service.
To respond to the message, please log on to Git
HuangZhenQiu commented on pull request #13650:
URL: https://github.com/apache/flink/pull/13650#issuecomment-764945040
@danny0405 @wuchong
As I remember, there was a FLIP talking about the cumulative window. But I
can't find it right now. Would you please point me to the design doc? We h
[
https://issues.apache.org/jira/browse/FLINK-20977?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17269921#comment-17269921
]
孙铮 commented on FLINK-20977:
[~jark] I created a `mod` table and executed it successfully wi
flinkbot edited a comment on pull request #14675:
URL: https://github.com/apache/flink/pull/14675#issuecomment-761769906
## CI report:
* 76e878bbb4c4e2d71523a5a2eb993d083a4eb0c5 Azure:
[SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
aljoscha commented on a change in pull request #14719:
URL: https://github.com/apache/flink/pull/14719#discussion_r561991514
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/state/heap/StateTableFactory.java
##
@@ -22,18 +22,14 @@
import org.apache.flink.run
flinkbot commented on pull request #14723:
URL: https://github.com/apache/flink/pull/14723#issuecomment-764887269
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and
zentol merged pull request #14716:
URL: https://github.com/apache/flink/pull/14716
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
flinkbot edited a comment on pull request #14723:
URL: https://github.com/apache/flink/pull/14723#issuecomment-764896712
## CI report:
* d9e7722050ff0f1c751d3f734a39f20d4b43870f Azure:
[SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
[
https://issues.apache.org/jira/browse/FLINK-21049?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17269907#comment-17269907
]
谢波 commented on FLINK-21049:
[~jark]，hello jark，how to build the docs on win10。I get an erro
flinkbot edited a comment on pull request #14713:
URL: https://github.com/apache/flink/pull/14713#issuecomment-764480003
This is an automated message from the Apache Git Service.
To respond to the message, please log on to Git
wuchong commented on a change in pull request #14693:
URL: https://github.com/apache/flink/pull/14693#discussion_r561709274
##
File path: flink-formats/flink-json/src/test/resources/canal-data.txt
##
@@ -1,5 +1,5 @@
{"data":[{"id":"101","name":"scooter","description":"Small 2-
flinkbot commented on pull request #14711:
URL: https://github.com/apache/flink/pull/14711#issuecomment-764423225
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and
flinkbot edited a comment on pull request #14611:
URL: https://github.com/apache/flink/pull/14611#issuecomment-758104213
This is an automated message from the Apache Git Service.
To respond to the message, please log on to Git
wangyang0918 commented on pull request #14591:
URL: https://github.com/apache/flink/pull/14591#issuecomment-765097625
ping @blublinsky Could you please address the comments before merging?
This is an automated message from th
flinkbot edited a comment on pull request #14708:
URL: https://github.com/apache/flink/pull/14708#issuecomment-763516524
This is an automated message from the Apache Git Service.
To respond to the message, please log on to Git
flinkbot edited a comment on pull request #14725:
URL: https://github.com/apache/flink/pull/14725#issuecomment-765052802
This is an automated message from the Apache Git Service.
To respond to the message, please log on to Git
flinkbot commented on pull request #14717:
URL: https://github.com/apache/flink/pull/14717#issuecomment-764596260
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and
wuchong merged pull request #14702:
URL: https://github.com/apache/flink/pull/14702
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
HuangZhenQiu commented on pull request #14678:
URL: https://github.com/apache/flink/pull/14678#issuecomment-764968449
@rmetzger @zentol
Thanks for these comments. Please review it again after the build is green.
This is a
flinkbot commented on pull request #14719:
URL: https://github.com/apache/flink/pull/14719#issuecomment-764621386
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and
flinkbot edited a comment on pull request #14710:
URL: https://github.com/apache/flink/pull/14710#issuecomment-764262487
## CI report:
* da3f3f6a21306e3b4fa3cfc7b79ef34d825f5efb Azure:
[SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot edited a comment on pull request #14662:
URL: https://github.com/apache/flink/pull/14662#issuecomment-760769285
This is an automated message from the Apache Git Service.
To respond to the message, please log on to Git
flinkbot commented on pull request #14714:
URL: https://github.com/apache/flink/pull/14714#issuecomment-764526169
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and
flinkbot edited a comment on pull request #14695:
URL: https://github.com/apache/flink/pull/14695#issuecomment-762724470
This is an automated message from the Apache Git Service.
To respond to the message, please log on to Git
twalthr commented on pull request #14720:
URL: https://github.com/apache/flink/pull/14720#issuecomment-764693910
@wuchong could you help with a review here?
This is an automated message from the Apache Git Service.
To respond
wangyang0918 commented on a change in pull request #59:
URL: https://github.com/apache/flink-docker/pull/59#discussion_r561851637
##
File path: docker-entrypoint.sh
##
@@ -112,41 +111,26 @@ if [ "$1" = "help" ]; then
elif [ "$1" = "jobmanager" ]; then
args=("${args[@]:1}"
KarmaGYZ commented on a change in pull request #14647:
URL: https://github.com/apache/flink/pull/14647#discussion_r561489225
##
File path:
flink-core/src/main/java/org/apache/flink/configuration/ClusterOptions.java
##
@@ -111,6 +111,19 @@
.withDescription(
flinkbot edited a comment on pull request #14687:
URL: https://github.com/apache/flink/pull/14687#issuecomment-762573853
This is an automated message from the Apache Git Service.
To respond to the message, please log on to Git
flinkbot commented on pull request #14722:
URL: https://github.com/apache/flink/pull/14722#issuecomment-764825583
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and
blublinsky commented on pull request #14629:
URL: https://github.com/apache/flink/pull/14629#issuecomment-765023075
Thanks @wangyang0918,
This works great, I tested it on my app, and its fine. I have 2 questions:
- With this in place, you now have 2 ways for setting annotations, la
tillrohrmann closed pull request #14692:
URL: https://github.com/apache/flink/pull/14692
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
flinkbot edited a comment on pull request #14722:
URL: https://github.com/apache/flink/pull/14722#issuecomment-764831307
## CI report:
* d0df1e8780e5964c6fac844a6403d17b3ebab69b Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
zentol closed pull request #54:
URL: https://github.com/apache/flink-docker/pull/54
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
flinkbot edited a comment on pull request #14613:
URL: https://github.com/apache/flink/pull/14613#issuecomment-758462709
This is an automated message from the Apache Git Service.
To respond to the message, please log on to Git
SteNicholas commented on pull request #14659:
URL: https://github.com/apache/flink/pull/14659#issuecomment-764192618
@zhuzhurk , I have merged these commits into two commit and CI result is
successful. Please check it.
This
flinkbot edited a comment on pull request #14721:
URL: https://github.com/apache/flink/pull/14721#issuecomment-764731800
This is an automated message from the Apache Git Service.
To respond to the message, please log on to Git
RocMarshal edited a comment on pull request #14710:
URL: https://github.com/apache/flink/pull/14710#issuecomment-764632952
@XBaith @klion26 Could you help me to review this PR?
Thank you.
This is an automated message f
flinkbot edited a comment on pull request #14714:
URL: https://github.com/apache/flink/pull/14714#issuecomment-764548835
This is an automated message from the Apache Git Service.
To respond to the message, please log on to Git
SteNicholas commented on pull request #14693:
URL: https://github.com/apache/flink/pull/14693#issuecomment-764196958
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub
HuangZhenQiu commented on a change in pull request #14678:
URL: https://github.com/apache/flink/pull/14678#discussion_r562223668
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/FailureListenerFactory.java
##
@@ -0,0 +1,50 @@
+/*
+ * Licensed t
blublinsky edited a comment on pull request #14629:
URL: https://github.com/apache/flink/pull/14629#issuecomment-765023075
This is an automated message from the Apache Git Service.
To respond to the message, please log on to G
[
https://issues.apache.org/jira/browse/FLINK-15262?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jiangjie Qin closed FLINK-15262.
Resolution: Cannot Reproduce
> kafka connector doesn't read from beginning immediately when
> 'co
[
https://issues.apache.org/jira/browse/FLINK-15262?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17269873#comment-17269873
]
Jiangjie Qin commented on FLINK-15262:
--
I am closing this issue as not reproducible
[
https://issues.apache.org/jira/browse/FLINK-21006?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17269871#comment-17269871
]
Jark Wu edited comment on FLINK-21006 at 1/22/21, 6:10 AM:
---
It
[
https://issues.apache.org/jira/browse/FLINK-21006?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17269871#comment-17269871
]
Jark Wu commented on FLINK-21006:
-
It maybe related to this issue FLINK-19971.
Could y
flinkbot edited a comment on pull request #14724:
URL: https://github.com/apache/flink/pull/14724#issuecomment-765052737
This is an automated message from the Apache Git Service.
To respond to the message, please log on to Git
flinkbot commented on pull request #14721:
URL: https://github.com/apache/flink/pull/14721#issuecomment-764710661
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and
flinkbot edited a comment on pull request #14716:
URL: https://github.com/apache/flink/pull/14716#issuecomment-764599549
This is an automated message from the Apache Git Service.
To respond to the message, please log on to Git
flinkbot commented on pull request #14720:
URL: https://github.com/apache/flink/pull/14720#issuecomment-764695238
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and
flinkbot edited a comment on pull request #14715:
URL: https://github.com/apache/flink/pull/14715#issuecomment-764599442
This is an automated message from the Apache Git Service.
To respond to the message, please log on to Git
flinkbot commented on pull request #14710:
URL: https://github.com/apache/flink/pull/14710#issuecomment-764230111
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and
rkhachatryan commented on a change in pull request #13797:
URL: https://github.com/apache/flink/pull/13797#discussion_r562165994
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/state/CheckpointStorageFactory.java
##
@@ -0,0 +1,51 @@
+/*
+ * Licensed to the A
zentol merged pull request #14715:
URL: https://github.com/apache/flink/pull/14715
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
HuangXingBo commented on pull request #14717:
URL: https://github.com/apache/flink/pull/14717#issuecomment-764699035
the failed test has been fixed in
https://issues.apache.org/jira/browse/FLINK-21044
This is an automated me
wuchong commented on pull request #13650:
URL: https://github.com/apache/flink/pull/13650#issuecomment-765068701
@HuangZhenQiu , here is the link
https://cwiki.apache.org/confluence/display/FLINK/FLIP-145%3A+Support+SQL+windowing+table-valued+function
-
AHeise merged pull request #14704:
URL: https://github.com/apache/flink/pull/14704
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
tzulitai closed pull request #193:
URL: https://github.com/apache/flink-statefun/pull/193
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
wangyang0918 commented on a change in pull request #14692:
URL: https://github.com/apache/flink/pull/14692#discussion_r561516683
##
File path:
flink-kubernetes/src/main/java/org/apache/flink/kubernetes/KubernetesClusterDescriptor.java
##
@@ -112,18 +112,27 @@ public String get
flinkbot edited a comment on pull request #14719:
URL: https://github.com/apache/flink/pull/14719#issuecomment-764631410
This is an automated message from the Apache Git Service.
To respond to the message, please log on to Git
flinkbot commented on pull request #14725:
URL: https://github.com/apache/flink/pull/14725#issuecomment-765048526
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and
1 - 100 of 467 matches
Mail list logo
