Jark Wu created FLINK-4420:
--
Summary: Introduce star(*) to select all of the columns in the
table
Key: FLINK-4420
URL: https://issues.apache.org/jira/browse/FLINK-4420
Project: Flink
Issue Type: Ne
[
https://issues.apache.org/jira/browse/FLINK-4435?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu reassigned FLINK-4435:
--
Assignee: Jark Wu
> Replace Guava's VisibleForTesting annotation with Flink's annotation
>
[
https://issues.apache.org/jira/browse/FLINK-4453?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu reassigned FLINK-4453:
--
Assignee: Jark Wu
> Scala code example in Window documentation shows Java
> ---
Jark Wu created FLINK-4469:
--
Summary: Add support for user defined table function in Table API
& SQL
Key: FLINK-4469
URL: https://issues.apache.org/jira/browse/FLINK-4469
Project: Flink
Issue Type:
Jark Wu created FLINK-4503:
--
Summary: Remove with method from CoGroupedStream and JoinedStream,
and change apply method return type
Key: FLINK-4503
URL: https://issues.apache.org/jira/browse/FLINK-4503
Proje
[
https://issues.apache.org/jira/browse/FLINK-4510?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15439292#comment-15439292
]
Jark Wu commented on FLINK-4510:
Hi [~uce] , I would like to contribute this issue.
> Alw
[
https://issues.apache.org/jira/browse/FLINK-4469?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15448024#comment-15448024
]
Jark Wu commented on FLINK-4469:
Agree with that. Using a collector will be more user-frie
[
https://issues.apache.org/jira/browse/FLINK-4469?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15448024#comment-15448024
]
Jark Wu edited comment on FLINK-4469 at 8/30/16 4:51 AM:
-
Agree wi
Jark Wu created FLINK-4546:
--
Summary: Remove STREAM keyword and use batch sql parser for stream
jobs
Key: FLINK-4546
URL: https://issues.apache.org/jira/browse/FLINK-4546
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-4546?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu updated FLINK-4546:
---
Issue Type: New Feature (was: Bug)
> Remove STREAM keyword and use batch sql parser for stream jobs
> ---
[
https://issues.apache.org/jira/browse/FLINK-4546?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu updated FLINK-4546:
---
Summary: Remove STREAM keyword in Stream SQL (was: Remove STREAM keyword
and use batch sql parser for stream
[
https://issues.apache.org/jira/browse/FLINK-4579?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15464832#comment-15464832
]
Jark Wu commented on FLINK-4579:
+1 for adding rocksdb to the standard distribution lib. S
[
https://issues.apache.org/jira/browse/FLINK-4565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15469402#comment-15469402
]
Jark Wu commented on FLINK-4565:
I think what is confusing [~chobeat] is what's "IN" 's co
[
https://issues.apache.org/jira/browse/FLINK-4591?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15472401#comment-15472401
]
Jark Wu commented on FLINK-4591:
It seems that {{GROUP BY *}} is not allowed in SQL. Mayb
Jark Wu created FLINK-4597:
--
Summary: Improve Scalar Function section in Table API documentation
Key: FLINK-4597
URL: https://issues.apache.org/jira/browse/FLINK-4597
Project: Flink
Issue Type: Impr
Jark Wu created FLINK-4598:
--
Summary: Support NULLIF in Table API
Key: FLINK-4598
URL: https://issues.apache.org/jira/browse/FLINK-4598
Project: Flink
Issue Type: New Feature
Components:
[
https://issues.apache.org/jira/browse/FLINK-4597?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15473160#comment-15473160
]
Jark Wu commented on FLINK-4597:
I have a look at Calcite documentation [1] , this syntax
[
https://issues.apache.org/jira/browse/FLINK-4597?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu closed FLINK-4597.
--
Resolution: Duplicate
> Improve Scalar Function section in Table API documentation
> ---
[
https://issues.apache.org/jira/browse/FLINK-4598?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15473200#comment-15473200
]
Jark Wu commented on FLINK-4598:
You are right. We should evaluate what functions should b
[
https://issues.apache.org/jira/browse/FLINK-4579?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu reassigned FLINK-4579:
--
Assignee: Jark Wu
> Add StateBackendFactory for RocksDB Backend
> -
[
https://issues.apache.org/jira/browse/FLINK-4591?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu reassigned FLINK-4591:
--
Assignee: Jark Wu
> Select star does not work with grouping
> ---
>
[
https://issues.apache.org/jira/browse/FLINK-4591?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15476058#comment-15476058
]
Jark Wu commented on FLINK-4591:
Make sense. I will look into it.
> Select star does not
[
https://issues.apache.org/jira/browse/FLINK-4591?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15476147#comment-15476147
]
Jark Wu commented on FLINK-4591:
Make sense... They are equal, we should encourage to use
[
https://issues.apache.org/jira/browse/FLINK-4591?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15476177#comment-15476177
]
Jark Wu edited comment on FLINK-4591 at 9/9/16 7:15 AM:
Is {{.grou
[
https://issues.apache.org/jira/browse/FLINK-4591?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15476177#comment-15476177
]
Jark Wu commented on FLINK-4591:
Is {{.groupBy( '* ).select( '* , 'a.count )}} a strong c
[
https://issues.apache.org/jira/browse/FLINK-4598?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu closed FLINK-4598.
--
Resolution: Won't Fix
> Support NULLIF in Table API
>
>
> Key: FLI
[
https://issues.apache.org/jira/browse/FLINK-4662?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu reassigned FLINK-4662:
--
Assignee: Jark Wu
> Bump Calcite version up to 1.9
> --
>
>
[
https://issues.apache.org/jira/browse/FLINK-4263?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15513401#comment-15513401
]
Jark Wu commented on FLINK-4263:
It seems that the data types in {{VALUES}} are always Rex
[
https://issues.apache.org/jira/browse/FLINK-4263?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15515209#comment-15515209
]
Jark Wu commented on FLINK-4263:
I have no idea how to code generate the values input form
[
https://issues.apache.org/jira/browse/FLINK-4605?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15515702#comment-15515702
]
Jark Wu commented on FLINK-4605:
Hi [~twalthr], could you explain this issue a little more
[
https://issues.apache.org/jira/browse/FLINK-4621?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15515830#comment-15515830
]
Jark Wu commented on FLINK-4621:
I think the problem is how to convert BigDecimal into re
[
https://issues.apache.org/jira/browse/FLINK-6259?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu closed FLINK-6259.
--
Resolution: Fixed
Fix Version/s: 1.3.0
fixed in cae4976a4b9d4fa67f207dd08b8c9480c6f8989b
> Fix a small s
[
https://issues.apache.org/jira/browse/FLINK-4692?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15652869#comment-15652869
]
Jark Wu commented on FLINK-4692:
Yes. I agree to move the sliding window to a separate iss
Jark Wu created FLINK-5047:
--
Summary: Add tumbling group-windows for batch tables
Key: FLINK-5047
URL: https://issues.apache.org/jira/browse/FLINK-5047
Project: Flink
Issue Type: Sub-task
[
https://issues.apache.org/jira/browse/FLINK-5047?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu updated FLINK-5047:
---
Summary: Add sliding group-windows for batch tables (was: Add Sliding
group-windows for batch tables)
> Add
[
https://issues.apache.org/jira/browse/FLINK-5047?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu updated FLINK-5047:
---
Description:
Add Slide group-windows for batch tables as described in
[FLIP-11|https://cwiki.apache.org/confl
[
https://issues.apache.org/jira/browse/FLINK-5047?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu updated FLINK-5047:
---
Summary: Add Sliding group-windows for batch tables (was: Add tumbling
group-windows for batch tables)
> Add
[
https://issues.apache.org/jira/browse/FLINK-4692?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu updated FLINK-4692:
---
Description: Add Tumble group-windows for batch tables as described in
[FLIP-11|https://cwiki.apache.org/confl
[
https://issues.apache.org/jira/browse/FLINK-4692?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu updated FLINK-4692:
---
Summary: Add tumbling group-windows for batch tables (was: Add tumbling
and sliding group-windows for batch t
[
https://issues.apache.org/jira/browse/FLINK-4692?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15652887#comment-15652887
]
Jark Wu commented on FLINK-4692:
Hi guys, I moved the sliding window into FLINK-5047. And
[
https://issues.apache.org/jira/browse/FLINK-5047?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15653869#comment-15653869
]
Jark Wu commented on FLINK-5047:
Hi [~fhueske] Agree. I think the first approach can be ea
[
https://issues.apache.org/jira/browse/FLINK-4692?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu reassigned FLINK-4692:
--
Assignee: Jark Wu
> Add tumbling group-windows for batch tables
> -
[
https://issues.apache.org/jira/browse/FLINK-5047?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15653975#comment-15653975
]
Jark Wu commented on FLINK-5047:
Make sense. I prefer the third approach too.
> Add slid
[
https://issues.apache.org/jira/browse/FLINK-4565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15654209#comment-15654209
]
Jark Wu commented on FLINK-4565:
Hi, [~nvasilishin], regarding to the second problem, I
[
https://issues.apache.org/jira/browse/FLINK-4565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15655847#comment-15655847
]
Jark Wu commented on FLINK-4565:
Thank you [~fhueske] for the detailed internals.
Regard
[
https://issues.apache.org/jira/browse/FLINK-4679?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15676708#comment-15676708
]
Jark Wu commented on FLINK-4679:
Hi [~fhueske] [~twalthr], if I understand correctly, the
[
https://issues.apache.org/jira/browse/FLINK-5094?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15676759#comment-15676759
]
Jark Wu commented on FLINK-5094:
Hi [~fhueske], this may need to modify the implementation
[
https://issues.apache.org/jira/browse/FLINK-4591?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu closed FLINK-4591.
--
Resolution: Won't Fix
> Select star does not work with grouping
> ---
>
>
[
https://issues.apache.org/jira/browse/FLINK-4692?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15698090#comment-15698090
]
Jark Wu commented on FLINK-4692:
Hi [~fhueske] [~twalthr], I have proposed a [design
doc|
[
https://issues.apache.org/jira/browse/FLINK-4692?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15698090#comment-15698090
]
Jark Wu edited comment on FLINK-4692 at 11/29/16 1:49 AM:
--
Hi [~f
Jark Wu created FLINK-5223:
--
Summary: Add documentation of UDTF in Table API & SQL
Key: FLINK-5223
URL: https://issues.apache.org/jira/browse/FLINK-5223
Project: Flink
Issue Type: Bug
Re
[
https://issues.apache.org/jira/browse/FLINK-5223?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu updated FLINK-5223:
---
Issue Type: Improvement (was: Bug)
> Add documentation of UDTF in Table API & SQL
> -
[
https://issues.apache.org/jira/browse/FLINK-5223?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu updated FLINK-5223:
---
Component/s: Table API & SQL
> Add documentation of UDTF in Table API & SQL
>
[
https://issues.apache.org/jira/browse/FLINK-5224?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu reassigned FLINK-5224:
--
Assignee: Jark Wu
> Improve UDTF: emit rows directly instead of buffering them
> --
Jark Wu created FLINK-5224:
--
Summary: Improve UDTF: emit rows directly instead of buffering them
Key: FLINK-5224
URL: https://issues.apache.org/jira/browse/FLINK-5224
Project: Flink
Issue Type: Impr
[
https://issues.apache.org/jira/browse/FLINK-5225?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu updated FLINK-5225:
---
Component/s: Table API & SQL
> Add interface to override parameter types of UDTF's eval method
> -
Jark Wu created FLINK-5225:
--
Summary: Add interface to override parameter types of UDTF's eval
method
Key: FLINK-5225
URL: https://issues.apache.org/jira/browse/FLINK-5225
Project: Flink
Issue Type
[
https://issues.apache.org/jira/browse/FLINK-5187?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15731686#comment-15731686
]
Jark Wu commented on FLINK-5187:
Hi [~tonycox], do you have been working on this issue? I
[
https://issues.apache.org/jira/browse/FLINK-5187?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15732044#comment-15732044
]
Jark Wu commented on FLINK-5187:
Sure. I will create the PR before tomorrow. Thanks.
> C
Jark Wu created FLINK-5304:
--
Summary: Change method name from crossApply to join in Table API
Key: FLINK-5304
URL: https://issues.apache.org/jira/browse/FLINK-5304
Project: Flink
Issue Type: Improve
[
https://issues.apache.org/jira/browse/FLINK-5304?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15734992#comment-15734992
]
Jark Wu commented on FLINK-5304:
Yes. {{outerApply}} will be renamed to {{leftOuterJoin}}
[
https://issues.apache.org/jira/browse/FLINK-5223?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu reassigned FLINK-5223:
--
Assignee: Jark Wu
> Add documentation of UDTF in Table API & SQL
>
[
https://issues.apache.org/jira/browse/FLINK-5225?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu reassigned FLINK-5225:
--
Assignee: Jark Wu
> Add interface to override parameter types of UDTF's eval method
> -
[
https://issues.apache.org/jira/browse/FLINK-5280?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15743965#comment-15743965
]
Jark Wu commented on FLINK-5280:
Hi [~ivan.mushketyk], I will try to answer your question.
[
https://issues.apache.org/jira/browse/FLINK-5280?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15750273#comment-15750273
]
Jark Wu commented on FLINK-5280:
Hi [~ivan.mushketyk], thanks for your detailed and clear
[
https://issues.apache.org/jira/browse/FLINK-5280?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15751325#comment-15751325
]
Jark Wu commented on FLINK-5280:
Hi [~ivan.mushketyk],
Yes, you are right. In your case,
Jark Wu created FLINK-5348:
--
Summary: Support custom field names for RowTypeInfo
Key: FLINK-5348
URL: https://issues.apache.org/jira/browse/FLINK-5348
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-5280?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15753315#comment-15753315
]
Jark Wu commented on FLINK-5280:
Row and RowTypeInfo has been moved to flink-core. So I wo
[
https://issues.apache.org/jira/browse/FLINK-5358?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15761026#comment-15761026
]
Jark Wu commented on FLINK-5358:
If one of the fields is null, what is the {{TypeInformati
Jark Wu created FLINK-4109:
--
Summary: Change the name of ternary condition operator 'eval' to
'?'
Key: FLINK-4109
URL: https://issues.apache.org/jira/browse/FLINK-4109
Project: Flink
Issue Type
Jark Wu created FLINK-4111:
--
Summary: Flink Table & SQL doesn't work in very simple example
Key: FLINK-4111
URL: https://issues.apache.org/jira/browse/FLINK-4111
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-4109?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15347564#comment-15347564
]
Jark Wu commented on FLINK-4109:
[~vkalavri] [~chengxiang li] [~rmetzger] what do you thi
[
https://issues.apache.org/jira/browse/FLINK-4130?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15356537#comment-15356537
]
Jark Wu commented on FLINK-4130:
It seems that cody has pulled a request for this issue:
[
https://issues.apache.org/jira/browse/FLINK-3792?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15356552#comment-15356552
]
Jark Wu commented on FLINK-3792:
Do we need this before 1.1.0 release ? If yes, I can tak
[
https://issues.apache.org/jira/browse/FLINK-4180?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu reassigned FLINK-4180:
--
Assignee: Jark Wu
> Create a batch SQL example
> --
>
> Key: FL
[
https://issues.apache.org/jira/browse/FLINK-4181?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu reassigned FLINK-4181:
--
Assignee: Jark Wu
> Add a basic streaming Table API example
> ---
>
[
https://issues.apache.org/jira/browse/FLINK-4180?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15367808#comment-15367808
]
Jark Wu commented on FLINK-4180:
I'll work on this.
> Create a batch SQL example
> --
[
https://issues.apache.org/jira/browse/FLINK-4181?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15367810#comment-15367810
]
Jark Wu commented on FLINK-4181:
I'll work on this.
> Add a basic streaming Table API exa
[
https://issues.apache.org/jira/browse/FLINK-4240?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15387824#comment-15387824
]
Jark Wu commented on FLINK-4240:
It's not a bug I think as we cannot select a column not i
[
https://issues.apache.org/jira/browse/FLINK-4244?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15387851#comment-15387851
]
Jark Wu commented on FLINK-4244:
Yes, we just merged [FLINK-2985] , but not update the doc
[
https://issues.apache.org/jira/browse/FLINK-4244?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu reassigned FLINK-4244:
--
Assignee: Jark Wu
> Field names for union operator do not have to be equal
> --
[
https://issues.apache.org/jira/browse/FLINK-4250?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15388780#comment-15388780
]
Jark Wu commented on FLINK-4250:
I think the second exception is similar to the first, bec
[
https://issues.apache.org/jira/browse/FLINK-4250?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15388780#comment-15388780
]
Jark Wu edited comment on FLINK-4250 at 7/22/16 2:55 AM:
-
I think
[
https://issues.apache.org/jira/browse/FLINK-4252?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15389003#comment-15389003
]
Jark Wu commented on FLINK-4252:
I debug it and find that we use {Class.getCanonicalName}
[
https://issues.apache.org/jira/browse/FLINK-4252?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15389003#comment-15389003
]
Jark Wu edited comment on FLINK-4252 at 7/22/16 6:35 AM:
-
I debug
[
https://issues.apache.org/jira/browse/FLINK-4252?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15389341#comment-15389341
]
Jark Wu commented on FLINK-4252:
Do we have the JIRA? Or just modify this JIRA to track i
[
https://issues.apache.org/jira/browse/FLINK-4203?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15389674#comment-15389674
]
Jark Wu commented on FLINK-4203:
We should also improve [Table API Operators
section|http
[
https://issues.apache.org/jira/browse/FLINK-4263?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu reassigned FLINK-4263:
--
Assignee: Jark Wu
> SQL's VALUES does not work properly
> ---
>
>
[
https://issues.apache.org/jira/browse/FLINK-4263?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15393950#comment-15393950
]
Jark Wu commented on FLINK-4263:
It seems that ValuesInputFormat has a {{Seq[Row]}} field,
[
https://issues.apache.org/jira/browse/FLINK-4263?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15396844#comment-15396844
]
Jark Wu commented on FLINK-4263:
Hi [~gallenvara_bg], thanks for your advice. But I think
[
https://issues.apache.org/jira/browse/FLINK-4271?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu reassigned FLINK-4271:
--
Assignee: Jark Wu
> There is no way to set parallelism of operators produced by CoGroupedStreams
>
[
https://issues.apache.org/jira/browse/FLINK-4271?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15397004#comment-15397004
]
Jark Wu commented on FLINK-4271:
The CoGroupStream will construct the following graph.
{
[
https://issues.apache.org/jira/browse/FLINK-4271?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15397004#comment-15397004
]
Jark Wu edited comment on FLINK-4271 at 7/28/16 6:17 AM:
-
The CoGr
[
https://issues.apache.org/jira/browse/FLINK-4271?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15397187#comment-15397187
]
Jark Wu commented on FLINK-4271:
Yea, SingleOutputStreamOperator can set parallelism, uid,
[
https://issues.apache.org/jira/browse/FLINK-4270?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu reassigned FLINK-4270:
--
Assignee: Jark Wu
> 'as' in front of join does not work
> ---
>
>
[
https://issues.apache.org/jira/browse/FLINK-4262?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15405384#comment-15405384
]
Jark Wu commented on FLINK-4262:
There is currently an open PR (https://github.com/apache/
[
https://issues.apache.org/jira/browse/FLINK-4288?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15407083#comment-15407083
]
Jark Wu commented on FLINK-4288:
Because {{SchemaPlus}} has no {{remove}} function, we can
[
https://issues.apache.org/jira/browse/FLINK-4359?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15415204#comment-15415204
]
Jark Wu commented on FLINK-4359:
Do we have any ideas how to implement StreamSQL window? B
[
https://issues.apache.org/jira/browse/FLINK-4366?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu reassigned FLINK-4366:
--
Assignee: Jark Wu
> Enforce parallelism=1 For AllWindowedStream
> -
[
https://issues.apache.org/jira/browse/FLINK-4359?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15417187#comment-15417187
]
Jark Wu commented on FLINK-4359:
Okay, I see.
I'm interested in this, and I'm glad if I c
1 - 100 of 8787 matches
Mail list logo
