Github user rtudoran closed the pull request at:
https://github.com/apache/flink/pull/3700
---
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 en
Github user rtudoran commented on the issue:
https://github.com/apache/flink/pull/3700
@fhueske I will close the 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 have this feature
enabled and w
[
https://issues.apache.org/jira/browse/FLINK-6090?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15967200#comment-15967200
]
ASF GitHub Bot commented on FLINK-6090:
---
Github user hequn8128 commented on a diff i
Github user hequn8128 commented on a diff in the pull request:
https://github.com/apache/flink/pull/3696#discussion_r111320841
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/datastream/DataStreamCorrelate.scala
---
@@ -36,14 +36,14 @@ import
[
https://issues.apache.org/jira/browse/FLINK-5092?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15967177#comment-15967177
]
Boris Osipov commented on FLINK-5092:
-
So, I give up to do reliable and simple solutio
[
https://issues.apache.org/jira/browse/FLINK-5092?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boris Osipov reassigned FLINK-5092:
---
Assignee: (was: Boris Osipov)
> Add integration with Sonarqube and code coverage
> --
[
https://issues.apache.org/jira/browse/FLINK-5092?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15967165#comment-15967165
]
ASF GitHub Bot commented on FLINK-5092:
---
Github user BorisOsipov closed the pull req
Github user BorisOsipov closed the pull request at:
https://github.com/apache/flink/pull/2836
---
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-6295?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15967091#comment-15967091
]
ASF GitHub Bot commented on FLINK-6295:
---
Github user wenlong88 commented on a diff i
Github user wenlong88 commented on a diff in the pull request:
https://github.com/apache/flink/pull/3709#discussion_r111308326
--- Diff:
flink-runtime-web/src/main/java/org/apache/flink/runtime/webmonitor/ExecutionGraphHolder.java
---
@@ -48,7 +52,41 @@
private final
[
https://issues.apache.org/jira/browse/FLINK-6232?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15967065#comment-15967065
]
ASF GitHub Bot commented on FLINK-6232:
---
GitHub user hongyuhong opened a pull reques
GitHub user hongyuhong opened a pull request:
https://github.com/apache/flink/pull/3715
[FLINK-6232][Table&SQL]Support proctime inner equi-join between two sâ¦
â¦treams in sql api
Thanks for contributing to Apache Flink. Before you open your pull request,
please take the
[
https://issues.apache.org/jira/browse/FLINK-6275?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15966977#comment-15966977
]
mingleizhang commented on FLINK-6275:
-
[~StephanEwen] Hi, Could you please take some t
[
https://issues.apache.org/jira/browse/FLINK-6143?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15966974#comment-15966974
]
mingleizhang commented on FLINK-6143:
-
[~StephanEwen] , Hi, Could you please take some
[
https://issues.apache.org/jira/browse/FLINK-5668?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15966934#comment-15966934
]
Bill Liu edited comment on FLINK-5668 at 4/13/17 12:56 AM:
---
[~St
[
https://issues.apache.org/jira/browse/FLINK-5668?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15966934#comment-15966934
]
Bill Liu edited comment on FLINK-5668 at 4/13/17 12:56 AM:
---
[~St
[
https://issues.apache.org/jira/browse/FLINK-5668?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15966934#comment-15966934
]
Bill Liu edited comment on FLINK-5668 at 4/13/17 12:53 AM:
---
[~St
[
https://issues.apache.org/jira/browse/FLINK-5668?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15966934#comment-15966934
]
Bill Liu commented on FLINK-5668:
-
[~StephanEwen] and [~wheat9]
Sorry to raise this issue
[
https://issues.apache.org/jira/browse/FLINK-6301?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15966797#comment-15966797
]
Rahul Yadav commented on FLINK-6301:
Linking to the underlying Kafka issue
> Flink Ka
[
https://issues.apache.org/jira/browse/FLINK-5005?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15966606#comment-15966606
]
ASF GitHub Bot commented on FLINK-5005:
---
Github user DieBauer commented on the issue
Github user DieBauer commented on the issue:
https://github.com/apache/flink/pull/3703
Ok, started looking into the issue a bit more.
It seems like it has to do with the new lambda generation in scala 2.12 and
not with the asm library.
From the scala 2.12-M3 release note
[
https://issues.apache.org/jira/browse/FLINK-6090?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15966531#comment-15966531
]
ASF GitHub Bot commented on FLINK-6090:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-6090?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15966533#comment-15966533
]
ASF GitHub Bot commented on FLINK-6090:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-6090?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15966523#comment-15966523
]
ASF GitHub Bot commented on FLINK-6090:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-6090?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15966525#comment-15966525
]
ASF GitHub Bot commented on FLINK-6090:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-6090?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15966535#comment-15966535
]
ASF GitHub Bot commented on FLINK-6090:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-6090?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15966519#comment-15966519
]
ASF GitHub Bot commented on FLINK-6090:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-6090?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15966526#comment-15966526
]
ASF GitHub Bot commented on FLINK-6090:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-6090?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15966534#comment-15966534
]
ASF GitHub Bot commented on FLINK-6090:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-6090?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15966518#comment-15966518
]
ASF GitHub Bot commented on FLINK-6090:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-6090?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15966521#comment-15966521
]
ASF GitHub Bot commented on FLINK-6090:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-6090?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15966515#comment-15966515
]
ASF GitHub Bot commented on FLINK-6090:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-6090?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15966529#comment-15966529
]
ASF GitHub Bot commented on FLINK-6090:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-6090?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15966514#comment-15966514
]
ASF GitHub Bot commented on FLINK-6090:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-6090?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15966524#comment-15966524
]
ASF GitHub Bot commented on FLINK-6090:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-6090?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15966517#comment-15966517
]
ASF GitHub Bot commented on FLINK-6090:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-6090?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15966520#comment-15966520
]
ASF GitHub Bot commented on FLINK-6090:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-6090?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15966516#comment-15966516
]
ASF GitHub Bot commented on FLINK-6090:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-6090?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15966527#comment-15966527
]
ASF GitHub Bot commented on FLINK-6090:
---
Github user fhueske commented on a diff in
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3696#discussion_r110399631
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/datastream/DataStreamRetractionRule.scala
---
@@ -0,0 +1,341 @@
+
[
https://issues.apache.org/jira/browse/FLINK-6090?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15966530#comment-15966530
]
ASF GitHub Bot commented on FLINK-6090:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-6090?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15966522#comment-15966522
]
ASF GitHub Bot commented on FLINK-6090:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-6090?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15966532#comment-15966532
]
ASF GitHub Bot commented on FLINK-6090:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-6090?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15966513#comment-15966513
]
ASF GitHub Bot commented on FLINK-6090:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-6090?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15966528#comment-15966528
]
ASF GitHub Bot commented on FLINK-6090:
---
Github user fhueske commented on a diff in
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3696#discussion_r110388774
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/datastream/DataStreamRetractionRule.scala
---
@@ -0,0 +1,341 @@
+
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3696#discussion_r110401510
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/datastream/DataStreamRetractionRule.scala
---
@@ -0,0 +1,341 @@
+
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3696#discussion_r110376285
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/datastream/DataStreamCorrelate.scala
---
@@ -36,14 +36,14 @@ import o
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3696#discussion_r110390018
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/datastream/DataStreamRetractionRule.scala
---
@@ -0,0 +1,341 @@
+
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3696#discussion_r110392501
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/datastream/DataStreamRetractionRule.scala
---
@@ -0,0 +1,341 @@
+
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3696#discussion_r110389978
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/datastream/DataStreamRetractionRule.scala
---
@@ -0,0 +1,341 @@
+
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3696#discussion_r110392466
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/datastream/DataStreamRetractionRule.scala
---
@@ -0,0 +1,341 @@
+
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3696#discussion_r110398565
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/datastream/DataStreamRetractionRule.scala
---
@@ -0,0 +1,341 @@
+
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3696#discussion_r111246143
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/datastream/DataStreamRetractionRule.scala
---
@@ -0,0 +1,341 @@
+
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3696#discussion_r110393126
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/datastream/DataStreamRetractionRule.scala
---
@@ -0,0 +1,341 @@
+
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3696#discussion_r111244797
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/datastream/DataStreamRetractionRule.scala
---
@@ -0,0 +1,341 @@
+
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3696#discussion_r111247042
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/datastream/RetractionTrait.scala
---
@@ -0,0 +1,86 @@
+/*
+ *
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3696#discussion_r110401619
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/datastream/DataStreamRetractionRule.scala
---
@@ -0,0 +1,341 @@
+
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3696#discussion_r110388706
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/datastream/DataStreamRetractionRule.scala
---
@@ -0,0 +1,341 @@
+
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3696#discussion_r110390397
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/datastream/DataStreamRetractionRule.scala
---
@@ -0,0 +1,341 @@
+
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3696#discussion_r111246693
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/datastream/DataStreamRetractionRule.scala
---
@@ -0,0 +1,341 @@
+
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3696#discussion_r111245186
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/datastream/DataStreamRetractionRule.scala
---
@@ -0,0 +1,341 @@
+
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3696#discussion_r110398315
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/datastream/DataStreamRetractionRule.scala
---
@@ -0,0 +1,341 @@
+
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3696#discussion_r110403637
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/datastream/DataStreamRetractionRule.scala
---
@@ -0,0 +1,341 @@
+
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3696#discussion_r110401135
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/datastream/DataStreamRetractionRule.scala
---
@@ -0,0 +1,341 @@
+
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3696#discussion_r110392776
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/datastream/DataStreamRetractionRule.scala
---
@@ -0,0 +1,341 @@
+
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3696#discussion_r110391516
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/datastream/DataStreamRetractionRule.scala
---
@@ -0,0 +1,341 @@
+
[
https://issues.apache.org/jira/browse/FLINK-6301?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rahul Yadav updated FLINK-6301:
---
Attachment: jeprof.24611.3138.i3138.heap.svg
jeprof.24611.1695.i1695.heap.svg
Rahul Yadav created FLINK-6301:
--
Summary: Flink KafkaConnector09 leaks memory on reading compressed
messages due to a Kafka consumer bug
Key: FLINK-6301
URL: https://issues.apache.org/jira/browse/FLINK-6301
Github user fhueske commented on the issue:
https://github.com/apache/flink/pull/3700
Hi @rtudoran, thanks for the new PR. I'll try to have a look at #3714 in
the next days.
Can you close this PR yourself? We can not directly close it but have to
add the ID to the message of a com
[
https://issues.apache.org/jira/browse/FLINK-4169?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15966258#comment-15966258
]
Shashank Agarwal commented on FLINK-4169:
-
Again getting this error in flink 1.2,
[
https://issues.apache.org/jira/browse/FLINK-4149?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15966249#comment-15966249
]
ASF GitHub Bot commented on FLINK-4149:
---
Github user shashank734 commented on the is
Github user shashank734 commented on the issue:
https://github.com/apache/flink/pull/2202
Again getting this error. After changing state backend from Rocksdb it's
working fine.
```
04/12/2017 10:05:04 Job execution switched to status FAILING.
java.lang.RuntimeException
[
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}
LOG.
[
https://issues.apache.org/jira/browse/FLINK-5486?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15822346#comment-15822346
]
Ted Yu edited comment on FLINK-5486 at 4/12/17 4:25 PM:
Lock on St
[
https://issues.apache.org/jira/browse/FLINK-6286?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15966152#comment-15966152
]
ASF GitHub Bot commented on FLINK-6286:
---
Github user greghogan commented on the issu
Github user greghogan commented on the issue:
https://github.com/apache/flink/pull/3711
Would it be better to replace the outer if-statement (line 312) with the
test for the presence of `hbase`? And to log a message that `HBASE_CONF_DIR` is
defined but `hbase` was not found so no HBas
Github user rtudoran commented on the issue:
https://github.com/apache/flink/pull/3700
@fhueske This PR can be closed. I have addressed all remarks and
reimplemented everything in #3714
---
If your project is set up for it, you can reply to this email and have your
reply appear on Gi
[
https://issues.apache.org/jira/browse/FLINK-6075?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15966104#comment-15966104
]
ASF GitHub Bot commented on FLINK-6075:
---
Github user rtudoran commented on the issue
Github user rtudoran commented on the issue:
https://github.com/apache/flink/pull/3714
@fhueske @shijinkui @hongyuhong @stefanobortoli @sunjincheng121 @twalthr
I have re-implemented the Sort based on the specifications in the #3700
Please have a look
---
If your project is s
[
https://issues.apache.org/jira/browse/FLINK-6075?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15966098#comment-15966098
]
ASF GitHub Bot commented on FLINK-6075:
---
GitHub user rtudoran opened a pull request:
GitHub user rtudoran opened a pull request:
https://github.com/apache/flink/pull/3714
[FLINK-6075] - Support Limit/Top(Sort) for Stream SQL
Implement the sort based on process function
Thanks for contributing to Apache Flink. Before you open your pull request,
please take t
[
https://issues.apache.org/jira/browse/FLINK-1539?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15966071#comment-15966071
]
Chesnay Schepler commented on FLINK-1539:
-
[~Matzz] when are you calling getRuntim
[
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 : ((ContextEnvironm
[
https://issues.apache.org/jira/browse/FLINK-6286?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger updated FLINK-6286:
--
Component/s: Startup Shell Scripts
> hbase command not found error
> ---
[
https://issues.apache.org/jira/browse/FLINK-6286?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger updated FLINK-6286:
--
Component/s: Batch Connectors and Input/Output Formats
> hbase command not found error
> ---
[
https://issues.apache.org/jira/browse/FLINK-5855?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated FLINK-5855:
--
Description:
{code}
handlePendingFilesForPreviousCheckpoints(restoredState.pendingFilesPerCheckpoint);
[
https://issues.apache.org/jira/browse/FLINK-5987?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15942518#comment-15942518
]
Ted Yu edited comment on FLINK-5987 at 4/12/17 3:05 PM:
We can upg
[
https://issues.apache.org/jira/browse/FLINK-5943?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated FLINK-5943:
--
Description:
{code}
protected void shutdown(ApplicationStatus status, String msg) {
// Need to clear the
[
https://issues.apache.org/jira/browse/FLINK-6172?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15966010#comment-15966010
]
Ted Yu commented on FLINK-6172:
---
+1
> Potentially unclosed RandomAccessFile in HistoryServe
[
https://issues.apache.org/jira/browse/FLINK-1539?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15965967#comment-15965967
]
Mateusz Zakarczemny commented on FLINK-1539:
[~gyfora] [~mbalassi]
It is not f
Github user lingjinjiang commented on the issue:
https://github.com/apache/flink/pull/3711
Hi @greghogan , In the config.sh, there is a if statement identifies
whether HBASE_CONF_DIR is setted.
If the HBASE_CONF_DIR is setted, then will use the "hbase classpath"
command to add the
[
https://issues.apache.org/jira/browse/FLINK-6286?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15965966#comment-15965966
]
ASF GitHub Bot commented on FLINK-6286:
---
Github user lingjinjiang commented on the i
[
https://issues.apache.org/jira/browse/FLINK-4973?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15965884#comment-15965884
]
Andrey commented on FLINK-4973:
---
Was able to reproduce in 1.2.0.
It looks like components
[
https://issues.apache.org/jira/browse/FLINK-6286?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15965821#comment-15965821
]
ASF GitHub Bot commented on FLINK-6286:
---
Github user greghogan commented on the issu
Github user greghogan commented on the issue:
https://github.com/apache/flink/pull/3711
Hi @lingjinjiang, I am not familiar with configuring HBase for Flink and we
don't seem to have documentation on this. What does it mean to have
`HBASE_CONF_DIR` set but not have `hbase` available?
[
https://issues.apache.org/jira/browse/FLINK-5481?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15965774#comment-15965774
]
ASF GitHub Bot commented on FLINK-5481:
---
Github user DmytroShkvyra commented on the
Github user DmytroShkvyra commented on the issue:
https://github.com/apache/flink/pull/3127
Hi @StephanEwen could you continue review 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 have
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/3713
Looks good, +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 this feature
enabled and wishes s
[
https://issues.apache.org/jira/browse/FLINK-6299?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15965742#comment-15965742
]
ASF GitHub Bot commented on FLINK-6299:
---
Github user zentol commented on the issue:
1 - 100 of 110 matches
Mail list logo
