Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/3358#discussion_r102400283
--- 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=15877698#comment-15877698
]
ASF GitHub Bot commented on FLINK-5487:
---
Github user tzulitai commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-4520?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15877693#comment-15877693
]
ASF GitHub Bot commented on FLINK-4520:
---
Github user rmetzger commented on the issue:
Github user rmetzger commented on the issue:
https://github.com/apache/flink/pull/2487
Cool, than you!
---
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-4520?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15877680#comment-15877680
]
ASF GitHub Bot commented on FLINK-4520:
---
Github user haoch commented on the issue:
Github user haoch commented on the issue:
https://github.com/apache/flink/pull/2487
@uce sure, will fix it and resend PR to Bahir.
---
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-5818?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15877656#comment-15877656
]
ASF GitHub Bot commented on FLINK-5818:
---
Github user WangTaoTheTonic commented on the issue:
Github user WangTaoTheTonic commented on the issue:
https://github.com/apache/flink/pull/3335
@greghogan I think it's more like an improvement rather than a new feature.
Anyway I'll post to mailling list for discussion.
Thanks all guys :)
---
If your project is set up for
[
https://issues.apache.org/jira/browse/FLINK-5501?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15877569#comment-15877569
]
ASF GitHub Bot commented on FLINK-5501:
---
GitHub user shuai-xu opened a pull request:
GitHub user shuai-xu opened a pull request:
https://github.com/apache/flink/pull/3385
[FLINK-5501] JM use running job registry to determine whether is the first
running
This pr if for
jira-#[5501](https://issues.apache.org/jira/browse/FLINK-5501).
The main changes are:
Github user huawei-flink commented on the issue:
https://github.com/apache/flink/pull/3370
@haohui thanks for the contribution. I merged your code, I will push it
later today.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as
[
https://issues.apache.org/jira/browse/FLINK-5710?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15877548#comment-15877548
]
ASF GitHub Bot commented on FLINK-5710:
---
Github user huawei-flink commented on the issue:
Github user huawei-flink commented on the issue:
https://github.com/apache/flink/pull/3302
I managed to merge the changes from PR #3370 into my branch after rebase,
and the test works. I will push the code later today. sorry if I am a little
latent, but I am travelling and
[
https://issues.apache.org/jira/browse/FLINK-5710?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15877546#comment-15877546
]
ASF GitHub Bot commented on FLINK-5710:
---
Github user huawei-flink commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-5701?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15877497#comment-15877497
]
ASF GitHub Bot commented on FLINK-5701:
---
Github user tzulitai commented on the issue:
Github user tzulitai commented on the issue:
https://github.com/apache/flink/pull/3278
Addressed waiting for flushing to start with a latch instead of sleeping.
Will merge this to `master` and `release-1.2` once Travis turns green
(running also locally due to the timeouts).
---
[
https://issues.apache.org/jira/browse/FLINK-4562?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15877486#comment-15877486
]
ASF GitHub Bot commented on FLINK-4562:
---
Github user wuchong commented on the issue:
Github user wuchong commented on the issue:
https://github.com/apache/flink/pull/2460
Hi @shijinkui , sorry for the delay, the change looks very good to me.
Regarding to your questions,
>1. all the example code moved in flink-examples module, as a sub-module.
Yes or No?
[
https://issues.apache.org/jira/browse/FLINK-5569?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kurt Young closed FLINK-5569.
-
> Migrate current table registration to in-memory catalog
>
[
https://issues.apache.org/jira/browse/FLINK-5376?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated FLINK-5376:
--
Description:
The following are two examples where ordered stream element queue is mentioned:
{code}
[
https://issues.apache.org/jira/browse/FLINK-4856?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15877444#comment-15877444
]
ASF GitHub Bot commented on FLINK-4856:
---
Github user wenlong88 commented on a diff in the pull
Github user wenlong88 commented on a diff in the pull request:
https://github.com/apache/flink/pull/3336#discussion_r102381085
--- Diff:
flink-core/src/main/java/org/apache/flink/api/common/state/MapStateDescriptor.java
---
@@ -0,0 +1,147 @@
+/*
+ * Licensed to the Apache
[
https://issues.apache.org/jira/browse/FLINK-4443?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Wenlong Lyu closed FLINK-4443.
--
fixed
> Add support in RpcCompletenessTest for inheritance of RpcGateway and
> RpcEndpoint
>
[
https://issues.apache.org/jira/browse/FLINK-4378?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Wenlong Lyu closed FLINK-4378.
--
fixed
> Enable RollingSink to custom HDFS client configuration
>
[
https://issues.apache.org/jira/browse/FLINK-5541?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated FLINK-5541:
--
Description:
{code}
if (localJar == null) {
try {
for (final URL url :
[
https://issues.apache.org/jira/browse/FLINK-5656?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15877380#comment-15877380
]
Jark Wu edited comment on FLINK-5656 at 2/22/17 3:17 AM:
-
[~sunjincheng121] I'm
[
https://issues.apache.org/jira/browse/FLINK-5656?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15877380#comment-15877380
]
Jark Wu commented on FLINK-5656:
[~sunjingcheng] I'm fine with this as I haven't start this issue. If you
[
https://issues.apache.org/jira/browse/FLINK-5656?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15877370#comment-15877370
]
sunjincheng edited comment on FLINK-5656 at 2/22/17 3:08 AM:
-
HI, [~fhueske] @
[
https://issues.apache.org/jira/browse/FLINK-5656?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15877370#comment-15877370
]
sunjincheng edited comment on FLINK-5656 at 2/22/17 3:09 AM:
-
HI, [~fhueske]
[
https://issues.apache.org/jira/browse/FLINK-5656?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15877370#comment-15877370
]
sunjincheng commented on FLINK-5656:
HI, [~fhueske] [~jack], IMO,In the case of `BETWEEN UNBOUNDED
Github user zhijiangW commented on the issue:
https://github.com/apache/flink/pull/3360
Hi @tillrohrmann , thank you for reviews and positive suggestions!
I try to explain the root case of this issue first:
From JobMaster side, it sends the cancel rpc message and gets
[
https://issues.apache.org/jira/browse/FLINK-5830?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15877368#comment-15877368
]
ASF GitHub Bot commented on FLINK-5830:
---
Github user zhijiangW commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-4326?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15877364#comment-15877364
]
Michi Mutsuzaki commented on FLINK-4326:
thanks [~greghogan], lgtm!
> Flink start-up scripts
[
https://issues.apache.org/jira/browse/FLINK-5710?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15877331#comment-15877331
]
ASF GitHub Bot commented on FLINK-5710:
---
Github user huawei-flink commented on the issue:
Github user huawei-flink commented on the issue:
https://github.com/apache/flink/pull/3302
Hi Fabian,
I will follow up in the next days, probably early next week. is it ok?
Stefano
---
If your project is set up for it, you can reply to this email and have your
reply
[
https://issues.apache.org/jira/browse/FLINK-4562?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15877294#comment-15877294
]
ASF GitHub Bot commented on FLINK-4562:
---
Github user shijinkui commented on the issue:
Github user shijinkui commented on the issue:
https://github.com/apache/flink/pull/2460
@wuchong @StephanEwen can you review this pull request.
Generating independent example runnable jar will increase the size of flink
distribution.
This table example jar is 13Mb or so.
[
https://issues.apache.org/jira/browse/FLINK-5795?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu closed FLINK-5795.
--
Resolution: Fixed
Fix Version/s: 1.3.0
Fixed in 1.3.0: 45e01cf2321dda58f572d8b9dbe64947c6725ad1
>
[
https://issues.apache.org/jira/browse/FLINK-5795?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15877288#comment-15877288
]
Jark Wu commented on FLINK-5795:
Fixed in 1.3.0: 45e01cf2321dda58f572d8b9dbe64947c6725ad1
> Improve UDF
[
https://issues.apache.org/jira/browse/FLINK-1526?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15877287#comment-15877287
]
ASF GitHub Bot commented on FLINK-1526:
---
Github user xccui commented on the issue:
Github user xccui commented on the issue:
https://github.com/apache/flink/pull/3284
With the present situation (for gelly), shall I close this 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 does not
[
https://issues.apache.org/jira/browse/FLINK-5795?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15877285#comment-15877285
]
ASF GitHub Bot commented on FLINK-5795:
---
Github user asfgit closed the pull request at:
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/3330
---
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-5795?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu updated FLINK-5795:
---
Summary: Improve UDF to support constructor with parameter (was:
Improve “UDTF" to support constructor with
[
https://issues.apache.org/jira/browse/FLINK-5546?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
shijinkui closed FLINK-5546.
Resolution: Duplicate
resolved in FLINK-5817
> java.io.tmpdir setted as project build directory in
[
https://issues.apache.org/jira/browse/FLINK-4754?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15877248#comment-15877248
]
ASF GitHub Bot commented on FLINK-4754:
---
Github user tony810430 commented on the issue:
Github user tony810430 commented on the issue:
https://github.com/apache/flink/pull/3374
Hi @StephanEwen thanks for your feedback.
I totally agree your opinion. I will make this setting be configured in
`FlinkConfiguration` and be passed to `CheckpointRecoveryFactory`.
Shaoxuan Wang created FLINK-5878:
Summary: Add stream-stream inner join on TableAPI
Key: FLINK-5878
URL: https://issues.apache.org/jira/browse/FLINK-5878
Project: Flink
Issue Type: New
[
https://issues.apache.org/jira/browse/FLINK-5524?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15877175#comment-15877175
]
ASF GitHub Bot commented on FLINK-5524:
---
Github user KurtYoung commented on a diff in the pull
Github user KurtYoung commented on a diff in the pull request:
https://github.com/apache/flink/pull/3372#discussion_r102361046
--- 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-4422?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15876990#comment-15876990
]
ASF GitHub Bot commented on FLINK-4422:
---
GitHub user jinmingjian opened a pull request:
GitHub user jinmingjian opened a pull request:
https://github.com/apache/flink/pull/3384
[FLINK-4422] Convert all time interval measurements to System.nanoTime() -
flink-clients
Thanks for contributing to Apache Flink. Before you open your pull request,
please take the following
[
https://issues.apache.org/jira/browse/FLINK-5824?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15876695#comment-15876695
]
Dawid Wysakowicz commented on FLINK-5824:
-
I've fixed all direct String <> bytes conversions as
GitHub user alkagin opened a pull request:
https://github.com/apache/flink/pull/3383
[FLINK-5877] [docs] Fix Scala snippet in Async I/O API doc
Thanks for contributing to Apache Flink. Before you open your pull request,
please take the following check list into consideration.
[
https://issues.apache.org/jira/browse/FLINK-5877?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15876630#comment-15876630
]
ASF GitHub Bot commented on FLINK-5877:
---
GitHub user alkagin opened a pull request:
Andrea Sella created FLINK-5877:
---
Summary: Fix Scala snippet in Async I/O API doc
Key: FLINK-5877
URL: https://issues.apache.org/jira/browse/FLINK-5877
Project: Flink
Issue Type: Improvement
Github user haohui commented on a diff in the pull request:
https://github.com/apache/flink/pull/3314#discussion_r102299038
--- Diff:
flink-connectors/flink-connector-kafka-0.8/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/SimpleConsumerThread.java
---
@@
[
https://issues.apache.org/jira/browse/FLINK-3679?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15876573#comment-15876573
]
ASF GitHub Bot commented on FLINK-3679:
---
Github user haohui commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-4754?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15876543#comment-15876543
]
ASF GitHub Bot commented on FLINK-4754:
---
Github user StephanEwen commented on the issue:
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/3374
Hi @tony810430 thank you for the pull request!
The code looks good.
My feeling is, though, that the number of checkpoints to retain is
something that we want rather in the
[
https://issues.apache.org/jira/browse/FLINK-5801?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15876416#comment-15876416
]
Ufuk Celebi commented on FLINK-5801:
The root cause of this a mismatch in the key serializers. The
Ufuk Celebi created FLINK-5876:
--
Summary: Mention Scala type fallacies for queryable state client
serializers
Key: FLINK-5876
URL: https://issues.apache.org/jira/browse/FLINK-5876
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-3695?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Greg Hogan updated FLINK-3695:
--
Fix Version/s: 1.3.0
> ValueArray types
>
>
> Key: FLINK-3695
>
[
https://issues.apache.org/jira/browse/FLINK-3695?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15876400#comment-15876400
]
Greg Hogan commented on FLINK-3695:
---
[~StephanEwen]
[
https://issues.apache.org/jira/browse/FLINK-3695?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15876394#comment-15876394
]
ASF GitHub Bot commented on FLINK-3695:
---
GitHub user greghogan opened a pull request:
GitHub user greghogan opened a pull request:
https://github.com/apache/flink/pull/3382
[FLINK-3695] [gelly] ValueArray types
Provide compact and efficiently serializable and comparable array
implementations for Flink mutable Value types and Java primitives.
You can merge this pull
Robert Metzger created FLINK-5875:
-
Summary: Use TypeComparator.hash instead of Object.hashCode() for
keying in DataStream API
Key: FLINK-5875
URL: https://issues.apache.org/jira/browse/FLINK-5875
[
https://issues.apache.org/jira/browse/FLINK-5875?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger updated FLINK-5875:
--
Summary: Use TypeComparator.hash() instead of Object.hashCode() for keying
in DataStream API
[
https://issues.apache.org/jira/browse/FLINK-4326?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15876351#comment-15876351
]
Greg Hogan commented on FLINK-4326:
---
[~michim] thank you for reporting the issue. This should now be
Robert Metzger created FLINK-5874:
-
Summary: Reject arrays as keys in DataStream API to avoid
inconsistent hashing
Key: FLINK-5874
URL: https://issues.apache.org/jira/browse/FLINK-5874
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-5871?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15876329#comment-15876329
]
ASF GitHub Bot commented on FLINK-5871:
---
GitHub user kl0u opened a pull request:
GitHub user kl0u opened a pull request:
https://github.com/apache/flink/pull/3381
[FLINK-5871] [cep] Enforce uniqueness of pattern names in CEP.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/kl0u/flink cep-uniq-pattern-name
[
https://issues.apache.org/jira/browse/FLINK-3163?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Greg Hogan closed FLINK-3163.
-
Resolution: Implemented
Implemented in 11c868f91db773af626ac6ac4dcba9820c13fa8a
> Configure Flink for
[
https://issues.apache.org/jira/browse/FLINK-3163?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15876282#comment-15876282
]
ASF GitHub Bot commented on FLINK-3163:
---
Github user asfgit closed the pull request at:
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/3249
---
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-5865?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xiaogang Shi updated FLINK-5865:
Summary: Throw original exception in states (was: Throw original exception
in RocksDB states)
>
[
https://issues.apache.org/jira/browse/FLINK-5865?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15876239#comment-15876239
]
ASF GitHub Bot commented on FLINK-5865:
---
GitHub user shixiaogang opened a pull request:
GitHub user shixiaogang opened a pull request:
https://github.com/apache/flink/pull/3380
[FLINK-5865][state] Throw original exception in the states
The wrapping of `RuntimeException` is removed so that we can avoid
redundant stack printed in the log.
You can merge this pull
[
https://issues.apache.org/jira/browse/FLINK-5824?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15876215#comment-15876215
]
Dawid Wysakowicz commented on FLINK-5824:
-
Right now such a regex will match also for
[
https://issues.apache.org/jira/browse/FLINK-5498?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15876190#comment-15876190
]
ASF GitHub Bot commented on FLINK-5498:
---
GitHub user lincoln-lil opened a pull request:
GitHub user lincoln-lil opened a pull request:
https://github.com/apache/flink/pull/3379
[FLINK-5498] [table] Add support for left/right outer joins with non-â¦
â¦equality predicates (and 1+ equality predicates)
Support left/right outer joins with non-equi-join conditions
[
https://issues.apache.org/jira/browse/FLINK-5812?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15876174#comment-15876174
]
ASF GitHub Bot commented on FLINK-5812:
---
Github user StephanEwen closed the pull request at:
[
https://issues.apache.org/jira/browse/FLINK-5812?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15876173#comment-15876173
]
ASF GitHub Bot commented on FLINK-5812:
---
Github user StephanEwen commented on the issue:
Github user StephanEwen closed the pull request at:
https://github.com/apache/flink/pull/3328
---
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
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/3328
Yes, it was accidentally merged together with another PR.
Since the changes were mostly comments and annotations, it should not be a
problem.
Closing...
---
If your project is set
GitHub user tzulitai opened a pull request:
https://github.com/apache/flink/pull/3378
[FLINK-5849] [kafka] Move FlinkKafkaConsumer start offset determination to
open()
This PR fixes a regression due to the recently merged #2509 (FLINK-4280).
The new start position feature added
[
https://issues.apache.org/jira/browse/FLINK-3123?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15876154#comment-15876154
]
ASF GitHub Bot commented on FLINK-3123:
---
Github user tzulitai commented on the issue:
Github user tzulitai commented on the issue:
https://github.com/apache/flink/pull/2687
I recommend reviewing this after #3378 is merged, as it touches a lot of
code related to the new start position features.
---
If your project is set up for it, you can reply to this email and have
[
https://issues.apache.org/jira/browse/FLINK-5487?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15876150#comment-15876150
]
ASF GitHub Bot commented on FLINK-5487:
---
Github user tzulitai commented on the issue:
Github user tzulitai commented on the issue:
https://github.com/apache/flink/pull/3358
Yes, I overlooked adding tests for this.
Thanks a lot for the reviews @rmetzger! I'll address your comments and
tests for the additional features.
Will ping you once it's ready for
[
https://issues.apache.org/jira/browse/FLINK-5487?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15876148#comment-15876148
]
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_r102233292
--- 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-5849?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15876139#comment-15876139
]
ASF GitHub Bot commented on FLINK-5849:
---
GitHub user tzulitai opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-5090?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15876124#comment-15876124
]
ASF GitHub Bot commented on FLINK-5090:
---
Github user zentol commented on a diff in the pull request:
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/3348#discussion_r102227821
--- Diff:
flink-core/src/main/java/org/apache/flink/configuration/ConfigConstants.java ---
@@ -227,6 +227,14 @@
public static final String
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/3323#discussion_r102227190
--- Diff:
flink-core/src/main/java/org/apache/flink/api/common/Archiveable.java ---
@@ -17,8 +17,11 @@
*/
package org.apache.flink.api.common;
[
https://issues.apache.org/jira/browse/FLINK-5812?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15876116#comment-15876116
]
ASF GitHub Bot commented on FLINK-5812:
---
Github user zentol commented on the issue:
Github user shixiaogang commented on the issue:
https://github.com/apache/flink/pull/3336
@StefanRRichter Very thanks for your work. I have rebased the pull
request and resolved the conflicts.
---
If your project is set up for it, you can reply to this email and have your
reply
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/3328
@StephanEwen Can this PR be closed?
---
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
[
https://issues.apache.org/jira/browse/FLINK-4856?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15876117#comment-15876117
]
ASF GitHub Bot commented on FLINK-4856:
---
Github user shixiaogang commented on the issue:
1 - 100 of 304 matches
Mail list logo
