[
https://issues.apache.org/jira/browse/FLINK-4817?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Wei-Che Wei reassigned FLINK-4817:
--
Assignee: (was: Wei-Che Wei)
> Checkpoint Coordinator should be called to restore state wit
[
https://issues.apache.org/jira/browse/FLINK-4816?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15896781#comment-15896781
]
ramkrishna.s.vasudevan commented on FLINK-4816:
---
[~tonywei]
I would like to
[
https://issues.apache.org/jira/browse/FLINK-5957?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15896761#comment-15896761
]
sunjincheng edited comment on FLINK-5957 at 3/6/17 5:32 AM:
Hi
[
https://issues.apache.org/jira/browse/FLINK-5957?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15896761#comment-15896761
]
sunjincheng commented on FLINK-5957:
Hi, [~fhueske], I have two ideas here:
First of a
Github user beyond1920 commented on a diff in the pull request:
https://github.com/apache/flink/pull/3406#discussion_r104343965
--- Diff:
flink-libraries/flink-table/src/test/scala/org/apache/flink/table/utils/CommonTestData.scala
---
@@ -68,6 +62,90 @@ object CommonTestData {
Github user beyond1920 commented on a diff in the pull request:
https://github.com/apache/flink/pull/3406#discussion_r104343679
--- Diff:
flink-libraries/flink-table/src/test/scala/org/apache/flink/table/utils/CommonTestData.scala
---
@@ -68,6 +62,90 @@ object CommonTestData {
[
https://issues.apache.org/jira/browse/FLINK-5957?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sunjincheng updated FLINK-5957:
---
Summary: Remove `getAccumulatorType` method from build-in
`AggregateFunction` (was: Remove `getAccu
[
https://issues.apache.org/jira/browse/FLINK-2720?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15896722#comment-15896722
]
ASF GitHub Bot commented on FLINK-2720:
---
Github user RalphSu commented on the issue:
Github user RalphSu commented on the issue:
https://github.com/apache/flink/pull/1157
okey, would try file a PR on this soon
---
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
enabl
[
https://issues.apache.org/jira/browse/FLINK-4848?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15582930#comment-15582930
]
Ted Yu edited comment on FLINK-4848 at 3/6/17 3:57 AM:
---
There is sim
Github user beyond1920 commented on a diff in the pull request:
https://github.com/apache/flink/pull/3406#discussion_r104340593
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/catalog/ExternalCatalogSchema.scala
---
@@ -0,0 +1,166 @@
+/*
+ * Lic
[
https://issues.apache.org/jira/browse/FLINK-5902?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
shijinkui updated FLINK-5902:
-
Issue Type: Sub-task (was: Bug)
Parent: FLINK-5839
> Some images can not show in IE
> ---
[
https://issues.apache.org/jira/browse/FLINK-4460?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=1589#comment-1589
]
ASF GitHub Bot commented on FLINK-4460:
---
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/3438#discussion_r104334699
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/ProcessFunction.java
---
@@ -19,30 +19,35 @@
package org.apache
Github user beyond1920 commented on a diff in the pull request:
https://github.com/apache/flink/pull/3406#discussion_r104333889
--- Diff: flink-libraries/flink-table/pom.xml ---
@@ -92,7 +92,12 @@ under the License.
-
+
[
https://issues.apache.org/jira/browse/FLINK-4364?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15896637#comment-15896637
]
ASF GitHub Bot commented on FLINK-4364:
---
Github user zhijiangW commented on the issu
StephenWithPH created FLINK-5966:
Summary: Document Running Flink on Kubernetes
Key: FLINK-5966
URL: https://issues.apache.org/jira/browse/FLINK-5966
Project: Flink
Issue Type: Improvement
Github user zhijiangW commented on the issue:
https://github.com/apache/flink/pull/3151
Hi @tillrohrmann , I have submitted the modifications as you suggest one
week ago. Have you received it and any other issues?
---
If your project is set up for it, you can reply to this email and
Github user mjsax commented on the issue:
https://github.com/apache/flink/pull/1157
@HuangWHWHW Are you still working on this? @RalphSu Are you interested in
talking this over?
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as w
[
https://issues.apache.org/jira/browse/FLINK-2720?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15896579#comment-15896579
]
ASF GitHub Bot commented on FLINK-2720:
---
Github user mjsax commented on the issue:
[
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
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/3475
+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 so, or if the
[
https://issues.apache.org/jira/browse/FLINK-5965?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15896491#comment-15896491
]
ASF GitHub Bot commented on FLINK-5965:
---
Github user zentol commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-5909?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15896265#comment-15896265
]
ASF GitHub Bot commented on FLINK-5909:
---
Github user greghogan commented on the issu
Github user greghogan commented on the issue:
https://github.com/apache/flink/pull/3434
Thanks for the review @vasia. The Unary/Binary/TertiaryResult interfaces
will allow follow-on algorithms to work with POJOs or non-conforming Tuples
(where we don't assume source and target vertice
[
https://issues.apache.org/jira/browse/FLINK-3679?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15896252#comment-15896252
]
ASF GitHub Bot commented on FLINK-3679:
---
Github user tzulitai commented on a diff in
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/3314#discussion_r104311996
--- 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&focusedCommentId=15896253#comment-15896253
]
ASF GitHub Bot commented on FLINK-3679:
---
Github user tzulitai commented on a diff in
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/3314#discussion_r104312079
--- Diff:
flink-connectors/flink-connector-kafka-0.9/src/test/java/org/apache/flink/streaming/connectors/kafka/Kafka09FetcherTest.java
---
@@ -419,6 +424,1
Github user RalphSu commented on the issue:
https://github.com/apache/flink/pull/1157
?
---
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 i
[
https://issues.apache.org/jira/browse/FLINK-2720?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15896239#comment-15896239
]
ASF GitHub Bot commented on FLINK-2720:
---
Github user RalphSu commented on the issue:
Github user RalphSu commented on the issue:
https://github.com/apache/flink/pull/1157
Here it looks user need to change code to make metrics work
---
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 ha
[
https://issues.apache.org/jira/browse/FLINK-2720?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15896238#comment-15896238
]
ASF GitHub Bot commented on FLINK-2720:
---
Github user RalphSu commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-2720?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15896237#comment-15896237
]
ASF GitHub Bot commented on FLINK-2720:
---
Github user RalphSu commented on the issue:
Github user RalphSu commented on the issue:
https://github.com/apache/flink/pull/1157
Here it looks user need to change code to make metrics work
---
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 ha
Github user RalphSu commented on the issue:
https://github.com/apache/flink/pull/1157
Any progress on this one? Looks this has been stop for a while.
---
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 no
[
https://issues.apache.org/jira/browse/FLINK-2720?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15896234#comment-15896234
]
ASF GitHub Bot commented on FLINK-2720:
---
Github user RalphSu commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-2720?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15896231#comment-15896231
]
ASF GitHub Bot commented on FLINK-2720:
---
Github user RalphSu commented on a diff in
Github user RalphSu commented on a diff in the pull request:
https://github.com/apache/flink/pull/1157#discussion_r104311095
--- Diff:
flink-contrib/flink-storm-compatibility/flink-storm-compatibility-core/src/main/java/org/apache/flink/stormcompatibility/api/FlinkTopologyContext.java
Github user RalphSu commented on a diff in the pull request:
https://github.com/apache/flink/pull/1157#discussion_r104311065
--- Diff:
flink-contrib/flink-storm-compatibility/flink-storm-compatibility-core/src/main/java/org/apache/flink/stormcompatibility/api/FlinkTopologyContext.java
[
https://issues.apache.org/jira/browse/FLINK-2720?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15896228#comment-15896228
]
ASF GitHub Bot commented on FLINK-2720:
---
Github user RalphSu commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-4816?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15896187#comment-15896187
]
Wei-Che Wei commented on FLINK-4816:
Hi [~ram_krish]
If you have been working on it,
42 matches
Mail list logo
