AHeise commented on a change in pull request #13604:
URL: https://github.com/apache/flink/pull/13604#discussion_r504931519
##
File path:
flink-test-utils-parent/flink-test-utils/src/main/java/org/apache/flink/test/util/TestBaseUtils.java
##
@@ -102,6 +116,24 @@ private static
flinkbot commented on pull request #13642:
URL: https://github.com/apache/flink/pull/13642#issuecomment-708665953
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
[
https://issues.apache.org/jira/browse/FLINK-19540?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17214304#comment-17214304
]
Chesnay Schepler commented on FLINK-19540:
--
[~jeromexlee] You can also use [log4j
flinkbot edited a comment on pull request #13637:
URL: https://github.com/apache/flink/pull/13637#issuecomment-708397828
## CI report:
* 1d5b26fb70f7cdc2f562dcc72f6d4b0b0eff716e UNKNOWN
* 9c59fc9385d7843f2ba7f818d88c99d6d1450d70 Azure:
dianfu commented on a change in pull request #13611:
URL: https://github.com/apache/flink/pull/13611#discussion_r505105967
##
File path: flink-python/pyflink/fn_execution/beam/beam_operations_slow.py
##
@@ -162,23 +165,36 @@ def __init__(self, name, spec, counter_factory,
Dian Fu created FLINK-19645:
---
Summary:
ShuffleCompressionITCase.testDataCompressionForBlockingShuffle is instable
Key: FLINK-19645
URL: https://issues.apache.org/jira/browse/FLINK-19645
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-19645?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu updated FLINK-19645:
Labels: test-stability (was: )
> ShuffleCompressionITCase.testDataCompressionForBlockingShuffle is
Nicholas Jiang created FLINK-19646:
--
Summary: StreamExecutionEnvironment support new Source interface
based on FLIP-27
Key: FLINK-19646
URL: https://issues.apache.org/jira/browse/FLINK-19646
shuiqiangchen commented on a change in pull request #12902:
URL: https://github.com/apache/flink/pull/12902#discussion_r505124256
##
File path:
flink-python/src/main/java/org/apache/flink/api/common/python/PythonBridgeUtils.java
##
@@ -162,7 +171,42 @@
return
JingsongLi commented on pull request #13605:
URL: https://github.com/apache/flink/pull/13605#issuecomment-708865098
After discussed with Jark, I think we should try to `EncodingFormatFactory`
and `DecodingFormatFactory`.
[
https://issues.apache.org/jira/browse/FLINK-19651?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shengkai Fang updated FLINK-19651:
--
Summary: Support the filter push down for the Jdbc connector (was: Support
filter push down
danny0405 commented on a change in pull request #13577:
URL: https://github.com/apache/flink/pull/13577#discussion_r505141222
##
File path:
flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/api/stream/table/CalcTest.scala
##
@@ -114,11 +114,13 @@ class
[
https://issues.apache.org/jira/browse/FLINK-19650?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shengkai Fang updated FLINK-19650:
--
Parent: FLINK-16987
Issue Type: Sub-task (was: New Feature)
> Support the limit push
[
https://issues.apache.org/jira/browse/FLINK-19647?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shengkai Fang updated FLINK-19647:
--
Parent: FLINK-16987
Issue Type: Sub-task (was: New Feature)
> Support the limit push
dianfu closed pull request #13262:
URL: https://github.com/apache/flink/pull/13262
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-19647?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shengkai Fang updated FLINK-19647:
--
Summary: Support the limit push down for the hbase connector (was: Support
limit push down
flinkbot edited a comment on pull request #13604:
URL: https://github.com/apache/flink/pull/13604#issuecomment-707513688
## CI report:
* 755d9eb83e7fa1f497fe083850ce369d8d1d5940 Azure:
flinkbot edited a comment on pull request #13629:
URL: https://github.com/apache/flink/pull/13629#issuecomment-708262130
## CI report:
* 548abe1c2b61698e8f8faf397b65864b5e367ed0 Azure:
flinkbot commented on pull request #13642:
URL: https://github.com/apache/flink/pull/13642#issuecomment-708668367
## CI report:
* 04f8d715a9a672b0d832e9b9e067294376eae211 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot
flinkbot edited a comment on pull request #13642:
URL: https://github.com/apache/flink/pull/13642#issuecomment-708668367
## CI report:
* 04f8d715a9a672b0d832e9b9e067294376eae211 Azure:
SteNicholas removed a comment on pull request #13637:
URL: https://github.com/apache/flink/pull/13637#issuecomment-708376472
@StephanEwen @aljoscha Could you please help to review this adjust?
This is an automated message
SteNicholas closed pull request #13637:
URL: https://github.com/apache/flink/pull/13637
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
dianfu commented on pull request #13611:
URL: https://github.com/apache/flink/pull/13611#issuecomment-708838823
@shuiqiangchen Thanks a lot for the review. Not sure why the tests are not
triggered. The tests have passed in my personal azure pipeline:
flinkbot edited a comment on pull request #13622:
URL: https://github.com/apache/flink/pull/13622#issuecomment-708066181
## CI report:
* 116ea43b00eac6494d40cf8349a147ebf958439b Azure:
Shengkai Fang created FLINK-19647:
-
Summary: Support limit push down for hbase connector
Key: FLINK-19647
URL: https://issues.apache.org/jira/browse/FLINK-19647
Project: Flink
Issue Type:
flinkbot edited a comment on pull request #13492:
URL: https://github.com/apache/flink/pull/13492#issuecomment-699626263
## CI report:
* af73558800083e341dcd9c89819cd00b0572696b UNKNOWN
* 59af0e9ec80df5072e44576882f8659db631e424 UNKNOWN
*
flinkbot edited a comment on pull request #13299:
URL: https://github.com/apache/flink/pull/13299#issuecomment-684842866
## CI report:
* d142b0a736b24b1d1d714da9c26bf89279e643c8 UNKNOWN
* e7f001da22368aed31002c28199b4f97d2a2b63b Azure:
zentol commented on a change in pull request #13640:
URL: https://github.com/apache/flink/pull/13640#discussion_r505038358
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/metrics/util/MetricUtils.java
##
@@ -214,6 +216,15 @@ static void
zentol commented on a change in pull request #13640:
URL: https://github.com/apache/flink/pull/13640#discussion_r505036909
##
File path: docs/monitoring/metrics.md
##
@@ -847,6 +847,8 @@ Thus, in order to infer the metric identifier:
### Memory
+The memory-related metrics
guoweiM commented on a change in pull request #13617:
URL: https://github.com/apache/flink/pull/13617#discussion_r505089210
##
File path:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/sink/AbstractWriterOperator.java
##
@@ -0,0 +1,146 @@
+/*
+ *
[
https://issues.apache.org/jira/browse/FLINK-19480?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu closed FLINK-19480.
---
Resolution: Fixed
Merged to master via c8938f9e238f8eb05430386d5bc3104b23d6c37c
> Support RichFunction in
dianfu closed pull request #13611:
URL: https://github.com/apache/flink/pull/13611
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
wangxlong closed pull request #13619:
URL: https://github.com/apache/flink/pull/13619
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
Shengkai Fang created FLINK-19651:
-
Summary: Support filter push down for the Jdbc connector
Key: FLINK-19651
URL: https://issues.apache.org/jira/browse/FLINK-19651
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-19649?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
gsralex updated FLINK-19649:
Description:
In Flink's module flink-sql-parser, the sqlCreateTable.class unparse method
The create
Shengkai Fang created FLINK-19650:
-
Summary: Support the limit push down for the Jdbc connector
Key: FLINK-19650
URL: https://issues.apache.org/jira/browse/FLINK-19650
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-19384?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17214242#comment-17214242
]
Stephan Ewen commented on FLINK-19384:
--
The Josh Bloch guide is what I try to follow in Flink's
flinkbot edited a comment on pull request #13604:
URL: https://github.com/apache/flink/pull/13604#issuecomment-707513688
## CI report:
* 755d9eb83e7fa1f497fe083850ce369d8d1d5940 Azure:
flinkbot edited a comment on pull request #13641:
URL: https://github.com/apache/flink/pull/13641#issuecomment-708569491
## CI report:
* 09d8deb89416f53dfe8b5c16fb9d723cbd98612c UNKNOWN
* fef9bff28a988ffab789fc6bb0cbde754273a2e0 Azure:
flinkbot edited a comment on pull request #13637:
URL: https://github.com/apache/flink/pull/13637#issuecomment-708397828
## CI report:
* 4722a51a254a14cfec5a968214ca473de32179cb Azure:
flinkbot edited a comment on pull request #13642:
URL: https://github.com/apache/flink/pull/13642#issuecomment-708668367
## CI report:
* 04f8d715a9a672b0d832e9b9e067294376eae211 Azure:
guoweiM commented on a change in pull request #13617:
URL: https://github.com/apache/flink/pull/13617#discussion_r505088060
##
File path:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/sink/AbstractWriterOperator.java
##
@@ -0,0 +1,146 @@
+/*
+ *
guoweiM commented on a change in pull request #13617:
URL: https://github.com/apache/flink/pull/13617#discussion_r505088576
##
File path:
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/sink/AbstractWriterOperator.java
##
@@ -0,0 +1,143 @@
+/*
dianfu commented on a change in pull request #13611:
URL: https://github.com/apache/flink/pull/13611#discussion_r505107742
##
File path: flink-python/pyflink/datastream/data_stream.py
##
@@ -467,25 +466,26 @@ def partition_custom(self, partitioner: Union[Callable,
flinkbot edited a comment on pull request #13638:
URL: https://github.com/apache/flink/pull/13638#issuecomment-708460375
## CI report:
* 3520e47d79c50f5a3c528b7878549e116445fcb4 Azure:
flinkbot edited a comment on pull request #13617:
URL: https://github.com/apache/flink/pull/13617#issuecomment-707791817
## CI report:
* 915e1ba014404cbbccbe49af1e86229fbca107ec UNKNOWN
* 165ea9806e660d4f8fc6de0e93de9a38c9353fc2 Azure:
flinkbot edited a comment on pull request #13636:
URL: https://github.com/apache/flink/pull/13636#issuecomment-708378225
## CI report:
* 37a21996231887c5d5b7227d0c38ab07612f3209 Azure:
[
https://issues.apache.org/jira/browse/FLINK-19646?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Nicholas Jiang updated FLINK-19646:
---
Priority: Minor (was: Major)
> StreamExecutionEnvironment support new Source interface
[
https://issues.apache.org/jira/browse/FLINK-19647?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shengkai Fang updated FLINK-19647:
--
Summary: Support limit push down for the hbase connector (was: Support
limit push down for
Shengkai Fang created FLINK-19648:
-
Summary: Support nested projection push down for hbase connector
Key: FLINK-19648
URL: https://issues.apache.org/jira/browse/FLINK-19648
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-18921?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu closed FLINK-18921.
---
Resolution: Fixed
Merged to 1.12 via 9f0650f5e6e3cb18dbc20a8af9e4492c85f72bb5
> Add a "SQL" link (linked
gaoyunhaii commented on pull request #13629:
URL: https://github.com/apache/flink/pull/13629#issuecomment-708875979
@flinkbot run azure
This is an automated message from the Apache Git Service.
To respond to the message,
stevenzwu commented on a change in pull request #13617:
URL: https://github.com/apache/flink/pull/13617#discussion_r504999762
##
File path:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/sink/AbstractWriterOperator.java
##
@@ -0,0 +1,146 @@
+/*
+
flinkbot edited a comment on pull request #13622:
URL: https://github.com/apache/flink/pull/13622#issuecomment-708066181
## CI report:
* 116ea43b00eac6494d40cf8349a147ebf958439b Azure:
stevenzwu commented on a change in pull request #13617:
URL: https://github.com/apache/flink/pull/13617#discussion_r505019969
##
File path:
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/sink/AbstractWriterOperator.java
##
@@ -0,0 +1,143 @@
flinkbot edited a comment on pull request #13637:
URL: https://github.com/apache/flink/pull/13637#issuecomment-708397828
## CI report:
* 4722a51a254a14cfec5a968214ca473de32179cb Azure:
[
https://issues.apache.org/jira/browse/FLINK-19645?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17214390#comment-17214390
]
Yingjie Cao commented on FLINK-19645:
-
>From the stack, we can see that the root cause is Akka RPC
[
https://issues.apache.org/jira/browse/FLINK-19648?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shengkai Fang updated FLINK-19648:
--
Parent: FLINK-16987
Issue Type: Sub-task (was: New Feature)
> Support the nested
[
https://issues.apache.org/jira/browse/FLINK-19648?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shengkai Fang updated FLINK-19648:
--
Summary: Support nested projection push down for the hbase connector (was:
Support nested
danny0405 commented on a change in pull request #13577:
URL: https://github.com/apache/flink/pull/13577#discussion_r505141774
##
File path:
flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/expressions/ScalarFunctionsTest.scala
##
@@ -2679,15 +2679,15 @@
[
https://issues.apache.org/jira/browse/FLINK-18921?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu updated FLINK-18921:
Component/s: API / Python
> Add a "SQL" link (linked to dev/table/sql/index.md) under the "Python API" ->
[
https://issues.apache.org/jira/browse/FLINK-18921?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu updated FLINK-18921:
Fix Version/s: 1.12.0
> Add a "SQL" link (linked to dev/table/sql/index.md) under the "Python API" ->
>
[
https://issues.apache.org/jira/browse/FLINK-19648?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shengkai Fang updated FLINK-19648:
--
Summary: Support the nested projection push down for the hbase connector
(was: Support
curcur commented on a change in pull request #13614:
URL: https://github.com/apache/flink/pull/13614#discussion_r504675916
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/buffer/BufferConsumerWithPartialRecordLength.java
##
@@ -0,0 +1,120 @@
+/*
curcur commented on a change in pull request #13614:
URL: https://github.com/apache/flink/pull/13614#discussion_r504675916
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/buffer/BufferConsumerWithPartialRecordLength.java
##
@@ -0,0 +1,120 @@
+/*
flinkbot edited a comment on pull request #13299:
URL: https://github.com/apache/flink/pull/13299#issuecomment-684842866
## CI report:
* d142b0a736b24b1d1d714da9c26bf89279e643c8 UNKNOWN
* e7f001da22368aed31002c28199b4f97d2a2b63b Azure:
flinkbot edited a comment on pull request #13599:
URL: https://github.com/apache/flink/pull/13599#issuecomment-707258177
## CI report:
* a419bd7f170482789f5e3c0bb0d279cc9fdf8244 Azure:
flinkbot edited a comment on pull request #13560:
URL: https://github.com/apache/flink/pull/13560#issuecomment-705391015
## CI report:
* 5000a1737c880c9b7fab1fcbca0a414d4881b891 Azure:
flinkbot edited a comment on pull request #13640:
URL: https://github.com/apache/flink/pull/13640#issuecomment-708477385
## CI report:
* c295945375d779e056cd2503b878c5ea6544a7a7 Azure:
flinkbot edited a comment on pull request #13639:
URL: https://github.com/apache/flink/pull/13639#issuecomment-708476237
## CI report:
* 4bac1d3f88930c269cab61688034af64b0f20a10 Azure:
rkhachatryan opened a new pull request #13642:
URL: https://github.com/apache/flink/pull/13642
## What is the purpose of the change
*Remove duplicated `PipelinedSubpartition.addBufferConsumer` method and use
`PipelinedSubpartition.add()` instead.*
## Verifying this change
flinkbot edited a comment on pull request #13637:
URL: https://github.com/apache/flink/pull/13637#issuecomment-708397828
## CI report:
* 4722a51a254a14cfec5a968214ca473de32179cb Azure:
flinkbot edited a comment on pull request #13637:
URL: https://github.com/apache/flink/pull/13637#issuecomment-708397828
## CI report:
* 1d5b26fb70f7cdc2f562dcc72f6d4b0b0eff716e UNKNOWN
* 9c59fc9385d7843f2ba7f818d88c99d6d1450d70 Azure:
flinkbot edited a comment on pull request #13617:
URL: https://github.com/apache/flink/pull/13617#issuecomment-707791817
## CI report:
* 915e1ba014404cbbccbe49af1e86229fbca107ec UNKNOWN
* 8de03dc540d21d631f2f606c5c4612d3e7937ad9 Azure:
[
https://issues.apache.org/jira/browse/FLINK-19202?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17214370#comment-17214370
]
Dian Fu commented on FLINK-19202:
-
Another instance:
flinkbot edited a comment on pull request #13492:
URL: https://github.com/apache/flink/pull/13492#issuecomment-699626263
## CI report:
* af73558800083e341dcd9c89819cd00b0572696b UNKNOWN
* 59af0e9ec80df5072e44576882f8659db631e424 UNKNOWN
*
[
https://issues.apache.org/jira/browse/FLINK-19633?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17214374#comment-17214374
]
dalongliu commented on FLINK-19633:
---
I can try it.
> Fix ArrayIndexOutOfBoundsException in
flinkbot edited a comment on pull request #13492:
URL: https://github.com/apache/flink/pull/13492#issuecomment-699626263
## CI report:
* af73558800083e341dcd9c89819cd00b0572696b UNKNOWN
* 59af0e9ec80df5072e44576882f8659db631e424 UNKNOWN
*
flinkbot edited a comment on pull request #13299:
URL: https://github.com/apache/flink/pull/13299#issuecomment-684842866
## CI report:
* d142b0a736b24b1d1d714da9c26bf89279e643c8 UNKNOWN
* e7f001da22368aed31002c28199b4f97d2a2b63b Azure:
danny0405 commented on a change in pull request #13577:
URL: https://github.com/apache/flink/pull/13577#discussion_r505135126
##
File path:
flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/functions/utils/TableSqlFunction.scala
##
@@ -40,12 +44,19 @@
danny0405 commented on a change in pull request #13577:
URL: https://github.com/apache/flink/pull/13577#discussion_r505135294
##
File path:
flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/functions/utils/UserDefinedFunctionUtils.scala
##
@@ -372,6 +373,9
[
https://issues.apache.org/jira/browse/FLINK-19642?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu closed FLINK-19642.
---
Resolution: Won't Fix
Thanks [~yunta], I noticed that FLINK-18373 is already merged which has removed
the
dianfu commented on pull request #13622:
URL: https://github.com/apache/flink/pull/13622#issuecomment-708801267
@flinkbot run azure
This is an automated message from the Apache Git Service.
To respond to the message, please
[
https://issues.apache.org/jira/browse/FLINK-19651?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shengkai Fang updated FLINK-19651:
--
Parent: FLINK-16987
Issue Type: Sub-task (was: New Feature)
> Support filter push
flinkbot commented on pull request #13643:
URL: https://github.com/apache/flink/pull/13643#issuecomment-708870329
## CI report:
* bf793887fbcc0b4f83cc76eb0565833476da0348 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot
[
https://issues.apache.org/jira/browse/FLINK-19540?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17214248#comment-17214248
]
Xinhao Li commented on FLINK-19540:
---
Thanks! I will give a try. Close the ticket for now.
> How to
[
https://issues.apache.org/jira/browse/FLINK-19540?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xinhao Li closed FLINK-19540.
-
Resolution: Resolved
> How to reduce or disable checkpoint logs in Flink
>
SteNicholas commented on pull request #13637:
URL: https://github.com/apache/flink/pull/13637#issuecomment-708686284
@flinkbot run azure
This is an automated message from the Apache Git Service.
To respond to the message,
shuiqiangchen commented on pull request #13611:
URL: https://github.com/apache/flink/pull/13611#issuecomment-708838133
@dianfu Thank you for you clarification. The PR looks good to me now. +1
This is an automated message
[
https://issues.apache.org/jira/browse/FLINK-19644?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee updated FLINK-19644:
-
Fix Version/s: 1.12.0
> Support read specific partition of Hive table in temporal join
>
[
https://issues.apache.org/jira/browse/FLINK-19644?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee reassigned FLINK-19644:
Assignee: Leonard Xu
> Support read specific partition of Hive table in temporal join
>
[
https://issues.apache.org/jira/browse/FLINK-19646?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu updated FLINK-19646:
Priority: Major (was: Minor)
> StreamExecutionEnvironment support new Source interface based on FLIP-27
danny0405 commented on a change in pull request #13577:
URL: https://github.com/apache/flink/pull/13577#discussion_r505133379
##
File path:
flink-table/flink-table-planner/src/main/java/org/apache/calcite/schema/Statistic.java
##
@@ -0,0 +1,73 @@
+/*
+ * Licensed to the
SteNicholas commented on pull request #13637:
URL: https://github.com/apache/flink/pull/13637#issuecomment-708861482
@StephanEwen @aljoscha Could you please help to review this adjust?
This is an automated message from the
flinkbot edited a comment on pull request #13636:
URL: https://github.com/apache/flink/pull/13636#issuecomment-708378225
## CI report:
* 37a21996231887c5d5b7227d0c38ab07612f3209 Azure:
wangxlong opened a new pull request #13643:
URL: https://github.com/apache/flink/pull/13643
## What is the purpose of the change
Fix DummyInputFormat class lacks Javadoc
## Brief change log
Add Javadoc to DummyInputFormat class
## Verifying this change
curcur commented on a change in pull request #13614:
URL: https://github.com/apache/flink/pull/13614#discussion_r504675916
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/buffer/BufferConsumerWithPartialRecordLength.java
##
@@ -0,0 +1,120 @@
+/*
gsralex created FLINK-19649:
---
Summary: In Flink's module
flink-sql-parser/sqlCreateTable/unparse, the tables without columns are not
supported.
Key: FLINK-19649
URL: https://issues.apache.org/jira/browse/FLINK-19649
scottxusayhi removed a comment on pull request #13555:
URL: https://github.com/apache/flink/pull/13555#issuecomment-708233139
@flinkbot run azure
This is an automated message from the Apache Git Service.
To respond to the
curcur commented on a change in pull request #13614:
URL: https://github.com/apache/flink/pull/13614#discussion_r504675916
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/buffer/BufferConsumerWithPartialRecordLength.java
##
@@ -0,0 +1,120 @@
+/*
1 - 100 of 525 matches
Mail list logo