flinkbot edited a comment on issue #9478: [FLINK-13766][task] Refactor the
implementation of StreamInputProcessor based on StreamTaskInput#emitNext
URL: https://github.com/apache/flink/pull/9478#issuecomment-522374042
## CI report:
* 1530600eaf36324966f343c277437e48c2416dc2 : FAI
xintongsong commented on issue #9299: [FLINK-13405][docs-zh] Translate "Basic
API Concepts" page into Chinese
URL: https://github.com/apache/flink/pull/9299#issuecomment-525166244
Thanks for addressing the comments, @YngwieWang. The translation looks good
to me now. I think it should be go
[
https://issues.apache.org/jira/browse/FLINK-13868?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16916453#comment-16916453
]
lining commented on FLINK-13868:
[~till.rohrmann] can add taskmanger's id in rest api
j
[
https://issues.apache.org/jira/browse/FLINK-13510?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16916436#comment-16916436
]
lining commented on FLINK-13510:
[~till.rohrmann] how about it?
> Show fail attemp for
lining created FLINK-13868:
--
Summary: Job vertex add taskmanager id in rest api
Key: FLINK-13868
URL: https://issues.apache.org/jira/browse/FLINK-13868
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-13848?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16916429#comment-16916429
]
Biao Liu commented on FLINK-13848:
--
Hi [~xiaogang.shi],
Thanks a lot for sharing valuab
flinkbot edited a comment on issue #9478: [FLINK-13766][task] Refactor the
implementation of StreamInputProcessor based on StreamTaskInput#emitNext
URL: https://github.com/apache/flink/pull/9478#issuecomment-522374042
## CI report:
* 1530600eaf36324966f343c277437e48c2416dc2 : FAI
[
https://issues.apache.org/jira/browse/FLINK-13850?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16916425#comment-16916425
]
Kostas Kloudas commented on FLINK-13850:
No, actually I like the idea of having
kl0u commented on a change in pull request #9527: [FLINK-13832] Rename
DefaultRollingPolicy create to builder
URL: https://github.com/apache/flink/pull/9527#discussion_r317910738
##
File path:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/filesyst
flinkbot edited a comment on issue #9478: [FLINK-13766][task] Refactor the
implementation of StreamInputProcessor based on StreamTaskInput#emitNext
URL: https://github.com/apache/flink/pull/9478#issuecomment-522374042
## CI report:
* 1530600eaf36324966f343c277437e48c2416dc2 : FAI
hequn8128 commented on issue #9496: [FLINK-13011][build] Add the Build logic
for Python API release package
URL: https://github.com/apache/flink/pull/9496#issuecomment-525156933
@sunjincheng121 Thanks for the PR. LGTM.
merging...
-
[
https://issues.apache.org/jira/browse/FLINK-13867?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16916407#comment-16916407
]
Kurt Young commented on FLINK-13867:
This is similar with FLINK-10995 but is actuall
[
https://issues.apache.org/jira/browse/FLINK-13865?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dagang Wei updated FLINK-13865:
---
External issue URL: https://github.com/docker-flink/docker-flink/pull/82
> Support custom config in
Kurt Young created FLINK-13867:
--
Summary: Write file only once when doing blocking broadcast shuffle
Key: FLINK-13867
URL: https://issues.apache.org/jira/browse/FLINK-13867
Project: Flink
Issue
flinkbot edited a comment on issue #9540: [FLINK-13859][docs]
JSONDeserializationSchema spell error
URL: https://github.com/apache/flink/pull/9540#issuecomment-525128086
## CI report:
* 5cb9691c978214d5f868c0e6a43f782b05b29ff6 : SUCCESS
[Build](https://travis-ci.com/flink-ci/fli
[
https://issues.apache.org/jira/browse/FLINK-13865?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dagang Wei updated FLINK-13865:
---
Component/s: (was: Deployment / Kubernetes)
Deployment / Docker
Environment:
[
https://issues.apache.org/jira/browse/FLINK-10995?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16916401#comment-16916401
]
zhijiang commented on FLINK-10995:
--
I think it was not planned in release-1.10 before.
[
https://issues.apache.org/jira/browse/FLINK-13865?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16916402#comment-16916402
]
Dagang Wei commented on FLINK-13865:
I noticed FLINK-13380 which is helpful for Kube
flinkbot edited a comment on issue #9477: [FLINK-13765][task] Introduce
TwoInputSelectionHandler for selecting input in
StreamTwoInputSelectableProcessor
URL: https://github.com/apache/flink/pull/9477#issuecomment-522360024
## CI report:
* 71e7fae9a212e19c83e1fe6d656de49a39334aa
[
https://issues.apache.org/jira/browse/FLINK-13865?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dagang Wei updated FLINK-13865:
---
Environment: (was: I noticed FLINK-13380 which is helpful for
Kubernetes, but it is still useful
zhijiangW commented on issue #9477: [FLINK-13765][task] Introduce
TwoInputSelectionHandler for selecting input in
StreamTwoInputSelectableProcessor
URL: https://github.com/apache/flink/pull/9477#issuecomment-525149250
@flinkbot run travis
--
[
https://issues.apache.org/jira/browse/FLINK-13488?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kurt Young updated FLINK-13488:
---
Fix Version/s: (was: 1.9.1)
(was: 1.10.0)
1.9.0
> flin
[
https://issues.apache.org/jira/browse/FLINK-13488?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16916399#comment-16916399
]
Kurt Young commented on FLINK-13488:
Yeah, you're right. I will revert the change, t
dianfu commented on issue #9496: [FLINK-13011][build] Add the Build logic for
Python API release package
URL: https://github.com/apache/flink/pull/9496#issuecomment-525145865
@sunjincheng121 Thanks a lot for the PR. LGTM. +1 from my side.
---
flinkbot edited a comment on issue #9511: [FLINK-13356][table][docs] Add
documentation for TopN and Deduplication in blink planner
URL: https://github.com/apache/flink/pull/9511#issuecomment-523878126
## CI report:
* 11889a791a35b40ef0a4f5456da889cec0ebf990 : CANCELED
[Build](ht
flinkbot edited a comment on issue #9511: [FLINK-13356][table][docs] Add
documentation for TopN and Deduplication in blink planner
URL: https://github.com/apache/flink/pull/9511#issuecomment-523878126
## CI report:
* 11889a791a35b40ef0a4f5456da889cec0ebf990 : CANCELED
[Build](ht
flinkbot edited a comment on issue #9511: [FLINK-13356][table][docs] Add
documentation for TopN and Deduplication in blink planner
URL: https://github.com/apache/flink/pull/9511#issuecomment-523878126
## CI report:
* 11889a791a35b40ef0a4f5456da889cec0ebf990 : CANCELED
[Build](ht
carp84 commented on a change in pull request #9501: [FLINK-12697] [State
Backends] Support on-disk state storage for spill-able heap backend
URL: https://github.com/apache/flink/pull/9501#discussion_r317895515
##
File path:
flink-state-backends/flink-statebackend-heap-spillable/src
carp84 commented on a change in pull request #9501: [FLINK-12697] [State
Backends] Support on-disk state storage for spill-able heap backend
URL: https://github.com/apache/flink/pull/9501#discussion_r317895384
##
File path:
flink-state-backends/flink-statebackend-heap-spillable/src
[
https://issues.apache.org/jira/browse/FLINK-13488?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16916370#comment-16916370
]
Dian Fu edited comment on FLINK-13488 at 8/27/19 5:01 AM:
--
Hi [
[
https://issues.apache.org/jira/browse/FLINK-13488?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16916370#comment-16916370
]
Dian Fu commented on FLINK-13488:
-
Hi [~ykt836], I guess this fix is actually contained
flinkbot edited a comment on issue #9477: [FLINK-13765][task] Introduce
TwoInputSelectionHandler for selecting input in
StreamTwoInputSelectableProcessor
URL: https://github.com/apache/flink/pull/9477#issuecomment-522360024
## CI report:
* 71e7fae9a212e19c83e1fe6d656de49a39334aa
flinkbot edited a comment on issue #9467: [FLINK-9941][ScalaAPI] Flush in
ScalaCsvOutputFormat before close
URL: https://github.com/apache/flink/pull/9467#issuecomment-522053886
## CI report:
* 009da497d7c551ba854dc7ed8fa658f2acd6d6ce : SUCCESS
[Build](https://travis-ci.com/flin
[
https://issues.apache.org/jira/browse/FLINK-13360?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu updated FLINK-13360:
Fix Version/s: 1.10.0
> Add documentation for HBase connector for Table API & SQL
> --
[
https://issues.apache.org/jira/browse/FLINK-13363?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu updated FLINK-13363:
Fix Version/s: 1.10.0
> Add documentation for streaming aggregate performance tunning.
> -
[
https://issues.apache.org/jira/browse/FLINK-13364?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu updated FLINK-13364:
Fix Version/s: (was: 1.9.1)
> Add documentation for setting resources in blink planner
> -
[
https://issues.apache.org/jira/browse/FLINK-13361?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu updated FLINK-13361:
Fix Version/s: 1.10.0
> Add documentation for JDBC connector for Table API & SQL
> ---
[
https://issues.apache.org/jira/browse/FLINK-13365?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu updated FLINK-13365:
Fix Version/s: (was: 1.9.1)
(was: 1.10.0)
> Add documentation for reusing upstr
[
https://issues.apache.org/jira/browse/FLINK-13520?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu updated FLINK-13520:
Fix Version/s: 1.10.0
> Add documentation for the different behavior of row count sliding window in
> bli
[
https://issues.apache.org/jira/browse/FLINK-13365?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu updated FLINK-13365:
Fix Version/s: 1.10.0
> Add documentation for reusing upstream operations when multi-sink is applied
> ---
[
https://issues.apache.org/jira/browse/FLINK-13708?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu updated FLINK-13708:
Fix Version/s: 1.10.0
> transformations should be cleared because a table environment could execute
> mul
[
https://issues.apache.org/jira/browse/FLINK-13359?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kurt Young updated FLINK-13359:
---
Fix Version/s: 1.10.0
> Add documentation for DDL introduction
> ---
[
https://issues.apache.org/jira/browse/FLINK-13362?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kurt Young updated FLINK-13362:
---
Fix Version/s: 1.10.0
> Add documentation for Kafka & ES & FileSystem DDL
>
[
https://issues.apache.org/jira/browse/FLINK-13105?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kurt Young updated FLINK-13105:
---
Fix Version/s: 1.10.0
> Add documentation for blink planner's built-in functions
> -
[
https://issues.apache.org/jira/browse/FLINK-13354?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kurt Young updated FLINK-13354:
---
Fix Version/s: 1.10.0
> Add documentation for how to use blink planner
> ---
[
https://issues.apache.org/jira/browse/FLINK-13564?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kurt Young updated FLINK-13564:
---
Fix Version/s: 1.10.0
> blink planner should also throw exception if constant with YEAR TO MONTH
>
carp84 commented on a change in pull request #9501: [FLINK-12697] [State
Backends] Support on-disk state storage for spill-able heap backend
URL: https://github.com/apache/flink/pull/9501#discussion_r317887398
##
File path:
flink-state-backends/flink-statebackend-heap-spillable/src
[
https://issues.apache.org/jira/browse/FLINK-13599?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16916349#comment-16916349
]
Kurt Young commented on FLINK-13599:
I've updated the fix version to 1.9.1 since thi
[
https://issues.apache.org/jira/browse/FLINK-13599?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kurt Young updated FLINK-13599:
---
Fix Version/s: (was: 1.9.0)
1.9.1
> Kinesis end-to-end test failed on Travis
flinkbot edited a comment on issue #9540: [FLINK-13859][docs]
JSONDeserializationSchema spell error
URL: https://github.com/apache/flink/pull/9540#issuecomment-525128086
## CI report:
* 5cb9691c978214d5f868c0e6a43f782b05b29ff6 : PENDING
[Build](https://travis-ci.com/flink-ci/fli
[
https://issues.apache.org/jira/browse/FLINK-13738?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kurt Young updated FLINK-13738:
---
Fix Version/s: 1.10.0
> NegativeArraySizeException in LongHybridHashTable
>
[
https://issues.apache.org/jira/browse/FLINK-13739?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kurt Young updated FLINK-13739:
---
Fix Version/s: 1.10.0
> BinaryRowTest.testWriteString() fails in some environments
> ---
[
https://issues.apache.org/jira/browse/FLINK-13742?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kurt Young updated FLINK-13742:
---
Fix Version/s: 1.10.0
> Fix code generation when aggregation contains both distinct aggregate with
[
https://issues.apache.org/jira/browse/FLINK-13277?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16916347#comment-16916347
]
Kurt Young commented on FLINK-13277:
Looks like this issue already merged, [~phoenix
[
https://issues.apache.org/jira/browse/FLINK-13277?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kurt Young updated FLINK-13277:
---
Fix Version/s: 1.10.0
> add documentation of Hive source/sink
>
[
https://issues.apache.org/jira/browse/FLINK-13737?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16916346#comment-16916346
]
Kurt Young commented on FLINK-13737:
I've updated the fix version to 1.9.1 since thi
[
https://issues.apache.org/jira/browse/FLINK-13737?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kurt Young updated FLINK-13737:
---
Fix Version/s: (was: 1.9.0)
1.9.1
1.10.0
> flink-dist shou
[
https://issues.apache.org/jira/browse/FLINK-13688?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16916344#comment-16916344
]
Kurt Young commented on FLINK-13688:
[~till.rohrmann] Thanks for the heads up, this
[
https://issues.apache.org/jira/browse/FLINK-13706?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16916339#comment-16916339
]
Kurt Young commented on FLINK-13706:
I've updated the fix version to 1.9.1 since thi
[
https://issues.apache.org/jira/browse/FLINK-13706?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kurt Young updated FLINK-13706:
---
Fix Version/s: (was: 1.9.0)
1.9.1
1.10.0
> add documentati
[
https://issues.apache.org/jira/browse/FLINK-13501?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kurt Young updated FLINK-13501:
---
Fix Version/s: (was: 1.9.0)
1.9.1
1.10.0
> Fixes a few iss
[
https://issues.apache.org/jira/browse/FLINK-13415?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16916338#comment-16916338
]
Kurt Young commented on FLINK-13415:
I've updated the fix version to 1.9.1 since thi
[
https://issues.apache.org/jira/browse/FLINK-13415?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kurt Young updated FLINK-13415:
---
Fix Version/s: (was: 1.9.0)
1.9.1
1.10.0
> Document how to
[
https://issues.apache.org/jira/browse/FLINK-13501?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16916337#comment-16916337
]
Kurt Young commented on FLINK-13501:
I've updated the fix version to 1.9.1 since thi
[
https://issues.apache.org/jira/browse/FLINK-13534?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kurt Young updated FLINK-13534:
---
Fix Version/s: 1.10.0
> Unable to query Hive table with decimal column
> ---
[
https://issues.apache.org/jira/browse/FLINK-13488?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16916336#comment-16916336
]
Kurt Young commented on FLINK-13488:
I've updated the fix version to 1.9.1 since thi
[
https://issues.apache.org/jira/browse/FLINK-13488?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kurt Young updated FLINK-13488:
---
Fix Version/s: (was: 1.9.0)
1.9.1
1.10.0
> flink-python fa
[
https://issues.apache.org/jira/browse/FLINK-13490?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kurt Young updated FLINK-13490:
---
Fix Version/s: 1.10.0
> Fix return null in JDBCUtils::getFieldFromResultSet
> --
[
https://issues.apache.org/jira/browse/FLINK-13517?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kurt Young updated FLINK-13517:
---
Fix Version/s: 1.10.0
> Restructure Hive Catalog documentation
> ---
[
https://issues.apache.org/jira/browse/FLINK-13526?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kurt Young updated FLINK-13526:
---
Fix Version/s: 1.10.0
> Switching to a non existing catalog or database crashes sql-client
> ---
[
https://issues.apache.org/jira/browse/FLINK-13563?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kurt Young updated FLINK-13563:
---
Fix Version/s: 1.10.0
> TumblingGroupWindow should implement toString method
> -
[
https://issues.apache.org/jira/browse/FLINK-13562?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kurt Young updated FLINK-13562:
---
Fix Version/s: 1.10.0
> throws exception when FlinkRelMdColumnInterval meets two stage stream group
[
https://issues.apache.org/jira/browse/FLINK-13637?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kurt Young updated FLINK-13637:
---
Fix Version/s: 1.10.0
> Anchors not working in document(building.md, common.md, queryable_state.md)
flinkbot commented on issue #9540: [FLINK-13859][docs]
JSONDeserializationSchema spell error
URL: https://github.com/apache/flink/pull/9540#issuecomment-525128086
## CI report:
* 5cb9691c978214d5f868c0e6a43f782b05b29ff6 : UNKNOWN
-
[
https://issues.apache.org/jira/browse/FLINK-13517?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16916323#comment-16916323
]
Kurt Young commented on FLINK-13517:
I've updated the fix version to 1.9.1 since thi
[
https://issues.apache.org/jira/browse/FLINK-13637?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16916320#comment-16916320
]
Kurt Young commented on FLINK-13637:
I've updated the fix version to 1.9.1 since thi
[
https://issues.apache.org/jira/browse/FLINK-13517?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kurt Young updated FLINK-13517:
---
Fix Version/s: (was: 1.9.0)
1.9.1
> Restructure Hive Catalog documentation
>
[
https://issues.apache.org/jira/browse/FLINK-13526?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kurt Young updated FLINK-13526:
---
Fix Version/s: (was: 1.9.0)
1.9.1
> Switching to a non existing catalog or da
[
https://issues.apache.org/jira/browse/FLINK-13526?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16916319#comment-16916319
]
Kurt Young commented on FLINK-13526:
I've updated the fix version to 1.9.1 since thi
[
https://issues.apache.org/jira/browse/FLINK-13637?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kurt Young updated FLINK-13637:
---
Fix Version/s: (was: 1.9.0)
1.9.1
> Anchors not working in document(building.
[
https://issues.apache.org/jira/browse/FLINK-10995?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16916315#comment-16916315
]
Kurt Young commented on FLINK-10995:
Would it possible to open the Jira for writing
flinkbot commented on issue #9540: [FLINK-13859][docs]
JSONDeserializationSchema spell error
URL: https://github.com/apache/flink/pull/9540#issuecomment-525126046
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
to review your pull
[
https://issues.apache.org/jira/browse/FLINK-13859?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-13859:
---
Labels: pull-request-available (was: )
> JSONDeserializationSchema spell error
> --
flinkbot edited a comment on issue #9539: [hotfix][docs] Fix typo
URL: https://github.com/apache/flink/pull/9539#issuecomment-525098010
## CI report:
* 9430aca9b85c3a226cf5d5546e174d57daa8174e : SUCCESS
[Build](https://travis-ci.com/flink-ci/flink/builds/124669373)
-
taizilongxu opened a new pull request #9540: [FLINK-13859][docs]
JSONDeserializationSchema spell error
URL: https://github.com/apache/flink/pull/9540
## What is the purpose of the change
The doc spell error
## Brief change log
JsonDeserializationSchema -> JSONDeseriali
[
https://issues.apache.org/jira/browse/FLINK-13547?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16916313#comment-16916313
]
Kevin Zhang commented on FLINK-13547:
-
Thanks [~docete] and [~jark], we will have a
flinkbot edited a comment on issue #9510: [FLINK-13807][tests] Read file with
UTF-8 charset in TestBaseUtils.getResultReader
URL: https://github.com/apache/flink/pull/9510#issuecomment-523878082
## CI report:
* 7e7bc9b213b2fadb8759449b65e5be19b11aa829 : FAILURE
[Build](https://t
flinkbot edited a comment on issue #9511: [FLINK-13356][table][docs] Add
documentation for TopN and Deduplication in blink planner
URL: https://github.com/apache/flink/pull/9511#issuecomment-523878126
## CI report:
* 11889a791a35b40ef0a4f5456da889cec0ebf990 : CANCELED
[Build](ht
flinkbot edited a comment on issue #9511: [FLINK-13356][table][docs] Add
documentation for TopN and Deduplication in blink planner
URL: https://github.com/apache/flink/pull/9511#issuecomment-523878126
## CI report:
* 11889a791a35b40ef0a4f5456da889cec0ebf990 : CANCELED
[Build](ht
JingsongLi commented on a change in pull request #9511:
[FLINK-13356][table][docs] Add documentation for TopN and Deduplication in
blink planner
URL: https://github.com/apache/flink/pull/9511#discussion_r317879792
##
File path: docs/dev/table/sql.md
##
@@ -813,6 +813,222
flinkbot edited a comment on issue #9477: [FLINK-13765][task] Introduce
TwoInputSelectionHandler for selecting input in
StreamTwoInputSelectableProcessor
URL: https://github.com/apache/flink/pull/9477#issuecomment-522360024
## CI report:
* 71e7fae9a212e19c83e1fe6d656de49a39334aa
flinkbot edited a comment on issue #9477: [FLINK-13765][task] Introduce
TwoInputSelectionHandler for selecting input in
StreamTwoInputSelectableProcessor
URL: https://github.com/apache/flink/pull/9477#issuecomment-522360024
## CI report:
* 71e7fae9a212e19c83e1fe6d656de49a39334aa
xuefuz commented on issue #8738: [FLINK-12845][sql-client] Execute multiple
statements in command line…
URL: https://github.com/apache/flink/pull/8738#issuecomment-525118500
As a reference, Hive has been doing, which seems quite simple.
https://github.com/apache/hive/blob/8190d2be7b7165eff
flinkbot edited a comment on issue #9538: [hotfix][docs] Fix typo
URL: https://github.com/apache/flink/pull/9538#issuecomment-525097982
## CI report:
* 07c04045c445ccd5d844ffc733d01ac7adbf88ee : SUCCESS
[Build](https://travis-ci.com/flink-ci/flink/builds/124669351)
-
zhijiangW commented on issue #9477: [FLINK-13765][task] Introduce
TwoInputSelectionHandler for selecting input in
StreamTwoInputSelectableProcessor
URL: https://github.com/apache/flink/pull/9477#issuecomment-525116894
Thanks for the confirmation and I would merge it after travis green.
@p
[
https://issues.apache.org/jira/browse/FLINK-13765?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhijiang updated FLINK-13765:
-
Description:
In StreamTwoInputSelectableProcessor there are three fields \{InputSelectable,
InputSelect
flinkbot edited a comment on issue #9477: [FLINK-13765][task] Introduce
TwoInputSelectionHandler for selecting input in
StreamTwoInputSelectableProcessor
URL: https://github.com/apache/flink/pull/9477#issuecomment-522360024
## CI report:
* 71e7fae9a212e19c83e1fe6d656de49a39334aa
[
https://issues.apache.org/jira/browse/FLINK-13765?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhijiang updated FLINK-13765:
-
Description:
In StreamTwoInputSelectableProcessor there are three fields \{InputSelectable,
InputSelect
flinkbot edited a comment on issue #9467: [FLINK-9941][ScalaAPI] Flush in
ScalaCsvOutputFormat before close
URL: https://github.com/apache/flink/pull/9467#issuecomment-522053886
## CI report:
* 009da497d7c551ba854dc7ed8fa658f2acd6d6ce : SUCCESS
[Build](https://travis-ci.com/flin
[
https://issues.apache.org/jira/browse/FLINK-13765?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhijiang updated FLINK-13765:
-
Summary: Introduce TwoInputSelectionHandler for selecting input in
StreamTwoInputSelectableProcessor (w
1 - 100 of 481 matches
Mail list logo
