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
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:
[
https://issues.apache.org/jira/browse/FLINK-8871?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16845585#comment-16845585
]
Yu Li edited comment on FLINK-8871 at 5/22/19 6:51 AM:
---
bq. His solution (also
[
https://issues.apache.org/jira/browse/FLINK-10707?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16845624#comment-16845624
]
Robert Metzger commented on FLINK-10707:
Okay, thanks for the update.
> Improve Cluster
zhijiangW commented on a change in pull request #8346: [FLINK-12405] [DataSet]
Introduce BLOCKING_PERSISTENT result partition type
URL: https://github.com/apache/flink/pull/8346#discussion_r286372609
##
File path:
Wei Zhong created FLINK-12588:
-
Summary: Add TableSchema for Python Table API
Key: FLINK-12588
URL: https://issues.apache.org/jira/browse/FLINK-12588
Project: Flink
Issue Type: Sub-task
Aljoscha Krettek created FLINK-12587:
Summary: Add pure-API Watermark class
Key: FLINK-12587
URL: https://issues.apache.org/jira/browse/FLINK-12587
Project: Flink
Issue Type: Improvement
asfgit closed pull request #8442: [FLINK-12483] Support (legacy) SourceFunction
as special case in the mailbox model for stream tasks
URL: https://github.com/apache/flink/pull/8442
This is an automated message from the
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
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
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
[
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
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
[
https://issues.apache.org/jira/browse/FLINK-8871?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16845631#comment-16845631
]
vinoyang commented on FLINK-8871:
-
[~carp84] Please pay attention to your words, I think you are close to
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-494705623
Thanks for the update @WeiZhong94
LGTM. +1 to merged.
@flinkbot approve all
zhijiangW commented on a change in pull request #8346: [FLINK-12405] [DataSet]
Introduce BLOCKING_PERSISTENT result partition type
URL: https://github.com/apache/flink/pull/8346#discussion_r286368931
##
File path:
zhijiangW commented on a change in pull request #8346: [FLINK-12405] [DataSet]
Introduce BLOCKING_PERSISTENT result partition type
URL: https://github.com/apache/flink/pull/8346#discussion_r286368588
##
File path:
zhijiangW commented on a change in pull request #8346: [FLINK-12405] [DataSet]
Introduce BLOCKING_PERSISTENT result partition type
URL: https://github.com/apache/flink/pull/8346#discussion_r286374621
##
File path:
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:
[
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: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:comment-tabpanel=16845566#comment-16845566
]
Liya Fan commented on FLINK-12319:
--
Hi [~mpf], thank you for your feedback. I am looking at this issue.
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-494682592
> Thanks for contributing this PR, and great to see new machine learning
effort arriving at Flink!
>
> We also need
[
https://issues.apache.org/jira/browse/FLINK-10707?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16845601#comment-16845601
]
Fabian Wollert commented on FLINK-10707:
[~rmetzger] unfortunately not. June looks more
tillrohrmann commented on issue #8509: [FLINK-12458][network] Introduce
PartitionConnectionException for unreachable producer
URL: https://github.com/apache/flink/pull/8509#issuecomment-494696364
The PR does not compile @zhijiangW.
flinkbot edited a comment on issue #8509: [FLINK-12458][network] Introduce
PartitionConnectionException for unreachable producer
URL: https://github.com/apache/flink/pull/8509#issuecomment-494679383
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help
JingsongLi 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_r286361709
##
File path:
[
https://issues.apache.org/jira/browse/FLINK-12579?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-12579.
Resolution: Duplicate
> Influx Metric exporter throws a lot of negative infinity errors
>
[
https://issues.apache.org/jira/browse/FLINK-12579?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-12579:
-
Component/s: Runtime / Metrics
> Influx Metric exporter throws a lot of negative
asfgit closed pull request #8431: [FLINK-12480] Introduce mailbox to StreamTask
main-loop
URL: https://github.com/apache/flink/pull/8431
This is an automated message from the Apache Git Service.
To respond to the message,
asfgit closed pull request #8409: [FLINK-12478] Decompose monolithic run-loops
in StreamTask implementa…
URL: https://github.com/apache/flink/pull/8409
This is an automated message from the Apache Git Service.
To respond to
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:
flinkbot commented on issue #8509: [FLINK-12458][network] Introduce
PartitionConnectionException for unreachable producer
URL: https://github.com/apache/flink/pull/8509#issuecomment-494679383
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the
[
https://issues.apache.org/jira/browse/FLINK-12458?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-12458:
---
Labels: pull-request-available (was: )
> Introduce PartitionConnectionException for
JingsongLi edited a comment 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
StefanRRichter commented on issue #8442: [FLINK-12483] Support (legacy)
SourceFunction as special case in the mailbox model for stream tasks
URL: https://github.com/apache/flink/pull/8442#issuecomment-494707360
Thanks for the reviews @pnowojski @Aitozi - merging.
[
https://issues.apache.org/jira/browse/FLINK-8871?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16845585#comment-16845585
]
Yu Li commented on FLINK-8871:
--
bq. His solution (also proposed by us) is now meaningless, I just gave my
[
https://issues.apache.org/jira/browse/FLINK-6227?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhijiang updated FLINK-6227:
Description:
It is part of FLIP-1.
We define a new abstract special exception called
zhijiangW commented on a change in pull request #8346: [FLINK-12405] [DataSet]
Introduce BLOCKING_PERSISTENT result partition type
URL: https://github.com/apache/flink/pull/8346#discussion_r286366466
##
File path:
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
[
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
> ---
>
>
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
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:
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_r286367535
##
File path: flink-python/pyflink/table/table_descriptor.py
zhijiangW commented on a change in pull request #8346: [FLINK-12405] [DataSet]
Introduce BLOCKING_PERSISTENT result partition type
URL: https://github.com/apache/flink/pull/8346#discussion_r286368082
##
File path:
twalthr commented on a change in pull request #8508: [FLINK-12533][table]
Introduce TABLE_AGGREGATE_FUNCTION FunctionDefinition.Type
URL: https://github.com/apache/flink/pull/8508#discussion_r286367280
##
File path:
Chesnay Schepler created FLINK-12589:
Summary: SQL end-to-end test fails on Travis
Key: FLINK-12589
URL: https://issues.apache.org/jira/browse/FLINK-12589
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-12588?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Wei Zhong updated FLINK-12588:
--
Description: As discussed in the PR of FLINK-12439, we need to add
TableSchema to Python Table API
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_r286345003
##
File path: flink-python/pyflink/table/table_descriptor.py
[
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
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
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:
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-12573?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=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=16845581#comment-16845581
]
yitzchak lieberman commented on FLINK-12573:
Hi Louis.
I think it could help if it will be
[
https://issues.apache.org/jira/browse/FLINK-6227?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhijiang updated FLINK-6227:
Summary: Introduce the abstract PartitionException for downstream task
failure (was: Introduce the
zhijiangW commented on a change in pull request #8346: [FLINK-12405] [DataSet]
Introduce BLOCKING_PERSISTENT result partition type
URL: https://github.com/apache/flink/pull/8346#discussion_r286369679
##
File path:
flinkbot 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-493961877
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I
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_r286375884
##
File path: flink-python/pyflink/table/table_descriptor.py
twalthr commented on a change in pull request #8349:
[FLINK-12411][table-planner][tests] Workaround limited support of not nullable
fields in window aggregation
URL: https://github.com/apache/flink/pull/8349#discussion_r286377273
##
File path:
[
https://issues.apache.org/jira/browse/FLINK-12477?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alex reassigned FLINK-12477:
Assignee: Alex
> Change threading-model in StreamTask to a mailbox-based approach
>
[
https://issues.apache.org/jira/browse/FLINK-12401?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16845700#comment-16845700
]
Hequn Cheng commented on FLINK-12401:
-
Hi [~sunjincheng121] [~jark], I'm going to support
[
https://issues.apache.org/jira/browse/FLINK-12589?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dawid Wysakowicz closed FLINK-12589.
Resolution: Fixed
> SQL end-to-end test fails on Travis
>
[
https://issues.apache.org/jira/browse/FLINK-12411?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dawid Wysakowicz updated FLINK-12411:
-
Description:
https://travis-ci.org/apache/flink/jobs/535231108
{code}
twalthr opened a new pull request #8510: [FLINK-12254][table] Update cast()
and TypeLiteralExpression to new type system
URL: https://github.com/apache/flink/pull/8510
## What is the purpose of the change
This PR updates `ImplicitExpressionOperations#cast` and
Chesnay Schepler created FLINK-12590:
Summary: Replace http links in documentation
Key: FLINK-12590
URL: https://issues.apache.org/jira/browse/FLINK-12590
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-12578?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16845792#comment-16845792
]
Jungtaek Lim commented on FLINK-12578:
--
Yes, I explained that changing scheme in MapR repo URL
dawidwys commented on issue #8500: [FLINK-12254][table-common] More preparation
for using the new type system
URL: https://github.com/apache/flink/pull/8500#issuecomment-494774411
@flinkbot approve until consensus
This is an
flinkbot commented on issue #8513: [FLINK-12147] [metrics] Error for monitor
kafka metrics when Use influxDB metr…
URL: https://github.com/apache/flink/pull/8513#issuecomment-494781909
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-12481?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alex reassigned FLINK-12481:
Assignee: Alex
> Make processing time timer trigger run via the mailbox
>
[
https://issues.apache.org/jira/browse/FLINK-12477?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alex reassigned FLINK-12477:
Assignee: (was: Alex)
> Change threading-model in StreamTask to a mailbox-based approach
>
Xpray commented on a change in pull request #8346: [FLINK-12405] [DataSet]
Introduce BLOCKING_PERSISTENT result partition type
URL: https://github.com/apache/flink/pull/8346#discussion_r286377261
##
File path:
Xpray commented on a change in pull request #8346: [FLINK-12405] [DataSet]
Introduce BLOCKING_PERSISTENT result partition type
URL: https://github.com/apache/flink/pull/8346#discussion_r286377381
##
File path:
[
https://issues.apache.org/jira/browse/FLINK-12122?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16845683#comment-16845683
]
Nico Kruber commented on FLINK-12122:
-
Since every subtask gets its own thread (not every slot /
[
https://issues.apache.org/jira/browse/FLINK-12568?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger updated FLINK-12568:
---
Component/s: Connectors / Hive
> Implement TableSink and OutputFormat to write Hive tables
zhijiangW commented on a change in pull request #8346: [FLINK-12405] [DataSet]
Introduce BLOCKING_PERSISTENT result partition type
URL: https://github.com/apache/flink/pull/8346#discussion_r286389776
##
File path:
[
https://issues.apache.org/jira/browse/FLINK-11634?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16845702#comment-16845702
]
Congxian Qiu(klion26) commented on FLINK-11634:
---
[~zxhe] I can't find your id for
[
https://issues.apache.org/jira/browse/FLINK-5544?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-5544:
--
Labels: pull-request-available (was: )
> Implement Internal Timer Service in RocksDB
>
pnowojski commented on issue #3359: [FLINK-5544][streaming] Add
InternalTimerService implemented in RocksDB
URL: https://github.com/apache/flink/pull/3359#issuecomment-494731669
This was superseded by @StefanRRichter work, so closing.
Xpray commented on a change in pull request #8346: [FLINK-12405] [DataSet]
Introduce BLOCKING_PERSISTENT result partition type
URL: https://github.com/apache/flink/pull/8346#discussion_r286410853
##
File path:
zentol merged pull request #8502: [FLINK-12578] Use secure URLs for Maven
repositories
URL: https://github.com/apache/flink/pull/8502
This is an automated message from the Apache Git Service.
To respond to the message,
sunjincheng121 commented on a change in pull request #8472:
[FLINK-12327][python] Adds support to submit Python Table API job in CliFrontend
URL: https://github.com/apache/flink/pull/8472#discussion_r286391030
##
File path:
pnowojski commented on a change in pull request #8495: [FLINK-12556][e2e]
Extend some end-to-end tests to run with custom (input) File System
implementation
URL: https://github.com/apache/flink/pull/8495#discussion_r286358387
##
File path:
pnowojski commented on a change in pull request #8495: [FLINK-12556][e2e]
Extend some end-to-end tests to run with custom (input) File System
implementation
URL: https://github.com/apache/flink/pull/8495#discussion_r286447515
##
File path:
pnowojski commented on a change in pull request #8495: [FLINK-12556][e2e]
Extend some end-to-end tests to run with custom (input) File System
implementation
URL: https://github.com/apache/flink/pull/8495#discussion_r286446063
##
File path:
pnowojski commented on a change in pull request #8495: [FLINK-12556][e2e]
Extend some end-to-end tests to run with custom (input) File System
implementation
URL: https://github.com/apache/flink/pull/8495#discussion_r286449211
##
File path:
pnowojski commented on a change in pull request #8495: [FLINK-12556][e2e]
Extend some end-to-end tests to run with custom (input) File System
implementation
URL: https://github.com/apache/flink/pull/8495#discussion_r286357388
##
File path:
pnowojski commented on a change in pull request #8495: [FLINK-12556][e2e]
Extend some end-to-end tests to run with custom (input) File System
implementation
URL: https://github.com/apache/flink/pull/8495#discussion_r286448379
##
File path:
rmetzger commented on issue #8414: [FLINK-12447][Build] Enforce maven version
3.1.1
URL: https://github.com/apache/flink/pull/8414#issuecomment-494777349
You are right @Myasuka, I've updated the ticket and commit.
Thank you @zentol for checking my PR. I opened a PR for the
pnowojski closed pull request #3359: [FLINK-5544][streaming] Add
InternalTimerService implemented in RocksDB
URL: https://github.com/apache/flink/pull/3359
This is an automated message from the Apache Git Service.
To
[
https://issues.apache.org/jira/browse/FLINK-12122?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16845716#comment-16845716
]
Till Rohrmann commented on FLINK-12122:
---
Thanks for reporting this issue [~mstar_benl]. I think
sunjincheng121 commented on a change in pull request #8472:
[FLINK-12327][python] Adds support to submit Python Table API job in CliFrontend
URL: https://github.com/apache/flink/pull/8472#discussion_r286391030
##
File path:
sunjincheng121 commented on a change in pull request #8472:
[FLINK-12327][python] Adds support to submit Python Table API job in CliFrontend
URL: https://github.com/apache/flink/pull/8472#discussion_r286380439
##
File path:
sunjincheng121 commented on a change in pull request #8472:
[FLINK-12327][python] Adds support to submit Python Table API job in CliFrontend
URL: https://github.com/apache/flink/pull/8472#discussion_r286397482
##
File path:
sunjincheng121 commented on a change in pull request #8472:
[FLINK-12327][python] Adds support to submit Python Table API job in CliFrontend
URL: https://github.com/apache/flink/pull/8472#discussion_r286399770
##
File path:
sunjincheng121 commented on a change in pull request #8472:
[FLINK-12327][python] Adds support to submit Python Table API job in CliFrontend
URL: https://github.com/apache/flink/pull/8472#discussion_r286394165
##
File path:
sunjincheng121 commented on a change in pull request #8472:
[FLINK-12327][python] Adds support to submit Python Table API job in CliFrontend
URL: https://github.com/apache/flink/pull/8472#discussion_r286405362
##
File path:
1 - 100 of 327 matches
Mail list logo