lsyldliu commented on a change in pull request #11482: [FLINK-16581][table]
Minibatch deduplication lack state TTL bug fix
URL: https://github.com/apache/flink/pull/11482#discussion_r399943133
##
File path:
lsyldliu commented on a change in pull request #11482: [FLINK-16581][table]
Minibatch deduplication lack state TTL bug fix
URL: https://github.com/apache/flink/pull/11482#discussion_r399940524
##
File path:
lsyldliu commented on a change in pull request #11482: [FLINK-16581][table]
Minibatch deduplication lack state TTL bug fix
URL: https://github.com/apache/flink/pull/11482#discussion_r399940472
##
File path:
lsyldliu commented on a change in pull request #11482: [FLINK-16581][table]
Minibatch deduplication lack state TTL bug fix
URL: https://github.com/apache/flink/pull/11482#discussion_r399940495
##
File path:
[
https://issues.apache.org/jira/browse/FLINK-14515?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee closed FLINK-14515.
Resolution: Duplicate
> Implement LimitableTableSource for FileSystemTableFactory
>
[
https://issues.apache.org/jira/browse/FLINK-14515?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17070702#comment-17070702
]
Jingsong Lee commented on FLINK-14515:
--
Will be included in FLINK-16859
> Implement
flinkbot commented on issue #11558: [FLINK-16070] [table-planner-blink] blink
stream planner supports remove constant keys from an aggregate
URL: https://github.com/apache/flink/pull/11558#issuecomment-605793624
## CI report:
* 67d546754c4817983c7ddad7f7253c5ec24e28e4 UNKNOWN
flinkbot edited a comment on issue #11555: [FLINK-16576][state backends]
Correct the logic of KeyGroupStateHandle#getIntersection
URL: https://github.com/apache/flink/pull/11555#issuecomment-605488014
## CI report:
* 90f2f05876e4eda952d512f5248dcd9bf0c6d913 Travis:
[
https://issues.apache.org/jira/browse/FLINK-14256?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee updated FLINK-14256:
-
Description:
Introduce FileSystemTableFactory to unify all file system connectors.
More
flinkbot edited a comment on issue #11543: [FLINK-16672][python] Support
Counter, Gauge, Meter, Distribution metric type for Python UDF
URL: https://github.com/apache/flink/pull/11543#issuecomment-604828903
## CI report:
* 7b8750cdb19d7ffe69e7aa8eacc320b7dee5 UNKNOWN
*
flinkbot edited a comment on issue #11353: [FLINK-16438][yarn] Make
YarnResourceManager starts workers using WorkerResourceSpec requested by
SlotManager
URL: https://github.com/apache/flink/pull/11353#issuecomment-596455079
## CI report:
*
[
https://issues.apache.org/jira/browse/FLINK-14255?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee updated FLINK-14255:
-
Description:
Based on StreamingFileSink.
Extends format support and partition commit support.
[
https://issues.apache.org/jira/browse/FLINK-14258?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee updated FLINK-14258:
-
Summary: Integrate hive to streaming sink (was: Integrate hive to
FileSystemTableFactory)
>
[
https://issues.apache.org/jira/browse/FLINK-14255?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee updated FLINK-14255:
-
Summary: Introduce StreamingSink for FileSystem connector (was: Introduce
[
https://issues.apache.org/jira/browse/FLINK-14266?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee updated FLINK-14266:
-
Summary: Introduce Row Csv InputFormat (was: Introduce RowCsvInputFormat
to new CSV module)
>
[
https://issues.apache.org/jira/browse/FLINK-14267?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee updated FLINK-14267:
-
Summary: Introduce Csv Encoder (was: Introduce csv Encoder)
> Introduce Csv Encoder
>
[
https://issues.apache.org/jira/browse/FLINK-14267?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee updated FLINK-14267:
-
Summary: Introduce Row Csv Encoder (was: Introduce Csv Encoder)
> Introduce Row Csv Encoder
>
[
https://issues.apache.org/jira/browse/FLINK-14267?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee updated FLINK-14267:
-
Summary: Introduce csv Encoder (was: Introduce RowCsvOutputFormat to new
CSV module)
>
JingsongLi closed pull request #10011: [FLINK-14267][table] Introduce
RowCsvOutputFormat to new CSV module
URL: https://github.com/apache/flink/pull/10011
This is an automated message from the Apache Git Service.
To respond
JingsongLi commented on issue #10011: [FLINK-14267][table] Introduce
RowCsvOutputFormat to new CSV module
URL: https://github.com/apache/flink/pull/10011#issuecomment-605792055
Close this, and use Encoder for csv in table.
Jingsong Lee created FLINK-16859:
Summary: Introduce FileSystemTableFactory, FileSystemTableSource,
FileSystemTableSink
Key: FLINK-16859
URL: https://issues.apache.org/jira/browse/FLINK-16859
[
https://issues.apache.org/jira/browse/FLINK-16774?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17070695#comment-17070695
]
Rui Li commented on FLINK-16774:
[~jark] Thanks for looping me in. I think [~jackylau]'s google doc has
Jingsong Lee created FLINK-16858:
Summary: Expose partitioned by grammar
Key: FLINK-16858
URL: https://issues.apache.org/jira/browse/FLINK-16858
Project: Flink
Issue Type: Sub-task
flinkbot commented on issue #11558: [FLINK-16070] [table-planner-blink] blink
stream planner supports remove constant keys from an aggregate
URL: https://github.com/apache/flink/pull/11558#issuecomment-605791081
Thanks a lot for your contribution to the Apache Flink project. I'm the
Jingsong Lee created FLINK-16857:
Summary: Support partition prune for PartitionableTableSource with
getPartitions
Key: FLINK-16857
URL: https://issues.apache.org/jira/browse/FLINK-16857
Project:
godfreyhe opened a new pull request #11558: [FLINK-16070] [table-planner-blink]
blink stream planner supports remove constant keys from an aggregate
URL: https://github.com/apache/flink/pull/11558
## What is the purpose of the change
*currently
[
https://issues.apache.org/jira/browse/FLINK-16856?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yang Wang updated FLINK-16856:
--
Fix Version/s: 1.11.0
> taskmanager.sh is broken because of invalid arguments of head
>
[
https://issues.apache.org/jira/browse/FLINK-16856?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yang Wang updated FLINK-16856:
--
Priority: Critical (was: Major)
> taskmanager.sh is broken because of invalid arguments of head
>
flinkbot edited a comment on issue #11353: [FLINK-16438][yarn] Make
YarnResourceManager starts workers using WorkerResourceSpec requested by
SlotManager
URL: https://github.com/apache/flink/pull/11353#issuecomment-596455079
## CI report:
*
Yang Wang created FLINK-16856:
-
Summary: taskmanager.sh is broken because of invalid arguments of
head
Key: FLINK-16856
URL: https://issues.apache.org/jira/browse/FLINK-16856
Project: Flink
flinkbot edited a comment on issue #11466: [FLINK-15400][connectors /
elasticsearch] elasticsearch table sink support dynamic index.
URL: https://github.com/apache/flink/pull/11466#issuecomment-601789375
## CI report:
* 4c252220928052025f30b4dc4c63c0479d7c20cd UNKNOWN
*
JingsongLi commented on issue #11158: [FLINK-16070] [table-planner-blink] blink
stream planner supports remove constant keys from an aggregate
URL: https://github.com/apache/flink/pull/11158#issuecomment-605788193
Merged, thanks for the contribution.
JingsongLi merged pull request #11158: [FLINK-16070] [table-planner-blink]
blink stream planner supports remove constant keys from an aggregate
URL: https://github.com/apache/flink/pull/11158
This is an automated message
godfreyhe commented on issue #11158: [FLINK-16070] [table-planner-blink] blink
stream planner supports remove constant keys from an aggregate
URL: https://github.com/apache/flink/pull/11158#issuecomment-605787304
> +1, should we add this rule to batch too?
Batch has already
JingsongLi commented on issue #11158: [FLINK-16070] [table-planner-blink] blink
stream planner supports remove constant keys from an aggregate
URL: https://github.com/apache/flink/pull/11158#issuecomment-605786557
Can you create a PR for release-1.10?
flinkbot edited a comment on issue #11543: [FLINK-16672][python] Support
Counter, Gauge, Meter, Distribution metric type for Python UDF
URL: https://github.com/apache/flink/pull/11543#issuecomment-604828903
## CI report:
* 7b8750cdb19d7ffe69e7aa8eacc320b7dee5 UNKNOWN
*
[
https://issues.apache.org/jira/browse/FLINK-16855?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Canbin Zheng updated FLINK-16855:
-
Description: Following FLINK-16602 and discussion in
Canbin Zheng created FLINK-16855:
Summary: Update K8s template for the standalone setup
Key: FLINK-16855
URL: https://issues.apache.org/jira/browse/FLINK-16855
Project: Flink
Issue Type:
wangyang0918 commented on issue #11456: [FLINK-16602][k8s] Rework the
internal/external Service
URL: https://github.com/apache/flink/pull/11456#issuecomment-605782134
Moreover, i have tested this PR in a real K8s cluster with/without HA
enabled. It works as expected. Great job.
flinkbot edited a comment on issue #11555: [FLINK-16576][state backends]
Correct the logic of KeyGroupStateHandle#getIntersection
URL: https://github.com/apache/flink/pull/11555#issuecomment-605488014
## CI report:
* 2ad0f77b544fffeb159f8f3c4935f8a8ed22ae4a Travis:
flinkbot edited a comment on issue #11363: [FLINK-16440][runtime] Extend
SlotManager metrics and status for dynamic slot allocation.
URL: https://github.com/apache/flink/pull/11363#issuecomment-596992287
## CI report:
* 2e22d057bb4f6ef9002a7e7e2713c7e37b735e69 Travis:
wangyang0918 commented on a change in pull request #11456: [FLINK-16602][k8s]
Rework the internal/external Service
URL: https://github.com/apache/flink/pull/11456#discussion_r399913762
##
File path:
flinkbot edited a comment on issue #11543: [FLINK-16672][python] Support
Counter, Gauge, Meter, Distribution metric type for Python UDF
URL: https://github.com/apache/flink/pull/11543#issuecomment-604828903
## CI report:
* 7b8750cdb19d7ffe69e7aa8eacc320b7dee5 UNKNOWN
*
flinkbot edited a comment on issue #11555: [FLINK-16576][state backends]
Correct the logic of KeyGroupStateHandle#getIntersection
URL: https://github.com/apache/flink/pull/11555#issuecomment-605488014
## CI report:
* 2ad0f77b544fffeb159f8f3c4935f8a8ed22ae4a Travis:
flinkbot edited a comment on issue #11353: [FLINK-16438][yarn] Make
YarnResourceManager starts workers using WorkerResourceSpec requested by
SlotManager
URL: https://github.com/apache/flink/pull/11353#issuecomment-596455079
## CI report:
*
flinkbot edited a comment on issue #11466: [FLINK-15400][connectors /
elasticsearch] elasticsearch table sink support dynamic index.
URL: https://github.com/apache/flink/pull/11466#issuecomment-601789375
## CI report:
* 4c252220928052025f30b4dc4c63c0479d7c20cd UNKNOWN
*
flinkbot edited a comment on issue #11425: [FLINK-16125][kafka] Remove
unnecessary zookeeper.connect property validation
URL: https://github.com/apache/flink/pull/11425#issuecomment-599933380
## CI report:
* b9f13d82a925af91d07dddf74f9a17cac987681e Travis:
DeliangFan commented on issue #11488: [FLINK-16717][k8s] Use headless service
for rpc and blob port
URL: https://github.com/apache/flink/pull/11488#issuecomment-605775517
@StephanEwen @wangyang0918 would you please take a review, thx!
klion26 commented on issue #11555: [FLINK-16576][state backends] Correct the
logic of KeyGroupStateHandle#getIntersection
URL: https://github.com/apache/flink/pull/11555#issuecomment-605773423
@carp84 thanks for the review, have added the IT case, Please have another
look when you're
flinkbot edited a comment on issue #11543: [FLINK-16672][python] Support
Counter, Gauge, Meter, Distribution metric type for Python UDF
URL: https://github.com/apache/flink/pull/11543#issuecomment-604828903
## CI report:
* 7b8750cdb19d7ffe69e7aa8eacc320b7dee5 UNKNOWN
*
flinkbot edited a comment on issue #11353: [FLINK-16438][yarn] Make
YarnResourceManager starts workers using WorkerResourceSpec requested by
SlotManager
URL: https://github.com/apache/flink/pull/11353#issuecomment-596455079
## CI report:
*
flinkbot edited a comment on issue #11363: [FLINK-16440][runtime] Extend
SlotManager metrics and status for dynamic slot allocation.
URL: https://github.com/apache/flink/pull/11363#issuecomment-596992287
## CI report:
* 2e22d057bb4f6ef9002a7e7e2713c7e37b735e69 Travis:
[
https://issues.apache.org/jira/browse/FLINK-16854?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai closed FLINK-16854.
---
Resolution: Fixed
Fixed.
master: 6a14369c205c45f97fbb61ae926052cc24a2e1f4
[
https://issues.apache.org/jira/browse/FLINK-16853?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai closed FLINK-16853.
---
Resolution: Fixed
Fixed.
master: b103bdc02b00a875f06d21399dcbb2808b62757c
[
https://issues.apache.org/jira/browse/FLINK-16018?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17070667#comment-17070667
]
Yu Li commented on FLINK-16018:
---
Hi folks, any update on this one? Asking since it's marked as a blocker
[
https://issues.apache.org/jira/browse/FLINK-16774?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17070664#comment-17070664
]
jackylau commented on FLINK-16774:
--
Hi [~jark], thanks for your reply. And i find the google doc miss
[
https://issues.apache.org/jira/browse/FLINK-16710?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17070661#comment-17070661
]
wangsan commented on FLINK-16710:
-
Hi [~gjy], I can help with this issue if no one is working on this.
[
https://issues.apache.org/jira/browse/FLINK-16379?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17070659#comment-17070659
]
Zhenghua Gao commented on FLINK-16379:
--
[~dwysakowicz] You could merge your branch first(better to
flinkbot edited a comment on issue #11466: [FLINK-15400][connectors /
elasticsearch] elasticsearch table sink support dynamic index.
URL: https://github.com/apache/flink/pull/11466#issuecomment-601789375
## CI report:
* 4c252220928052025f30b4dc4c63c0479d7c20cd UNKNOWN
*
flinkbot edited a comment on issue #11353: [FLINK-16438][yarn] Make
YarnResourceManager starts workers using WorkerResourceSpec requested by
SlotManager
URL: https://github.com/apache/flink/pull/11353#issuecomment-596455079
## CI report:
*
flinkbot edited a comment on issue #11363: [FLINK-16440][runtime] Extend
SlotManager metrics and status for dynamic slot allocation.
URL: https://github.com/apache/flink/pull/11363#issuecomment-596992287
## CI report:
* adffa3044deda0014a9e7e60c3715e8b22e7f17c Travis:
flinkbot edited a comment on issue #11425: [FLINK-16125][kafka] Remove
unnecessary zookeeper.connect property validation
URL: https://github.com/apache/flink/pull/11425#issuecomment-599933380
## CI report:
* b9f13d82a925af91d07dddf74f9a17cac987681e Travis:
flinkbot edited a comment on issue #11466: [FLINK-15400][connectors /
elasticsearch] elasticsearch table sink support dynamic index.
URL: https://github.com/apache/flink/pull/11466#issuecomment-601789375
## CI report:
* 4c252220928052025f30b4dc4c63c0479d7c20cd UNKNOWN
*
flinkbot edited a comment on issue #11425: [FLINK-16125][kafka] Remove
unnecessary zookeeper.connect property validation
URL: https://github.com/apache/flink/pull/11425#issuecomment-599933380
## CI report:
* b9f13d82a925af91d07dddf74f9a17cac987681e Travis:
flinkbot edited a comment on issue #11353: [FLINK-16438][yarn] Make
YarnResourceManager starts workers using WorkerResourceSpec requested by
SlotManager
URL: https://github.com/apache/flink/pull/11353#issuecomment-596455079
## CI report:
*
flinkbot edited a comment on issue #11363: [FLINK-16440][runtime] Extend
SlotManager metrics and status for dynamic slot allocation.
URL: https://github.com/apache/flink/pull/11363#issuecomment-596992287
## CI report:
* adffa3044deda0014a9e7e60c3715e8b22e7f17c Travis:
wuchong commented on a change in pull request #11482: [FLINK-16581][table]
Minibatch deduplication lack state TTL bug fix
URL: https://github.com/apache/flink/pull/11482#discussion_r399898724
##
File path:
wuchong commented on a change in pull request #11482: [FLINK-16581][table]
Minibatch deduplication lack state TTL bug fix
URL: https://github.com/apache/flink/pull/11482#discussion_r399899324
##
File path:
wuchong commented on a change in pull request #11482: [FLINK-16581][table]
Minibatch deduplication lack state TTL bug fix
URL: https://github.com/apache/flink/pull/11482#discussion_r399898344
##
File path:
wuchong commented on a change in pull request #11482: [FLINK-16581][table]
Minibatch deduplication lack state TTL bug fix
URL: https://github.com/apache/flink/pull/11482#discussion_r399897112
##
File path:
wuchong commented on a change in pull request #11482: [FLINK-16581][table]
Minibatch deduplication lack state TTL bug fix
URL: https://github.com/apache/flink/pull/11482#discussion_r399901428
##
File path:
tzulitai closed pull request #80: [FLINK-16853][legal] Update the version of
protobuf-java from 3.8.0 to 3.7.1 in the NOTICE file of module
statefun-flink-distribution
URL: https://github.com/apache/flink-statefun/pull/80
tzulitai closed pull request #81: [FLINK-16854][legal] Correct dependency
versions in the NOTICE file of module statefun-ridesharing-example-simulator
URL: https://github.com/apache/flink-statefun/pull/81
This is an
tzulitai commented on issue #80: [FLINK-16853][legal] Update the version of
protobuf-java from 3.8.0 to 3.7.1 in the NOTICE file of module
statefun-flink-distribution
URL: https://github.com/apache/flink-statefun/pull/80#issuecomment-605754189
Thanks again @hequn8128.
LGTM, merging ...
tzulitai commented on issue #81: [FLINK-16854][legal] Correct dependency
versions in the NOTICE file of module statefun-ridesharing-example-simulator
URL: https://github.com/apache/flink-statefun/pull/81#issuecomment-605753707
Thank you @hequn8128! LGTM, merging.
PatrickRen commented on issue #11425: [FLINK-16125][kafka] Remove unnecessary
zookeeper.connect property validation
URL: https://github.com/apache/flink/pull/11425#issuecomment-605750314
@flinkbot run travis
@flinkbot run azure
[
https://issues.apache.org/jira/browse/FLINK-16854?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hequn Cheng reassigned FLINK-16854:
---
Assignee: Hequn Cheng
> Correct dependency versions in the NOTICE file of module
>
[
https://issues.apache.org/jira/browse/FLINK-16774?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17070637#comment-17070637
]
Jark Wu commented on FLINK-16774:
-
Thanks [~jackylau] for the doc. I think it's a reasonable feature to
[
https://issues.apache.org/jira/browse/FLINK-16787?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17070636#comment-17070636
]
Jingsong Lee commented on FLINK-16787:
--
Thanks [~zjwang] for your reply, I just create this Jira
hequn8128 opened a new pull request #81: [FLINK-16854][legal] Correct
dependency versions in the NOTICE file of module
statefun-ridesharing-example-simulator
URL: https://github.com/apache/flink-statefun/pull/81
There are some dependencies with a wrong version in the NOTICE file:
```
hequn8128 commented on issue #81: [FLINK-16854][legal] Correct dependency
versions in the NOTICE file of module statefun-ridesharing-example-simulator
URL: https://github.com/apache/flink-statefun/pull/81#issuecomment-605743735
CC @tzulitai
[
https://issues.apache.org/jira/browse/FLINK-16854?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-16854:
---
Labels: pull-request-available (was: )
> Correct dependency versions in the NOTICE file of
[
https://issues.apache.org/jira/browse/FLINK-16853?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-16853:
---
Labels: pull-request-available (was: )
> Update the version of protobuf-java from 3.8.0 to
hequn8128 commented on issue #80: [FLINK-16853][legal] Update the version of
protobuf-java from 3.8.0 to 3.7.1 in the NOTICE file of module
statefun-flink-distribution
URL: https://github.com/apache/flink-statefun/pull/80#issuecomment-605742710
CC @tzulitai
hequn8128 opened a new pull request #80: [FLINK-16853][legal] Update the
version of protobuf-java from 3.8.0 to 3.7.1 in the NOTICE file of module
statefun-flink-distribution
URL: https://github.com/apache/flink-statefun/pull/80
In the NOTICE file, the version of protobuf-java should be
[
https://issues.apache.org/jira/browse/FLINK-16854?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hequn Cheng updated FLINK-16854:
Priority: Blocker (was: Major)
> Correct dependency versions in the NOTICE file of module
>
[
https://issues.apache.org/jira/browse/FLINK-16853?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hequn Cheng reassigned FLINK-16853:
---
Assignee: Hequn Cheng
> Update the version of protobuf-java from 3.8.0 to 3.7.1 in the
dianfu commented on issue #11543: [FLINK-16672][python] Support Counter, Gauge,
Meter, Distribution metric type for Python UDF
URL: https://github.com/apache/flink/pull/11543#issuecomment-605741339
@hequn8128 Thanks for the update. There are some test failures. Could you
take a look?
Hequn Cheng created FLINK-16854:
---
Summary: Correct dependency versions in the NOTICE file of module
statefun-ridesharing-example-simulator
Key: FLINK-16854
URL: https://issues.apache.org/jira/browse/FLINK-16854
[
https://issues.apache.org/jira/browse/FLINK-16840?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17070632#comment-17070632
]
Jark Wu commented on FLINK-16840:
-
cc [~phoenixjiangnan]
> PostgresCatalogTest fails waiting for server
Hequn Cheng created FLINK-16853:
---
Summary: Update the version of protobuf-java from 3.8.0 to 3.7.1
in the NOTICE file of module statefun-flink-distribution
Key: FLINK-16853
URL:
[
https://issues.apache.org/jira/browse/FLINK-16774?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17070630#comment-17070630
]
jackylau commented on FLINK-16774:
--
hi [~jark] i have edited the sharing setting of google docs, which
Jiangjie Qin created FLINK-16852:
Summary: Add metrics to the source coordinator.
Key: FLINK-16852
URL: https://issues.apache.org/jira/browse/FLINK-16852
Project: Flink
Issue Type: Sub-task
Jiangjie Qin created FLINK-16851:
Summary: Add common metrics to the SourceReader base
implementation.
Key: FLINK-16851
URL: https://issues.apache.org/jira/browse/FLINK-16851
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-14881?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17070534#comment-17070534
]
Rafi Aroch commented on FLINK-14881:
I looked into the testing aspect:
Kinesis - Kinesalite doesn't
[
https://issues.apache.org/jira/browse/FLINK-16850?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17070435#comment-17070435
]
Yun Tang commented on FLINK-16850:
--
What do you think of this? [~pnowojski], [~liyu]
> Make
Yun Tang created FLINK-16850:
Summary: Make flink-benchmark align with different releases of
Flink
Key: FLINK-16850
URL: https://issues.apache.org/jira/browse/FLINK-16850
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-16444?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Tang reassigned FLINK-16444:
Assignee: Yun Tang
> Count the read/write/seek/next latency of RocksDB as metrics
>
flinkbot edited a comment on issue #11554: [FLINK-15101][connector/common] Add
SourceCoordinator implementation.
URL: https://github.com/apache/flink/pull/11554#issuecomment-605459909
## CI report:
* bd27b1b4dd97173d85bb0867f7c377ac4c638af5 Travis:
sjwiesman commented on issue #79: [FLINK-16730][docs] Add walkthrough
distribution as build step
URL: https://github.com/apache/flink-statefun/pull/79#issuecomment-605653039
Sounds good, thanks
This is an automated message
1 - 100 of 156 matches
Mail list logo
