[
https://issues.apache.org/jira/browse/FLINK-2435?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15708691#comment-15708691
]
Anton Mushin commented on FLINK-2435:
-
Hi [~fhueske]
could you tell for what case need new abstract
[
https://issues.apache.org/jira/browse/FLINK-5193?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15708684#comment-15708684
]
ASF GitHub Bot commented on FLINK-5193:
---
Github user uce commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-5193?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15708682#comment-15708682
]
ASF GitHub Bot commented on FLINK-5193:
---
Github user uce commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-5193?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15708683#comment-15708683
]
ASF GitHub Bot commented on FLINK-5193:
---
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/2910#discussion_r90235653
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/jobmanager/ZooKeeperSubmittedJobGraphStore.java
---
@@ -275,6 +242,25 @@ public void
Till Rohrmann created FLINK-5210:
Summary: Failing performCheckpoint method causes task to fail
Key: FLINK-5210
URL: https://issues.apache.org/jira/browse/FLINK-5210
Project: Flink
Issue
Github user uce commented on a diff in the pull request:
https://github.com/apache/flink/pull/2910#discussion_r90237601
--- Diff:
flink-runtime/src/main/scala/org/apache/flink/runtime/jobmanager/JobManager.scala
---
@@ -505,37 +507,31 @@ class JobManager(
}
Github user uce commented on a diff in the pull request:
https://github.com/apache/flink/pull/2910#discussion_r90235223
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/jobmanager/SubmittedJobGraphStore.java
---
@@ -64,6 +57,14 @@
void removeJobGraph(JobID
[
https://issues.apache.org/jira/browse/FLINK-2435?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Anton Mushin reassigned FLINK-2435:
---
Assignee: Anton Mushin
> Add support for custom CSV field parsers
>
Github user uce commented on a diff in the pull request:
https://github.com/apache/flink/pull/2899#discussion_r90235045
--- Diff: flink-dist/src/main/flink-bin/conf/log4j.properties ---
@@ -16,14 +16,26 @@
# limitations under the License.
Github user rmetzger commented on a diff in the pull request:
https://github.com/apache/flink/pull/2899#discussion_r90234726
--- Diff: flink-dist/src/main/flink-bin/conf/log4j.properties ---
@@ -16,14 +16,26 @@
# limitations under the License.
Github user uce commented on a diff in the pull request:
https://github.com/apache/flink/pull/2899#discussion_r90233890
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/TaskState.java
---
@@ -168,4 +168,21 @@ public boolean equals(Object obj) {
Github user uce commented on a diff in the pull request:
https://github.com/apache/flink/pull/2899#discussion_r90233907
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/fs/hdfs/HadoopFileSystem.java
---
@@ -211,17 +209,14 @@ public HadoopFileSystem(Class fsClass
[
https://issues.apache.org/jira/browse/FLINK-3053?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15708611#comment-15708611
]
Robert Metzger commented on FLINK-3053:
---
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/2899#discussion_r90229315
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/TaskState.java
---
@@ -168,4 +168,21 @@ public boolean equals(Object obj) {
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/2899#discussion_r90229425
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/fs/hdfs/HadoopFileSystem.java
---
@@ -211,17 +209,14 @@ public HadoopFileSystem(Class
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/2899#discussion_r90228943
--- Diff: flink-dist/src/main/flink-bin/conf/log4j.properties ---
@@ -16,14 +16,26 @@
# limitations under the License.
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/2899#discussion_r90229390
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/fs/hdfs/HadoopFileSystem.java
---
@@ -211,17 +209,14 @@ public HadoopFileSystem(Class
[
https://issues.apache.org/jira/browse/FLINK-5193?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15708557#comment-15708557
]
ASF GitHub Bot commented on FLINK-5193:
---
GitHub user tillrohrmann opened a pull request:
GitHub user tillrohrmann opened a pull request:
https://github.com/apache/flink/pull/2910
[backport] [FLINK-5193] [jm] Harden job recovery in case of recovery
failures
This is a backport of #2909 to the release 1.1 branch.
When recovering multiple jobs a single recovery
[
https://issues.apache.org/jira/browse/FLINK-5193?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15708551#comment-15708551
]
ASF GitHub Bot commented on FLINK-5193:
---
GitHub user tillrohrmann opened a pull request:
GitHub user tillrohrmann opened a pull request:
https://github.com/apache/flink/pull/2909
[FLINK-5193] [jm] Harden job recovery in case of recovery failures
When recovering multiple jobs a single recovery failure caused all jobs to
be not recovered.
This PR changes this
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/2908
had small comment, but looks good. The `builder-helper-maven-plugin` block
is identical to the ones used in other modules containing scala code.
---
If your project is set up for it, you can reply
[
https://issues.apache.org/jira/browse/FLINK-5197?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15708503#comment-15708503
]
ASF GitHub Bot commented on FLINK-5197:
---
Github user tillrohrmann closed the pull request at:
[
https://issues.apache.org/jira/browse/FLINK-5197?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15708500#comment-15708500
]
ASF GitHub Bot commented on FLINK-5197:
---
Github user tillrohrmann closed the pull request at:
[
https://issues.apache.org/jira/browse/FLINK-5197?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15708502#comment-15708502
]
ASF GitHub Bot commented on FLINK-5197:
---
Github user tillrohrmann commented on the issue:
Github user tillrohrmann closed the pull request at:
https://github.com/apache/flink/pull/2895
---
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
Github user tillrohrmann commented on the issue:
https://github.com/apache/flink/pull/2895
Forgot to include the closing tag in the commit.
---
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 tillrohrmann closed the pull request at:
https://github.com/apache/flink/pull/2896
---
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
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/2908#discussion_r90225400
--- Diff: flink-libraries/flink-cep-scala/pom.xml ---
@@ -93,6 +93,8 @@ under the License.
+
+src/main/scala
[
https://issues.apache.org/jira/browse/FLINK-5197?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann closed FLINK-5197.
Resolution: Fixed
1.2.0 fixed via ae0975c16b997fe792790216820a559d01a01894
1.1.4 fixed via
[
https://issues.apache.org/jira/browse/FLINK-5197?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15708494#comment-15708494
]
ASF GitHub Bot commented on FLINK-5197:
---
Github user tillrohrmann commented on the issue:
Github user tillrohrmann commented on the issue:
https://github.com/apache/flink/pull/2895
Merging this PR. @uce reviewed the backport.
---
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-5197?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15708485#comment-15708485
]
ASF GitHub Bot commented on FLINK-5197:
---
Github user tillrohrmann commented on the issue:
Github user tillrohrmann commented on the issue:
https://github.com/apache/flink/pull/2896
Thanks for the review @uce. Failing test cases are unrelated. Merging 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.
[
https://issues.apache.org/jira/browse/FLINK-5088?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15708432#comment-15708432
]
ASF GitHub Bot commented on FLINK-5088:
---
Github user uce commented on the issue:
Github user uce commented on the issue:
https://github.com/apache/flink/pull/2883
I renamed the config key and added unit tests for the sub components. This
should be good enough to get it in if Travis gives us an OK. As a follow up I
would like to finish a end to end test similar to
[
https://issues.apache.org/jira/browse/FLINK-4611?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske updated FLINK-4611:
-
Assignee: Wei-Che Wei
> Make "AUTO" credential provider as default for Kinesis Connector
>
GitHub user mxm opened a pull request:
https://github.com/apache/flink/pull/2908
[maven] properly attach the CEP Scala source code
Two options, either change the default Maven source directory from
'src/main/java' to 'src/main/scala' or use the build-helper-maven-plugin
to
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/2876#discussion_r90209936
--- Diff:
flink-java/src/test/java/org/apache/flink/api/java/io/TextInputFormatTest.java
---
@@ -90,7 +91,9 @@ public void testSimpleRead() {
[
https://issues.apache.org/jira/browse/FLINK-5166?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15708231#comment-15708231
]
ASF GitHub Bot commented on FLINK-5166:
---
Github user zentol commented on a diff in the pull request:
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/2897
This looks good; we should merge it at soon as possible.
---
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-4676?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15708217#comment-15708217
]
ASF GitHub Bot commented on FLINK-4676:
---
Github user zentol commented on the issue:
Github user mxm commented on the issue:
https://github.com/apache/flink/pull/2900
Rebased again to the latest Mesos changes to make sure tests pass.
---
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
[
https://issues.apache.org/jira/browse/FLINK-4905?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15708105#comment-15708105
]
Andrew Efimov edited comment on FLINK-4905 at 11/30/16 10:38 AM:
-
Hi
[
https://issues.apache.org/jira/browse/FLINK-5164?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15708191#comment-15708191
]
ASF GitHub Bot commented on FLINK-5164:
---
Github user zentol commented on the issue:
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/2889
@fhueske Thank you for the review. I'll add a comment and merge it.
---
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
[
https://issues.apache.org/jira/browse/FLINK-4905?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15708105#comment-15708105
]
Andrew Efimov edited comment on FLINK-4905 at 11/30/16 10:34 AM:
-
Hi
GitHub user wangzhijiang999 opened a pull request:
https://github.com/apache/flink/pull/2907
[FLINK-5135][JM]ResourceProfile for slot request should be expanded to
correspond with ResourceSpec
Currently the **ResourceProfile** only contains cpu cores and memory
properties. The
[
https://issues.apache.org/jira/browse/FLINK-5138?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang Wang reassigned FLINK-5138:
Assignee: Zhijiang Wang
> The StateBackend provides the method to estimate memory usage
[
https://issues.apache.org/jira/browse/FLINK-4905?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15708105#comment-15708105
]
Andrew Efimov commented on FLINK-4905:
--
Hi [~tzulitai]
Thanks for reply.
It is very difficult to
GitHub user wangzhijiang999 opened a pull request:
https://github.com/apache/flink/pull/2906
[FLINK-5132][FLINK-5133][FLINK-5134][Core,DataStream API,DataSet API]
Fine-grained Resource Configuration
Introduce the **ResourceSpec** structure to describe the different resource
[
https://issues.apache.org/jira/browse/FLINK-5132?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15708097#comment-15708097
]
ASF GitHub Bot commented on FLINK-5132:
---
GitHub user wangzhijiang999 opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-4905?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Andrew Efimov updated FLINK-4905:
-
Attachment: Kafka08Fetcher.png
> Kafka test instability IllegalStateException: Client is not
Github user twalthr commented on the issue:
https://github.com/apache/flink/pull/2653
I have already reviewed half of the new code. I will review the rest
tomorrow.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If
[
https://issues.apache.org/jira/browse/FLINK-5190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15708017#comment-15708017
]
ASF GitHub Bot commented on FLINK-5190:
---
GitHub user shuai-xu opened a pull request:
GitHub user shuai-xu opened a pull request:
https://github.com/apache/flink/pull/2905
[FLINK-5190] [runtime] fix ZooKeeperLeaderRetrievalService close the â¦
This pr is for jira
#[5190](https://issues.apache.org/jira/browse/FLINK-5190).
The zk client for
[
https://issues.apache.org/jira/browse/FLINK-5091?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15707963#comment-15707963
]
ASF GitHub Bot commented on FLINK-5091:
---
GitHub user EronWright opened a pull request:
GitHub user EronWright opened a pull request:
https://github.com/apache/flink/pull/2904
[FLINK-5091] Formalize the Mesos AppMaster environment for docker
compatibility
Fixes FLINK-5091 and FLINK-4826.
- introduced ContainerSpecification.
- reworked how the TM container
GitHub user shuai-xu opened a pull request:
https://github.com/apache/flink/pull/2903
[FLINK-5704] [runtime] add a zookeeper based running job registry
This pr is for jira
#[5074](https://issues.apache.org/jira/browse/FLINK-5074).
Implement a zookeeper based running job
[
https://issues.apache.org/jira/browse/FLINK-4469?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15707951#comment-15707951
]
ASF GitHub Bot commented on FLINK-4469:
---
Github user wuchong commented on the issue:
Github user wuchong commented on the issue:
https://github.com/apache/flink/pull/2653
Hi @fhueske @twalthr , could you have a look at this PR again ? I have fix
the conflicts again and squashed the commits.
---
If your project is set up for it, you can reply to this email and have
[
https://issues.apache.org/jira/browse/FLINK-2186?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Anton Solovev updated FLINK-2186:
-
Assignee: (was: Anton Solovev)
> Rework CSV import to support very wide files
>
101 - 163 of 163 matches
Mail list logo
