Github user fhueske commented on the issue:
https://github.com/apache/flink/pull/3370
Thanks @haohui! The only thing missing would in fact be a test. IMO,
extending `WindowAggregateTest` by copying the methods and adapting them to
`proctime` would be sufficient.
Let's see
[
https://issues.apache.org/jira/browse/FLINK-5710?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15875654#comment-15875654
]
ASF GitHub Bot commented on FLINK-5710:
---
Github user fhueske commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-4856?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15875673#comment-15875673
]
ASF GitHub Bot commented on FLINK-4856:
---
Github user StefanRRichter commented on a diff in the pull
Github user StefanRRichter commented on a diff in the pull request:
https://github.com/apache/flink/pull/3336#discussion_r102164095
--- Diff:
flink-contrib/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBMapState.java
---
@@ -0,0 +1,579 @@
[
https://issues.apache.org/jira/browse/FLINK-5803?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15875706#comment-15875706
]
Fabian Hueske commented on FLINK-5803:
--
Hi [~sunjincheng121], I hope that we can resolve FLINK-5710
Github user shixiaogang commented on the issue:
https://github.com/apache/flink/pull/3336
I have added the documentation for `MapState`. You may take a look to see
if it's properly written.
---
If your project is set up for it, you can reply to this email and have your
reply appear
[
https://issues.apache.org/jira/browse/FLINK-4856?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15875713#comment-15875713
]
ASF GitHub Bot commented on FLINK-4856:
---
Github user shixiaogang commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-5511?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
lincoln.lee resolved FLINK-5511.
Resolution: Duplicate
We can simply divide join conditions into the equi part and the non-equi
[
https://issues.apache.org/jira/browse/FLINK-5487?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15875782#comment-15875782
]
ASF GitHub Bot commented on FLINK-5487:
---
Github user rmetzger commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-5487?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15875788#comment-15875788
]
ASF GitHub Bot commented on FLINK-5487:
---
Github user rmetzger commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-5487?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15875783#comment-15875783
]
ASF GitHub Bot commented on FLINK-5487:
---
Github user rmetzger commented on a diff in the pull
Github user rmetzger commented on a diff in the pull request:
https://github.com/apache/flink/pull/3358#discussion_r102178621
--- Diff:
flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/ElasticsearchSinkBase.java
---
Github user rmetzger commented on a diff in the pull request:
https://github.com/apache/flink/pull/3358#discussion_r102178460
--- Diff:
flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/ElasticsearchSinkBase.java
---
[
https://issues.apache.org/jira/browse/FLINK-5487?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15875786#comment-15875786
]
ASF GitHub Bot commented on FLINK-5487:
---
Github user rmetzger commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-5487?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15875785#comment-15875785
]
ASF GitHub Bot commented on FLINK-5487:
---
Github user rmetzger commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-5487?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15875780#comment-15875780
]
ASF GitHub Bot commented on FLINK-5487:
---
Github user rmetzger commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-5487?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15875787#comment-15875787
]
ASF GitHub Bot commented on FLINK-5487:
---
Github user rmetzger commented on a diff in the pull
Github user rmetzger commented on a diff in the pull request:
https://github.com/apache/flink/pull/3358#discussion_r102177099
--- Diff: docs/dev/connectors/elasticsearch.md ---
@@ -272,9 +308,115 @@ input.addSink(new ElasticsearchSink(config, new
ElasticsearchSinkFunction[String
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/3358#discussion_r102183423
--- Diff: docs/dev/connectors/elasticsearch.md ---
@@ -272,9 +308,115 @@ input.addSink(new ElasticsearchSink(config, new
ElasticsearchSinkFunction[String
[
https://issues.apache.org/jira/browse/FLINK-5487?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15875797#comment-15875797
]
ASF GitHub Bot commented on FLINK-5487:
---
Github user tzulitai commented on a diff in the pull
Github user StefanRRichter commented on a diff in the pull request:
https://github.com/apache/flink/pull/3336#discussion_r102188520
--- Diff:
flink-contrib/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBMapState.java
---
@@ -0,0 +1,579 @@
[
https://issues.apache.org/jira/browse/FLINK-4856?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15875844#comment-15875844
]
ASF GitHub Bot commented on FLINK-4856:
---
Github user StefanRRichter commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-4856?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15875843#comment-15875843
]
ASF GitHub Bot commented on FLINK-4856:
---
Github user StefanRRichter commented on a diff in the pull
Github user StefanRRichter commented on a diff in the pull request:
https://github.com/apache/flink/pull/3336#discussion_r102187482
--- Diff:
flink-contrib/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBMapState.java
---
@@ -382,11
Github user fhueske commented on the issue:
https://github.com/apache/flink/pull/3302
Hi @huawei-flink, do you plan to follow up on this PR?
Otherwise, I'd merge #3370 after adding a test.
Thanks, Fabian
---
If your project is set up for it, you can reply to this email
[
https://issues.apache.org/jira/browse/FLINK-5710?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15875651#comment-15875651
]
ASF GitHub Bot commented on FLINK-5710:
---
Github user fhueske commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-5859?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15875689#comment-15875689
]
Fabian Hueske commented on FLINK-5859:
--
Partition pruning is a kind of coarse-grained filter
Github user rmetzger commented on the issue:
https://github.com/apache/flink/pull/3369
Cool, very nice!
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or
[
https://issues.apache.org/jira/browse/FLINK-5795?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15875774#comment-15875774
]
ASF GitHub Bot commented on FLINK-5795:
---
Github user wuchong commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-5487?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15875810#comment-15875810
]
ASF GitHub Bot commented on FLINK-5487:
---
Github user tzulitai commented on a diff in the pull
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/3358#discussion_r102184622
--- Diff:
flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/ElasticsearchSinkBase.java
---
[
https://issues.apache.org/jira/browse/FLINK-5607?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dawid Wysakowicz reassigned FLINK-5607:
---
Assignee: (was: Dawid Wysakowicz)
> Move location lookup retry out of
[
https://issues.apache.org/jira/browse/FLINK-5864?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kostas Kloudas reassigned FLINK-5864:
-
Assignee: Dawid Wysakowicz
> CEP: fix duplicate output patterns problem.
>
Kostas Kloudas created FLINK-5864:
-
Summary: CEP: fix duplicate output patterns problem.
Key: FLINK-5864
URL: https://issues.apache.org/jira/browse/FLINK-5864
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-4856?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15875657#comment-15875657
]
ASF GitHub Bot commented on FLINK-4856:
---
Github user StefanRRichter commented on a diff in the pull
Github user StefanRRichter commented on a diff in the pull request:
https://github.com/apache/flink/pull/3336#discussion_r102162187
--- Diff:
flink-contrib/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBMapState.java
---
@@ -0,0 +1,579 @@
Github user uce commented on the issue:
https://github.com/apache/flink/pull/3344
I think that 10 minutes are actually quite an improvement. Currently, the
PR builds usually time out and we only see red crosses next to the PR
(including this one ;)). I would certainly try this setup.
[
https://issues.apache.org/jira/browse/FLINK-5731?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15875698#comment-15875698
]
ASF GitHub Bot commented on FLINK-5731:
---
Github user uce commented on the issue:
Github user aljoscha commented on a diff in the pull request:
https://github.com/apache/flink/pull/3336#discussion_r102173582
--- Diff:
flink-contrib/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBMapState.java
---
@@ -0,0 +1,579 @@
shuai.xu created FLINK-5868:
---
Summary: Implement a new RestartStrategy that works for the
FailoverRegion.
Key: FLINK-5868
URL: https://issues.apache.org/jira/browse/FLINK-5868
Project: Flink
Github user fhueske commented on the issue:
https://github.com/apache/flink/pull/3330
@wuchong just sent you mail with the steps I take to merge a PR. :-)
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project
[
https://issues.apache.org/jira/browse/FLINK-5795?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15875808#comment-15875808
]
ASF GitHub Bot commented on FLINK-5795:
---
Github user fhueske commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-5487?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15875819#comment-15875819
]
ASF GitHub Bot commented on FLINK-5487:
---
Github user tzulitai commented on a diff in the pull
Github user wuchong commented on the issue:
https://github.com/apache/flink/pull/3330
Thank your for the steps.
merging...
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this
[
https://issues.apache.org/jira/browse/FLINK-5795?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15875821#comment-15875821
]
ASF GitHub Bot commented on FLINK-5795:
---
Github user wuchong commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-4803?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15875892#comment-15875892
]
Stephan Ewen commented on FLINK-4803:
-
This has actually been fixed with the introduction of the
[
https://issues.apache.org/jira/browse/FLINK-5794?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sunjincheng updated FLINK-5794:
---
Summary: update the documentation about “UDF/UDTF" support have
parameters constructor. (was:
Github user sunjincheng121 commented on the issue:
https://github.com/apache/flink/pull/3330
HI @twalthr, Thanks for the reminder, I'll update document in FLINK-5794.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If
[
https://issues.apache.org/jira/browse/FLINK-5827?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
kaibo.zhou reassigned FLINK-5827:
-
Assignee: kaibo.zhou
> Exception when do filter after join a udtf which returns a POJO type
>
[
https://issues.apache.org/jira/browse/FLINK-5824?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15875649#comment-15875649
]
Dawid Wysakowicz commented on FLINK-5824:
-
Just two more questions.
First I tried to investigate
Github user StefanRRichter commented on a diff in the pull request:
https://github.com/apache/flink/pull/3336#discussion_r102163881
--- Diff:
flink-contrib/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBMapState.java
---
@@ -0,0 +1,579 @@
[
https://issues.apache.org/jira/browse/FLINK-4856?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15875671#comment-15875671
]
ASF GitHub Bot commented on FLINK-4856:
---
Github user StefanRRichter commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-5830?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15875727#comment-15875727
]
ASF GitHub Bot commented on FLINK-5830:
---
Github user tillrohrmann commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-5808?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15875748#comment-15875748
]
Tao Meng commented on FLINK-5808:
-
Maybe it depends on which is the first value to be set that one value
[
https://issues.apache.org/jira/browse/FLINK-4256?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
shuai.xu updated FLINK-4256:
Description:
When a task fails during execution, Flink currently resets the entire execution
graph and
Github user wuchong commented on the issue:
https://github.com/apache/flink/pull/3330
Yes @fhueske , I would like to help merge it. Is there anything I need to
pay attention to ?
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub
GitHub user tony810430 opened a pull request:
https://github.com/apache/flink/pull/3374
[FLINK-4754] [checkpoints] Make number of retained checkpoints user
configurable
I add `CheckpointConfig.setMaxNumberOfCheckpointsToRetain` to expose user
the configuration for number of
[
https://issues.apache.org/jira/browse/FLINK-4754?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15875626#comment-15875626
]
ASF GitHub Bot commented on FLINK-4754:
---
GitHub user tony810430 opened a pull request:
Github user StefanRRichter commented on a diff in the pull request:
https://github.com/apache/flink/pull/3336#discussion_r102163224
--- Diff:
flink-contrib/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBMapState.java
---
@@ -0,0 +1,579 @@
[
https://issues.apache.org/jira/browse/FLINK-4856?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15875663#comment-15875663
]
ASF GitHub Bot commented on FLINK-4856:
---
Github user StefanRRichter commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-4856?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15875661#comment-15875661
]
ASF GitHub Bot commented on FLINK-4856:
---
Github user StefanRRichter commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-4856?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15875675#comment-15875675
]
ASF GitHub Bot commented on FLINK-4856:
---
Github user StefanRRichter commented on the issue:
Github user aljoscha commented on a diff in the pull request:
https://github.com/apache/flink/pull/3336#discussion_r102173749
--- Diff:
flink-contrib/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBKeyedStateBackend.java
---
@@ -834,7
[
https://issues.apache.org/jira/browse/FLINK-4856?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15875741#comment-15875741
]
ASF GitHub Bot commented on FLINK-4856:
---
Github user aljoscha commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-4856?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15875742#comment-15875742
]
ASF GitHub Bot commented on FLINK-4856:
---
Github user aljoscha commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-5864?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dawid Wysakowicz updated FLINK-5864:
Description:
Currently when searching for a pattern {{a,b,c}} and we have input elements
[
https://issues.apache.org/jira/browse/FLINK-5487?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15875825#comment-15875825
]
ASF GitHub Bot commented on FLINK-5487:
---
Github user tzulitai commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-5510?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dawid Wysakowicz reassigned FLINK-5510:
---
Assignee: (was: Dawid Wysakowicz)
> Replace Scala Future with FlinkFuture in
Github user StefanRRichter commented on a diff in the pull request:
https://github.com/apache/flink/pull/3336#discussion_r102162632
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/state/DefaultKeyedStateStore.java
---
@@ -93,6 +95,18 @@ public
Github user StefanRRichter commented on a diff in the pull request:
https://github.com/apache/flink/pull/3336#discussion_r102162964
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/query/netty/message/KvStateRequestSerializerTest.java
---
@@ -410,6 +415,124 @@
Github user nellboy commented on the issue:
https://github.com/apache/flink/pull/3369
Ok, this has been updated now.
---
If your project
[
https://issues.apache.org/jira/browse/FLINK-5831?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15875750#comment-15875750
]
ASF GitHub Bot commented on FLINK-5831:
---
Github user rmetzger commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-5487?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15875804#comment-15875804
]
ASF GitHub Bot commented on FLINK-5487:
---
Github user tzulitai commented on a diff in the pull
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/3358#discussion_r102183643
--- Diff: docs/dev/connectors/elasticsearch.md ---
@@ -272,9 +308,115 @@ input.addSink(new ElasticsearchSink(config, new
ElasticsearchSinkFunction[String
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/2903
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/3358#discussion_r102183754
--- Diff:
flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/ElasticsearchSinkBase.java
---
[
https://issues.apache.org/jira/browse/FLINK-5487?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15875802#comment-15875802
]
ASF GitHub Bot commented on FLINK-5487:
---
Github user tzulitai commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-5074?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15875800#comment-15875800
]
ASF GitHub Bot commented on FLINK-5074:
---
Github user asfgit closed the pull request at:
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/2770
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is
[
https://issues.apache.org/jira/browse/FLINK-4354?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15875801#comment-15875801
]
ASF GitHub Bot commented on FLINK-4354:
---
Github user asfgit closed the pull request at:
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/3358#discussion_r102186137
--- Diff: docs/dev/connectors/elasticsearch.md ---
@@ -272,9 +308,115 @@ input.addSink(new ElasticsearchSink(config, new
ElasticsearchSinkFunction[String
Chesnay Schepler created FLINK-5870:
---
Summary: Make handlers aware of their REST URLs
Key: FLINK-5870
URL: https://issues.apache.org/jira/browse/FLINK-5870
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-5795?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15875894#comment-15875894
]
ASF GitHub Bot commented on FLINK-5795:
---
Github user sunjincheng121 commented on the issue:
Github user rmetzger commented on a diff in the pull request:
https://github.com/apache/flink/pull/3358#discussion_r102177012
--- Diff: docs/dev/connectors/elasticsearch.md ---
@@ -272,9 +308,115 @@ input.addSink(new ElasticsearchSink(config, new
ElasticsearchSinkFunction[String
Github user rmetzger commented on a diff in the pull request:
https://github.com/apache/flink/pull/3358#discussion_r102179118
--- Diff:
flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/ElasticsearchSinkBase.java
---
[
https://issues.apache.org/jira/browse/FLINK-5487?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15875784#comment-15875784
]
ASF GitHub Bot commented on FLINK-5487:
---
Github user rmetzger commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-5487?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15875781#comment-15875781
]
ASF GitHub Bot commented on FLINK-5487:
---
Github user rmetzger commented on a diff in the pull
Github user rmetzger commented on a diff in the pull request:
https://github.com/apache/flink/pull/3358#discussion_r102180098
--- Diff:
flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/ElasticsearchSinkBase.java
---
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/3358#discussion_r102184175
--- Diff:
flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/ElasticsearchSinkBase.java
---
[
https://issues.apache.org/jira/browse/FLINK-5487?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15875807#comment-15875807
]
ASF GitHub Bot commented on FLINK-5487:
---
Github user tzulitai commented on a diff in the pull
Github user twalthr commented on a diff in the pull request:
https://github.com/apache/flink/pull/3372#discussion_r102185303
--- Diff:
flink-libraries/flink-table/src/test/scala/org/apache/flink/table/api/scala/batch/table/CalcITCase.scala
---
@@ -217,6 +218,65 @@ class
[
https://issues.apache.org/jira/browse/FLINK-5524?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15875818#comment-15875818
]
ASF GitHub Bot commented on FLINK-5524:
---
Github user twalthr commented on a diff in the pull
Github user StefanRRichter commented on the issue:
https://github.com/apache/flink/pull/3336
Besides the problem with the `WriteOption`, which I suggest to resolve in
another PR, this looks good to merge for me now. +1 from me and waiting for the
second approval through @aljoscha.
[
https://issues.apache.org/jira/browse/FLINK-4856?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15875852#comment-15875852
]
ASF GitHub Bot commented on FLINK-4856:
---
Github user StefanRRichter commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-5487?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger reassigned FLINK-5487:
-
Assignee: Tzu-Li (Gordon) Tai
> Proper at-least-once support for ElasticsearchSink
>
[
https://issues.apache.org/jira/browse/FLINK-4856?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15875659#comment-15875659
]
ASF GitHub Bot commented on FLINK-4856:
---
Github user StefanRRichter commented on a diff in the pull
Github user StefanRRichter commented on the issue:
https://github.com/apache/flink/pull/3336
I have one more point that I forgot in my initial review. It would be great
if you could also provide a paragraph in the Flink documentation about the
MapState. This would improve the
Github user fhueske commented on the issue:
https://github.com/apache/flink/pull/3107
Agreed, for Scala the inlined variant looks really good. Like @wuchong,
I'm curious how we can intercept the inlined string arguments. Do you know
how to do that @twalthr?
---
If your project
[
https://issues.apache.org/jira/browse/FLINK-5441?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15875676#comment-15875676
]
ASF GitHub Bot commented on FLINK-5441:
---
Github user fhueske commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-5795?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15875696#comment-15875696
]
ASF GitHub Bot commented on FLINK-5795:
---
Github user fhueske commented on the issue:
1 - 100 of 304 matches
Mail list logo
