c4e commented on a change in pull request #8402: [FLINK-12473][ml] Add the
interface of ML pipeline and ML lib
URL: https://github.com/apache/flink/pull/8402#discussion_r286336701
##
File path:
flink-ml/flink-ml-api/src/main/java/org/apache/flink/ml/api/misc/persist/Persistable
[
https://issues.apache.org/jira/browse/FLINK-8871?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16845585#comment-16845585
]
Yu Li edited comment on FLINK-8871 at 5/22/19 6:51 AM:
---
bq. His sol
[
https://issues.apache.org/jira/browse/FLINK-12458?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhijiang updated FLINK-12458:
-
Description: If the consumer can not establish a connection to remote task
executor, which might indicat
lirui-apache commented on issue #8449: [FLINK-12235][hive] Support Hive
partition in HiveCatalog
URL: https://github.com/apache/flink/pull/8449#issuecomment-494675094
Rebased and addressed comments.
@bowenli86 @xuefuz please take another look. Thanks.
---
[
https://issues.apache.org/jira/browse/FLINK-12458?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhijiang updated FLINK-12458:
-
Summary: Introduce PartitionConnectionException for unreachable producer
(was: Throw PartitionNotFoundE
[
https://issues.apache.org/jira/browse/FLINK-8871?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16845585#comment-16845585
]
Yu Li commented on FLINK-8871:
--
bq. His solution (also proposed by us) is now meaningless, I
[
https://issues.apache.org/jira/browse/FLINK-12573?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16845581#comment-16845581
]
yitzchak lieberman edited comment on FLINK-12573 at 5/22/19 6:43 AM:
-
[
https://issues.apache.org/jira/browse/FLINK-12573?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16845581#comment-16845581
]
yitzchak lieberman commented on FLINK-12573:
Hi Louis.
I think it could hel
c4e commented on issue #8402: [FLINK-12473][ml] Add the interface of ML
pipeline and ML lib
URL: https://github.com/apache/flink/pull/8402#issuecomment-494672243
As mentioned in the mail "[DISCUSS] FLIP-39: Flink ML pipeline and ML libs"
in flink-dev, we have to add a TableEnvironment
[
https://issues.apache.org/jira/browse/FLINK-6962?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Chan reassigned FLINK-6962:
-
Assignee: Danny Chan (was: Shuyi Chen)
> Add a table SQL DDL
> ---
>
>
KurtYoung commented on a change in pull request #8492:
[FLINK-12563][table-runtime-blink] Introduce vector data format in blink
URL: https://github.com/apache/flink/pull/8492#discussion_r286328269
##
File path:
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/ta
KurtYoung commented on a change in pull request #8492:
[FLINK-12563][table-runtime-blink] Introduce vector data format in blink
URL: https://github.com/apache/flink/pull/8492#discussion_r286328947
##
File path:
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/ta
flinkbot commented on issue #8508: [FLINK-12533][table] Introduce
TABLE_AGGREGATE_FUNCTION FunctionDefinition.Type
URL: https://github.com/apache/flink/pull/8508#issuecomment-494669031
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
[
https://issues.apache.org/jira/browse/FLINK-12533?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-12533:
---
Labels: pull-request-available (was: )
> Introduce TABLE_AGGREGATE_FUNCTION FunctionDefinit
hequn8128 opened a new pull request #8508: [FLINK-12533][table] Introduce
TABLE_AGGREGATE_FUNCTION FunctionDefinition.Type
URL: https://github.com/apache/flink/pull/8508
## What is the purpose of the change
This pull request adds TABLE_AGGREGATE_FUNCTION FunctionDefinition.Type.
[
https://issues.apache.org/jira/browse/FLINK-12319?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Liya Fan reassigned FLINK-12319:
Assignee: Liya Fan
> StackOverFlowError in cep.nfa.sharedbuffer.SharedBuffer
> --
[
https://issues.apache.org/jira/browse/FLINK-12319?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Liya Fan reassigned FLINK-12319:
Assignee: (was: Liya Fan)
> StackOverFlowError in cep.nfa.sharedbuffer.SharedBuffer
> ---
[
https://issues.apache.org/jira/browse/FLINK-12319?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16845566#comment-16845566
]
Liya Fan commented on FLINK-12319:
--
Hi [~mpf], thank you for your feedback. I am lookin
[
https://issues.apache.org/jira/browse/FLINK-12319?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Liya Fan reassigned FLINK-12319:
Assignee: Liya Fan
> StackOverFlowError in cep.nfa.sharedbuffer.SharedBuffer
> --
sunjincheng121 commented on a change in pull request #8488:
[FLINK-12439][python] Add FileSystem Connector with CSV format support in
Python Table API
URL: https://github.com/apache/flink/pull/8488#discussion_r286326763
##
File path: flink-python/pyflink/table/tests/test_descriptor
sunjincheng121 commented on a change in pull request #8488:
[FLINK-12439][python] Add FileSystem Connector with CSV format support in
Python Table API
URL: https://github.com/apache/flink/pull/8488#discussion_r286326566
##
File path: flink-python/pyflink/table/table_descriptor.py
WeiZhong94 commented on issue #8488: [FLINK-12439][python] Add FileSystem
Connector with CSV format support in Python Table API
URL: https://github.com/apache/flink/pull/8488#issuecomment-494665375
@sunjincheng121 Thanks for your review! I have addressed your comments and
remove the outdat
WeiZhong94 commented on a change in pull request #8488: [FLINK-12439][python]
Add FileSystem Connector with CSV format support in Python Table API
URL: https://github.com/apache/flink/pull/8488#discussion_r286324516
##
File path: flink-python/pyflink/table/tests/test_descriptor.py
WeiZhong94 commented on a change in pull request #8488: [FLINK-12439][python]
Add FileSystem Connector with CSV format support in Python Table API
URL: https://github.com/apache/flink/pull/8488#discussion_r286324342
##
File path: flink-python/pyflink/table/table_descriptor.py
#
WeiZhong94 commented on a change in pull request #8488: [FLINK-12439][python]
Add FileSystem Connector with CSV format support in Python Table API
URL: https://github.com/apache/flink/pull/8488#discussion_r286324342
##
File path: flink-python/pyflink/table/table_descriptor.py
#
WeiZhong94 commented on a change in pull request #8488: [FLINK-12439][python]
Add FileSystem Connector with CSV format support in Python Table API
URL: https://github.com/apache/flink/pull/8488#discussion_r286324419
##
File path: flink-python/pyflink/table/tests/test_descriptor.py
klion26 commented on a change in pull request #8479: [FLINK-11193][State
Backends]Use user passed configuration overriding default configuration loading
from file
URL: https://github.com/apache/flink/pull/8479#discussion_r286323947
##
File path:
flink-state-backends/flink-statebac
WeiZhong94 commented on a change in pull request #8488: [FLINK-12439][python]
Add FileSystem Connector with CSV format support in Python Table API
URL: https://github.com/apache/flink/pull/8488#discussion_r286323352
##
File path: flink-python/pyflink/table/table_descriptor.py
#
WeiZhong94 commented on a change in pull request #8488: [FLINK-12439][python]
Add FileSystem Connector with CSV format support in Python Table API
URL: https://github.com/apache/flink/pull/8488#discussion_r286323448
##
File path: flink-python/pyflink/table/table_descriptor.py
#
WeiZhong94 commented on a change in pull request #8488: [FLINK-12439][python]
Add FileSystem Connector with CSV format support in Python Table API
URL: https://github.com/apache/flink/pull/8488#discussion_r286323428
##
File path: flink-python/pyflink/table/table_descriptor.py
#
WeiZhong94 commented on a change in pull request #8488: [FLINK-12439][python]
Add FileSystem Connector with CSV format support in Python Table API
URL: https://github.com/apache/flink/pull/8488#discussion_r286323352
##
File path: flink-python/pyflink/table/table_descriptor.py
#
zhijiangW commented on issue #8463: [FLINK-12530][network] Move
Task.inputGatesById to NetworkEnvironment
URL: https://github.com/apache/flink/pull/8463#issuecomment-494661586
Thanks for the updates @azagrebin!
I left several minor comments, only one concern of new proposed
`Partiti
zhijiangW commented on a change in pull request #8463: [FLINK-12530][network]
Move Task.inputGatesById to NetworkEnvironment
URL: https://github.com/apache/flink/pull/8463#discussion_r286318037
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/NetworkEnv
Kazunori Shinhira created FLINK-12586:
-
Summary: Stderr and stdout are reversed in OptimizerPlanEnvironment
Key: FLINK-12586
URL: https://issues.apache.org/jira/browse/FLINK-12586
Project: Flink
Aitozi commented on a change in pull request #8479: [FLINK-11193][State
Backends]Use user passed configuration overriding default configuration loading
from file
URL: https://github.com/apache/flink/pull/8479#discussion_r286315022
##
File path:
flink-state-backends/flink-stateback
[
https://issues.apache.org/jira/browse/FLINK-8871?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16845520#comment-16845520
]
vinoyang edited comment on FLINK-8871 at 5/22/19 4:58 AM:
--
[~car
[
https://issues.apache.org/jira/browse/FLINK-8871?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16845520#comment-16845520
]
vinoyang commented on FLINK-8871:
-
[~carp84] Ok, I will reply directly to your question f
[
https://issues.apache.org/jira/browse/FLINK-8871?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16845510#comment-16845510
]
vinoyang commented on FLINK-8871:
-
[~yunta] OK, I am very happy to hear your own thoughts
[
https://issues.apache.org/jira/browse/FLINK-8871?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16845507#comment-16845507
]
Yu Li commented on FLINK-8871:
--
bq. Yun Tang Your solution sounds good, but it would wait fo
WeiZhong94 commented on a change in pull request #8488: [FLINK-12439][python]
Add FileSystem Connector with CSV format support in Python Table API
URL: https://github.com/apache/flink/pull/8488#discussion_r286307285
##
File path: flink-python/pyflink/table/table_descriptor.py
#
klion26 commented on a change in pull request #8479: [FLINK-11193][State
Backends]Use user passed configuration overriding default configuration loading
from file
URL: https://github.com/apache/flink/pull/8479#discussion_r286307041
##
File path:
flink-state-backends/flink-statebac
[
https://issues.apache.org/jira/browse/FLINK-8871?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16845496#comment-16845496
]
Yun Tang commented on FLINK-8871:
-
[~yanghua] Yu is my mentor and just want to help me fo
[
https://issues.apache.org/jira/browse/FLINK-12585?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Wei Zhong reassigned FLINK-12585:
-
Assignee: Wei Zhong
> Align Stream/BatchTableEnvironment with JAVA Table API
>
[
https://issues.apache.org/jira/browse/FLINK-12585?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16845494#comment-16845494
]
Dian Fu commented on FLINK-12585:
-
Agree. Having a Python StreamExecutionEnvironment/Exe
[
https://issues.apache.org/jira/browse/FLINK-8585?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Louis Xu reassigned FLINK-8585:
---
Assignee: (was: Louis Xu)
> Efficiently handle read-only and non array ByteBuffers in
> DataInp
[
https://issues.apache.org/jira/browse/FLINK-12235?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rui Li updated FLINK-12235:
---
Summary: Support Hive partition in HiveCatalog (was: Support partition
related operations in HiveCatalog)
[
https://issues.apache.org/jira/browse/FLINK-12397?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sunjincheng updated FLINK-12397:
Fix Version/s: (was: shaded-8.0)
shaded-7.0
> Drop flink-shaded-asm-5
> ---
sunjincheng created FLINK-12585:
---
Summary: Align Stream/BatchTableEnvironment with JAVA Table API
Key: FLINK-12585
URL: https://issues.apache.org/jira/browse/FLINK-12585
Project: Flink
Issue Ty
flinkbot commented on issue #8507: [FLINK-12236][hive] Support Hive function in
HiveCatalog
URL: https://github.com/apache/flink/pull/8507#issuecomment-494643454
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
to review your pull r
bowenli86 commented on a change in pull request #8449: [FLINK-12235][hive]
Support partition related operations in HiveCatalog
URL: https://github.com/apache/flink/pull/8449#discussion_r286304895
##
File path:
flink-table/flink-table-common/src/test/java/org/apache/flink/table/cata
[
https://issues.apache.org/jira/browse/FLINK-12236?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-12236:
---
Labels: pull-request-available (was: )
> Support Hive function in HiveCatalog
> ---
bowenli86 opened a new pull request #8507: [FLINK-12236][hive] Support Hive
function in HiveCatalog
URL: https://github.com/apache/flink/pull/8507
## What is the purpose of the change
This PR creates `HiveCatalogFunction` class and adds support for Hive
function operations in `HiveC
[
https://issues.apache.org/jira/browse/FLINK-12573?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16845482#comment-16845482
]
Louis Xu commented on FLINK-12573:
--
Hello，[~yitz589]，I am interested in this issue. And
[
https://issues.apache.org/jira/browse/FLINK-12241?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bowen Li closed FLINK-12241.
Resolution: Fixed
merged in 1.9.0: 3813bb90ba4fb8bc8637b7c1c5de2e24196c4b3b
> Support Flink functions in
[
https://issues.apache.org/jira/browse/FLINK-12573?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Louis Xu reassigned FLINK-12573:
Assignee: Louis Xu
> ability to add suffix to part file created in Bucket (StreamingFileSink)
> -
liyafan82 edited a comment on issue #8278: [FLINK-12335][Table-runtime]Remove
useless code in class SegmentsUtil
URL: https://github.com/apache/flink/pull/8278#issuecomment-494286726
> Thanks @liyafan82 for you code, maybe you can change the title to `remove
useless code in SegmentsUtil`,
JingsongLi commented on issue #8278: [FLINK-12335][Table-runtime]Remove useless
code in class SegmentsUtil
URL: https://github.com/apache/flink/pull/8278#issuecomment-494638754
Thanks @liyafan82 , LGTM +1
This is an automated
[
https://issues.apache.org/jira/browse/FLINK-12558?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
lamber-ken closed FLINK-12558.
--
Resolution: Not A Problem
Fix Version/s: 1.6.3
Release Note:
it needs to add -ace option t
JingsongLi commented on a change in pull request #8278:
[FLINK-12335][Table-runtime]Remove useless code in class SegmentsUtil
URL: https://github.com/apache/flink/pull/8278#discussion_r286296038
##
File path:
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/tabl
[
https://issues.apache.org/jira/browse/FLINK-12558?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16845457#comment-16845457
]
lamber-ken commented on FLINK-12558:
hi, thanks for assign this issue [~frank wang],
lirui-apache commented on a change in pull request #8449: [FLINK-12235][hive]
Support partition related operations in HiveCatalog
URL: https://github.com/apache/flink/pull/8449#discussion_r286299254
##
File path:
flink-table/flink-table-common/src/test/java/org/apache/flink/table/c
zhijiangW commented on a change in pull request #8463: [FLINK-12530][network]
Move Task.inputGatesById to NetworkEnvironment
URL: https://github.com/apache/flink/pull/8463#discussion_r286299195
##
File path:
flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/
lirui-apache commented on a change in pull request #8449: [FLINK-12235][hive]
Support partition related operations in HiveCatalog
URL: https://github.com/apache/flink/pull/8449#discussion_r286297702
##
File path:
flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/
lirui-apache commented on a change in pull request #8449: [FLINK-12235][hive]
Support partition related operations in HiveCatalog
URL: https://github.com/apache/flink/pull/8449#discussion_r286297791
##
File path:
flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/
lirui-apache commented on a change in pull request #8449: [FLINK-12235][hive]
Support partition related operations in HiveCatalog
URL: https://github.com/apache/flink/pull/8449#discussion_r286298510
##
File path:
flink-table/flink-table-api-java/src/main/java/org/apache/flink/table
zhijiangW commented on a change in pull request #8463: [FLINK-12530][network]
Move Task.inputGatesById to NetworkEnvironment
URL: https://github.com/apache/flink/pull/8463#discussion_r286297035
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/NetworkEnv
sunjincheng121 edited a comment on issue #8472: [FLINK-12327][python] Adds
support to submit Python Table API job in CliFrontend
URL: https://github.com/apache/flink/pull/8472#issuecomment-494627775
@HuangXingBo Thanks for the PR！
I am glad to see you had listed the detail change in `Bri
JingsongLi commented on a change in pull request #8278:
[FLINK-12335][Table-runtime]Remove useless code in class SegmentsUtil
URL: https://github.com/apache/flink/pull/8278#discussion_r286296038
##
File path:
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/tabl
HuangXingBo commented on issue #8472: [FLINK-12327][python] Adds support to
submit Python Table API job in CliFrontend
URL: https://github.com/apache/flink/pull/8472#issuecomment-494629938
> @HuangXingBo Thanks for the PR！
> I am glad to see you had listed the detail change in `` section
[
https://issues.apache.org/jira/browse/FLINK-11560?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16845437#comment-16845437
]
Congxian Qiu(klion26) commented on FLINK-11560:
---
thanks for your contribut
asfgit closed pull request #8503: [FLINK-12241][hive] Support Flink functions
in catalog function APIs of HiveCatalog
URL: https://github.com/apache/flink/pull/8503
This is an automated message from the Apache Git Service.
T
lirui-apache commented on a change in pull request #8449: [FLINK-12235][hive]
Support partition related operations in HiveCatalog
URL: https://github.com/apache/flink/pull/8449#discussion_r286292141
##
File path:
flink-table/flink-table-api-java/src/main/java/org/apache/flink/table
sunjincheng121 commented on issue #8472: [FLINK-12327][python] Adds support to
submit Python Table API job in CliFrontend
URL: https://github.com/apache/flink/pull/8472#issuecomment-494627775
@HuangXingBo Thanks for the PR！
I am glad to see you had listed the detail change in `` section
JingsongLi commented on issue #8435: [FLINK-12443][table-planner-blink] Replace
InternalType with LogicalType in blink
URL: https://github.com/apache/flink/pull/8435#issuecomment-494625782
> I try to start reviewing from runtime package, and noticed that the old
internal types haven't yet
shuai-xu commented on a change in pull request #8486: [FLINK-12372] [runtime]
implement ExecutionSlotAllocator
URL: https://github.com/apache/flink/pull/8486#discussion_r286290311
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/DefaultExecutionSlotAlloc
flinkbot edited a comment on issue #8472: [FLINK-12327][python] Adds support to
submit Python Table API job in CliFrontend
URL: https://github.com/apache/flink/pull/8472#issuecomment-493313848
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the com
sunjincheng121 commented on issue #8472: [FLINK-12327][python] Adds support to
submit Python Table API job in CliFrontend
URL: https://github.com/apache/flink/pull/8472#issuecomment-494623534
@flinkbot attention @StephanEwen
sunjincheng121 edited a comment on issue #8488: [FLINK-12439][python] Add
FileSystem Connector with CSV format support in Python Table API
URL: https://github.com/apache/flink/pull/8488#issuecomment-494621847
One more comment: Please improve the description of PR, It's better to tell
the r
sunjincheng121 edited a comment on issue #8488: [FLINK-12439][python] Add
FileSystem Connector with CSV format support in Python Table API
URL: https://github.com/apache/flink/pull/8488#issuecomment-494621847
One more comment: Please improve the description of PR, It's better to tell
the r
sunjincheng121 edited a comment on issue #8488: [FLINK-12439][python] Add
FileSystem Connector with CSV format support in Python Table API
URL: https://github.com/apache/flink/pull/8488#issuecomment-494621847
One more comment: Please improve the description of PR, It's better to tell
the r
sunjincheng121 commented on issue #8488: [FLINK-12439][python] Add FileSystem
Connector with CSV format support in Python Table API
URL: https://github.com/apache/flink/pull/8488#issuecomment-494621847
One more comment: Please improve the description of PR, It's better to tell
the reviewer
sunjincheng121 commented on a change in pull request #8488:
[FLINK-12439][python] Add FileSystem Connector with CSV format support in
Python Table API
URL: https://github.com/apache/flink/pull/8488#discussion_r286278062
##
File path: flink-python/pyflink/table/table_descriptor.py
sunjincheng121 commented on a change in pull request #8488:
[FLINK-12439][python] Add FileSystem Connector with CSV format support in
Python Table API
URL: https://github.com/apache/flink/pull/8488#discussion_r286278465
##
File path: flink-python/pyflink/table/table_descriptor.py
sunjincheng121 commented on a change in pull request #8488:
[FLINK-12439][python] Add FileSystem Connector with CSV format support in
Python Table API
URL: https://github.com/apache/flink/pull/8488#discussion_r286275713
##
File path: flink-python/pyflink/table/table_descriptor.py
sunjincheng121 commented on a change in pull request #8488:
[FLINK-12439][python] Add FileSystem Connector with CSV format support in
Python Table API
URL: https://github.com/apache/flink/pull/8488#discussion_r286277293
##
File path: flink-python/pyflink/table/table_descriptor.py
sunjincheng121 commented on a change in pull request #8488:
[FLINK-12439][python] Add FileSystem Connector with CSV format support in
Python Table API
URL: https://github.com/apache/flink/pull/8488#discussion_r286285192
##
File path: flink-python/pyflink/table/tests/test_descriptor
sunjincheng121 commented on a change in pull request #8488:
[FLINK-12439][python] Add FileSystem Connector with CSV format support in
Python Table API
URL: https://github.com/apache/flink/pull/8488#discussion_r286275045
##
File path: flink-python/pyflink/table/table_descriptor.py
sunjincheng121 commented on a change in pull request #8488:
[FLINK-12439][python] Add FileSystem Connector with CSV format support in
Python Table API
URL: https://github.com/apache/flink/pull/8488#discussion_r286285542
##
File path: flink-python/pyflink/table/tests/test_descriptor
liyafan82 commented on a change in pull request #8492:
[FLINK-12563][table-runtime-blink] Introduce vector data format in blink
URL: https://github.com/apache/flink/pull/8492#discussion_r285988252
##
File path:
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/ta
liyafan82 commented on a change in pull request #8492:
[FLINK-12563][table-runtime-blink] Introduce vector data format in blink
URL: https://github.com/apache/flink/pull/8492#discussion_r285992779
##
File path:
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/ta
[
https://issues.apache.org/jira/browse/FLINK-12584?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhangjun updated FLINK-12584:
-
Description:
1. *Motivation*
In flink, the file system (especially hdfs) is a very common output, but f
zhangjun created FLINK-12584:
Summary: Add Bucket File Syetem Table Sink
Key: FLINK-12584
URL: https://issues.apache.org/jira/browse/FLINK-12584
Project: Flink
Issue Type: New Feature
C
[
https://issues.apache.org/jira/browse/FLINK-12509?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kurt Young closed FLINK-12509.
--
Resolution: Implemented
Fix Version/s: 1.9.0
merge in 1.9.0: b36c54dd06122b7ddf10048ca72f1b5e44
KurtYoung merged pull request #8440: [FLINK-12509] [table-planner-blink]
Introduce planner rules about non semi/anti join
URL: https://github.com/apache/flink/pull/8440
This is an automated message from the Apache Git Servic
[
https://issues.apache.org/jira/browse/FLINK-12524?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kurt Young closed FLINK-12524.
--
Resolution: Implemented
Fix Version/s: 1.9.0
merge in 1.9.0: e6f968c504ac323b8ae5da8a9545aae3ac
KurtYoung merged pull request #8460: [FLINK-12524] [table-planner-blink]
Introduce planner rules about rank
URL: https://github.com/apache/flink/pull/8460
This is an automated message from the Apache Git Service.
To respond
sunjincheng created FLINK-12583:
---
Summary: Add all format support align with the Java Table API
Key: FLINK-12583
URL: https://issues.apache.org/jira/browse/FLINK-12583
Project: Flink
Issue Type
[
https://issues.apache.org/jira/browse/FLINK-12236?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16845355#comment-16845355
]
Bowen Li commented on FLINK-12236:
--
Hi [~Terry1897] I'll just quickly implement this fu
[
https://issues.apache.org/jira/browse/FLINK-12236?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bowen Li updated FLINK-12236:
-
Description: Support Hive function related operations in HiveCatalog (was:
Support function related ope
[
https://issues.apache.org/jira/browse/FLINK-12236?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bowen Li updated FLINK-12236:
-
Summary: Support Hive function in HiveCatalog (was: Support function
related operations in HiveCatalog)
1 - 100 of 378 matches
Mail list logo
