[
https://issues.apache.org/jira/browse/FLINK-22815?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17354879#comment-17354879
]
Till Rohrmann commented on FLINK-22815:
---
We shipped UC with Flink {{1.11.0}}, righ
[
https://issues.apache.org/jira/browse/FLINK-22737?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17354878#comment-17354878
]
Timo Walther commented on FLINK-22737:
--
After thinking about this topic again, also
[
https://issues.apache.org/jira/browse/FLINK-22815?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski updated FLINK-22815:
---
Priority: Blocker (was: Critical)
> Disable unaligned checkpoints for broadcast partitionin
[
https://issues.apache.org/jira/browse/FLINK-22737?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17354876#comment-17354876
]
Leonard Xu commented on FLINK-22737:
* -1 for using *NULL* which will bring the thre
luoyuxia commented on a change in pull request #16015:
URL: https://github.com/apache/flink/pull/16015#discussion_r642821594
##
File path:
flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/catalog/hive/client/HiveShimLoader.java
##
@@ -49,6 +49,7 @@
luoyuxia commented on a change in pull request #16015:
URL: https://github.com/apache/flink/pull/16015#discussion_r642821594
##
File path:
flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/catalog/hive/client/HiveShimLoader.java
##
@@ -49,6 +49,7 @@
[
https://issues.apache.org/jira/browse/FLINK-22789?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17354857#comment-17354857
]
luoyuxia commented on FLINK-22789:
--
[~tigerhou] Thanks for your contribution, but ther
[
https://issues.apache.org/jira/browse/FLINK-22484?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ingo Bürk updated FLINK-22484:
--
Summary: Built-in functions for collections (was: Buit-in functions for
collections)
> Built-in func
flinkbot commented on pull request #16037:
URL: https://github.com/apache/flink/pull/16037#issuecomment-851863905
## CI report:
* 41d093ec05780cbaad85e6789abac24f6fa0af95 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot r
flinkbot edited a comment on pull request #15885:
URL: https://github.com/apache/flink/pull/15885#issuecomment-837001445
## CI report:
* 4c1a9dbb3034eb0ac880db84954b2c40fed365c2 UNKNOWN
* fc4cedd8a305e6cb1947d3ecdbced6c879b536e3 Azure:
[FAILURE](https://dev.azure.com/apache-fl
[
https://issues.apache.org/jira/browse/FLINK-22817?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
xingyuan cheng updated FLINK-22817:
---
Description:
Hello everyone
At present, there are codes that depend on hive in many places
twalthr edited a comment on pull request #16037:
URL: https://github.com/apache/flink/pull/16037#issuecomment-851859090
@lirui-apache Yes, having two commits would be better to review. I think we
are also disable spotless for Calcite copied classes. Ideally, we can also have
one commit for
twalthr commented on pull request #16037:
URL: https://github.com/apache/flink/pull/16037#issuecomment-851859090
@lirui-apache Yes, having two commits would be better to review. I think we
are also disable spotless for Calcite copied classes.
--
This is an automated message from the Apac
[
https://issues.apache.org/jira/browse/FLINK-22776?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17354851#comment-17354851
]
luoyuxia edited comment on FLINK-22776 at 6/1/21, 6:31 AM:
---
+1
[
https://issues.apache.org/jira/browse/FLINK-22776?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17354851#comment-17354851
]
luoyuxia commented on FLINK-22776:
--
+1
I think we can delete it.
You can sumit pr and
xingyuan cheng created FLINK-22817:
--
Summary: About flink1.13 hive integration Kafka SQL
Key: FLINK-22817
URL: https://issues.apache.org/jira/browse/FLINK-22817
Project: Flink
Issue Type: N
lirui-apache commented on pull request #16037:
URL: https://github.com/apache/flink/pull/16037#issuecomment-851855563
The copied code is formatted by spotless. Perhaps I should disable spotless
for this module, so that we can easily compare the diff between copied and
original hive files?
flinkbot commented on pull request #16037:
URL: https://github.com/apache/flink/pull/16037#issuecomment-851850302
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
JingsongLi commented on a change in pull request #13921:
URL: https://github.com/apache/flink/pull/13921#discussion_r642806420
##
File path:
flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/stream/StreamExecRank.java
##
@@ -207
[
https://issues.apache.org/jira/browse/FLINK-22812?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-22812:
---
Labels: pull-request-available (was: )
> Fix hive issues in sql-connector-hive jars
> -
lirui-apache opened a new pull request #16037:
URL: https://github.com/apache/flink/pull/16037
…o for hive 3.1.2
## What is the purpose of the change
Fix some hive issues in flink-sql-connector-hive-3.1.2
## Brief change log
- Fix HiveConf initializa
[
https://issues.apache.org/jira/browse/FLINK-22796?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xintong Song closed FLINK-22796.
Resolution: Fixed
Fixed via
- master (1.14): 59fd4c60f4ca664c4ba16480e9700e4f9bb9b8c0
- release-1.
[
https://issues.apache.org/jira/browse/FLINK-22796?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xintong Song updated FLINK-22796:
-
Fix Version/s: 1.13.2
1.14.0
> Update mem_setup_tm documentation
> --
[
https://issues.apache.org/jira/browse/FLINK-22796?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xintong Song updated FLINK-22796:
-
Priority: Major (was: Minor)
> Update mem_setup_tm documentation
>
[
https://issues.apache.org/jira/browse/FLINK-22796?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xintong Song updated FLINK-22796:
-
Affects Version/s: 1.13.1
> Update mem_setup_tm documentation
>
[
https://issues.apache.org/jira/browse/FLINK-22796?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xintong Song updated FLINK-22796:
-
Parent: (was: FLINK-19604)
Issue Type: Bug (was: Sub-task)
> Update mem_setup_tm do
xintongsong closed pull request #16016:
URL: https://github.com/apache/flink/pull/16016
--
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.
For queries about this service, pl
flinkbot edited a comment on pull request #15885:
URL: https://github.com/apache/flink/pull/15885#issuecomment-837001445
## CI report:
* 4c1a9dbb3034eb0ac880db84954b2c40fed365c2 UNKNOWN
* fc4cedd8a305e6cb1947d3ecdbced6c879b536e3 Azure:
[FAILURE](https://dev.azure.com/apache-fl
[
https://issues.apache.org/jira/browse/FLINK-22737?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17354813#comment-17354813
]
Ingo Bürk commented on FLINK-22737:
---
Just for completeness, this is how the SQL client
[
https://issues.apache.org/jira/browse/FLINK-22737?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ingo Bürk updated FLINK-22737:
--
Attachment: screenshot-2021-05-31_14-22-43.png
> Add support for CURRENT_WATERMARK to SQL
> --
flinkbot edited a comment on pull request #16029:
URL: https://github.com/apache/flink/pull/16029#issuecomment-851388620
## CI report:
* 2d98e97a844ff39a858c9500ff0a8cf49b8ca055 Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot edited a comment on pull request #14820:
URL: https://github.com/apache/flink/pull/14820#issuecomment-770327711
## CI report:
* d83bee7799051ef32e0f9ec9e26339b23b7dc057 UNKNOWN
* 045971a4900dc6798be00108c8e639e1c77fa18c Azure:
[CANCELED](https://dev.azure.com/apache-f
JasonLeeCoding commented on a change in pull request #16028:
URL: https://github.com/apache/flink/pull/16028#discussion_r642783697
##
File path:
flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/SqlClient.java
##
@@ -213,6 +214,16 @@ protected static voi
flinkbot edited a comment on pull request #16029:
URL: https://github.com/apache/flink/pull/16029#issuecomment-851388620
## CI report:
* 2d98e97a844ff39a858c9500ff0a8cf49b8ca055 Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot edited a comment on pull request #16016:
URL: https://github.com/apache/flink/pull/16016#issuecomment-850273330
## CI report:
* 8e520a025e21f3f14d789f9326fa5c7782336a43 Azure:
[SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
JasonLeeCoding commented on a change in pull request #16028:
URL: https://github.com/apache/flink/pull/16028#discussion_r642775785
##
File path:
flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/SqlExecutionException.java
##
@@ -0,0 +1,33 @@
+/*
+ * Lice
JasonLeeCoding commented on a change in pull request #16028:
URL: https://github.com/apache/flink/pull/16028#discussion_r642774290
##
File path:
flink-table/flink-sql-client/src/test/java/org/apache/flink/table/client/SqlClientTest.java
##
@@ -205,6 +205,17 @@ public void test
flinkbot edited a comment on pull request #16029:
URL: https://github.com/apache/flink/pull/16029#issuecomment-851388620
## CI report:
* 2d98e97a844ff39a858c9500ff0a8cf49b8ca055 Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot edited a comment on pull request #16016:
URL: https://github.com/apache/flink/pull/16016#issuecomment-850273330
## CI report:
* 8e520a025e21f3f14d789f9326fa5c7782336a43 Azure:
[SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot edited a comment on pull request #14820:
URL: https://github.com/apache/flink/pull/14820#issuecomment-770327711
## CI report:
* d83bee7799051ef32e0f9ec9e26339b23b7dc057 UNKNOWN
* 045971a4900dc6798be00108c8e639e1c77fa18c Azure:
[CANCELED](https://dev.azure.com/apache-f
[
https://issues.apache.org/jira/browse/FLINK-21905?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu reassigned FLINK-21905:
---
Assignee: luoyuxia
> Hive streaming source should use FIFO FileSplitAssigner instead of LIFO
>
[
https://issues.apache.org/jira/browse/FLINK-22689?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17354785#comment-17354785
]
Jark Wu edited comment on FLINK-22689 at 6/1/21, 4:11 AM:
--
Fixe
[
https://issues.apache.org/jira/browse/FLINK-22689?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu updated FLINK-22689:
Fix Version/s: 1.13.2
> Table API Documentation Row-Based Operations Example Fails
> -
[
https://issues.apache.org/jira/browse/FLINK-22689?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu closed FLINK-22689.
---
Fix Version/s: 1.14.0
Resolution: Fixed
Fixed in master: 997fa27e462c612f70401939c0fa9b217490dd73
>
wuchong merged pull request #16036:
URL: https://github.com/apache/flink/pull/16036
--
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.
For queries about this service, please
[
https://issues.apache.org/jira/browse/FLINK-21741?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu closed FLINK-21741.
---
Fix Version/s: 1.14.0
Assignee: Nicholas Jiang
Resolution: Fixed
Implemented in master: 6668
wuchong merged pull request #16010:
URL: https://github.com/apache/flink/pull/16010
--
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.
For queries about this service, please
wuchong commented on pull request #16010:
URL: https://github.com/apache/flink/pull/16010#issuecomment-851789262
The failed case is not related to this PR. Will merge this.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and
pensz removed a comment on pull request #16029:
URL: https://github.com/apache/flink/pull/16029#issuecomment-851783298
` mvn spotless:apply` test success in my local. I will check in an another
environment.
```
[INFO] Reactor Summary for Flink : 1.14-SNAPSHOT:
[INFO]
[INFO]
[
https://issues.apache.org/jira/browse/FLINK-21905?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17354781#comment-17354781
]
luoyuxia commented on FLINK-21905:
--
[~jark] Could you assign this issue to me?
> Hive
[
https://issues.apache.org/jira/browse/FLINK-22806?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17354780#comment-17354780
]
Jark Wu commented on FLINK-22806:
-
Hi [~yunta], could you post the link here so others c
zuston commented on pull request #15653:
URL: https://github.com/apache/flink/pull/15653#issuecomment-851787011
If you have time, could you help review again? Thanks @lirui-apache
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to Git
[
https://issues.apache.org/jira/browse/FLINK-21086?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Gao updated FLINK-21086:
Summary: Make checkpointBarrierHandler Support EndOfPartition (was:
CheckpointBarrierHandler Insert barri
tony810430 commented on pull request #16016:
URL: https://github.com/apache/flink/pull/16016#issuecomment-851785081
Hi @xintongsong
I have addressed your comments. what do you think for these update?
--
This is an automated message from the Apache Git Service.
To respond to the messag
pensz commented on pull request #16029:
URL: https://github.com/apache/flink/pull/16029#issuecomment-851783298
` mvn spotless:apply` test success in my local. I will check in an another
environment.
```
[INFO] Reactor Summary for Flink : 1.14-SNAPSHOT:
[INFO]
[INFO] Flink :
flinkbot edited a comment on pull request #16029:
URL: https://github.com/apache/flink/pull/16029#issuecomment-851388620
## CI report:
* 08a786455ddca7efb86a77dae27511f050d728f6 Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
[
https://issues.apache.org/jira/browse/FLINK-10205?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17354777#comment-17354777
]
wangwj commented on FLINK-10205:
[~Ryantaocer][~isunjin]
Hi, excuse me.
After I read thi
xintongsong commented on a change in pull request #16016:
URL: https://github.com/apache/flink/pull/16016#discussion_r642757794
##
File path: docs/content/docs/deployment/memory/mem_setup_tm.md
##
@@ -98,13 +98,14 @@ See also [how to configure memory for state backends]({{<
re
flinkbot edited a comment on pull request #16034:
URL: https://github.com/apache/flink/pull/16034#issuecomment-851582958
## CI report:
* 777b9e65a26b6dbca69c7a9bae35bb8baf90d327 Azure:
[SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot edited a comment on pull request #16029:
URL: https://github.com/apache/flink/pull/16029#issuecomment-851388620
## CI report:
* 08a786455ddca7efb86a77dae27511f050d728f6 Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot edited a comment on pull request #16036:
URL: https://github.com/apache/flink/pull/16036#issuecomment-851746085
## CI report:
* 484f4fed68bd22ecfe249e4fc909da2a23e0d826 Azure:
[SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot edited a comment on pull request #15524:
URL: https://github.com/apache/flink/pull/15524#issuecomment-815574117
## CI report:
* f5d1cd207a362b395ad1628b25b40f9abc2caaf9 Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
[
https://issues.apache.org/jira/browse/FLINK-22806?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Tang closed FLINK-22806.
Resolution: Information Provided
> The folder /checkpoint/shared state of FLINKSQL is getting bigger and
[
https://issues.apache.org/jira/browse/FLINK-22806?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17354767#comment-17354767
]
Yun Tang edited comment on FLINK-22806 at 6/1/21, 3:14 AM:
---
I
fsk119 commented on pull request #16029:
URL: https://github.com/apache/flink/pull/16029#issuecomment-851774064
@pensz Hi, the CI test fails. Please run `mvn spotless:apply` to fix the
checkstyle problem.
--
This is an automated message from the Apache Git Service.
To respond to the mess
[
https://issues.apache.org/jira/browse/FLINK-22806?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17354767#comment-17354767
]
Yun Tang commented on FLINK-22806:
--
I noticed that you have already opened related issu
pensz commented on a change in pull request #16029:
URL: https://github.com/apache/flink/pull/16029#discussion_r642753682
##
File path:
flink-table/flink-sql-client/src/test/java/org/apache/flink/table/client/cli/CliUtilsTest.java
##
@@ -0,0 +1,55 @@
+/*
+ * Licensed to the Ap
xintongsong commented on pull request #15524:
URL: https://github.com/apache/flink/pull/15524#issuecomment-851772901
@wangyang0918,
I've addressed your comments, and rebased for conflict resolving. Please
take another look.
I've also opened FLINK-22816 for investigating the possibilit
Xintong Song created FLINK-22816:
Summary: Investigate feasibility of supporting multiple RM leader
sessions within JM process
Key: FLINK-22816
URL: https://issues.apache.org/jira/browse/FLINK-22816
P
fsk119 commented on a change in pull request #16028:
URL: https://github.com/apache/flink/pull/16028#discussion_r642751015
##
File path:
flink-table/flink-sql-client/src/test/java/org/apache/flink/table/client/SqlClientTest.java
##
@@ -205,6 +205,17 @@ public void testExecuteS
fsk119 commented on a change in pull request #16028:
URL: https://github.com/apache/flink/pull/16028#discussion_r642749269
##
File path:
flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/SqlClient.java
##
@@ -213,6 +214,16 @@ protected static void startC
fsk119 commented on a change in pull request #16028:
URL: https://github.com/apache/flink/pull/16028#discussion_r642749501
##
File path:
flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/SqlExecutionException.java
##
@@ -0,0 +1,33 @@
+/*
+ * Licensed to
flinkbot edited a comment on pull request #16034:
URL: https://github.com/apache/flink/pull/16034#issuecomment-851582958
## CI report:
* 777b9e65a26b6dbca69c7a9bae35bb8baf90d327 Azure:
[SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot edited a comment on pull request #16029:
URL: https://github.com/apache/flink/pull/16029#issuecomment-851388620
## CI report:
* 08a786455ddca7efb86a77dae27511f050d728f6 Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot edited a comment on pull request #15524:
URL: https://github.com/apache/flink/pull/15524#issuecomment-815574117
## CI report:
* f5d1cd207a362b395ad1628b25b40f9abc2caaf9 Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
godfreyhe commented on a change in pull request #16024:
URL: https://github.com/apache/flink/pull/16024#discussion_r642744349
##
File path:
flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/rules/FlinkStreamRuleSets.scala
##
@@ -374,6 +37
[
https://issues.apache.org/jira/browse/FLINK-16069?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17354757#comment-17354757
]
Zhu Zhu edited comment on FLINK-16069 at 6/1/21, 2:54 AM:
--
Even
[
https://issues.apache.org/jira/browse/FLINK-16069?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17354757#comment-17354757
]
Zhu Zhu commented on FLINK-16069:
-
Even if the main thread can have the highest priority
JasonLeeCoding commented on pull request #16028:
URL: https://github.com/apache/flink/pull/16028#issuecomment-851766303
@fsk119 Please help me review the code ,thanks.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use t
xintongsong commented on pull request #15524:
URL: https://github.com/apache/flink/pull/15524#issuecomment-851765702
> What will currently happen if a RM loses the leadership? Will it simply
terminate the process and let Yarn start a new process to reapply for the
leadership?
Yes, e
wuchong commented on pull request #16034:
URL: https://github.com/apache/flink/pull/16034#issuecomment-851765396
It seems that the `flink-sql-parser` and `flink-sql-parser-hive` modules are
never tested in CI build. I just added them into test modules, cc @twalthr
@zentol .
--
This is
flinkbot edited a comment on pull request #16029:
URL: https://github.com/apache/flink/pull/16029#issuecomment-851388620
## CI report:
* 233774d84c03ea4a77b3433cf44dc12dcb3a8814 Azure:
[SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
[
https://issues.apache.org/jira/browse/FLINK-18958?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu updated FLINK-18958:
Labels: auto-unassigned pull-request-available (was: auto-unassigned
pull-request-available stale-major)
godfreyhe commented on a change in pull request #15997:
URL: https://github.com/apache/flink/pull/15997#discussion_r642741007
##
File path:
flink-table/flink-table-planner-blink/src/test/resources/org/apache/flink/table/planner/plan/rules/physical/stream/WatermarkAssignerChangelogNorm
flinkbot edited a comment on pull request #16029:
URL: https://github.com/apache/flink/pull/16029#issuecomment-851388620
## CI report:
* 233774d84c03ea4a77b3433cf44dc12dcb3a8814 Azure:
[SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot edited a comment on pull request #16036:
URL: https://github.com/apache/flink/pull/16036#issuecomment-851746085
## CI report:
* 484f4fed68bd22ecfe249e4fc909da2a23e0d826 Azure:
[PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
fsk119 commented on a change in pull request #16029:
URL: https://github.com/apache/flink/pull/16029#discussion_r642737314
##
File path:
flink-table/flink-sql-client/src/test/java/org/apache/flink/table/client/cli/CliUtilsTest.java
##
@@ -0,0 +1,55 @@
+/*
+ * Licensed to the A
fsk119 commented on a change in pull request #15986:
URL: https://github.com/apache/flink/pull/15986#discussion_r642734823
##
File path:
flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/operations/SqlToOperationConverter.java
##
@@ -844,16 +84
pensz commented on a change in pull request #16029:
URL: https://github.com/apache/flink/pull/16029#discussion_r642733457
##
File path:
flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/cli/CliUtils.java
##
@@ -109,7 +109,7 @@ public static boolean creat
flinkbot commented on pull request #16036:
URL: https://github.com/apache/flink/pull/16036#issuecomment-851746085
## CI report:
* 484f4fed68bd22ecfe249e4fc909da2a23e0d826 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot r
paul8263 commented on pull request #16036:
URL: https://github.com/apache/flink/pull/16036#issuecomment-851740041
This issue could be fixed by changing the "as" expression in
org/apache/flink/table/api/internal/BaseExpressions.java to as "in"
org/apache/flink/table/api/Table.java. I have t
flinkbot commented on pull request #16036:
URL: https://github.com/apache/flink/pull/16036#issuecomment-851739474
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
paul8263 commented on pull request #16036:
URL: https://github.com/apache/flink/pull/16036#issuecomment-851739001
This issue could be fixed by changing the "as" expression in
org/apache/flink/table/api/internal/BaseExpressions.java to as "in"
org/apache/flink/table/api/Table.java. I have t
[
https://issues.apache.org/jira/browse/FLINK-22689?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-22689:
---
Labels: pull-request-available (was: )
> Table API Documentation Row-Based Operations Examp
paul8263 opened a new pull request #16036:
URL: https://github.com/apache/flink/pull/16036
…le Fails
## What is the purpose of the change
Correct error sample codes in chapter map and flatmap in
docs/content/docs/dev/table/tableApi.md.
## Brief change log
- docs/
SteNicholas commented on a change in pull request #16023:
URL: https://github.com/apache/flink/pull/16023#discussion_r642718447
##
File path:
flink-connectors/flink-connector-rabbitmq/src/main/java/org/apache/flink/streaming/connectors/rabbitmq/common/RMQConnectionConfig.java
SteNicholas commented on a change in pull request #16023:
URL: https://github.com/apache/flink/pull/16023#discussion_r642718447
##
File path:
flink-connectors/flink-connector-rabbitmq/src/main/java/org/apache/flink/streaming/connectors/rabbitmq/common/RMQConnectionConfig.java
SteNicholas commented on a change in pull request #16023:
URL: https://github.com/apache/flink/pull/16023#discussion_r642717539
##
File path:
flink-connectors/flink-connector-rabbitmq/src/main/java/org/apache/flink/streaming/connectors/rabbitmq/common/RMQConnectionConfig.java
[
https://issues.apache.org/jira/browse/FLINK-22722?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jiangjie Qin reassigned FLINK-22722:
Assignee: Qingsheng Ren
> Add Documentation for Kafka New Source
> --
[
https://issues.apache.org/jira/browse/FLINK-22722?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jiangjie Qin resolved FLINK-22722.
--
Resolution: Fixed
Merged to master:
b582991b8b2b8dadb89e71d5002c4a9cc2055e34
> Add Document
1 - 100 of 381 matches
Mail list logo
