wuchong commented on a change in pull request #352:
URL: https://github.com/apache/flink-web/pull/352#discussion_r449957050
##
File path: _posts/2020-07-06-release-1.11.0.md
##
@@ -0,0 +1,307 @@
+---
+layout: post
+title: "Apache Flink 1.11.0 Release Announcement"
+date:
liuyongvs commented on a change in pull request #12790:
URL: https://github.com/apache/flink/pull/12790#discussion_r449956717
##
File path:
[
https://issues.apache.org/jira/browse/FLINK-17855?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17151715#comment-17151715
]
Jark Wu commented on FLINK-17855:
-
UDTF doesn't support {{Row[]}} as parameter, reported in user-zh:
flinkbot edited a comment on pull request #12756:
URL: https://github.com/apache/flink/pull/12756#issuecomment-648131818
## CI report:
* 577fbda18ee035db9e05432738a1450c52fdf3e2 Azure:
TJX2014 commented on a change in pull request #12819:
URL: https://github.com/apache/flink/pull/12819#discussion_r449990838
##
File path:
flink-table/flink-table-planner-blink/src/main/java/org/apache/calcite/sql/SqlRankFunction.java
##
@@ -0,0 +1,50 @@
+/*
+ * Licensed to
klion26 commented on a change in pull request #12798:
URL: https://github.com/apache/flink/pull/12798#discussion_r449984080
##
File path: docs/dev/table/streaming/match_recognize.zh.md
##
@@ -24,28 +24,17 @@ specific language governing permissions and limitations
under the
wuchong commented on a change in pull request #12819:
URL: https://github.com/apache/flink/pull/12819#discussion_r449993292
##
File path:
flink-table/flink-table-planner-blink/src/main/java/org/apache/calcite/sql/SqlRankFunction.java
##
@@ -0,0 +1,50 @@
+/*
+ * Licensed to
[
https://issues.apache.org/jira/browse/FLINK-18487?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17151735#comment-17151735
]
Jark Wu commented on FLINK-18487:
-
If {{WildcardValidatorUtil}} is also commonly required by other
morsapaes commented on a change in pull request #352:
URL: https://github.com/apache/flink-web/pull/352#discussion_r449927661
##
File path: _posts/2020-07-06-release-1.11.0.md
##
@@ -0,0 +1,307 @@
+---
+layout: post
+title: "Apache Flink 1.11.0 Release Announcement"
+date:
[
https://issues.apache.org/jira/browse/FLINK-18449?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17151709#comment-17151709
]
Jingsong Lee commented on FLINK-18449:
--
If we respect DataStream API, In {{FlinkKafkaConsumer}} ,
[
https://issues.apache.org/jira/browse/FLINK-18487?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17151719#comment-17151719
]
Danny Chen commented on FLINK-18487:
+1 to have the validation logic in the factory. The FactoryUtil
[
https://issues.apache.org/jira/browse/FLINK-18457?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu closed FLINK-18457.
---
Fix Version/s: 1.11.1
1.12.0
Resolution: Fixed
- master (1.12.0):
Huang Xingbo created FLINK-18490:
Summary: Extract the implementation logic of Beam in
AbstractPythonFunctionOperator
Key: FLINK-18490
URL: https://issues.apache.org/jira/browse/FLINK-18490
Project:
[
https://issues.apache.org/jira/browse/FLINK-18488?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu updated FLINK-18488:
Affects Version/s: 1.11.0
1.9.0
1.10.0
> Python API
[
https://issues.apache.org/jira/browse/FLINK-18488?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu updated FLINK-18488:
Fix Version/s: 1.12.0
> Python API CsvTableSource missing optional constructor params
>
[
https://issues.apache.org/jira/browse/FLINK-18488?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu reassigned FLINK-18488:
---
Assignee: Chris Nix
> Python API CsvTableSource missing optional constructor params
>
wuchong commented on pull request #12790:
URL: https://github.com/apache/flink/pull/12790#issuecomment-654028784
Wait until the build pass.
This is an automated message from the Apache Git Service.
To respond to the
flinkbot edited a comment on pull request #12824:
URL: https://github.com/apache/flink/pull/12824#issuecomment-653937012
## CI report:
* a112ae76f326f1abfa2f921dcdb0acd5f63ebf25 Azure:
wuchong merged pull request #12802:
URL: https://github.com/apache/flink/pull/12802
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
wuchong commented on a change in pull request #12819:
URL: https://github.com/apache/flink/pull/12819#discussion_r449959578
##
File path:
flink-table/flink-table-planner-blink/src/main/java/org/apache/calcite/sql/SqlRankFunction.java
##
@@ -0,0 +1,48 @@
+/*
+ * Licensed to
dianfu commented on a change in pull request #12824:
URL: https://github.com/apache/flink/pull/12824#discussion_r449959865
##
File path: flink-python/pyflink/table/sources.py
##
@@ -38,16 +38,62 @@ class CsvTableSource(TableSource):
(logically) unlimited number of fields.
[
https://issues.apache.org/jira/browse/FLINK-18449?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17151730#comment-17151730
]
Jingsong Lee commented on FLINK-18449:
--
single topic constructor is just a helper for users, there
[
https://issues.apache.org/jira/browse/FLINK-18491?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Huang Xingbo updated FLINK-18491:
-
Component/s: API / Python
> Extract the implementation logic of Beam in coders
>
Huang Xingbo created FLINK-18491:
Summary: Extract the implementation logic of Beam in coders
Key: FLINK-18491
URL: https://issues.apache.org/jira/browse/FLINK-18491
Project: Flink
Issue
Huang Xingbo created FLINK-18492:
Summary: Extract the implementation logic of Beam in Operations
Key: FLINK-18492
URL: https://issues.apache.org/jira/browse/FLINK-18492
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-18402?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17151744#comment-17151744
]
Yun Gao commented on FLINK-18402:
-
>From the [code of
[
https://issues.apache.org/jira/browse/FLINK-18487?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17151713#comment-17151713
]
Jark Wu commented on FLINK-18487:
-
We can have a custom validation logic in
[
https://issues.apache.org/jira/browse/FLINK-18487?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17151722#comment-17151722
]
Jark Wu commented on FLINK-18487:
-
Yes. {{FactoryUtil}} is just a helper for common cases.
Btw, we can
[
https://issues.apache.org/jira/browse/FLINK-18485?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17151733#comment-17151733
]
Dian Fu commented on FLINK-18485:
-
Similar issue from StackOverflow:
[
https://issues.apache.org/jira/browse/FLINK-18487?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17151732#comment-17151732
]
Jingsong Lee commented on FLINK-18487:
--
We can create a separate validator for
[
https://issues.apache.org/jira/browse/FLINK-16947?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17151737#comment-17151737
]
Dian Fu commented on FLINK-16947:
-
[
https://issues.apache.org/jira/browse/FLINK-18487?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17151736#comment-17151736
]
Jingsong Lee commented on FLINK-18487:
--
I got what are you mean, every connectors should chooses
flinkbot edited a comment on pull request #12756:
URL: https://github.com/apache/flink/pull/12756#issuecomment-648131818
## CI report:
* 577fbda18ee035db9e05432738a1450c52fdf3e2 Azure:
TJX2014 commented on a change in pull request #12819:
URL: https://github.com/apache/flink/pull/12819#discussion_r449990273
##
File path:
flink-table/flink-table-planner-blink/src/test/scala/org/apache/flink/table/planner/plan/stream/sql/TableScanTest.scala
##
@@ -357,4
wuchong commented on a change in pull request #12819:
URL: https://github.com/apache/flink/pull/12819#discussion_r449993715
##
File path:
flink-table/flink-table-planner-blink/src/test/scala/org/apache/flink/table/planner/plan/stream/sql/TableScanTest.scala
##
@@ -357,4
flinkbot edited a comment on pull request #12819:
URL: https://github.com/apache/flink/pull/12819#issuecomment-653477506
## CI report:
* 9d62744ad9b4c2796aa02b96096b5340dd6163b8 Azure:
wuchong merged pull request #12778:
URL: https://github.com/apache/flink/pull/12778
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 #12824:
URL: https://github.com/apache/flink/pull/12824#issuecomment-653937012
## CI report:
* a112ae76f326f1abfa2f921dcdb0acd5f63ebf25 Azure:
[
https://issues.apache.org/jira/browse/FLINK-18150?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17144768#comment-17144768
]
Julius Michaelis edited comment on FLINK-18150 at 7/6/20, 1:23 AM:
---
My
[
https://issues.apache.org/jira/browse/FLINK-18150?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17144768#comment-17144768
]
Julius Michaelis edited comment on FLINK-18150 at 7/6/20, 1:23 AM:
---
My
[
https://issues.apache.org/jira/browse/FLINK-18150?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17151690#comment-17151690
]
Julius Michaelis commented on FLINK-18150:
--
Even worse, with Flink 1.11, the options that
[
https://issues.apache.org/jira/browse/FLINK-18487?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu updated FLINK-18487:
Affects Version/s: (was: 1.10.1)
1.11.0
> New table source factory omits
[
https://issues.apache.org/jira/browse/FLINK-18487?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17151705#comment-17151705
]
Jingsong Lee commented on FLINK-18487:
--
It is true, we can implement a validator for this. But it
dianfu commented on a change in pull request #12824:
URL: https://github.com/apache/flink/pull/12824#discussion_r449958503
##
File path: flink-python/pyflink/table/sources.py
##
@@ -38,16 +38,62 @@ class CsvTableSource(TableSource):
(logically) unlimited number of fields.
RocMarshal commented on pull request #12778:
URL: https://github.com/apache/flink/pull/12778#issuecomment-653994878
@wuchong Could you help me to merge this PR if the condition is met ?
Thank you.
This is an automated
[
https://issues.apache.org/jira/browse/FLINK-18449?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17151727#comment-17151727
]
zhisheng commented on FLINK-18449:
--
In FlinkKafkaConsumer, the constructor method as the follow:
[
https://issues.apache.org/jira/browse/FLINK-18397?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17151738#comment-17151738
]
Leo commented on FLINK-18397:
-
Thank you Benchao Li.
@ Jark Wu，@Benchao Li
I have a question now. When I
wuchong commented on a change in pull request #12805:
URL: https://github.com/apache/flink/pull/12805#discussion_r449967255
##
File path:
flink-connectors/flink-connector-kafka-base/src/test/java/org/apache/flink/streaming/connectors/kafka/table/KafkaDynamicTableFactoryTestBase.java
[
https://issues.apache.org/jira/browse/FLINK-18422?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu closed FLINK-18422.
---
Fix Version/s: 1.11.1
1.12.0
Resolution: Fixed
- master (1.12.0):
[
https://issues.apache.org/jira/browse/FLINK-18397?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17151493#comment-17151493
]
Benchao Li commented on FLINK-18397:
[~LeoGq] I've commented on the pr again this morning, you can
Ori Popowski created FLINK-18489:
Summary: java.lang.ArrayIndexOutOfBoundsException
Key: FLINK-18489
URL: https://issues.apache.org/jira/browse/FLINK-18489
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-18489?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ori Popowski updated FLINK-18489:
-
Description:
Getting {{java.lang.ArrayIndexOutOfBoundsException}} with the following
[
https://issues.apache.org/jira/browse/FLINK-18489?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ori Popowski updated FLINK-18489:
-
Environment:
{code:java}
OS current user: yarn
Current Hadoop/Kerberos user: hadoop
JVM: Java
[
https://issues.apache.org/jira/browse/FLINK-18489?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ori Popowski updated FLINK-18489:
-
Description:
Getting {{java.lang.ArrayIndexOutOfBoundsException}} with the following
[
https://issues.apache.org/jira/browse/FLINK-18489?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ori Popowski updated FLINK-18489:
-
Description:
Getting {{java.lang.ArrayIndexOutOfBoundsException}} with the following
[
https://issues.apache.org/jira/browse/FLINK-18489?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ori Popowski updated FLINK-18489:
-
Summary: java.lang.ArrayIndexOutOfBoundsException from
DataOutputSerializer.write (was:
[
https://issues.apache.org/jira/browse/FLINK-17177?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17151533#comment-17151533
]
Robert Metzger commented on FLINK-17177:
Thanks for your response. Let's see what
Chris Nix created FLINK-18488:
-
Summary: Python API CsvTableSource missing optional constructor
params
Key: FLINK-18488
URL: https://issues.apache.org/jira/browse/FLINK-18488
Project: Flink
Benchao Li created FLINK-18487:
--
Summary: New table source factory omits unrecognized properties
silently
Key: FLINK-18487
URL: https://issues.apache.org/jira/browse/FLINK-18487
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-16855?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17151534#comment-17151534
]
Robert Metzger commented on FLINK-16855:
Okay, I understand. I added it to the "Documentation"
[
https://issues.apache.org/jira/browse/FLINK-16855?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger updated FLINK-16855:
---
Component/s: Documentation
> Update K8s template for the standalone setup
>
[
https://issues.apache.org/jira/browse/FLINK-17273?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17151535#comment-17151535
]
Robert Metzger commented on FLINK-17273:
no problem & done.
> Fix not calling
[
https://issues.apache.org/jira/browse/FLINK-17273?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger updated FLINK-17273:
---
Fix Version/s: (was: 1.11.0)
1.12.0
> Fix not calling
[
https://issues.apache.org/jira/browse/FLINK-18488?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17151553#comment-17151553
]
Chris Nix commented on FLINK-18488:
---
One option to fix this might be to add keyword params to the
flinkbot commented on pull request #12824:
URL: https://github.com/apache/flink/pull/12824#issuecomment-653935647
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
BryceCicada opened a new pull request #12824:
URL: https://github.com/apache/flink/pull/12824
## What is the purpose of the change
CsvTableSource in Python API is missing a number of constructor params
compared to the Java API.
## Brief change log
- *Added
[
https://issues.apache.org/jira/browse/FLINK-18488?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-18488:
---
Labels: pull-request-available (was: )
> Python API CsvTableSource missing optional
flinkbot commented on pull request #12824:
URL: https://github.com/apache/flink/pull/12824#issuecomment-653937012
## CI report:
* a112ae76f326f1abfa2f921dcdb0acd5f63ebf25 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot
zenfenan opened a new pull request #12823:
URL: https://github.com/apache/flink/pull/12823
## What is the purpose of the change
To reduce code duplication.
## Brief change log
We have significant duplications of utility classes related to Hadoop in
different
[
https://issues.apache.org/jira/browse/FLINK-18013?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-18013:
---
Labels: pull-request-available (was: )
> Refactor Hadoop Utility classes/functions into a
[
https://issues.apache.org/jira/browse/FLINK-17073?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17151618#comment-17151618
]
Biao Liu commented on FLINK-17073:
--
Hi [~echauchot], thanks for doing so much. I left a couple of
flinkbot commented on pull request #12823:
URL: https://github.com/apache/flink/pull/12823#issuecomment-653912402
## CI report:
* 5d34b7f319c1df3f899c033e27b466cb6de14f7c UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot
flinkbot edited a comment on pull request #12823:
URL: https://github.com/apache/flink/pull/12823#issuecomment-653912402
## CI report:
* 5d34b7f319c1df3f899c033e27b466cb6de14f7c Azure:
[
https://issues.apache.org/jira/browse/FLINK-18013?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17151619#comment-17151619
]
Sivaprasanna Sethuraman edited comment on FLINK-18013 at 7/5/20, 4:47 PM:
[
https://issues.apache.org/jira/browse/FLINK-18013?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17151619#comment-17151619
]
Sivaprasanna Sethuraman commented on FLINK-18013:
-
[~rmetzger] Hi, sorry about the
flinkbot commented on pull request #12823:
URL: https://github.com/apache/flink/pull/12823#issuecomment-653911139
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-18488?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17151570#comment-17151570
]
Chris Nix commented on FLINK-18488:
---
I'll create a merge request with the change as described above
[
https://issues.apache.org/jira/browse/FLINK-13414?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17151590#comment-17151590
]
Aris Koliopoulos commented on FLINK-13414:
--
I had a go at it using two different ways:
[
https://issues.apache.org/jira/browse/FLINK-13414?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17151590#comment-17151590
]
Aris Koliopoulos edited comment on FLINK-13414 at 7/5/20, 2:34 PM:
---
I
morsapaes commented on a change in pull request #352:
URL: https://github.com/apache/flink-web/pull/352#discussion_r449857553
##
File path: _posts/2020-07-06-release-1.11.0.md
##
@@ -0,0 +1,307 @@
+---
+layout: post
+title: "Apache Flink 1.11.0 Release Announcement"
+date:
morsapaes commented on a change in pull request #352:
URL: https://github.com/apache/flink-web/pull/352#discussion_r449857553
##
File path: _posts/2020-07-06-release-1.11.0.md
##
@@ -0,0 +1,307 @@
+---
+layout: post
+title: "Apache Flink 1.11.0 Release Announcement"
+date:
81 matches
Mail list logo
