[
https://issues.apache.org/jira/browse/FLINK-17145?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee updated FLINK-17145:
-
Description:
instance: [https://api.travis-ci.com/v3/job/319161311/log.txt]
PR:
dianfu commented on issue #11717:
[FLINK-17093][python][table-planner][table-planner-blink] Fix Python UDF to
make it work with inputs from composite field
URL: https://github.com/apache/flink/pull/11717#issuecomment-613776556
@flinkbot run azure
dianfu commented on issue #11717:
[FLINK-17093][python][table-planner][table-planner-blink] Fix Python UDF to
make it work with inputs from composite field
URL: https://github.com/apache/flink/pull/11717#issuecomment-613776518
@flinkbot run travis
Jingsong Lee created FLINK-17145:
Summary: AggregateRemoveITCase.testAggregateRemove failed in travis
Key: FLINK-17145
URL: https://issues.apache.org/jira/browse/FLINK-17145
Project: Flink
flinkbot edited a comment on issue #11717:
[FLINK-17093][python][table-planner][table-planner-blink] Fix Python UDF to
make it work with inputs from composite field
URL: https://github.com/apache/flink/pull/11717#issuecomment-612882448
## CI report:
*
flinkbot edited a comment on issue #11531: [FLINK-16748][python][doc] Add
Python UDTF doc
URL: https://github.com/apache/flink/pull/11531#issuecomment-604443579
## CI report:
* e0206bfd6f024f6dc1b6b490fe4c1ed366f68ed0 Travis:
flinkbot edited a comment on issue #11726: [FLINK-17128][table] Add isBounded
to TableSinkFactory#Context
URL: https://github.com/apache/flink/pull/11726#issuecomment-613258923
## CI report:
* c1dc3facd8d02fd5bebc1919d12cce372b681a91 Travis:
flinkbot edited a comment on issue #11734: [FLINK-14713][rest]Show All Attempts
For Vertex SubTask In Rest Api
URL: https://github.com/apache/flink/pull/11734#issuecomment-613396242
## CI report:
* 0eeb53aacb4950a211faf775388e3bdd38df4a13 Travis:
[
https://issues.apache.org/jira/browse/FLINK-17139?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu closed FLINK-17139.
---
Resolution: Not A Problem
Hi [~hackergin], [~wenlong.lwl] is correct. This is an expected behavior.
[
https://issues.apache.org/jira/browse/FLINK-16113?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17083756#comment-17083756
]
Jark Wu edited comment on FLINK-16113 at 4/15/20, 3:12 AM:
---
Sure. Would you
[
https://issues.apache.org/jira/browse/FLINK-16113?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17083756#comment-17083756
]
Jark Wu commented on FLINK-16113:
-
Sure. Would like like to open a pull request for 1.9 branch? There
[
https://issues.apache.org/jira/browse/FLINK-17138?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17083763#comment-17083763
]
Rui Li commented on FLINK-17138:
Actually some test cases are intended to test LocalExecutor with Hive
Dian Fu created FLINK-17148:
---
Summary: Support converting pandas dataframe to flink table
Key: FLINK-17148
URL: https://issues.apache.org/jira/browse/FLINK-17148
Project: Flink
Issue Type:
yuchuanchen opened a new pull request #11745: [FLINK-17133] [Table SQL/API]
Support CsvParser Features for CSV form…
URL: https://github.com/apache/flink/pull/11745
## What is the purpose of the change
Support [CsvParser
zhijiangW commented on a change in pull request #11687:
[FLINK-16536][network][checkpointing] Implement InputChannel state recovery for
unaligned checkpoint
URL: https://github.com/apache/flink/pull/11687#discussion_r408575571
##
File path:
[
https://issues.apache.org/jira/browse/FLINK-16967?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17083798#comment-17083798
]
molsion commented on FLINK-16967:
-
If no one work for this issue , i can work it.
> Convert Slf4j
xintongsong commented on issue #11545: [FLINK-16742][runtime][dist] Extend and
use BashJavaUtils to start JM JVM process and pass JVM memory args
URL: https://github.com/apache/flink/pull/11545#issuecomment-613833551
Thanks @azagrebin, comments addressed.
leonardBang commented on issue #11466: [FLINK-15400][connectors /
elasticsearch] elasticsearch table sink support dynamic index.
URL: https://github.com/apache/flink/pull/11466#issuecomment-613833378
> Hi @leonardBang , what's the progress of this pr?
waiting for review 藍, CC:
flinkbot edited a comment on issue #11734: [FLINK-14713][rest]Show All Attempts
For Vertex SubTask In Rest Api
URL: https://github.com/apache/flink/pull/11734#issuecomment-613396242
## CI report:
* 0eeb53aacb4950a211faf775388e3bdd38df4a13 Travis:
[
https://issues.apache.org/jira/browse/FLINK-16100?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu reassigned FLINK-16100:
---
Assignee: Meiminda
> Translate "Reading & Writing Hive Tables" page of "Hive Integration" into
>
[
https://issues.apache.org/jira/browse/FLINK-17138?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17083750#comment-17083750
]
Jark Wu commented on FLINK-17138:
-
cc [~lzljs3620320]
> LocalExecutorITCase.testParameterizedTypes
Myasuka commented on issue #11742: [FLINK-16770][checkpoint] Avoid dispose
checkpoint during async finalization of pendingcheckpoint
URL: https://github.com/apache/flink/pull/11742#issuecomment-613789126
@ifndef-SleePy Already fix the broken tests by allowing pending checkpoint
could
[
https://issues.apache.org/jira/browse/FLINK-16100?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17083751#comment-17083751
]
Jark Wu commented on FLINK-16100:
-
Assign this issue to you [~Minda Mei].
> Translate "Reading &
[
https://issues.apache.org/jira/browse/FLINK-16113?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17083759#comment-17083759
]
Benchao Li commented on FLINK-16113:
[~jark] sure, I'd like to do it.
> ExpressionReducer shouldn't
Dian Fu created FLINK-17146:
---
Summary: Support conversion between PyFlink Table and Pandas
DataFrame
Key: FLINK-17146
URL: https://issues.apache.org/jira/browse/FLINK-17146
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-17137?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17083760#comment-17083760
]
Benchao Li commented on FLINK-17137:
OK, I'll attach a design documentation in a few days.
>
flinkbot edited a comment on issue #11545: [FLINK-16742][runtime][dist] Extend
and use BashJavaUtils to start JM JVM process and pass JVM memory args
URL: https://github.com/apache/flink/pull/11545#issuecomment-604848813
## CI report:
* 7e5cae7e3825eb84d974708caa195e39dd9d8bfd
flinkbot edited a comment on issue #11743: [FLINK-15827][runtime][coordination]
Deprecate unused taskmanager.registration.* options
URL: https://github.com/apache/flink/pull/11743#issuecomment-613752677
## CI report:
* 36914420a6e26355a6012170fa033a8f3b93dbe8 Travis:
[
https://issues.apache.org/jira/browse/FLINK-13811?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu updated FLINK-13811:
Parent: FLINK-17146
Issue Type: Sub-task (was: New Feature)
> Support converting flink table to
yuchuanchen opened a new pull request #11744: [Flink 17133][Table SQL/API]
Support CsvParser Features for CSV format via SQL DDL
URL: https://github.com/apache/flink/pull/11744
## What is the purpose of the change
Support [CsvParser
[
https://issues.apache.org/jira/browse/FLINK-17133?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-17133:
---
Labels: pull-request-available (was: )
> Support CsvParser Features for CSV format via SQL
yuchuanchen closed pull request #11744: [FLINK-17133][Table SQL/API] Support
CsvParser Features for CSV format via SQL DDL
URL: https://github.com/apache/flink/pull/11744
This is an automated message from the Apache Git
flinkbot edited a comment on issue #11717:
[FLINK-17093][python][table-planner][table-planner-blink] Fix Python UDF to
make it work with inputs from composite field
URL: https://github.com/apache/flink/pull/11717#issuecomment-612882448
## CI report:
*
flinkbot edited a comment on issue #11726: [FLINK-17128][table] Add isBounded
to TableSinkFactory#Context
URL: https://github.com/apache/flink/pull/11726#issuecomment-613258923
## CI report:
* 7618afd25170b1e5fcf12ebab4443558c13a8a50 Travis:
flinkbot edited a comment on issue #11745: [FLINK-17133] [Table SQL/API]
Support CsvParser Features for CSV form…
URL: https://github.com/apache/flink/pull/11745#issuecomment-613814332
## CI report:
* 4ce6d27ebc0bc4856c73ecb42724cc5650053b38 Travis:
flinkbot edited a comment on issue #11734: [FLINK-14713][rest]Show All Attempts
For Vertex SubTask In Rest Api
URL: https://github.com/apache/flink/pull/11734#issuecomment-613396242
## CI report:
* b619054eb53f92507c905b101598374a12be322c Travis:
flinkbot edited a comment on issue #11742: [FLINK-16770][checkpoint] Avoid
dispose checkpoint during async finalization of pendingcheckpoint
URL: https://github.com/apache/flink/pull/11742#issuecomment-613607174
## CI report:
* 3f205fca8d3d3385eb80dd7f2d9bfd9e3d6ccc37 Travis:
danny0405 commented on a change in pull request #11711:
[FLINK-17103][table-planner-blink] Supports dynamic options for Blink…
URL: https://github.com/apache/flink/pull/11711#discussion_r408587966
##
File path:
jinglining removed a comment on issue #11734: [FLINK-14713][rest]Show All
Attempts For Vertex SubTask In Rest Api
URL: https://github.com/apache/flink/pull/11734#issuecomment-613760275
@flinkbot run travis
This is an
wuchong commented on a change in pull request #11692:
[FLINK-16992][table-common] Add all ability interfaces for table sources and
sinks
URL: https://github.com/apache/flink/pull/11692#discussion_r408547579
##
File path:
[
https://issues.apache.org/jira/browse/FLINK-17140?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17083747#comment-17083747
]
Jark Wu commented on FLINK-17140:
-
Probably caused by FLINK-16770.
>
[
https://issues.apache.org/jira/browse/FLINK-17133?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17083757#comment-17083757
]
Jark Wu commented on FLINK-17133:
-
I think it's reasonable to support them if they are needed for Flink
Jark Wu created FLINK-17150:
---
Summary: Introduce Canal format to support reading canal changelogs
Key: FLINK-17150
URL: https://issues.apache.org/jira/browse/FLINK-17150
Project: Flink
Issue Type:
wangyang0918 commented on issue #11427: [FLINK-15790][k8s] Make FlinkKubeClient
and its implementations asynchronous
URL: https://github.com/apache/flink/pull/11427#issuecomment-613795334
@azagrebin Thanks for the additional comments. First, i agree with you after
these changes,
[
https://issues.apache.org/jira/browse/FLINK-13811?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jeff Zhang updated FLINK-13811:
---
Description: Pandas dataframe is the de facto standard tableau data format
of python community. It
wsry commented on a change in pull request #11351: [FLINK-16404][runtime] Avoid
caching buffers for blocked input channels before barrier alignment
URL: https://github.com/apache/flink/pull/11351#discussion_r408568257
##
File path:
flinkbot edited a comment on issue #11717:
[FLINK-17093][python][table-planner][table-planner-blink] Fix Python UDF to
make it work with inputs from composite field
URL: https://github.com/apache/flink/pull/11717#issuecomment-612882448
## CI report:
*
dianfu commented on issue #11717:
[FLINK-17093][python][table-planner][table-planner-blink] Fix Python UDF to
make it work with inputs from composite field
URL: https://github.com/apache/flink/pull/11717#issuecomment-613831240
The test failure of Azure is a known issue tracked in
[
https://issues.apache.org/jira/browse/FLINK-16572?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17083816#comment-17083816
]
Dian Fu commented on FLINK-16572:
-
Another instance:
flinkbot edited a comment on issue #11711: [FLINK-17103][table-planner-blink]
Supports dynamic options for Blink…
URL: https://github.com/apache/flink/pull/11711#issuecomment-612758431
## CI report:
* 3ea01f3d73194e787d483bc463ddaa5b58a3dd9f Travis:
ifndef-SleePy commented on issue #11742: [FLINK-16770][checkpoint] Avoid
dispose checkpoint during async finalization of pendingcheckpoint
URL: https://github.com/apache/flink/pull/11742#issuecomment-613778835
Hi @Myasuka , there are several unit testing cases failed. I think we should
[
https://issues.apache.org/jira/browse/FLINK-17006?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu updated FLINK-17006:
Description:
AggregateITCase.testDistinctGroupBy fails with FileNotFoundException (in
Rocksdb)
CI run:
[
https://issues.apache.org/jira/browse/FLINK-17006?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu updated FLINK-17006:
Summary: Various integration tests in table module fail with
FileNotFoundException (in Rocksdb) (was:
[
https://issues.apache.org/jira/browse/FLINK-15331?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu updated FLINK-15331:
Fix Version/s: 1.11.0
> Create a table from a changelog
> ---
>
>
Danny Chen created FLINK-17147:
--
Summary: Remove dynamic table options from table source table
digest
Key: FLINK-17147
URL: https://issues.apache.org/jira/browse/FLINK-17147
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-16748?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hequn Cheng closed FLINK-16748.
---
Resolution: Resolved
> Add Python UDTF doc
> ---
>
> Key:
flinkbot edited a comment on issue #11742: [FLINK-16770][checkpoint] Avoid
dispose checkpoint during async finalization of pendingcheckpoint
URL: https://github.com/apache/flink/pull/11742#issuecomment-613607174
## CI report:
* 91051213112fc562af8f7e51c3b10fb650f3ea3b Travis:
flinkbot edited a comment on issue #11717:
[FLINK-17093][python][table-planner][table-planner-blink] Fix Python UDF to
make it work with inputs from composite field
URL: https://github.com/apache/flink/pull/11717#issuecomment-612882448
## CI report:
*
flinkbot edited a comment on issue #11742: [FLINK-16770][checkpoint] Avoid
dispose checkpoint during async finalization of pendingcheckpoint
URL: https://github.com/apache/flink/pull/11742#issuecomment-613607174
## CI report:
* 91051213112fc562af8f7e51c3b10fb650f3ea3b Travis:
flinkbot edited a comment on issue #11734: [FLINK-14713][rest]Show All Attempts
For Vertex SubTask In Rest Api
URL: https://github.com/apache/flink/pull/11734#issuecomment-613396242
## CI report:
* b619054eb53f92507c905b101598374a12be322c Travis:
flinkbot edited a comment on issue #11743: [FLINK-15827][runtime][coordination]
Deprecate unused taskmanager.registration.* options
URL: https://github.com/apache/flink/pull/11743#issuecomment-613752677
## CI report:
* 36914420a6e26355a6012170fa033a8f3b93dbe8 Travis:
flinkbot commented on issue #11744: [FLINK-17133][Table SQL/API] Support
CsvParser Features for CSV format via SQL DDL
URL: https://github.com/apache/flink/pull/11744#issuecomment-613803547
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the
flinkbot edited a comment on issue #11351: [FLINK-16404][runtime] Avoid caching
buffers for blocked input channels before barrier alignment
URL: https://github.com/apache/flink/pull/11351#issuecomment-596351676
## CI report:
* 715889a35cfcc3aaf1b17f39dadaa86f755cc75d UNKNOWN
zhijiangW commented on a change in pull request #11687:
[FLINK-16536][network][checkpointing] Implement InputChannel state recovery for
unaligned checkpoint
URL: https://github.com/apache/flink/pull/11687#discussion_r408574292
##
File path:
flinkbot commented on issue #11745: [FLINK-17133] [Table SQL/API] Support
CsvParser Features for CSV form…
URL: https://github.com/apache/flink/pull/11745#issuecomment-613810067
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
to
flinkbot edited a comment on issue #11545: [FLINK-16742][runtime][dist] Extend
and use BashJavaUtils to start JM JVM process and pass JVM memory args
URL: https://github.com/apache/flink/pull/11545#issuecomment-604848813
## CI report:
* 7e5cae7e3825eb84d974708caa195e39dd9d8bfd
flinkbot commented on issue #11745: [FLINK-17133] [Table SQL/API] Support
CsvParser Features for CSV form…
URL: https://github.com/apache/flink/pull/11745#issuecomment-613814332
## CI report:
* 4ce6d27ebc0bc4856c73ecb42724cc5650053b38 UNKNOWN
Bot commands
The
flinkbot edited a comment on issue #11351: [FLINK-16404][runtime] Avoid caching
buffers for blocked input channels before barrier alignment
URL: https://github.com/apache/flink/pull/11351#issuecomment-596351676
## CI report:
* 715889a35cfcc3aaf1b17f39dadaa86f755cc75d UNKNOWN
[
https://issues.apache.org/jira/browse/FLINK-13553?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17082920#comment-17082920
]
Till Rohrmann commented on FLINK-13553:
---
[~gjy] do you think that this issue has been resolved
[
https://issues.apache.org/jira/browse/FLINK-10052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17082938#comment-17082938
]
huweihua commented on FLINK-10052:
--
hi [~Tison]
Is there any progress in the curator upgrade?
>
flinkbot edited a comment on issue #11726: [FLINK-17128][table] Add isBounded
to TableSinkFactory#Context
URL: https://github.com/apache/flink/pull/11726#issuecomment-613258923
## CI report:
* f63b3f6b25177bee8063fbcdf84224c15988a0eb Travis:
kl0u commented on issue #11671: [FLINK-17052] [client] Introduce PlanGenerator
URL: https://github.com/apache/flink/pull/11671#issuecomment-613278490
BTW both builds (Azure and Travis) seem to be failing. Have you checked them?
JingsongLi merged pull request #11511: [FLINK-16771][table-planner-blink] NPE
when filtering by decimal column
URL: https://github.com/apache/flink/pull/11511
This is an automated message from the Apache Git Service.
To
flinkbot edited a comment on issue #11725: [FLINK-15670][API] Provide a Kafka
Source/Sink pair as KafkaShuffle
URL: https://github.com/apache/flink/pull/11725#issuecomment-613252882
## CI report:
* e8a76909539302fd9935d912a07fb9ddb580c905 Travis:
flinkbot commented on issue #11728: [hotfix][typo] Fix a comment error in
StreamExecLocalGroupAggregate
URL: https://github.com/apache/flink/pull/11728#issuecomment-613281286
## CI report:
* 47b515e1131d960acf77f78ba3583a3db64a19ba UNKNOWN
Bot commands
The
flinkbot edited a comment on issue #11727: [FLINK-17106][table] Support create
and drop view in Flink SQL
URL: https://github.com/apache/flink/pull/11727#issuecomment-613273432
## CI report:
* fa5592cec0a6a5dcecc4f45c4bf72caf6e166eb4 UNKNOWN
*
flinkbot edited a comment on issue #11700: [FLINK-16366] [table] Introduce
executeSql method in TableEnvironment and support many statements
URL: https://github.com/apache/flink/pull/11700#issuecomment-612000686
## CI report:
* f52f4a10b99fa573ffeb63f16491d735cc157a4b UNKNOWN
flinkbot edited a comment on issue #11722: [FLINK-5763][state backends] Make
savepoints self-contained and relocatable
URL: https://github.com/apache/flink/pull/11722#issuecomment-613227820
## CI report:
* 0923302d1a1a9b672e3d6c24644bc22b476461a0 Travis:
flinkbot edited a comment on issue #11724: [FLINK-16486][python][docs] Add
documentation for vectorized Python UDF
URL: https://github.com/apache/flink/pull/11724#issuecomment-613241606
## CI report:
* 5acec4bb31966ec054331a629ce51b616b7a020b Travis:
flinkbot edited a comment on issue #11723: [FLINK-16762][python] Relocate Beam
dependency
URL: https://github.com/apache/flink/pull/11723#issuecomment-613231879
## CI report:
* f97fa4efd44756bff435f3b16f9dd1694f18a278 Travis:
kl0u commented on issue #11671: [FLINK-17052] [client] Introduce PlanGenerator
URL: https://github.com/apache/flink/pull/11671#issuecomment-613311020
Hehe I see.
This is an automated message from the Apache Git Service.
To
flinkbot edited a comment on issue #11719: [FLINK-17124][python] Fix The
PyFlink Job runs into infinite loop if the UDF file imports job code.
URL: https://github.com/apache/flink/pull/11719#issuecomment-612955433
## CI report:
* 3217fe626768708cf04bc7b3b0aa81b9c184d0f4 Travis:
flinkbot edited a comment on issue #11717:
[FLINK-17093][python][table-planner][table-planner-blink] Fix Python UDF to
make it work with inputs from composite field
URL: https://github.com/apache/flink/pull/11717#issuecomment-612882448
## CI report:
*
WeiZhong94 opened a new pull request #11729: [FLINK-17114][python] Set the
default value of 'python.executable' to the path of the python interpreter
which launches the job when the job is executed by LocalExecutor.
URL: https://github.com/apache/flink/pull/11729
## What is the purpose of
[
https://issues.apache.org/jira/browse/FLINK-16770?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17083018#comment-17083018
]
Biao Liu commented on FLINK-16770:
--
[~aljoscha], the uploading to transfer.sh failed, I can't confirm
WeiZhong94 commented on issue #11714: [FLINK-17114][python] Set the default
value of 'python.executable' to the path of the python interpreter which
launches the job when the job is executed by LocalExecutor.
URL: https://github.com/apache/flink/pull/11714#issuecomment-613243489
@dianfu
curcur opened a new pull request #11725: [FLINK-15670] Provide a Kafka
Source/Sink pair as KafkaShuffle
URL: https://github.com/apache/flink/pull/11725
## What is the purpose of the change
This pull request is to provide a Kafka Source/Sink pair to simulate a
KafkaShuffle
[
https://issues.apache.org/jira/browse/FLINK-15670?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-15670:
---
Labels: pull-request-available usability (was: usability)
> Provide a Kafka Source/Sink
[
https://issues.apache.org/jira/browse/FLINK-15670?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17082909#comment-17082909
]
Yuan Mei commented on FLINK-15670:
--
Pull Request is filed:
[
https://issues.apache.org/jira/browse/FLINK-15670?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17082909#comment-17082909
]
Yuan Mei edited comment on FLINK-15670 at 4/14/20, 6:40 AM:
Pull Request is
[
https://issues.apache.org/jira/browse/FLINK-17128?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-17128:
---
Labels: pull-request-available (was: )
> Add isBounded to TableSinkFactory#Context
>
JingsongLi opened a new pull request #11726: [FLINK-17128][table] Add isBounded
to TableSinkFactory#Context
URL: https://github.com/apache/flink/pull/11726
## What is the purpose of the change
For current table environment, the difference between batch and streaming is
very
kl0u commented on issue #11671: [FLINK-17052] [client] Introduce PlanGenerator
URL: https://github.com/apache/flink/pull/11671#issuecomment-613271010
Yes @godfreyhe , I will do it today.
This is an automated message from the
hequn8128 commented on a change in pull request #11717:
[FLINK-17093][python][table-planner][table-planner-blink] Fix Python UDF to
make it work with inputs from composite field
URL: https://github.com/apache/flink/pull/11717#discussion_r407923651
##
File path:
hequn8128 commented on a change in pull request #11717:
[FLINK-17093][python][table-planner][table-planner-blink] Fix Python UDF to
make it work with inputs from composite field
URL: https://github.com/apache/flink/pull/11717#discussion_r407927071
##
File path:
[
https://issues.apache.org/jira/browse/FLINK-17006?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17082983#comment-17082983
]
Yun Tang commented on FLINK-17006:
--
I think Robert is right, this should be related to FLINK-16770
godfreyhe commented on issue #11671: [FLINK-17052] [client] Introduce
PlanGenerator
URL: https://github.com/apache/flink/pull/11671#issuecomment-613305143
my private travis is passed
https://travis-ci.org/github/godfreyhe/flink/builds/673799271
flinkbot edited a comment on issue #11351: [FLINK-16404][runtime] Avoid caching
buffers for blocked input channels before barrier alignment
URL: https://github.com/apache/flink/pull/11351#issuecomment-596351676
## CI report:
* 715889a35cfcc3aaf1b17f39dadaa86f755cc75d UNKNOWN
flinkbot commented on issue #11726: [FLINK-17128][table] Add isBounded to
TableSinkFactory#Context
URL: https://github.com/apache/flink/pull/11726#issuecomment-613256260
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
to review
zoudan opened a new pull request #11728: [hotfix][typo] Fix a comment error in
StreamExecLocalGroupAggregate
URL: https://github.com/apache/flink/pull/11728
global group aggregate -> local group aggregate
This is an
101 - 200 of 670 matches
Mail list logo
