[
https://issues.apache.org/jira/browse/FLINK-3633?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15201893#comment-15201893
]
ASF GitHub Bot commented on FLINK-3633:
---
Github user rmetzger commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-3637?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lasse Dalegaard updated FLINK-3637:
---
Remaining Estimate: (was: 168h)
Original Estimate: (was: 168h)
> Change
Github user fhueske commented on the pull request:
https://github.com/apache/flink/pull/1553#issuecomment-198364412
Hi @ramkrish86, I thought about this PR and came to the conclusion that we
should not continue. The optimizer's design does not allow to modify operators
in or inject
[
https://issues.apache.org/jira/browse/FLINK-3179?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15201482#comment-15201482
]
ASF GitHub Bot commented on FLINK-3179:
---
Github user fhueske commented on the pull request:
[
https://issues.apache.org/jira/browse/FLINK-2997?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15201558#comment-15201558
]
ASF GitHub Bot commented on FLINK-2997:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-3633?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15201665#comment-15201665
]
ASF GitHub Bot commented on FLINK-3633:
---
Github user greghogan commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-3609?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15197296#comment-15197296
]
ASF GitHub Bot commented on FLINK-3609:
---
Github user fhueske commented on a diff in the pull
Github user mxm commented on the pull request:
https://github.com/apache/flink/pull/1764#issuecomment-197937643
Thanks @kl0u. In addition to the JavaDoc, we should also document this in
the streaming Programming Guide. Here:
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/1741#discussion_r56507764
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/clusterframework/FlinkResourceManager.java
---
@@ -0,0 +1,796 @@
+/*
+ * Licensed to the
[
https://issues.apache.org/jira/browse/FLINK-3544?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15199292#comment-15199292
]
ASF GitHub Bot commented on FLINK-3544:
---
Github user tillrohrmann commented on a diff in the pull
Jamie Grier created FLINK-3627:
--
Summary: Task stuck on lock in StreamSource when cancelling
Key: FLINK-3627
URL: https://issues.apache.org/jira/browse/FLINK-3627
Project: Flink
Issue Type: Bug
Fabian Hueske created FLINK-3632:
Summary: Clean up Table API exceptions
Key: FLINK-3632
URL: https://issues.apache.org/jira/browse/FLINK-3632
Project: Flink
Issue Type: Improvement
Github user zentol commented on the pull request:
https://github.com/apache/flink/pull/1794#issuecomment-197832914
Third time's the charm:
* the time of the last triggered checkpoint is stored
* when a checkpoint is triggered we check whether the interval has passed,
if so we
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/1810
---
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 fhueske commented on the pull request:
https://github.com/apache/flink/pull/1797#issuecomment-197340028
Removed `FlinkJoinUnionTransposeRule` and updated the PR.
---
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-3239?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15199162#comment-15199162
]
Stefano Baghino commented on FLINK-3239:
If no one is working on this I would assign this to
[
https://issues.apache.org/jira/browse/FLINK-2997?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15201594#comment-15201594
]
ASF GitHub Bot commented on FLINK-2997:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-3544?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15199290#comment-15199290
]
ASF GitHub Bot commented on FLINK-3544:
---
Github user tillrohrmann commented on a diff in the pull
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/1741#discussion_r56479509
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/clusterframework/FlinkResourceManager.java
---
@@ -0,0 +1,796 @@
+/*
+ * Licensed to the
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/1804#issuecomment-197412962
Can you close the issue manually? I forgot to include the close message
into the commit
---
If your project is set up for it, you can reply to this email and have
Github user ramkrish86 commented on the pull request:
https://github.com/apache/flink/pull/1788#issuecomment-197681445
Let me close and try to create a new pull request.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well.
Github user rmetzger commented on a diff in the pull request:
https://github.com/apache/flink/pull/1792#discussion_r56637650
--- Diff: docs/apis/streaming/connectors/elasticsearch2.md ---
@@ -0,0 +1,207 @@
+---
+title: "Elasticsearch 2.x Connector"
+
+# Sub-level
[
https://issues.apache.org/jira/browse/FLINK-3633?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15201635#comment-15201635
]
Greg Hogan edited comment on FLINK-3633 at 3/18/16 3:33 PM:
I am puzzled why
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/1776#discussion_r56664157
--- Diff:
flink-tests/src/test/java/org/apache/flink/test/distribution/TestDataDist.java
---
@@ -0,0 +1,77 @@
+/*
+ * Licensed to the Apache
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/1741#discussion_r56520101
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/clusterframework/FlinkResourceManager.java
---
@@ -0,0 +1,796 @@
+/*
+ * Licensed to the
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/1741#discussion_r56366895
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/clusterframework/FlinkResourceManager.java
---
@@ -0,0 +1,796 @@
+/*
+ *
Github user shikhar commented on a diff in the pull request:
https://github.com/apache/flink/pull/1690#discussion_r56450314
--- Diff:
flink-streaming-connectors/flink-connector-kafka-0.8/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaConsumer08.java
---
@@
[
https://issues.apache.org/jira/browse/FLINK-3544?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15199280#comment-15199280
]
ASF GitHub Bot commented on FLINK-3544:
---
Github user mxm commented on a diff in the pull request:
GitHub user fhueske opened a pull request:
https://github.com/apache/flink/pull/1801
[FLINK-3621] Improve documentation of memory configuration parameters
PR clarifies that the memory configuration parameters
`taskmanager.memory.size` and `taskmanager.memory.fraction` are also used
[
https://issues.apache.org/jira/browse/FLINK-2732?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15201430#comment-15201430
]
ASF GitHub Bot commented on FLINK-2732:
---
Github user rmetzger commented on the pull request:
Github user vasia commented on the pull request:
https://github.com/apache/flink/pull/1807#issuecomment-198336366
Yes, this sounds like a good idea. I would also have the library methods as
a separate page.
---
If your project is set up for it, you can reply to this email and have
GitHub user vasia opened a pull request:
https://github.com/apache/flink/pull/1820
[FLINK-3547] add support for streaming filter, project, and union in the
Table API
This PR adds:
- Java and Scala stream translators
- methods to convert a table to a DataStream and vice
Github user greghogan commented on a diff in the pull request:
https://github.com/apache/flink/pull/1818#discussion_r56676581
--- Diff: docs/setup/config.md ---
@@ -183,7 +184,7 @@ The following parameters configure Flink's JobManager
and TaskManagers.
-
Github user vasia commented on the pull request:
https://github.com/apache/flink/pull/1797#issuecomment-197357617
and 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 feature
Github user zentol commented on the pull request:
https://github.com/apache/flink/pull/1810#issuecomment-197857499
+1
---
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
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/1741#discussion_r56508199
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/clusterframework/FlinkResourceManager.java
---
@@ -0,0 +1,796 @@
+/*
+ * Licensed to the
[
https://issues.apache.org/jira/browse/FLINK-3609?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15197276#comment-15197276
]
ASF GitHub Bot commented on FLINK-3609:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-3633?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-3633:
-
Fix Version/s: 1.1.0
> Job submission silently fails when using user code types
>
[
https://issues.apache.org/jira/browse/FLINK-1964?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15197610#comment-15197610
]
ASF GitHub Bot commented on FLINK-1964:
---
Github user rmetzger commented on the pull request:
[
https://issues.apache.org/jira/browse/FLINK-3629?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15199486#comment-15199486
]
ASF GitHub Bot commented on FLINK-3629:
---
Github user aljoscha commented on the pull request:
Github user zentol commented on the pull request:
https://github.com/apache/flink/pull/1790#issuecomment-198348395
It also reduces the number of changed classes, since no new messsages to
the jobmanager had to be added.
---
If your project is set up for it, you can reply to this
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/1776#discussion_r56669752
--- Diff:
flink-tests/src/test/java/org/apache/flink/test/javaApiOperators/CustomDistributionITCase.java
---
@@ -0,0 +1,116 @@
+/*
+ * Licensed to
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/1741#discussion_r56373341
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/clusterframework/messages/SetWorkerPoolSize.java
---
@@ -0,0 +1,63 @@
+/*
+ *
[
https://issues.apache.org/jira/browse/FLINK-3544?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15199242#comment-15199242
]
ASF GitHub Bot commented on FLINK-3544:
---
Github user mxm commented on a diff in the pull request:
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/1776#discussion_r56669667
--- Diff:
flink-tests/src/test/java/org/apache/flink/test/javaApiOperators/CustomDistributionITCase.java
---
@@ -0,0 +1,116 @@
+/*
+ * Licensed to
Github user vasia commented on the pull request:
https://github.com/apache/flink/pull/1797#issuecomment-197342267
Thanks, will 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
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/1776#discussion_r56344247
--- Diff:
flink-tests/src/test/java/org/apache/flink/test/javaApiOperators/CustomDistributionITCase.java
---
@@ -0,0 +1,161 @@
+/*
+ * Licensed to
Gyula Fora created FLINK-3620:
-
Summary: Remove DbStateBackend
Key: FLINK-3620
URL: https://issues.apache.org/jira/browse/FLINK-3620
Project: Flink
Issue Type: Task
Components:
[
https://issues.apache.org/jira/browse/FLINK-3620?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15197277#comment-15197277
]
ASF GitHub Bot commented on FLINK-3620:
---
Github user uce commented on the pull request:
GitHub user aljoscha opened a pull request:
https://github.com/apache/flink/pull/1805
[FLINK-3614] Remove Non-Keyed Window Operator
Instead we use a dummy KeySelector and the regular WindowOperator now.
You can merge this pull request into a Git repository by running:
$ git
[
https://issues.apache.org/jira/browse/FLINK-3633?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15201749#comment-15201749
]
ASF GitHub Bot commented on FLINK-3633:
---
Github user greghogan commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-3632?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Vasia Kalavri resolved FLINK-3632.
--
Resolution: Fixed
Assignee: Fabian Hueske
Fix Version/s: 1.1.0
> Clean up Table
Github user ankurcha closed the pull request at:
https://github.com/apache/flink/pull/948
---
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 rmetzger commented on the pull request:
https://github.com/apache/flink/pull/1792#issuecomment-198313758
I resolved above issue by not using the `embedded Node` mode. I suggest not
to document it at all.
There is currently no way of disabling the `JarHell` check of ES.
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/1741#discussion_r56483788
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/clusterframework/FlinkResourceManager.java
---
@@ -0,0 +1,796 @@
+/*
+ * Licensed to the
[
https://issues.apache.org/jira/browse/FLINK-3428?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15199313#comment-15199313
]
ASF GitHub Bot commented on FLINK-3428:
---
Github user kl0u commented on the pull request:
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/1741#discussion_r56374504
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/clusterframework/messages/ShutdownClusterAfterJob.java
---
@@ -0,0 +1,46 @@
+/*
Ted Yu created FLINK-3635:
-
Summary: Potential null deference in
TwitterExample#SelectEnglishAndTokenizeFlatMap#flatMap
Key: FLINK-3635
URL: https://issues.apache.org/jira/browse/FLINK-3635
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-1984?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15201022#comment-15201022
]
ASF GitHub Bot commented on FLINK-1984:
---
Github user ankurcha closed the pull request at:
[
https://issues.apache.org/jira/browse/FLINK-3398?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15198677#comment-15198677
]
ASF GitHub Bot commented on FLINK-3398:
---
Github user shikhar commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-2732?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15197479#comment-15197479
]
ASF GitHub Bot commented on FLINK-2732:
---
Github user zentol commented on the pull request:
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/1741#discussion_r56482752
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/clusterframework/FlinkResourceManager.java
---
@@ -0,0 +1,796 @@
+/*
+ *
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/1741#discussion_r56368028
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/clusterframework/FlinkResourceManager.java
---
@@ -0,0 +1,796 @@
+/*
+ *
Github user chiwanpark commented on the pull request:
https://github.com/apache/flink/pull/1812#issuecomment-198181529
Thanks for contribution! :-)
---
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-3544?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15197721#comment-15197721
]
ASF GitHub Bot commented on FLINK-3544:
---
Github user tillrohrmann commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-3630?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Vasia Kalavri reassigned FLINK-3630:
Assignee: Vasia Kalavri
> Little mistake in documentation
>
[
https://issues.apache.org/jira/browse/FLINK-3544?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15197268#comment-15197268
]
ASF GitHub Bot commented on FLINK-3544:
---
Github user mxm commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-3621?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15197291#comment-15197291
]
ASF GitHub Bot commented on FLINK-3621:
---
Github user asfgit closed the pull request at:
[
https://issues.apache.org/jira/browse/FLINK-2997?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15201595#comment-15201595
]
ASF GitHub Bot commented on FLINK-2997:
---
Github user fhueske commented on a diff in the pull
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/1776#discussion_r56665371
--- Diff:
flink-tests/src/test/java/org/apache/flink/test/distribution/TestDataDist.java
---
@@ -0,0 +1,77 @@
+/*
+ * Licensed to the Apache
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/1776#discussion_r56344323
--- Diff:
flink-tests/src/test/java/org/apache/flink/test/javaApiOperators/CustomDistributionITCase.java
---
@@ -0,0 +1,161 @@
+/*
+ * Licensed to
[
https://issues.apache.org/jira/browse/FLINK-3633?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15201635#comment-15201635
]
Greg Hogan commented on FLINK-3633:
---
I am puzzled why this appears to work for some user classes yet
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/1741#discussion_r56518228
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/clusterframework/FlinkResourceManager.java
---
@@ -0,0 +1,796 @@
+/*
+ *
[
https://issues.apache.org/jira/browse/FLINK-3633?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15201670#comment-15201670
]
ASF GitHub Bot commented on FLINK-3633:
---
Github user tillrohrmann commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-3629?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15199478#comment-15199478
]
Aljoscha Krettek commented on FLINK-3629:
-
Nope, you did everything correctly. I just didn't
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/1741#discussion_r56479540
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/clusterframework/FlinkResourceManager.java
---
@@ -0,0 +1,796 @@
+/*
+ * Licensed to the
[
https://issues.apache.org/jira/browse/FLINK-3637?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek updated FLINK-3637:
Assignee: Lasse Dalegaard
> Change RollingSink Writer interface to allow wider range of
[
https://issues.apache.org/jira/browse/FLINK-3477?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15201616#comment-15201616
]
ASF GitHub Bot commented on FLINK-3477:
---
Github user fhueske commented on the pull request:
78 matches
Mail list logo
