sunjincheng121 commented on issue #8267: [FLINK-12311][table][python] Add base
python framework and Add Scan, Projection, and Filter operator support
URL: https://github.com/apache/flink/pull/8267#issuecomment-489480948
@flinkbot approve all
Merging...
sunjincheng created FLINK-12407:
---
Summary: Add all table operators align Java Table API
Key: FLINK-12407
URL: https://issues.apache.org/jira/browse/FLINK-12407
Project: Flink
Issue Type:
Xpray opened a new pull request #8346: [FLINK-12405] [DataSet] Introduce
BLOCKING_PERSISTENT result partition type
URL: https://github.com/apache/flink/pull/8346
## What is the purpose of the change
Introducing a new``` ResultPartitionType```, result partition of this type
[
https://issues.apache.org/jira/browse/FLINK-12405?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-12405:
---
Labels: pull-request-available (was: )
> Introduce BLOCKING_PERSISTENT result partition
dianfu opened a new pull request #8347: [FLINK-12326][python] Add basic test
framework for python api
URL: https://github.com/apache/flink/pull/8347
## What is the purpose of the change
*This pull request adds the basic test framework for python api just like
the existing
[
https://issues.apache.org/jira/browse/FLINK-12326?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-12326:
---
Labels: pull-request-available (was: )
> Add a basic test framework, just like the
flinkbot commented on issue #8347: [FLINK-12326][python] Add basic test
framework for python api
URL: https://github.com/apache/flink/pull/8347#issuecomment-489486437
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
to review your
shaoxuan-wang commented on issue #7446: Added Model serving - implementation of
the Flip -23.
URL: https://github.com/apache/flink/pull/7446#issuecomment-489486186
Hi @blublinsky, thanks for the contribution. As we talked offline, I have
observed there are at least three issues of this PR
Dian Fu created FLINK-12409:
---
Summary: Adds from_elements in TableEnvironment
Key: FLINK-12409
URL: https://issues.apache.org/jira/browse/FLINK-12409
Project: Flink
Issue Type: Sub-task
eaglewatcherwb commented on a change in pull request #8309: [FLINK-12229]
[runtime] Implement LazyFromSourcesScheduling Strategy
URL: https://github.com/apache/flink/pull/8309#discussion_r281049742
##
File path:
[
https://issues.apache.org/jira/browse/FLINK-12407?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Wei Zhong reassigned FLINK-12407:
-
Assignee: Wei Zhong
> Add all table operators align Java Table API
>
klion26 commented on issue #8341: [FLINK-11633][docs-zh] Translate "Working
with state" into Chinese
URL: https://github.com/apache/flink/pull/8341#issuecomment-489487389
@wuchong thanks for the review and advice.
This is an
Ryantaocer commented on a change in pull request #8290: [FLINK-12070] [network]
Implement new bounded blocking subpartitions
URL: https://github.com/apache/flink/pull/8290#discussion_r281057098
##
File path:
Leev commented on issue #8319: [FLINK-11636] [docs-zh] Translate "State
Schema Evolution" into Chinese
URL: https://github.com/apache/flink/pull/8319#issuecomment-489497303
> @Leev thanks for addressing the comments, LGTM now.
Thanks for your review .
xuefuz commented on a change in pull request #8314: [FLINK-12365][table] Add
stats related catalog APIs
URL: https://github.com/apache/flink/pull/8314#discussion_r281065645
##
File path:
KurtYoung commented on a change in pull request #8314: [FLINK-12365][table] Add
stats related catalog APIs
URL: https://github.com/apache/flink/pull/8314#discussion_r281065647
##
File path:
Ryantaocer commented on a change in pull request #8290: [FLINK-12070] [network]
Implement new bounded blocking subpartitions
URL: https://github.com/apache/flink/pull/8290#discussion_r281054990
##
File path:
Dian Fu created FLINK-12408:
---
Summary: Support to define all kinds of types in Python API
Key: FLINK-12408
URL: https://issues.apache.org/jira/browse/FLINK-12408
Project: Flink
Issue Type:
Chethan U created FLINK-12410:
-
Summary: KafkaTopicPartition cannot be used as a POJO type because
not all fields are valid POJO fields
Key: FLINK-12410
URL: https://issues.apache.org/jira/browse/FLINK-12410
zhijiangW commented on issue #8310: [FLINK-12331][network] Introduce
partition/gate setup to decouple task registration with NetworkEnvironment
URL: https://github.com/apache/flink/pull/8310#issuecomment-489495824
Thanks for further reviews @azagrebin
My previous understanding of
Leev opened a new pull request #8344: [FLINK-12141] [API/Type Serialization
System] Allow @TypeInfo annotation on POJO field declarations
URL: https://github.com/apache/flink/pull/8344
## What is the purpose of the change
*Allow @TypeInfo annotation on POJO field
Leev closed pull request #8344: [FLINK-12141] [API/Type Serialization
System] Allow @TypeInfo annotation on POJO field declarations
URL: https://github.com/apache/flink/pull/8344
This is an automated message from the
[
https://issues.apache.org/jira/browse/FLINK-12141?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-12141:
---
Labels: pull-request-available starter (was: starter)
> Allow @TypeInfo annotation on POJO
[
https://issues.apache.org/jira/browse/FLINK-12348?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16833528#comment-16833528
]
Jark Wu commented on FLINK-12348:
-
Yes, I totally agree with your points [~hequn8128]
> Use TableConfig
wsry commented on a change in pull request #8290: [FLINK-12070] [network]
Implement new bounded blocking subpartitions
URL: https://github.com/apache/flink/pull/8290#discussion_r281051963
##
File path:
[
https://issues.apache.org/jira/browse/FLINK-12348?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16833507#comment-16833507
]
Hequn Cheng commented on FLINK-12348:
-
Hi [~jark], thanks for the detailed description and
Ryantaocer commented on a change in pull request #8290: [FLINK-12070] [network]
Implement new bounded blocking subpartitions
URL: https://github.com/apache/flink/pull/8290#discussion_r281053691
##
File path:
Ryantaocer commented on a change in pull request #8290: [FLINK-12070] [network]
Implement new bounded blocking subpartitions
URL: https://github.com/apache/flink/pull/8290#discussion_r281054851
##
File path:
shuai-xu commented on a change in pull request #8296: [FLINK-12228] [runtime]
Implement Eager Scheduling Strategy
URL: https://github.com/apache/flink/pull/8296#discussion_r281059574
##
File path:
flinkbot commented on issue #8348: [FLINK-12404] [docs-zh] Translate the
"Register a custom serializer f…
URL: https://github.com/apache/flink/pull/8348#issuecomment-489496900
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
to
[
https://issues.apache.org/jira/browse/FLINK-12404?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16833523#comment-16833523
]
YangFei commented on FLINK-12404:
-
[~jark] can you review this issue ? thanks
> Translate the "Register
xuefuz commented on a change in pull request #8314: [FLINK-12365][table] Add
stats related catalog APIs
URL: https://github.com/apache/flink/pull/8314#discussion_r281065464
##
File path:
asfgit closed pull request #8267: [FLINK-12311][table][python] Add base python
framework and Add Scan, Projection, and Filter operator support
URL: https://github.com/apache/flink/pull/8267
This is an automated message from
[
https://issues.apache.org/jira/browse/FLINK-12311?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sunjincheng closed FLINK-12311.
---
Resolution: Fixed
Fix Version/s: 1.9.0
Fixed in master:
[
https://issues.apache.org/jira/browse/FLINK-12308?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sunjincheng reopened FLINK-12308:
-
> Support python language in Flink Table API
> --
>
>
[
https://issues.apache.org/jira/browse/FLINK-12308?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sunjincheng closed FLINK-12308.
---
Resolution: Fixed
Fix Version/s: 1.9.0
Fixed in master:
[
https://issues.apache.org/jira/browse/FLINK-12308?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sunjincheng updated FLINK-12308:
Comment: was deleted
(was: Fixed in master: a09bd4c6f1dc5d83d6634bad53af6237a9cd4fe5)
> Support
[
https://issues.apache.org/jira/browse/FLINK-11633?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu closed FLINK-11633.
---
Resolution: Fixed
Fix Version/s: 1.9.0
Resolved in 1.9.0: 906d593ae21c98e335e0a078fe37d6d295e6f993
asfgit closed pull request #8341: [FLINK-11633][docs-zh] Translate "Working
with state" into Chinese
URL: https://github.com/apache/flink/pull/8341
This is an automated message from the Apache Git Service.
To respond to the
wuchong commented on issue #8341: [FLINK-11633][docs-zh] Translate "Working
with state" into Chinese
URL: https://github.com/apache/flink/pull/8341#issuecomment-489485181
Merged.
This is an automated message from the Apache
flinkbot commented on issue #8346: [FLINK-12405] [DataSet] Introduce
BLOCKING_PERSISTENT result partition type
URL: https://github.com/apache/flink/pull/8346#issuecomment-489484986
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
Ryantaocer commented on a change in pull request #8290: [FLINK-12070] [network]
Implement new bounded blocking subpartitions
URL: https://github.com/apache/flink/pull/8290#discussion_r281054990
##
File path:
shuai-xu commented on a change in pull request #8296: [FLINK-12228] [runtime]
Implement Eager Scheduling Strategy
URL: https://github.com/apache/flink/pull/8296#discussion_r281059348
##
File path:
shuai-xu commented on a change in pull request #8296: [FLINK-12228] [runtime]
Implement Eager Scheduling Strategy
URL: https://github.com/apache/flink/pull/8296#discussion_r281059332
##
File path:
Leev opened a new pull request #8348: [FLINK-12404] [docs-zh] Translate the
"Register a custom serializer f…
URL: https://github.com/apache/flink/pull/8348
…or your Flink program" page into Chinese
## What is the purpose of the change
*This pull request completes the
shuai-xu commented on a change in pull request #8296: [FLINK-12228] [runtime]
Implement Eager Scheduling Strategy
URL: https://github.com/apache/flink/pull/8296#discussion_r281059477
##
File path:
shuai-xu commented on a change in pull request #8296: [FLINK-12228] [runtime]
Implement Eager Scheduling Strategy
URL: https://github.com/apache/flink/pull/8296#discussion_r281059488
##
File path:
xuefuz commented on a change in pull request #8314: [FLINK-12365][table] Add
stats related catalog APIs
URL: https://github.com/apache/flink/pull/8314#discussion_r281066379
##
File path:
eaglewatcherwb commented on a change in pull request #8309: [FLINK-12229]
[runtime] Implement LazyFromSourcesScheduling Strategy
URL: https://github.com/apache/flink/pull/8309#discussion_r281002357
##
File path:
[
https://issues.apache.org/jira/browse/FLINK-12229?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16833241#comment-16833241
]
ryantaocer commented on FLINK-12229:
Maybe we could introduce a new scheduling trigger {{PROGRESS}}
zhijiangW commented on a change in pull request #8320:
[FLINK-12201][network][metrics] Introduce InputGateWithMetrics in Task to
increment numBytesIn metric
URL: https://github.com/apache/flink/pull/8320#discussion_r281006940
##
File path:
Hequn Cheng created FLINK-12402:
---
Summary: Make validation error message for CallExpression more
user friendly
Key: FLINK-12402
URL: https://issues.apache.org/jira/browse/FLINK-12402
Project: Flink
asfgit closed pull request #8230: [FLINK-10977][table] Add streaming non-window
FlatAggregate to Table API
URL: https://github.com/apache/flink/pull/8230
This is an automated message from the Apache Git Service.
To respond
zhijiangW commented on a change in pull request #8242: [FLINK-6227][network]
Introduce the DataConsumptionException for downstream task failure
URL: https://github.com/apache/flink/pull/8242#discussion_r281005734
##
File path:
zhijiangW commented on a change in pull request #8320:
[FLINK-12201][network][metrics] Introduce InputGateWithMetrics in Task to
increment numBytesIn metric
URL: https://github.com/apache/flink/pull/8320#discussion_r281006200
##
File path:
zjffdu commented on a change in pull request #8144: [FLINK-12159]. Enable
YarnMiniCluster integration test under non-secure mode
URL: https://github.com/apache/flink/pull/8144#discussion_r281006208
##
File path:
[
https://issues.apache.org/jira/browse/FLINK-12229?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16833241#comment-16833241
]
ryantaocer edited comment on FLINK-12229 at 5/5/19 6:40 AM:
Maybe we could
[
https://issues.apache.org/jira/browse/FLINK-10977?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sunjincheng closed FLINK-10977.
---
Resolution: Fixed
Fixed in master: e5cadf69d176181af7d097928bf2a6cade1b6c76
> Add FlatAggregate
sunjincheng121 commented on issue #8311: [FLINK-10976][table] Add Aggregate
operator to Table API
URL: https://github.com/apache/flink/pull/8311#issuecomment-489401476
@flinkbot approve-until architecture
I am glad to review this change after you rebase the code. :) @hequn8128
Best,
zhijiangW commented on a change in pull request #8242: [FLINK-6227][network]
Introduce the DataConsumptionException for downstream task failure
URL: https://github.com/apache/flink/pull/8242#discussion_r281005899
##
File path:
sunjincheng121 commented on a change in pull request #8267:
[FLINK-12311][table][python] Add base python framework and Add Scan,
Projection, and Filter operator support
URL: https://github.com/apache/flink/pull/8267#discussion_r281006384
##
File path:
[
https://issues.apache.org/jira/browse/FLINK-12229?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16833241#comment-16833241
]
ryantaocer edited comment on FLINK-12229 at 5/5/19 8:10 AM:
Maybe we could
wuchong commented on a change in pull request #8244: [FLINK-11945]
[table-runtime-blink] Support over aggregation for blink streaming runtime
URL: https://github.com/apache/flink/pull/8244#discussion_r281020309
##
File path:
wuchong commented on a change in pull request #8244: [FLINK-11945]
[table-runtime-blink] Support over aggregation for blink streaming runtime
URL: https://github.com/apache/flink/pull/8244#discussion_r281020786
##
File path:
wuchong commented on a change in pull request #8244: [FLINK-11945]
[table-runtime-blink] Support over aggregation for blink streaming runtime
URL: https://github.com/apache/flink/pull/8244#discussion_r281020464
##
File path:
wuchong commented on a change in pull request #8244: [FLINK-11945]
[table-runtime-blink] Support over aggregation for blink streaming runtime
URL: https://github.com/apache/flink/pull/8244#discussion_r281020800
##
File path:
wuchong commented on a change in pull request #8244: [FLINK-11945]
[table-runtime-blink] Support over aggregation for blink streaming runtime
URL: https://github.com/apache/flink/pull/8244#discussion_r281019195
##
File path:
wuchong commented on a change in pull request #8244: [FLINK-11945]
[table-runtime-blink] Support over aggregation for blink streaming runtime
URL: https://github.com/apache/flink/pull/8244#discussion_r281019590
##
File path:
wuchong commented on a change in pull request #8244: [FLINK-11945]
[table-runtime-blink] Support over aggregation for blink streaming runtime
URL: https://github.com/apache/flink/pull/8244#discussion_r281020516
##
File path:
wuchong commented on a change in pull request #8244: [FLINK-11945]
[table-runtime-blink] Support over aggregation for blink streaming runtime
URL: https://github.com/apache/flink/pull/8244#discussion_r281020965
##
File path:
wuchong commented on a change in pull request #8244: [FLINK-11945]
[table-runtime-blink] Support over aggregation for blink streaming runtime
URL: https://github.com/apache/flink/pull/8244#discussion_r281019681
##
File path:
wuchong commented on a change in pull request #8244: [FLINK-11945]
[table-runtime-blink] Support over aggregation for blink streaming runtime
URL: https://github.com/apache/flink/pull/8244#discussion_r281019632
##
File path:
wuchong commented on a change in pull request #8244: [FLINK-11945]
[table-runtime-blink] Support over aggregation for blink streaming runtime
URL: https://github.com/apache/flink/pull/8244#discussion_r281020398
##
File path:
wuchong commented on a change in pull request #8244: [FLINK-11945]
[table-runtime-blink] Support over aggregation for blink streaming runtime
URL: https://github.com/apache/flink/pull/8244#discussion_r281019484
##
File path:
wuchong commented on a change in pull request #8244: [FLINK-11945]
[table-runtime-blink] Support over aggregation for blink streaming runtime
URL: https://github.com/apache/flink/pull/8244#discussion_r281020373
##
File path:
klion26 commented on issue #8319: [FLINK-11636] [docs-zh] Translate "State
Schema Evolution" into Chinese
URL: https://github.com/apache/flink/pull/8319#issuecomment-489428851
@Leev thanks for addressing the comments, LGTM now.
klion26 commented on issue #8341: [FLINK-11633][docs-zh] Translate "Working
with state" into Chinese
URL: https://github.com/apache/flink/pull/8341#issuecomment-489428263
@wuchong thanks for the review, I've updated according to the comments.
I think we can let `managed state` and `raw
wuchong commented on a change in pull request #8244: [FLINK-11945]
[table-runtime-blink] Support over aggregation for blink streaming runtime
URL: https://github.com/apache/flink/pull/8244#discussion_r281020930
##
File path:
wuchong commented on a change in pull request #8244: [FLINK-11945]
[table-runtime-blink] Support over aggregation for blink streaming runtime
URL: https://github.com/apache/flink/pull/8244#discussion_r281021249
##
File path:
wuchong commented on a change in pull request #8244: [FLINK-11945]
[table-runtime-blink] Support over aggregation for blink streaming runtime
URL: https://github.com/apache/flink/pull/8244#discussion_r281021219
##
File path:
wuchong commented on a change in pull request #8244: [FLINK-11945]
[table-runtime-blink] Support over aggregation for blink streaming runtime
URL: https://github.com/apache/flink/pull/8244#discussion_r281021772
##
File path:
wuchong commented on a change in pull request #8244: [FLINK-11945]
[table-runtime-blink] Support over aggregation for blink streaming runtime
URL: https://github.com/apache/flink/pull/8244#discussion_r281021281
##
File path:
wuchong commented on a change in pull request #8244: [FLINK-11945]
[table-runtime-blink] Support over aggregation for blink streaming runtime
URL: https://github.com/apache/flink/pull/8244#discussion_r281021760
##
File path:
wuchong commented on a change in pull request #8244: [FLINK-11945]
[table-runtime-blink] Support over aggregation for blink streaming runtime
URL: https://github.com/apache/flink/pull/8244#discussion_r281021507
##
File path:
wuchong commented on a change in pull request #8244: [FLINK-11945]
[table-runtime-blink] Support over aggregation for blink streaming runtime
URL: https://github.com/apache/flink/pull/8244#discussion_r281022513
##
File path:
wuchong commented on a change in pull request #8244: [FLINK-11945]
[table-runtime-blink] Support over aggregation for blink streaming runtime
URL: https://github.com/apache/flink/pull/8244#discussion_r281022503
##
File path:
wuchong commented on a change in pull request #8244: [FLINK-11945]
[table-runtime-blink] Support over aggregation for blink streaming runtime
URL: https://github.com/apache/flink/pull/8244#discussion_r281020771
##
File path:
wuchong commented on a change in pull request #8244: [FLINK-11945]
[table-runtime-blink] Support over aggregation for blink streaming runtime
URL: https://github.com/apache/flink/pull/8244#discussion_r281021244
##
File path:
wuchong commented on a change in pull request #8244: [FLINK-11945]
[table-runtime-blink] Support over aggregation for blink streaming runtime
URL: https://github.com/apache/flink/pull/8244#discussion_r281021262
##
File path:
wuchong commented on a change in pull request #8244: [FLINK-11945]
[table-runtime-blink] Support over aggregation for blink streaming runtime
URL: https://github.com/apache/flink/pull/8244#discussion_r281021226
##
File path:
wuchong commented on a change in pull request #8244: [FLINK-11945]
[table-runtime-blink] Support over aggregation for blink streaming runtime
URL: https://github.com/apache/flink/pull/8244#discussion_r281021752
##
File path:
wuchong commented on a change in pull request #8244: [FLINK-11945]
[table-runtime-blink] Support over aggregation for blink streaming runtime
URL: https://github.com/apache/flink/pull/8244#discussion_r281022499
##
File path:
wuchong commented on a change in pull request #8244: [FLINK-11945]
[table-runtime-blink] Support over aggregation for blink streaming runtime
URL: https://github.com/apache/flink/pull/8244#discussion_r281021967
##
File path:
wuchong commented on a change in pull request #8244: [FLINK-11945]
[table-runtime-blink] Support over aggregation for blink streaming runtime
URL: https://github.com/apache/flink/pull/8244#discussion_r281021825
##
File path:
wuchong commented on a change in pull request #8244: [FLINK-11945]
[table-runtime-blink] Support over aggregation for blink streaming runtime
URL: https://github.com/apache/flink/pull/8244#discussion_r281021776
##
File path:
wuchong commented on a change in pull request #8244: [FLINK-11945]
[table-runtime-blink] Support over aggregation for blink streaming runtime
URL: https://github.com/apache/flink/pull/8244#discussion_r281021766
##
File path:
wuchong commented on a change in pull request #8244: [FLINK-11945]
[table-runtime-blink] Support over aggregation for blink streaming runtime
URL: https://github.com/apache/flink/pull/8244#discussion_r281022518
##
File path:
wuchong commented on a change in pull request #8244: [FLINK-11945]
[table-runtime-blink] Support over aggregation for blink streaming runtime
URL: https://github.com/apache/flink/pull/8244#discussion_r281022717
##
File path:
wuchong commented on a change in pull request #8244: [FLINK-11945]
[table-runtime-blink] Support over aggregation for blink streaming runtime
URL: https://github.com/apache/flink/pull/8244#discussion_r281022356
##
File path:
wuchong commented on a change in pull request #8244: [FLINK-11945]
[table-runtime-blink] Support over aggregation for blink streaming runtime
URL: https://github.com/apache/flink/pull/8244#discussion_r281022189
##
File path:
1 - 100 of 250 matches
Mail list logo
