Github user NicoK commented on a diff in the pull request:
https://github.com/apache/flink/pull/6238#discussion_r199702444
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/buffer/NetworkBufferPool.java
---
@@ -147,7 +151,12 @@ public void
[
https://issues.apache.org/jira/browse/FLINK-9622?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16530928#comment-16530928
]
Till Rohrmann commented on FLINK-9622:
--
Well the actual problem is that there are two concurrent
Chesnay Schepler created FLINK-9706:
---
Summary: DispatcherTest#testSubmittedJobGraphListener fails on
Travis
Key: FLINK-9706
URL: https://issues.apache.org/jira/browse/FLINK-9706
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-9178?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16530933#comment-16530933
]
buptljy commented on FLINK-9178:
[~tzulitai] I'd like to add something about this issue, whick is very
[
https://issues.apache.org/jira/browse/FLINK-9004?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16530977#comment-16530977
]
ASF GitHub Bot commented on FLINK-9004:
---
Github user zentol commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-9004?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16530983#comment-16530983
]
ASF GitHub Bot commented on FLINK-9004:
---
Github user asfgit closed the pull request at:
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/6211
I've merged the PR, @jelmerk could you close it? Thanks!
---
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/6239
whoops, sorry I accidentally closed this PR, added the wrong PR ID to a
commit :(
I'm so sorry.
---
[
https://issues.apache.org/jira/browse/FLINK-9004?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16530985#comment-16530985
]
ASF GitHub Bot commented on FLINK-9004:
---
Github user zentol commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-9665?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16530986#comment-16530986
]
ASF GitHub Bot commented on FLINK-9665:
---
Github user zentol commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-9665?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-9665.
---
Resolution: Fixed
Fix Version/s: 1.5.1
1.4.3
[
https://issues.apache.org/jira/browse/FLINK-7593?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16530995#comment-16530995
]
Fabian Hueske commented on FLINK-7593:
--
Thanks for the feedback and the effort to reproduce the
Github user florianschmidt1994 commented on the issue:
https://github.com/apache/flink/pull/6216
Thanks @zentol, I have one remark (see above), besides that looks good to
me!
Additionally I had some ideas that came to mind that I think we could
discuss:
- We have a
[
https://issues.apache.org/jira/browse/FLINK-9699?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16531004#comment-16531004
]
Fabian Hueske commented on FLINK-9699:
--
It might be possible to change the translation behavior,
[
https://issues.apache.org/jira/browse/FLINK-9674?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16531006#comment-16531006
]
ASF GitHub Bot commented on FLINK-9674:
---
Github user florianschmidt1994 commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-9554?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-9554:
--
Labels: pull-request-available (was: )
> flink scala shell doesn't work in yarn mode
>
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/6140#discussion_r199724031
--- Diff:
flink-scala-shell/src/main/scala/org/apache/flink/api/scala/FlinkShell.scala ---
@@ -255,14 +257,25 @@ object FlinkShell {
Florian Schmidt created FLINK-9709:
--
Summary: Docs: Unnecessary transition in flink job lifecycle
visualization
Key: FLINK-9709
URL: https://issues.apache.org/jira/browse/FLINK-9709
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-9554?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16531011#comment-16531011
]
ASF GitHub Bot commented on FLINK-9554:
---
Github user zentol commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-9709?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Florian Schmidt updated FLINK-9709:
---
Description: The docs at
[
https://issues.apache.org/jira/browse/FLINK-9709?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Florian Schmidt updated FLINK-9709:
---
Summary: Docs: Unnecessary transition in flink job state visualization
(was: Docs:
[
https://issues.apache.org/jira/browse/FLINK-9004?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16531018#comment-16531018
]
ASF GitHub Bot commented on FLINK-9004:
---
GitHub user GJL opened a pull request:
GitHub user GJL opened a pull request:
https://github.com/apache/flink/pull/6240
[FLINK-9004][tests] Implement Jepsen tests to test job availability.
## What is the purpose of the change
*Use the Jepsen framework (https://github.com/jepsen-io/jepsen) to implement
tests
Chuanlei Ni created FLINK-9710:
--
Summary: Make ClusterClient be used as multiple instances in a
single jvm process
Key: FLINK-9710
URL: https://issues.apache.org/jira/browse/FLINK-9710
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-9004?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16531019#comment-16531019
]
ASF GitHub Bot commented on FLINK-9004:
---
Github user GJL commented on the issue:
Github user GJL commented on the issue:
https://github.com/apache/flink/pull/6239
@zentol No problem, I opened a new one.
---
Github user GJL commented on the issue:
https://github.com/apache/flink/pull/6240
As @zentol mentioned, we might want to exclude this from
create_source_release.sh.
---
[
https://issues.apache.org/jira/browse/FLINK-9004?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16531021#comment-16531021
]
ASF GitHub Bot commented on FLINK-9004:
---
Github user GJL commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-9699?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16531027#comment-16531027
]
Jeff Zhang commented on FLINK-9699:
---
Thanks [~fhueske], let's hold this ticket for now. I will try to
[
https://issues.apache.org/jira/browse/FLINK-9674?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16531030#comment-16531030
]
ASF GitHub Bot commented on FLINK-9674:
---
Github user zentol commented on the issue:
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/6216
@florianschmidt1994 I don't see the comment you're referring to :(
(Did you start a review, but wrote your comment separately? Then your
review would still be in progress!)
The issues you
[
https://issues.apache.org/jira/browse/FLINK-9674?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16531034#comment-16531034
]
ASF GitHub Bot commented on FLINK-9674:
---
Github user florianschmidt1994 commented on a diff in the
Github user florianschmidt1994 commented on a diff in the pull request:
https://github.com/apache/flink/pull/6216#discussion_r199719951
--- Diff:
flink-end-to-end-tests/test-scripts/test_queryable_state_restart_tm.sh ---
@@ -85,20 +90,23 @@ function run_test() {
exit
Github user florianschmidt1994 commented on the issue:
https://github.com/apache/flink/pull/6216
> (Did you start a review, but wrote your comment separately? Then your
review would still be in progress!)
Yes :D I submitted it now
>The issues you identified are
[
https://issues.apache.org/jira/browse/FLINK-9674?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16531040#comment-16531040
]
ASF GitHub Bot commented on FLINK-9674:
---
Github user florianschmidt1994 commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-9444?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16531044#comment-16531044
]
ASF GitHub Bot commented on FLINK-9444:
---
Github user twalthr commented on a diff in the pull
Github user twalthr commented on a diff in the pull request:
https://github.com/apache/flink/pull/6218#discussion_r199731327
--- Diff:
flink-core/src/test/java/org/apache/flink/api/java/typeutils/RowTypeInfoTest.java
---
@@ -123,4 +125,24 @@ public void testNestedRowTypeInfo() {
[
https://issues.apache.org/jira/browse/FLINK-9699?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16530922#comment-16530922
]
Jeff Zhang commented on FLINK-9699:
---
[~fhueske] I don't know much about the internal mechanism of flink
[
https://issues.apache.org/jira/browse/FLINK-9636?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16530927#comment-16530927
]
ASF GitHub Bot commented on FLINK-9636:
---
Github user NicoK commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-9622?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16530931#comment-16530931
]
Till Rohrmann commented on FLINK-9622:
--
The problem there seems to be that
Till Rohrmann created FLINK-9707:
Summary: LocalFileSystem does not support concurrent directory
creations
Key: FLINK-9707
URL: https://issues.apache.org/jira/browse/FLINK-9707
Project: Flink
Github user suez1224 commented on the issue:
https://github.com/apache/flink/pull/6201
@fhueske @twalthr thanks for the comments. In `from-source`, the only
system i know of is Kafka10 or Kafka11, which support writing record along with
timestamp. To support `from-source` in table
[
https://issues.apache.org/jira/browse/FLINK-8866?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16530939#comment-16530939
]
ASF GitHub Bot commented on FLINK-8866:
---
Github user suez1224 commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-9707?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-9707:
-
Priority: Blocker (was: Major)
> LocalFileSystem does not support concurrent directory
Nico Kruber created FLINK-9708:
--
Summary: Network buffer leaks when buffer request fails during
buffer redistribution
Key: FLINK-9708
URL: https://issues.apache.org/jira/browse/FLINK-9708
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-9688?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16530946#comment-16530946
]
ASF GitHub Bot commented on FLINK-9688:
---
Github user snuyanzin commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-9636?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16530944#comment-16530944
]
ASF GitHub Bot commented on FLINK-9636:
---
Github user NicoK commented on the issue:
Github user NicoK commented on the issue:
https://github.com/apache/flink/pull/6238
actually, it was quite easy to reproduce and the fix was also just as you
proposed - please see the new commits (the old one was only renamed since I
created a separate issue for that now)
---
Github user snuyanzin commented on the issue:
https://github.com/apache/flink/pull/6223
@fhueske @hequn8128 @yanghua thank you very much for your review and
comments
I did almost all the corrections except one related to atan2 description
So I have a question:
as
[
https://issues.apache.org/jira/browse/FLINK-9554?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jeff Zhang updated FLINK-9554:
--
Fix Version/s: 1.5.1
> flink scala shell doesn't work in yarn mode
>
[
https://issues.apache.org/jira/browse/FLINK-9554?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jeff Zhang updated FLINK-9554:
--
Priority: Blocker (was: Major)
> flink scala shell doesn't work in yarn mode
>
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/6239
As i understand it we don't want this to be part of the source release, as
such we need an exclusion in
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/6239
---
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/6222#discussion_r199719645
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/job/JobSubmitHandler.java
---
@@ -66,6 +67,9 @@ public JobSubmitHandler(
[
https://issues.apache.org/jira/browse/FLINK-8785?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16530990#comment-16530990
]
ASF GitHub Bot commented on FLINK-8785:
---
Github user zentol commented on a diff in the pull
Github user twalthr commented on a diff in the pull request:
https://github.com/apache/flink/pull/6218#discussion_r199733710
--- Diff: flink-formats/flink-avro/pom.xml ---
@@ -51,6 +51,17 @@ under the License.
+
+
[
https://issues.apache.org/jira/browse/FLINK-9444?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16531052#comment-16531052
]
ASF GitHub Bot commented on FLINK-9444:
---
Github user twalthr commented on a diff in the pull
Github user twalthr commented on a diff in the pull request:
https://github.com/apache/flink/pull/6218#discussion_r199734399
--- Diff:
flink-connectors/flink-connector-kafka-base/src/test/java/org/apache/flink/streaming/connectors/kafka/KafkaAvroTableSourceTestBase.java
---
@@
[
https://issues.apache.org/jira/browse/FLINK-9444?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16531056#comment-16531056
]
ASF GitHub Bot commented on FLINK-9444:
---
Github user twalthr commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-9444?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16531061#comment-16531061
]
ASF GitHub Bot commented on FLINK-9444:
---
Github user twalthr commented on a diff in the pull
Github user twalthr commented on a diff in the pull request:
https://github.com/apache/flink/pull/6218#discussion_r199736070
--- Diff:
flink-formats/flink-avro/src/test/java/org/apache/flink/formats/avro/typeutils/BackwardsCompatibleAvroSerializerTest.java
---
@@ -26,7 +26,7 @@
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/6216#discussion_r199738568
--- Diff:
flink-end-to-end-tests/test-scripts/test_queryable_state_restart_tm.sh ---
@@ -85,20 +90,23 @@ function run_test() {
exit 1
[
https://issues.apache.org/jira/browse/FLINK-9674?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16531072#comment-16531072
]
ASF GitHub Bot commented on FLINK-9674:
---
Github user zentol commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-9280?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16531094#comment-16531094
]
ASF GitHub Bot commented on FLINK-9280:
---
Github user zentol commented on a diff in the pull
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/6203#discussion_r199741252
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/job/JobSubmitRequestBody.java
---
@@ -18,64 +18,118 @@
package
Sayat Satybaldiyev created FLINK-9711:
-
Summary: Flink CLI does not filter RUNNING only jobs
Key: FLINK-9711
URL: https://issues.apache.org/jira/browse/FLINK-9711
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-9711?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sayat Satybaldiyev updated FLINK-9711:
--
Summary: Flink CLI --running option does not show RUNNING only jobs (was:
Flink CLI
[
https://issues.apache.org/jira/browse/FLINK-9688?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16531099#comment-16531099
]
ASF GitHub Bot commented on FLINK-9688:
---
Github user fhueske commented on a diff in the pull
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/6223#discussion_r199743600
--- Diff: docs/dev/table/tableApi.md ---
@@ -2184,6 +2184,17 @@ NUMERIC.atan()
+
+
+{% highlight
[
https://issues.apache.org/jira/browse/FLINK-9711?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-9711.
---
Resolution: Duplicate
Already fixed for 1.5.1.
> Flink CLI --running option does not show
GitHub user zentol opened a pull request:
https://github.com/apache/flink/pull/6241
[FLINK-9289][rest] Rework JobSubmitHandler to accept jar files
Backport of #6203 for 1.5.
The differences to the current version of the linked PR (state @
[
https://issues.apache.org/jira/browse/FLINK-9713?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski updated FLINK-9713:
--
Component/s: Table API & SQL
> Support versioned joins in planning phase
>
Github user fhueske commented on the issue:
https://github.com/apache/flink/pull/6201
Hi @suez1224, that sounds good overall. :-)
A few comments:
- I would not add a user-facing property `connector.support-timestamp`
because a user chooses that by choosing the
[
https://issues.apache.org/jira/browse/FLINK-9713?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski updated FLINK-9713:
--
Affects Version/s: 1.5.0
> Support versioned joins in planning phase
>
[
https://issues.apache.org/jira/browse/FLINK-9289?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16531112#comment-16531112
]
ASF GitHub Bot commented on FLINK-9289:
---
GitHub user zentol opened a pull request:
Piotr Nowojski created FLINK-9712:
-
Summary: Support enrichment joins in Flink SQL/Table API
Key: FLINK-9712
URL: https://issues.apache.org/jira/browse/FLINK-9712
Project: Flink
Issue Type:
Piotr Nowojski created FLINK-9713:
-
Summary: Support versioned joins in planning phase
Key: FLINK-9713
URL: https://issues.apache.org/jira/browse/FLINK-9713
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-9444?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16531117#comment-16531117
]
ASF GitHub Bot commented on FLINK-9444:
---
Github user twalthr commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-9712?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski updated FLINK-9712:
--
Description:
As described here:
[
https://issues.apache.org/jira/browse/FLINK-8866?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16531114#comment-16531114
]
ASF GitHub Bot commented on FLINK-8866:
---
Github user fhueske commented on the issue:
Github user twalthr commented on a diff in the pull request:
https://github.com/apache/flink/pull/6218#discussion_r199746600
--- Diff:
flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AvroRowDeserializationSchema.java
---
@@ -17,154 +17,338 @@
[
https://issues.apache.org/jira/browse/FLINK-9674?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16531118#comment-16531118
]
ASF GitHub Bot commented on FLINK-9674:
---
Github user zentol commented on the issue:
Piotr Nowojski created FLINK-9714:
-
Summary: Support versioned joins with processing time
Key: FLINK-9714
URL: https://issues.apache.org/jira/browse/FLINK-9714
Project: Flink
Issue Type:
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/6216
merging.
---
Github user twalthr commented on a diff in the pull request:
https://github.com/apache/flink/pull/6218#discussion_r199746426
--- Diff:
flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AvroRowSerializationSchema.java
---
@@ -37,18 +43,42 @@
import
[
https://issues.apache.org/jira/browse/FLINK-9715?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski updated FLINK-9715:
--
Affects Version/s: 1.5.0
> Support versioned joins with event time
>
[
https://issues.apache.org/jira/browse/FLINK-9444?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16531120#comment-16531120
]
ASF GitHub Bot commented on FLINK-9444:
---
Github user twalthr commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-9715?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski updated FLINK-9715:
--
Component/s: Table API & SQL
> Support versioned joins with event time
>
Piotr Nowojski created FLINK-9715:
-
Summary: Support versioned joins with event time
Key: FLINK-9715
URL: https://issues.apache.org/jira/browse/FLINK-9715
Project: Flink
Issue Type: Sub-task
Github user twalthr commented on a diff in the pull request:
https://github.com/apache/flink/pull/6218#discussion_r199747223
--- Diff:
flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AvroRowDeserializationSchema.java
---
@@ -17,154 +17,338 @@
GitHub user satybald opened a pull request:
https://github.com/apache/flink/pull/6242
[FLINK-9711][CLI] Filter only RUNNING jobs when --running option provided
in CLI
## What is the purpose of the change
In Flink CLI there's a command list with option --running that
[
https://issues.apache.org/jira/browse/FLINK-9444?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16531123#comment-16531123
]
ASF GitHub Bot commented on FLINK-9444:
---
Github user twalthr commented on a diff in the pull
Piotr Nowojski created FLINK-9716:
-
Summary: Support scans from table version function
Key: FLINK-9716
URL: https://issues.apache.org/jira/browse/FLINK-9716
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-9711?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16531124#comment-16531124
]
ASF GitHub Bot commented on FLINK-9711:
---
GitHub user satybald opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-9714?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski updated FLINK-9714:
--
Description:
Queries like:
{code:java}
SELECT
o.amount * r.rate
FROM
Orders AS o,
[
https://issues.apache.org/jira/browse/FLINK-9713?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski updated FLINK-9713:
--
Description:
Queries like:
{code:java}
SELECT
o.amount * r.rate
FROM
Orders AS o,
Github user twalthr commented on a diff in the pull request:
https://github.com/apache/flink/pull/6218#discussion_r199748214
--- Diff:
flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AvroRowDeserializationSchema.java
---
@@ -17,154 +17,338 @@
[
https://issues.apache.org/jira/browse/FLINK-9444?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16531128#comment-16531128
]
ASF GitHub Bot commented on FLINK-9444:
---
Github user twalthr commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-9713?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski updated FLINK-9713:
--
Description:
Queries like:
{code:java}
SELECT
o.amount * r.rate
FROM
Orders AS o,
[
https://issues.apache.org/jira/browse/FLINK-9715?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski updated FLINK-9715:
--
Description:
Queries like:
{code:java}
SELECT
o.amount * r.rate
FROM
Orders AS o,
1 - 100 of 483 matches
Mail list logo
