[
https://issues.apache.org/jira/browse/FLINK-10603?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16688260#comment-16688260
]
vinoyang commented on FLINK-10603:
--
[~pnowojski] Considering that Kafka 0.8 is too far away from the
[
https://issues.apache.org/jira/browse/FLINK-10801?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16678077#comment-16678077
]
vinoyang commented on FLINK-10801:
--
[~pnowojski] Ok, go ahead. I know that sleep 20s is not the best
[
https://issues.apache.org/jira/browse/FLINK-10384?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
vinoyang closed FLINK-10384.
Resolution: Fixed
Fix Version/s: 1.7.0
> Add Sinh math function supported in Table API and SQL
>
[
https://issues.apache.org/jira/browse/FLINK-10384?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
vinoyang updated FLINK-10384:
-
Comment: was deleted
(was: [~pnovi...@gmail.com] I think this issue could be closed.)
> Add Sinh math
vinoyang created FLINK-10798:
Summary: Add the version number of Flink 1.7 to MigrationVersion
Key: FLINK-10798
URL: https://issues.apache.org/jira/browse/FLINK-10798
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-10795?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
vinoyang reassigned FLINK-10795:
Assignee: vinoyang
> STDDEV_POP error
>
>
> Key: FLINK-10795
>
[
https://issues.apache.org/jira/browse/FLINK-10771?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16676042#comment-16676042
]
vinoyang commented on FLINK-10771:
--
[~till.rohrmann] Yes, I know. What I mean is that if it is not used
vinoyang created FLINK-10801:
Summary: Fix sql client integrate elasticsearch connector test
failure
Key: FLINK-10801
URL: https://issues.apache.org/jira/browse/FLINK-10801
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-10801?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
vinoyang updated FLINK-10801:
-
Description:
It usually reports :
{code:java}
FAIL SQL Client Elasticsearch Upsert: Output hash
[
https://issues.apache.org/jira/browse/FLINK-10867?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
vinoyang reassigned FLINK-10867:
Assignee: vinoyang
> Add a DataSet-based CacheOperator to reuse results between jobs
>
[
https://issues.apache.org/jira/browse/FLINK-10620?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
vinoyang closed FLINK-10620.
Resolution: Duplicate
> Remove the dependency on the version string literal.
>
vinoyang created FLINK-10872:
Summary: Extend SQL client end-to-end to test KafkaTableSink for
kafka connector 0.11
Key: FLINK-10872
URL: https://issues.apache.org/jira/browse/FLINK-10872
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-10867?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16686221#comment-16686221
]
vinoyang commented on FLINK-10867:
--
hi [~mcoimbra] Thanks for your idea. I think this is a nice
[
https://issues.apache.org/jira/browse/FLINK-10867?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16686345#comment-16686345
]
vinoyang commented on FLINK-10867:
--
[~Zentol] Maybe the PR you submitted should not bind to this issue?
vinoyang created FLINK-10891:
Summary: Upgrade Kafka client version to 2.0.1
Key: FLINK-10891
URL: https://issues.apache.org/jira/browse/FLINK-10891
Project: Flink
Issue Type: Sub-task
[
https://issues.apache.org/jira/browse/FLINK-10889?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
vinoyang reassigned FLINK-10889:
Assignee: vinoyang
> Semantic inconsistency between DataSet#print and DataStream#print
>
[
https://issues.apache.org/jira/browse/FLINK-10892?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16687663#comment-16687663
]
vinoyang commented on FLINK-10892:
--
I think this issue is meaningful, and our internal Flink version
[
https://issues.apache.org/jira/browse/FLINK-10892?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
vinoyang reassigned FLINK-10892:
Assignee: vinoyang
> Flink Yarn app name is hard coded
> -
>
>
[
https://issues.apache.org/jira/browse/FLINK-10840?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16681390#comment-16681390
]
vinoyang commented on FLINK-10840:
--
[~till.rohrmann] and [~Zentol] I didn't actually encounter this
[
https://issues.apache.org/jira/browse/FLINK-10840?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
vinoyang updated FLINK-10840:
-
Description:
BucketingSink#snapshotState : (see the *comment* in this method)
{code:java}
public void
[
https://issues.apache.org/jira/browse/FLINK-10840?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16681398#comment-16681398
]
vinoyang commented on FLINK-10840:
--
yes.Isn't it?
> BucketingSink incorrectly clears the pendingFiles
vinoyang created FLINK-10840:
Summary: BucketingSink incorrectly clears the pendingFiles List
Key: FLINK-10840
URL: https://issues.apache.org/jira/browse/FLINK-10840
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-10771?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16676866#comment-16676866
]
vinoyang commented on FLINK-10771:
--
OK, since it may be used, why don't we refactor it as: if it's not
[
https://issues.apache.org/jira/browse/FLINK-10384?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16676875#comment-16676875
]
vinoyang commented on FLINK-10384:
--
[~pnovi...@gmail.com] I think this issue could be closed.
> Add
[
https://issues.apache.org/jira/browse/FLINK-10791?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16683412#comment-16683412
]
vinoyang commented on FLINK-10791:
--
[~pnowojski] Do you think we need to add end-to-end test cases for
[
https://issues.apache.org/jira/browse/FLINK-10771?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16676916#comment-16676916
]
vinoyang commented on FLINK-10771:
--
Yes, In AbstractYarnClusterDescriptor, we can explicitly set the
[
https://issues.apache.org/jira/browse/FLINK-10477?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
vinoyang reassigned FLINK-10477:
Assignee: vinoyang
> Add rescale button to web interface
> ---
>
[
https://issues.apache.org/jira/browse/FLINK-10478?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
vinoyang reassigned FLINK-10478:
Assignee: vinoyang
> Kafka Producer wrongly formats "%" for transaction ID
>
[
https://issues.apache.org/jira/browse/FLINK-10514?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16642848#comment-16642848
]
vinoyang commented on FLINK-10514:
--
hi [~yangxiaoshuo] , Usually you need to send an email to the dev
[
https://issues.apache.org/jira/browse/FLINK-10420?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16643614#comment-16643614
]
vinoyang commented on FLINK-10420:
--
[~twalthr] What's your opinion?
> Create and drop view in sql
[
https://issues.apache.org/jira/browse/FLINK-10114?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16643634#comment-16643634
]
vinoyang commented on FLINK-10114:
--
[~Zentol] and [~pnowojski] can you give some suggestion? The
[
https://issues.apache.org/jira/browse/FLINK-10114?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16644724#comment-16644724
]
vinoyang commented on FLINK-10114:
--
[~kkl0u] In fact, I saw the PR of Parquet implementation FLINK-9753
[
https://issues.apache.org/jira/browse/FLINK-10472?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
vinoyang updated FLINK-10472:
-
Issue Type: Sub-task (was: Task)
Parent: FLINK-6810
> Add CBRT math function supported in
[
https://issues.apache.org/jira/browse/FLINK-10472?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16634160#comment-16634160
]
vinoyang commented on FLINK-10472:
--
[~Aleksei_Izmalkin] Done. Ping [~twalthr] or [~till.rohrmann] ,
[
https://issues.apache.org/jira/browse/FLINK-10420?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16631287#comment-16631287
]
vinoyang commented on FLINK-10420:
--
hi [~twalthr] I think the *CREATE OR REPLACE VIEW* syntax is a good
[
https://issues.apache.org/jira/browse/FLINK-7525?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16632688#comment-16632688
]
vinoyang commented on FLINK-7525:
-
hi [~till.rohrmann] yes, you are right. I mean, do we still need to
[
https://issues.apache.org/jira/browse/FLINK-10527?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16645881#comment-16645881
]
vinoyang commented on FLINK-10527:
--
cc [~till.rohrmann] and [~Tison]
> Cleanup constant isNewMode in
[
https://issues.apache.org/jira/browse/FLINK-10527?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
vinoyang updated FLINK-10527:
-
Issue Type: Sub-task (was: Bug)
Parent: FLINK-10392
> Cleanup constant isNewMode in
vinoyang created FLINK-10527:
Summary: Cleanup constant isNewMode in YarnTestBase
Key: FLINK-10527
URL: https://issues.apache.org/jira/browse/FLINK-10527
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-10279?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16602674#comment-16602674
]
vinoyang commented on FLINK-10279:
--
cc [~Zentol]
> Better clarification for status
>
[
https://issues.apache.org/jira/browse/FLINK-10114?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
vinoyang reassigned FLINK-10114:
Assignee: vinoyang
> Support Orc for StreamingFileSink
> -
>
>
[
https://issues.apache.org/jira/browse/FLINK-10114?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16602656#comment-16602656
]
vinoyang commented on FLINK-10114:
--
[~mingleizhang] OK, I will try to implement this feature when I
[
https://issues.apache.org/jira/browse/FLINK-9854?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
vinoyang reassigned FLINK-9854:
---
Assignee: vinoyang
> Allow passing multi-line input to SQL Client CLI
>
[
https://issues.apache.org/jira/browse/FLINK-10384?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
vinoyang updated FLINK-10384:
-
Description: like FLINK-10340 for adding Cosh math function (was: like
FLINK-10340)
> Add Sinh math
vinoyang created FLINK-10384:
Summary: Add Sinh math function supported in Table API and SQL
Key: FLINK-10384
URL: https://issues.apache.org/jira/browse/FLINK-10384
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-10265?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16620773#comment-16620773
]
vinoyang commented on FLINK-10265:
--
[~twalthr] any opinion and suggestion?
> Configure checkpointing
[
https://issues.apache.org/jira/browse/FLINK-10389?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16625599#comment-16625599
]
vinoyang commented on FLINK-10389:
--
OK, will create a PR to fix this issue.
>
[
https://issues.apache.org/jira/browse/FLINK-10114?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16625480#comment-16625480
]
vinoyang commented on FLINK-10114:
--
[~kkl0u] about this issue, any suggestion?
> Support Orc for
[
https://issues.apache.org/jira/browse/FLINK-10389?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16624449#comment-16624449
]
vinoyang commented on FLINK-10389:
--
Good catach, Does it make sense to send a PR or "hotfix" to fix
[
https://issues.apache.org/jira/browse/FLINK-10389?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16624449#comment-16624449
]
vinoyang edited comment on FLINK-10389 at 9/22/18 3:06 AM:
---
Good catch, Does
[
https://issues.apache.org/jira/browse/FLINK-10389?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
vinoyang reassigned FLINK-10389:
Assignee: vinoyang
> TaskManagerServicesConfiguration ctor contains self assignment
>
[
https://issues.apache.org/jira/browse/FLINK-10315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16625632#comment-16625632
]
vinoyang commented on FLINK-10315:
--
Hi [~flacombe],
A custom sink essentially provides a UDF. If you
[
https://issues.apache.org/jira/browse/FLINK-10315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16625632#comment-16625632
]
vinoyang edited comment on FLINK-10315 at 9/24/18 10:54 AM:
Hi [~flacombe],
vinoyang created FLINK-10398:
Summary: Add Tanh math function supported in Table API and SQL
Key: FLINK-10398
URL: https://issues.apache.org/jira/browse/FLINK-10398
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-10413?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
vinoyang reassigned FLINK-10413:
Assignee: vinoyang
> requestPartitionState messages overwhelms JM RPC main thread
>
[
https://issues.apache.org/jira/browse/FLINK-10412?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16626712#comment-16626712
]
vinoyang commented on FLINK-10412:
--
[~zhuzh] Good catch! Will fix it soon.
> toString field in
[
https://issues.apache.org/jira/browse/FLINK-10412?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
vinoyang reassigned FLINK-10412:
Assignee: vinoyang
> toString field in AbstractID should be transient to avoid been serialized
>
[
https://issues.apache.org/jira/browse/FLINK-10315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16626912#comment-16626912
]
vinoyang commented on FLINK-10315:
--
[~twalthr] any opinion?
> Let JDBCAppendTableSink be built with
[
https://issues.apache.org/jira/browse/FLINK-10292?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16626884#comment-16626884
]
vinoyang commented on FLINK-10292:
--
[~uce] First of all, I have a bit of doubt about your comment. What
[
https://issues.apache.org/jira/browse/FLINK-10413?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
vinoyang closed FLINK-10413.
Resolution: Duplicate
> requestPartitionState messages overwhelms JM RPC main thread
>
[
https://issues.apache.org/jira/browse/FLINK-10420?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16627208#comment-16627208
]
vinoyang commented on FLINK-10420:
--
cc [~twalthr] and [~fhueske]
> Create and drop view in sql client
vinoyang created FLINK-10420:
Summary: Create and drop view in sql client should check the view
created based on the configuration.
Key: FLINK-10420
URL: https://issues.apache.org/jira/browse/FLINK-10420
[
https://issues.apache.org/jira/browse/FLINK-10418?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16627224#comment-16627224
]
vinoyang commented on FLINK-10418:
--
Hi [~Aleksei_Izmalkin] thanks for opening this issue, please mark
[
https://issues.apache.org/jira/browse/FLINK-10418?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16627271#comment-16627271
]
vinoyang commented on FLINK-10418:
--
[~Aleksei_Izmalkin] I did it.
> Add COTH math function supported
[
https://issues.apache.org/jira/browse/FLINK-10413?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16626815#comment-16626815
]
vinoyang commented on FLINK-10413:
--
[~Tison] Looks like yes. cc [~zhuzh]
> requestPartitionState
[
https://issues.apache.org/jira/browse/FLINK-10292?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16628139#comment-16628139
]
vinoyang commented on FLINK-10292:
--
Hi [~uce] Thank you for your clarification on "image", that doesn't
[
https://issues.apache.org/jira/browse/FLINK-10420?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16628208#comment-16628208
]
vinoyang commented on FLINK-10420:
--
[~hequn8128] What do you think about this issue?
> Create and drop
[
https://issues.apache.org/jira/browse/FLINK-10428?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
vinoyang reassigned FLINK-10428:
Assignee: vinoyang
> AbstractServerBase should bind to any address per default
>
[
https://issues.apache.org/jira/browse/FLINK-10420?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16628437#comment-16628437
]
vinoyang commented on FLINK-10420:
--
[~twalthr] I mean shall we consider MergedEnvironment when checking
[
https://issues.apache.org/jira/browse/FLINK-10425?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
vinoyang reassigned FLINK-10425:
Assignee: vinoyang
> taskmaster.host is not respected
>
>
>
[
https://issues.apache.org/jira/browse/FLINK-10418?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
vinoyang updated FLINK-10418:
-
Issue Type: Sub-task (was: Task)
Parent: FLINK-6810
> Add COTH math function supported in
[
https://issues.apache.org/jira/browse/FLINK-10418?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
vinoyang updated FLINK-10418:
-
Description: Inspired by FLINK-10398 (was: This issue is sub-task of
FLINK-6810
Inspired by
[
https://issues.apache.org/jira/browse/FLINK-10420?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16628456#comment-16628456
]
vinoyang commented on FLINK-10420:
--
Since I have implemented showCreateView before, I found that if we
[
https://issues.apache.org/jira/browse/FLINK-7525?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16621728#comment-16621728
]
vinoyang commented on FLINK-7525:
-
[~Zentol] [~till.rohrmann] so can we close this issue?
> Add config
[
https://issues.apache.org/jira/browse/FLINK-10252?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
vinoyang reassigned FLINK-10252:
Assignee: vinoyang
> Handle oversized metric messges
> ---
>
>
[
https://issues.apache.org/jira/browse/FLINK-10315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16625014#comment-16625014
]
vinoyang commented on FLINK-10315:
--
Hi [~flacombe] , I think there are a few questions about your
[
https://issues.apache.org/jira/browse/FLINK-10448?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
vinoyang reassigned FLINK-10448:
Assignee: vinoyang
> VALUES clause is translated into a separate operator per value
>
[
https://issues.apache.org/jira/browse/FLINK-10265?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16629951#comment-16629951
]
vinoyang commented on FLINK-10265:
--
[~twalthr] OK, I am getting ready to start processing this issue.
[
https://issues.apache.org/jira/browse/FLINK-10292?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16627538#comment-16627538
]
vinoyang commented on FLINK-10292:
--
[~uce] Thank you for verifying, my understanding of "image". Then I
[
https://issues.apache.org/jira/browse/FLINK-11231?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16730654#comment-16730654
]
vinoyang commented on FLINK-11231:
--
[~sunjincheng121] Agree with your opinion, do you mind if I claim
[
https://issues.apache.org/jira/browse/FLINK-11231?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16731347#comment-16731347
]
vinoyang commented on FLINK-11231:
--
[~sunjincheng121] Yes, agree. Will wait for feedback before
[
https://issues.apache.org/jira/browse/FLINK-11229?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16731345#comment-16731345
]
vinoyang commented on FLINK-11229:
--
[~hequn8128] I'd like to make where/filter table API support scalar
[
https://issues.apache.org/jira/browse/FLINK-10615?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
vinoyang reassigned FLINK-10615:
Assignee: vinoyang
> Cancel with savepoint can fail the job
>
[
https://issues.apache.org/jira/browse/FLINK-11226?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16730062#comment-16730062
]
vinoyang commented on FLINK-11226:
--
[~hequn8128] Agree with the idea of adding {{getKeySelector()}} to
[
https://issues.apache.org/jira/browse/FLINK-11226?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
vinoyang reassigned FLINK-11226:
Assignee: vinoyang
> Lack of getKeySelector in Scala KeyedStream API unlike Java KeyedStream
>
[
https://issues.apache.org/jira/browse/FLINK-11247?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
vinoyang reassigned FLINK-11247:
Assignee: vinoyang
> Fix DESCRIBE command to support catalog tables
>
[
https://issues.apache.org/jira/browse/FLINK-11249?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
vinoyang reassigned FLINK-11249:
Assignee: vinoyang
> FlinkKafkaProducer011 can not be migrated to FlinkKafkaProducer
>
[
https://issues.apache.org/jira/browse/FLINK-11253?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
vinoyang reassigned FLINK-11253:
Assignee: leesf
> Incorrect way to stop yarn session described in yarn_setup document
>
[
https://issues.apache.org/jira/browse/FLINK-11239?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
vinoyang reassigned FLINK-11239:
Assignee: vinoyang
> Enhance SQL-Client to recursively list UDFs
>
[
https://issues.apache.org/jira/browse/FLINK-11229?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16732631#comment-16732631
]
vinoyang commented on FLINK-11229:
--
[~hequn8128] yes, you are right.
> Support ScalarFunction for the
[
https://issues.apache.org/jira/browse/FLINK-11229?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
vinoyang closed FLINK-11229.
Resolution: Won't Do
> Support ScalarFunction for the where/filter clause.
>
[
https://issues.apache.org/jira/browse/FLINK-11249?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
vinoyang updated FLINK-11249:
-
Issue Type: Sub-task (was: Bug)
Parent: FLINK-10598
> FlinkKafkaProducer011 can not be
[
https://issues.apache.org/jira/browse/FLINK-5018?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16732743#comment-16732743
]
vinoyang commented on FLINK-5018:
-
I am going to start implementing this issue. Currently {{idleTimeout}}
[
https://issues.apache.org/jira/browse/FLINK-11226?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16732894#comment-16732894
]
vinoyang commented on FLINK-11226:
--
I guess there may be some need for extension and customization.
[
https://issues.apache.org/jira/browse/FLINK-11226?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16732728#comment-16732728
]
vinoyang commented on FLINK-11226:
--
[~Zentol] Before implementing, make sure that you approve the
[
https://issues.apache.org/jira/browse/FLINK-11226?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16732728#comment-16732728
]
vinoyang edited comment on FLINK-11226 at 1/3/19 7:38 AM:
--
[~Zentol] Before
[
https://issues.apache.org/jira/browse/FLINK-11257?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
vinoyang updated FLINK-11257:
-
Issue Type: Sub-task (was: New Feature)
Parent: FLINK-10598
> FlinkKafkaConsumer should
[
https://issues.apache.org/jira/browse/FLINK-11249?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16732725#comment-16732725
]
vinoyang commented on FLINK-11249:
--
[~pnowojski] What do you think we define a new class in the
[
https://issues.apache.org/jira/browse/FLINK-11257?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
vinoyang reassigned FLINK-11257:
Assignee: vinoyang
> FlinkKafkaConsumer should support assgin partition
>
[
https://issues.apache.org/jira/browse/FLINK-11249?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16732912#comment-16732912
]
vinoyang commented on FLINK-11249:
--
[~aljoscha] Understand, I will provide a custom serializer for the
501 - 600 of 1645 matches
Mail list logo
