[
https://issues.apache.org/jira/browse/FLINK-5695?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15855633#comment-15855633
]
sunjincheng commented on FLINK-5695:
Thanks [~fhueske] got your mean.
I will think about it and reply
Ufuk Celebi created FLINK-5731:
--
Summary: Split up CI builds
Key: FLINK-5731
URL: https://issues.apache.org/jira/browse/FLINK-5731
Project: Flink
Issue Type: Improvement
Components:
GitHub user WangTaoTheTonic opened a pull request:
https://github.com/apache/flink/pull/3283
[FLINK-5729][EXAMPLES]add hostname option to be more convenient
"hostname" option will help users to get data from the right port,
otherwise the example would fail easily due to connection
Tao Wang created FLINK-5729:
---
Summary: add hostname option in SocketWindowWordCount example to
be more convenient
Key: FLINK-5729
URL: https://issues.apache.org/jira/browse/FLINK-5729
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-5309?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15855687#comment-15855687
]
Nico Kruber commented on FLINK-5309:
Quickstart seems to point to 1.2 (which is stable now) but it
Github user tzulitai commented on the issue:
https://github.com/apache/flink/pull/3112
Thank you for the review! I'll address the missing semicolons and merge
this today.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well.
[
https://issues.apache.org/jira/browse/FLINK-4988?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15855688#comment-15855688
]
ASF GitHub Bot commented on FLINK-4988:
---
Github user tzulitai commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-5729?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15855569#comment-15855569
]
ASF GitHub Bot commented on FLINK-5729:
---
GitHub user WangTaoTheTonic opened a pull request:
Github user WangTaoTheTonic commented on the issue:
https://github.com/apache/flink/pull/3274
Travis timeout :) How to kick it up again?
---
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-5723?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15855578#comment-15855578
]
ASF GitHub Bot commented on FLINK-5723:
---
Github user WangTaoTheTonic commented on the issue:
Github user KurtYoung commented on the issue:
https://github.com/apache/flink/pull/3281
Hi @fhueske , thanks for your reviewing and comments, it makes sense to me.
The motivation behind this refactoring is we want to eliminate most differences
between batch and stream execution
[
https://issues.apache.org/jira/browse/FLINK-5727?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15855627#comment-15855627
]
ASF GitHub Bot commented on FLINK-5727:
---
Github user KurtYoung commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-5698?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15855634#comment-15855634
]
ASF GitHub Bot commented on FLINK-5698:
---
Github user wuchong commented on the issue:
Github user wuchong commented on the issue:
https://github.com/apache/flink/pull/3269
Hi @tonycox , thanks for this PR.
It seems that you are using column names to represent the (nested) fields
that are projected. I'm afraid that it can't work when the composite columns
[
https://issues.apache.org/jira/browse/FLINK-5657?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15855641#comment-15855641
]
radu commented on FLINK-5657:
-
Hi Yuhong,
In my experience it worked to have the translation to Logical
[
https://issues.apache.org/jira/browse/FLINK-4988?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15855671#comment-15855671
]
ASF GitHub Bot commented on FLINK-4988:
---
Github user rmetzger commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-5725?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=1585#comment-1585
]
radu commented on FLINK-5725:
-
Can you post please a description with the key idea to approach this task (SQL
[
https://issues.apache.org/jira/browse/FLINK-5727?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15855583#comment-15855583
]
ASF GitHub Bot commented on FLINK-5727:
---
Github user fhueske commented on the issue:
Stefan Richter created FLINK-5730:
-
Summary: User can concurrently modify state metadata of RocksDB
asynchronous snapshots
Key: FLINK-5730
URL: https://issues.apache.org/jira/browse/FLINK-5730
[
https://issues.apache.org/jira/browse/FLINK-5730?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stefan Richter updated FLINK-5730:
--
Summary: Users can concurrently modify state metadata of RocksDB
asynchronous snapshots (was:
[
https://issues.apache.org/jira/browse/FLINK-4988?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15855663#comment-15855663
]
ASF GitHub Bot commented on FLINK-4988:
---
Github user rmetzger commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-4988?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15855662#comment-15855662
]
ASF GitHub Bot commented on FLINK-4988:
---
Github user rmetzger commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-5695?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15855567#comment-15855567
]
sunjincheng commented on FLINK-5695:
Hi, [~fhueske] you are right when users simply use "tableapi",
Github user rmetzger commented on the issue:
https://github.com/apache/flink/pull/3112
+1 to merge.
I've tried the ES2 connector (just to check one of the connectors) and it
worked well.
---
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-5657?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15855686#comment-15855686
]
Fabian Hueske commented on FLINK-5657:
--
Hi [~Yuhong_kyo] and [~rtudoran],
There is a pull request to
Github user fhueske commented on the issue:
https://github.com/apache/flink/pull/3281
Hi @KurtYoung,
thanks for the refactoring. Moving `sql()` and `scan()` to
`TableEnvironment` makes sense.
However, I'd like to keep `registerTableSource` at the
[
https://issues.apache.org/jira/browse/FLINK-5256?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15855638#comment-15855638
]
ASF GitHub Bot commented on FLINK-5256:
---
Github user ex00 commented on a diff in the pull request:
Github user ex00 commented on a diff in the pull request:
https://github.com/apache/flink/pull/3033#discussion_r99778650
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/dataset/DataSetSingleRowJoin.scala
---
@@ -144,21 +150,46 @@ class
[
https://issues.apache.org/jira/browse/FLINK-5435?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15855653#comment-15855653
]
Anton Mushin commented on FLINK-5435:
-
Hi.
We have problem in FLINK-5435 with calcite rule. In PR for
Github user rmetzger commented on a diff in the pull request:
https://github.com/apache/flink/pull/3112#discussion_r99783050
--- Diff: docs/dev/connectors/elasticsearch.md ---
@@ -23,158 +23,291 @@ specific language governing permissions and
limitations
under the License.
Github user rmetzger commented on a diff in the pull request:
https://github.com/apache/flink/pull/3112#discussion_r99782995
--- Diff: docs/dev/connectors/elasticsearch.md ---
@@ -23,158 +23,291 @@ specific language governing permissions and
limitations
under the License.
Github user rmetzger commented on a diff in the pull request:
https://github.com/apache/flink/pull/3112#discussion_r99783072
--- Diff: docs/dev/connectors/elasticsearch.md ---
@@ -23,158 +23,291 @@ specific language governing permissions and
limitations
under the License.
[
https://issues.apache.org/jira/browse/FLINK-4988?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15855661#comment-15855661
]
ASF GitHub Bot commented on FLINK-4988:
---
Github user rmetzger commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-5657?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15855699#comment-15855699
]
Fabian Hueske commented on FLINK-5657:
--
Regarding the assignment of this issue:
Flink committers do
[
https://issues.apache.org/jira/browse/FLINK-5695?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15855575#comment-15855575
]
Fabian Hueske commented on FLINK-5695:
--
Hi [~sunjincheng121],
IDEs usually show the Java / ScalaDocs
Github user tzulitai commented on the issue:
https://github.com/apache/flink/pull/3282
Thank you for the review @uce! I'll address all of them except the last one
(please see my inline reply).
---
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-5690?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger reassigned FLINK-5690:
-
Assignee: Robert Metzger
> protobuf is not shaded properly
>
[
https://issues.apache.org/jira/browse/FLINK-5717?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15855926#comment-15855926
]
Oriol Orellana commented on FLINK-5717:
---
[~aljoscha] Should I fix it and create a PR to master?
>
[
https://issues.apache.org/jira/browse/FLINK-5702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15855731#comment-15855731
]
ASF GitHub Bot commented on FLINK-5702:
---
Github user uce commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-5702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15855736#comment-15855736
]
ASF GitHub Bot commented on FLINK-5702:
---
Github user uce commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-5731?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15855726#comment-15855726
]
Robert Metzger commented on FLINK-5731:
---
I will probably work on this later this week or next week.
Github user uce commented on a diff in the pull request:
https://github.com/apache/flink/pull/3282#discussion_r99790794
--- Diff: docs/dev/connectors/kafka.md ---
@@ -250,57 +250,116 @@ if a new watermark should be emitted and with which
timestamp.
### Kafka Producer
[
https://issues.apache.org/jira/browse/FLINK-5702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15855775#comment-15855775
]
ASF GitHub Bot commented on FLINK-5702:
---
Github user tzulitai commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-1588?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15855790#comment-15855790
]
Robert Metzger commented on FLINK-1588:
---
Thank you for looking into the issue.
I would load the
Github user twalthr commented on the issue:
https://github.com/apache/flink/pull/3277
Ready to be reviewed ;)
---
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
[
https://issues.apache.org/jira/browse/FLINK-5662?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15855799#comment-15855799
]
ASF GitHub Bot commented on FLINK-5662:
---
Github user twalthr commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-5699?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15855742#comment-15855742
]
ASF GitHub Bot commented on FLINK-5699:
---
Github user asfgit closed the pull request at:
Github user uce commented on the issue:
https://github.com/apache/flink/pull/3263
Build failures are unrelated in change is self-contained. Merging this to
`master` and `release-1.2`.
---
If your project is set up for it, you can reply to this email and have your
reply appear on
[
https://issues.apache.org/jira/browse/FLINK-5517?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15855743#comment-15855743
]
ASF GitHub Bot commented on FLINK-5517:
---
Github user rmetzger commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-5699?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ufuk Celebi closed FLINK-5699.
--
Resolution: Fixed
Fix Version/s: 1.2.1
1.3.0
Fixed in b452c8b (master),
[
https://issues.apache.org/jira/browse/FLINK-5702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15855761#comment-15855761
]
ASF GitHub Bot commented on FLINK-5702:
---
Github user tzulitai commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-5727?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15855762#comment-15855762
]
ASF GitHub Bot commented on FLINK-5727:
---
Github user fhueske commented on the issue:
Github user dawidwys closed the pull request at:
https://github.com/apache/flink/pull/3255
---
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 dawidwys closed the pull request at:
https://github.com/apache/flink/pull/3253
---
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-5658?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15855868#comment-15855868
]
Yuhong Hong commented on FLINK-5658:
Hi, [~sunjincheng121] & Fabian, i have some confuse about this
[
https://issues.apache.org/jira/browse/FLINK-5732?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ufuk Celebi closed FLINK-5732.
--
Resolution: Fixed
Assignee: Ufuk Celebi
Fix Version/s: 1.2.1
Thanks for spotting this.
[
https://issues.apache.org/jira/browse/FLINK-5710?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15855945#comment-15855945
]
Fabian Hueske commented on FLINK-5710:
--
Actually, the function should not return anything. It is just
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/3282#discussion_r99793771
--- Diff: docs/dev/connectors/kafka.md ---
@@ -250,57 +250,116 @@ if a new watermark should be emitted and with which
timestamp.
### Kafka
Github user rmetzger commented on the issue:
https://github.com/apache/flink/pull/3235
Has anybody of you tested flink against hbase with the 1.3.0 version?
Is Hbase 1.3.0 adding any new dependencies?
I'm asking because its a major version change, which is likely to cause
some
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/3263
---
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-5657?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15855793#comment-15855793
]
sunjincheng commented on FLINK-5657:
Hi [~Yuhong_kyo], [~rtudoran], and [~fhueske], thanks for sharing
[
https://issues.apache.org/jira/browse/FLINK-5517?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15855795#comment-15855795
]
ASF GitHub Bot commented on FLINK-5517:
---
Github user tzulitai commented on the issue:
Github user tzulitai commented on the issue:
https://github.com/apache/flink/pull/3235
I can look into this tomorrow and check.
---
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
Colin Breame created FLINK-5732:
---
Summary: Java quick start mvn command line is incorrect
Key: FLINK-5732
URL: https://issues.apache.org/jira/browse/FLINK-5732
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-5690?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15855933#comment-15855933
]
Andrey commented on FLINK-5690:
---
Not blocking actually. We were able to shade our own jars
> protobuf is
[
https://issues.apache.org/jira/browse/FLINK-5431?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15855939#comment-15855939
]
Anton Solovev edited comment on FLINK-5431 at 2/7/17 1:07 PM:
--
How should I
Github user uce commented on a diff in the pull request:
https://github.com/apache/flink/pull/3282#discussion_r99792597
--- Diff: docs/dev/connectors/kafka.md ---
@@ -250,57 +250,116 @@ if a new watermark should be emitted and with which
timestamp.
### Kafka Producer
[
https://issues.apache.org/jira/browse/FLINK-5702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15855734#comment-15855734
]
ASF GitHub Bot commented on FLINK-5702:
---
Github user uce commented on a diff in the pull request:
Github user uce commented on a diff in the pull request:
https://github.com/apache/flink/pull/3282#discussion_r99791642
--- Diff: docs/dev/connectors/kafka.md ---
@@ -250,57 +250,116 @@ if a new watermark should be emitted and with which
timestamp.
### Kafka Producer
[
https://issues.apache.org/jira/browse/FLINK-5699?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15855739#comment-15855739
]
ASF GitHub Bot commented on FLINK-5699:
---
Github user uce commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-5702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15855735#comment-15855735
]
ASF GitHub Bot commented on FLINK-5702:
---
Github user uce commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-5702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15855732#comment-15855732
]
ASF GitHub Bot commented on FLINK-5702:
---
Github user uce commented on a diff in the pull request:
Github user uce commented on a diff in the pull request:
https://github.com/apache/flink/pull/3282#discussion_r99791528
--- Diff: docs/dev/connectors/kafka.md ---
@@ -250,57 +250,116 @@ if a new watermark should be emitted and with which
timestamp.
### Kafka Producer
[
https://issues.apache.org/jira/browse/FLINK-5702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15855733#comment-15855733
]
ASF GitHub Bot commented on FLINK-5702:
---
Github user uce commented on a diff in the pull request:
Github user uce commented on a diff in the pull request:
https://github.com/apache/flink/pull/3282#discussion_r99792130
--- Diff: docs/dev/connectors/kafka.md ---
@@ -250,57 +250,116 @@ if a new watermark should be emitted and with which
timestamp.
### Kafka Producer
Github user uce commented on a diff in the pull request:
https://github.com/apache/flink/pull/3282#discussion_r99791696
--- Diff: docs/dev/connectors/kafka.md ---
@@ -250,57 +250,116 @@ if a new watermark should be emitted and with which
timestamp.
### Kafka Producer
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/3282#discussion_r99796056
--- Diff: docs/dev/connectors/kafka.md ---
@@ -250,57 +250,116 @@ if a new watermark should be emitted and with which
timestamp.
### Kafka
Github user fhueske commented on the issue:
https://github.com/apache/flink/pull/3281
Thanks for the update @KurtYoung.
+1 to merge
---
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
[
https://issues.apache.org/jira/browse/FLINK-5509?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15855778#comment-15855778
]
ASF GitHub Bot commented on FLINK-5509:
---
Github user dawidwys closed the pull request at:
[
https://issues.apache.org/jira/browse/FLINK-5606?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15855779#comment-15855779
]
ASF GitHub Bot commented on FLINK-5606:
---
Github user dawidwys closed the pull request at:
[
https://issues.apache.org/jira/browse/FLINK-5005?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15855870#comment-15855870
]
Joan Goyeau commented on FLINK-5005:
Ned
> Publish Scala 2.12 artifacts
>
[
https://issues.apache.org/jira/browse/FLINK-5702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15855918#comment-15855918
]
ASF GitHub Bot commented on FLINK-5702:
---
Github user tzulitai commented on the issue:
Github user tzulitai commented on the issue:
https://github.com/apache/flink/pull/3282
The comments have been addressed. Apart from the minor fixes for grammar,
all sections were moved up the hierarchy by one to show a better ToC. The
at-least-once info for the producer is moved to a
[
https://issues.apache.org/jira/browse/FLINK-5710?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15855942#comment-15855942
]
Stefano Bortoli commented on FLINK-5710:
Just to track this, what you had in mind is something
[
https://issues.apache.org/jira/browse/FLINK-5690?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15855966#comment-15855966
]
Robert Metzger commented on FLINK-5690:
---
Okay, cool.
I still tried to reproduce the issue, but I was
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/3138
It would be good to add the removed code back in a way that does not
conflict with powermock, like @zentol suggested.
---
If your project is set up for it, you can reply to this email and have
[
https://issues.apache.org/jira/browse/FLINK-5710?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15855986#comment-15855986
]
Haohui Mai edited comment on FLINK-5710 at 2/7/17 1:47 PM:
---
Can you please
[
https://issues.apache.org/jira/browse/FLINK-5690?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15856009#comment-15856009
]
Andrey commented on FLINK-5690:
---
Your project contains dependency on protobuf 2.5.0 which means protobuf was
[
https://issues.apache.org/jira/browse/FLINK-4364?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15856024#comment-15856024
]
ASF GitHub Bot commented on FLINK-4364:
---
Github user tillrohrmann commented on a diff in the pull
Github user tzulitai commented on the issue:
https://github.com/apache/flink/pull/2767
Hi @mikedias! Your contribution has been merged with
8699b03d79a441ca33d9f62b96490d29a0efaf44 and
b5caaef82add4a6f424094d526700c77b011724e. Could you manually close this PR? The
bot only closed
[
https://issues.apache.org/jira/browse/FLINK-5658?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15856095#comment-15856095
]
sunjincheng edited comment on FLINK-5658 at 2/7/17 2:55 PM:
Hi,[~Yuhong_kyo]
[
https://issues.apache.org/jira/browse/FLINK-4988?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15856152#comment-15856152
]
Tzu-Li (Gordon) Tai edited comment on FLINK-4988 at 2/7/17 3:00 PM:
[
https://issues.apache.org/jira/browse/FLINK-5710?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15855986#comment-15855986
]
Haohui Mai commented on FLINK-5710:
---
Can you please elaborate a little bit more, particularly how the
[
https://issues.apache.org/jira/browse/FLINK-5701?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15855991#comment-15855991
]
ASF GitHub Bot commented on FLINK-5701:
---
Github user tillrohrmann commented on the issue:
Github user tillrohrmann commented on the issue:
https://github.com/apache/flink/pull/3278
Ah now I understand what the problem of
`testAtLeastOnceProdcuerFailsIfFlushingDisabled` was. Can't we mock the
`KafkaProducer` to control when the record's callbacks are triggered? That way
[
https://issues.apache.org/jira/browse/FLINK-5413?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tao Meng reassigned FLINK-5413:
---
Assignee: Tao Meng (was: GaoLun)
> Convert TableEnvironmentITCases to unit tests
>
[
https://issues.apache.org/jira/browse/FLINK-5413?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tao Meng reassigned FLINK-5413:
---
Assignee: GaoLun (was: Tao Meng)
> Convert TableEnvironmentITCases to unit tests
>
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/3151#discussion_r99826924
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/TaskExecutor.java
---
@@ -1058,6 +1092,30 @@ public void
[
https://issues.apache.org/jira/browse/FLINK-4364?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15856033#comment-15856033
]
ASF GitHub Bot commented on FLINK-4364:
---
Github user tillrohrmann commented on a diff in the pull
Github user tillrohrmann commented on the issue:
https://github.com/apache/flink/pull/2770
Alright @wangzhijiang999. Sorry for the late review. Once you've rebased
the PR ping me :-)
---
If your project is set up for it, you can reply to this email and have your
reply appear on
1 - 100 of 228 matches
Mail list logo
