[
https://issues.apache.org/jira/browse/FLINK-6225?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16005953#comment-16005953
]
ASF GitHub Bot commented on FLINK-6225:
---
Github user zentol commented on a diff in t
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/3748#discussion_r115911445
--- Diff: flink-connectors/flink-connector-cassandra/pom.xml ---
@@ -176,5 +176,23 @@ under the License.
Github user fanzhidongyzby commented on the issue:
https://github.com/apache/flink/pull/3802
@greghogan , when would this pr be merged ?
---
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 f
[
https://issues.apache.org/jira/browse/FLINK-6491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16005933#comment-16005933
]
ASF GitHub Bot commented on FLINK-6491:
---
Github user sunjincheng121 commented on the
Github user sunjincheng121 commented on the issue:
https://github.com/apache/flink/pull/3863
Hi @fhueske thanks a lot for your reviewing. I had update the PR. with
following changes:
* Uniform hump name, change all `qConfig` and `qConf` to `queryConfig`.
* Add warn log into `Da
[
https://issues.apache.org/jira/browse/FLINK-6491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16005922#comment-16005922
]
ASF GitHub Bot commented on FLINK-6491:
---
Github user sunjincheng121 commented on a d
Github user sunjincheng121 commented on a diff in the pull request:
https://github.com/apache/flink/pull/3863#discussion_r115908788
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/datastream/DataStreamOverAggregate.scala
---
@@ -239,6 +248,7
[
https://issues.apache.org/jira/browse/FLINK-6491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16005913#comment-16005913
]
ASF GitHub Bot commented on FLINK-6491:
---
Github user sunjincheng121 commented on a d
Github user sunjincheng121 commented on a diff in the pull request:
https://github.com/apache/flink/pull/3863#discussion_r115907975
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/ProcessFunctionWithCleanupState.scala
---
@@ -0,0 +1,99
Eron Wright created FLINK-6532:
---
Summary: Mesos version check
Key: FLINK-6532
URL: https://issues.apache.org/jira/browse/FLINK-6532
Project: Flink
Issue Type: Improvement
Components:
[
https://issues.apache.org/jira/browse/FLINK-6502?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16005806#comment-16005806
]
ASF GitHub Bot commented on FLINK-6502:
---
GitHub user 397090770 opened a pull request
GitHub user 397090770 opened a pull request:
https://github.com/apache/flink/pull/3869
[FLINK-6502] Add support ElasticsearchSink for DataSet
Currently, Flink only support writing data in `DataStream` to ElasticSearch
through `ElasticsearchSink`, it will be very useful if Flink int
[
https://issues.apache.org/jira/browse/FLINK-6502?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
wyp updated FLINK-6502:
---
Summary: Add Support ElasticsearchSink for DataSet (was: Support writing
data in DataSet to ElasticSearch)
> Add Sup
[
https://issues.apache.org/jira/browse/FLINK-6502?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
wyp updated FLINK-6502:
---
Summary: Add support ElasticsearchSink for DataSet (was: Add Support
ElasticsearchSink for DataSet)
> Add support El
[
https://issues.apache.org/jira/browse/FLINK-6491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16005751#comment-16005751
]
ASF GitHub Bot commented on FLINK-6491:
---
Github user sunjincheng121 commented on a d
Github user sunjincheng121 commented on a diff in the pull request:
https://github.com/apache/flink/pull/3863#discussion_r115888057
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/StreamTableEnvironment.scala
---
@@ -81,6 +81,8 @@ abstract class Str
[
https://issues.apache.org/jira/browse/FLINK-4534?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated FLINK-4534:
--
Description:
Iteration over state.bucketStates is protected by synchronization in other
methods, except for the
[
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 5/11/17 1:04 AM:
Lock on St
[
https://issues.apache.org/jira/browse/FLINK-6105?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated FLINK-6105:
--
Description:
When catching InterruptedException, we should throw InterruptedIOException
instead of IOException.
[
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-5488?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16005742#comment-16005742
]
Ted Yu commented on FLINK-5488:
---
I agree.
> yarnClient should be closed in AbstractYarnClus
[
https://issues.apache.org/jira/browse/FLINK-6332?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16005740#comment-16005740
]
Ted Yu commented on FLINK-6332:
---
We can wait for newer Scala release for more visible benefi
[
https://issues.apache.org/jira/browse/FLINK-6414?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16005717#comment-16005717
]
ASF GitHub Bot commented on FLINK-6414:
---
Github user greghogan commented on the issu
Github user greghogan commented on the issue:
https://github.com/apache/flink/pull/3800
@StephanEwen does the recent discussion on packaging shaded dependencies
mean that `force-shading` will go away? Or do we keep that even if dependencies
are no longer being shaded? Or will only som
[
https://issues.apache.org/jira/browse/FLINK-6529?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16005710#comment-16005710
]
Greg Hogan commented on FLINK-6529:
---
[~wheat9] appreciate your enthusiasm and just wante
Github user rbonifacio commented on the issue:
https://github.com/apache/flink/pull/3866
@greghogan I changed the files, introducing the missing spaces after
catches. Thanks!
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as wel
[
https://issues.apache.org/jira/browse/FLINK-6232?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16005634#comment-16005634
]
ASF GitHub Bot commented on FLINK-6232:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-6232?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16005644#comment-16005644
]
ASF GitHub Bot commented on FLINK-6232:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-6232?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16005645#comment-16005645
]
ASF GitHub Bot commented on FLINK-6232:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-6232?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16005649#comment-16005649
]
ASF GitHub Bot commented on FLINK-6232:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-6232?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16005641#comment-16005641
]
ASF GitHub Bot commented on FLINK-6232:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-6232?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16005636#comment-16005636
]
ASF GitHub Bot commented on FLINK-6232:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-6232?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16005632#comment-16005632
]
ASF GitHub Bot commented on FLINK-6232:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-6232?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16005623#comment-16005623
]
ASF GitHub Bot commented on FLINK-6232:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-6232?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16005630#comment-16005630
]
ASF GitHub Bot commented on FLINK-6232:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-6232?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16005631#comment-16005631
]
ASF GitHub Bot commented on FLINK-6232:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-6232?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16005637#comment-16005637
]
ASF GitHub Bot commented on FLINK-6232:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-6232?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16005642#comment-16005642
]
ASF GitHub Bot commented on FLINK-6232:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-6232?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16005622#comment-16005622
]
ASF GitHub Bot commented on FLINK-6232:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-6232?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16005635#comment-16005635
]
ASF GitHub Bot commented on FLINK-6232:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-6232?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16005638#comment-16005638
]
ASF GitHub Bot commented on FLINK-6232:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-6232?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16005643#comment-16005643
]
ASF GitHub Bot commented on FLINK-6232:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-6232?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16005633#comment-16005633
]
ASF GitHub Bot commented on FLINK-6232:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-6232?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16005648#comment-16005648
]
ASF GitHub Bot commented on FLINK-6232:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-6232?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16005646#comment-16005646
]
ASF GitHub Bot commented on FLINK-6232:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-6232?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16005624#comment-16005624
]
ASF GitHub Bot commented on FLINK-6232:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-6232?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16005639#comment-16005639
]
ASF GitHub Bot commented on FLINK-6232:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-6232?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16005647#comment-16005647
]
ASF GitHub Bot commented on FLINK-6232:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-6232?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16005625#comment-16005625
]
ASF GitHub Bot commented on FLINK-6232:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-6232?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16005640#comment-16005640
]
ASF GitHub Bot commented on FLINK-6232:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-6232?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16005628#comment-16005628
]
ASF GitHub Bot commented on FLINK-6232:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-6232?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16005626#comment-16005626
]
ASF GitHub Bot commented on FLINK-6232:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-6232?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16005627#comment-16005627
]
ASF GitHub Bot commented on FLINK-6232:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-6232?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16005629#comment-16005629
]
ASF GitHub Bot commented on FLINK-6232:
---
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/3715#discussion_r115868422
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/join/ProcTimeInnerJoin.scala
---
@@ -0,0 +1,323 @@
+/*
+ * Licen
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3715#discussion_r115855446
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/datastream/DataStreamJoin.scala
---
@@ -0,0 +1,180 @@
+/*
+ *
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3715#discussion_r115873645
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/join/ProcTimeInnerJoin.scala
---
@@ -0,0 +1,323 @@
+/*
+ * Licen
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3715#discussion_r115868097
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/join/JoinUtil.scala
---
@@ -0,0 +1,488 @@
+/*
+ * Licensed to th
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3715#discussion_r115868597
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/join/ProcTimeInnerJoin.scala
---
@@ -0,0 +1,323 @@
+/*
+ * Licen
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3715#discussion_r115874115
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/FilterRunner.scala
---
@@ -0,0 +1,54 @@
+/*
+ * Licensed to the
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3715#discussion_r115796448
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/rules/datastream/DataStreamJoinRule.scala
---
@@ -0,0 +1,69 @@
+/*
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3715#discussion_r115874289
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/codegen/CodeGenerator.scala
---
@@ -698,6 +698,12 @@ class CodeGenerator(
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3715#discussion_r115851247
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/join/JoinUtil.scala
---
@@ -0,0 +1,488 @@
+/*
+ * Licensed to th
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3715#discussion_r115866207
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/join/ProcTimeInnerJoin.scala
---
@@ -0,0 +1,323 @@
+/*
+ * Licen
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3715#discussion_r115873251
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/join/ProcTimeInnerJoin.scala
---
@@ -0,0 +1,323 @@
+/*
+ * Licen
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3715#discussion_r115866096
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/join/ProcTimeInnerJoin.scala
---
@@ -0,0 +1,323 @@
+/*
+ * Licen
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3715#discussion_r115864221
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/datastream/DataStreamJoin.scala
---
@@ -0,0 +1,180 @@
+/*
+ *
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3715#discussion_r115864005
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/FilterRunner.scala
---
@@ -0,0 +1,54 @@
+/*
+ * Licensed to the
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3715#discussion_r115852606
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/datastream/DataStreamJoin.scala
---
@@ -0,0 +1,180 @@
+/*
+ *
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3715#discussion_r115873581
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/join/ProcTimeInnerJoin.scala
---
@@ -0,0 +1,323 @@
+/*
+ * Licen
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3715#discussion_r115845838
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/rules/datastream/DataStreamJoinRule.scala
---
@@ -0,0 +1,69 @@
+/*
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3715#discussion_r115871238
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/join/ProcTimeInnerJoin.scala
---
@@ -0,0 +1,323 @@
+/*
+ * Licen
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3715#discussion_r115872865
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/join/ProcTimeInnerJoin.scala
---
@@ -0,0 +1,323 @@
+/*
+ * Licen
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3715#discussion_r115844805
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/rules/datastream/DataStreamJoinRule.scala
---
@@ -0,0 +1,69 @@
+/*
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3715#discussion_r115847719
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/datastream/DataStreamJoin.scala
---
@@ -0,0 +1,180 @@
+/*
+ *
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3715#discussion_r115874222
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/datastream/DataStreamJoin.scala
---
@@ -0,0 +1,180 @@
+/*
+ *
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3715#discussion_r115847866
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/datastream/DataStreamJoin.scala
---
@@ -0,0 +1,180 @@
+/*
+ *
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3715#discussion_r115852788
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/datastream/DataStreamJoin.scala
---
@@ -0,0 +1,180 @@
+/*
+ *
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3715#discussion_r115864982
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/join/ProcTimeInnerJoin.scala
---
@@ -0,0 +1,323 @@
+/*
+ * Licen
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3715#discussion_r115865585
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/join/ProcTimeInnerJoin.scala
---
@@ -0,0 +1,323 @@
+/*
+ * Licen
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3715#discussion_r115850396
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/datastream/DataStreamJoin.scala
---
@@ -0,0 +1,180 @@
+/*
+ *
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3715#discussion_r115875501
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/join/ProcTimeInnerJoin.scala
---
@@ -0,0 +1,323 @@
+/*
+ * Licen
[
https://issues.apache.org/jira/browse/FLINK-5536?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16005585#comment-16005585
]
Stavros Kontopoulos edited comment on FLINK-5536 at 5/10/17 10:43 PM:
--
[
https://issues.apache.org/jira/browse/FLINK-5536?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16005585#comment-16005585
]
Stavros Kontopoulos commented on FLINK-5536:
https://github.com/mesosphere/dco
[
https://issues.apache.org/jira/browse/FLINK-6225?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16005509#comment-16005509
]
ASF GitHub Bot commented on FLINK-6225:
---
Github user haohui commented on a diff in t
Github user haohui commented on a diff in the pull request:
https://github.com/apache/flink/pull/3748#discussion_r115861002
--- Diff: flink-connectors/flink-connector-cassandra/pom.xml ---
@@ -176,5 +176,23 @@ under the License.
[
https://issues.apache.org/jira/browse/FLINK-6225?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16005494#comment-16005494
]
ASF GitHub Bot commented on FLINK-6225:
---
Github user zentol commented on a diff in t
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/3748#discussion_r115859400
--- Diff: flink-connectors/flink-connector-cassandra/pom.xml ---
@@ -176,5 +176,23 @@ under the License.
[
https://issues.apache.org/jira/browse/FLINK-6531?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16005401#comment-16005401
]
ASF GitHub Bot commented on FLINK-6531:
---
Github user EronWright closed the pull requ
Github user EronWright closed the pull request at:
https://github.com/apache/flink/pull/3867
---
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 EronWright commented on the issue:
https://github.com/apache/flink/pull/3868
The title should refer to FLINK-6531
---
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
enab
[
https://issues.apache.org/jira/browse/FLINK-6531?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16005364#comment-16005364
]
ASF GitHub Bot commented on FLINK-6531:
---
Github user StephanEwen commented on the is
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/3867
@EronWright Here is a slightly modified version of your code:
https://github.com/apache/flink/pull/3868
I added a small test to also validate the class loading.
---
If your project is s
GitHub user StephanEwen opened a pull request:
https://github.com/apache/flink/pull/3868
[FLINK-6532] [checkpoints] Ensure proper classloading for user-defined
checkpoint hooks
This also adds a test that validates that the correct class loader is
passed.
Note the neat tric
[
https://issues.apache.org/jira/browse/FLINK-6529?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16005350#comment-16005350
]
Haohui Mai commented on FLINK-6529:
---
That makes sense as we are being hit by this proble
[
https://issues.apache.org/jira/browse/FLINK-6529?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Haohui Mai reassigned FLINK-6529:
-
Assignee: Haohui Mai
> Rework the shading model in Flink
> -
>
>
[
https://issues.apache.org/jira/browse/FLINK-4499?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16005325#comment-16005325
]
ASF GitHub Bot commented on FLINK-4499:
---
Github user tedyu commented on the issue:
Github user tedyu commented on the issue:
https://github.com/apache/flink/pull/2422
Hadoop has switched to spotbugs
---
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 wi
[
https://issues.apache.org/jira/browse/FLINK-4499?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16005283#comment-16005283
]
ASF GitHub Bot commented on FLINK-4499:
---
Github user greghogan commented on the issu
1 - 100 of 384 matches
Mail list logo
