GitHub user tzulitai opened a pull request:
https://github.com/apache/flink/pull/2071
[FLINK-4018](streaming-connectors) Configurable idle time between
getRecords requests to Kinesis shards
Along with this new configuration and the already existing
`KinesisConfigConstants.CONFIG_SH
[
https://issues.apache.org/jira/browse/FLINK-4018?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15315316#comment-15315316
]
ASF GitHub Bot commented on FLINK-4018:
---
GitHub user tzulitai opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-4018?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15315290#comment-15315290
]
Tzu-Li (Gordon) Tai commented on FLINK-4018:
We have a user who has tried out
Tzu-Li (Gordon) Tai created FLINK-4018:
--
Summary: Configurable idle time between getRecords requests to
Kinesis shards
Key: FLINK-4018
URL: https://issues.apache.org/jira/browse/FLINK-4018
Projec
[
https://issues.apache.org/jira/browse/FLINK-1979?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15315212#comment-15315212
]
ASF GitHub Bot commented on FLINK-1979:
---
Github user skavulya commented on the issue
Github user skavulya commented on the issue:
https://github.com/apache/flink/pull/1985
@chiwanpark Decoupling the gradient descent step is complicated for L1
regularization because we are using the proximal gradient method that applies
soft thresholding after executing the gradient de
[
https://issues.apache.org/jira/browse/FLINK-3872?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15314656#comment-15314656
]
ASF GitHub Bot commented on FLINK-3872:
---
Github user rmetzger commented on the issue
Github user rmetzger commented on the issue:
https://github.com/apache/flink/pull/2069
Quickly checked the maven and kafka stuff. Looks good. Very clean, well
documented and tested code.
Further review for the table api specific parts are still needed.
---
If your project is set
[
https://issues.apache.org/jira/browse/FLINK-3850?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15314630#comment-15314630
]
ramkrishna.s.vasudevan commented on FLINK-3850:
---
[~fhueske]
Is it possible t
Github user ramkrish86 commented on the issue:
https://github.com/apache/flink/pull/1856
Thanks @zentol . I pushed a new one after wrapping the longer lines.
---
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 projec
[
https://issues.apache.org/jira/browse/FLINK-3650?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15314611#comment-15314611
]
ASF GitHub Bot commented on FLINK-3650:
---
Github user ramkrish86 commented on the iss
[
https://issues.apache.org/jira/browse/FLINK-4016?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15314326#comment-15314326
]
ASF GitHub Bot commented on FLINK-4016:
---
GitHub user rvdwenden opened a pull request
GitHub user rvdwenden opened a pull request:
https://github.com/apache/flink/pull/2070
[FLINK-4016] initialize FoldApplyWindowFunction properly
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/rvdwenden/flink master
Alterna
Geoffrey Mon created FLINK-4017:
---
Summary: [py] Add Aggregation support to Python API
Key: FLINK-4017
URL: https://issues.apache.org/jira/browse/FLINK-4017
Project: Flink
Issue Type: Improvemen
[
https://issues.apache.org/jira/browse/FLINK-3872?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15314238#comment-15314238
]
ASF GitHub Bot commented on FLINK-3872:
---
GitHub user uce opened a pull request:
GitHub user uce opened a pull request:
https://github.com/apache/flink/pull/2069
[FLINK-3872] [table, connector-kafka] Add KafkaJsonTableSource
Adds `StreamTableSource` variants for Kafka with syntactic sugar for
parsing JSON streams.
```java
KafkaJsonTableSource source
RWenden created FLINK-4016:
--
Summary: FoldApplyWindowFunction is not properly initialized
Key: FLINK-4016
URL: https://issues.apache.org/jira/browse/FLINK-4016
Project: Flink
Issue Type: Bug
Github user greghogan commented on the issue:
https://github.com/apache/flink/pull/2002
This looks very handy. We should also update the formats table in the
documentation.
https://ci.apache.org/projects/flink/flink-docs-master/apis/batch/index.html#read-compressed-files
--
Github user greghogan commented on a diff in the pull request:
https://github.com/apache/flink/pull/2066#discussion_r65717466
--- Diff: flink-contrib/docker-flink/base/Dockerfile ---
@@ -38,12 +38,12 @@ ENV JAVA_HOME /usr/java/default/
RUN echo 'root:secret' | chpasswd
[
https://issues.apache.org/jira/browse/FLINK-3921?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15314172#comment-15314172
]
ASF GitHub Bot commented on FLINK-3921:
---
Github user greghogan commented on the issu
Github user greghogan commented on the issue:
https://github.com/apache/flink/pull/2060
The only internal usage of `StringParser` is from `GenericCsvInputFormat`.
Should we make the encoding configurable in `GenericCsvInputFormat` with a
default of US-ASCII? This could then be overrid
GitHub user zentol opened a pull request:
https://github.com/apache/flink/pull/2068
[hotfix] [core] Fix scope format keys
Fixes the scope format keys that were broken in
7ad8375a89374bec80571029e9166f1336bdea8e.
You can merge this pull request into a Git repository by running:
[
https://issues.apache.org/jira/browse/FLINK-4013?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15314136#comment-15314136
]
ASF GitHub Bot commented on FLINK-4013:
---
GitHub user greghogan opened a pull request
GitHub user greghogan opened a pull request:
https://github.com/apache/flink/pull/2067
[FLINK-4013] [gelly] GraphAlgorithms to simplify directed and undirected
graphs
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/greghogan/fli
Github user subhankarb commented on the issue:
https://github.com/apache/flink/pull/2054
Hi @rmetzger ,
would you plzzz review the changes.
---
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 hav
[
https://issues.apache.org/jira/browse/FLINK-3763?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15314095#comment-15314095
]
ASF GitHub Bot commented on FLINK-3763:
---
Github user subhankarb commented on the iss
[
https://issues.apache.org/jira/browse/FLINK-3311?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15314074#comment-15314074
]
ASF GitHub Bot commented on FLINK-3311:
---
Github user rmetzger commented on the issue
Github user rmetzger commented on the issue:
https://github.com/apache/flink/pull/1771
I've reviewed the connector again.
The issues I've seen previously (failure on restart) are resolved.
However, I found new issues:
- The Cassandra Sink doesn't fail (at least not within 15
[
https://issues.apache.org/jira/browse/FLINK-4014?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15314069#comment-15314069
]
Ufuk Celebi commented on FLINK-4014:
Hey Zheng! Thanks for posting the issue. It's bet
[
https://issues.apache.org/jira/browse/FLINK-1730?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gabor Gevay updated FLINK-1730:
---
Priority: Major (was: Minor)
> Add a FlinkTools.persist style method to the Data Set.
> -
[
https://issues.apache.org/jira/browse/FLINK-4015?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15314042#comment-15314042
]
Sebastian Klemke commented on FLINK-4015:
-
We use default retries: 0. Also, we can
[
https://issues.apache.org/jira/browse/FLINK-4002?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15314040#comment-15314040
]
ASF GitHub Bot commented on FLINK-4002:
---
Github user zentol commented on the issue:
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/2063
you're right, that falls through. we should add additional checks:
- Verify: index is equal to the size of expected values
- Verify2: expected is empty
---
If your project is set up for it, yo
Github user omaralvarez commented on the issue:
https://github.com/apache/flink/pull/2063
Sorry, I said it wrong, it's the opposite. The case that fails in Verify()
and Verify2(), is when we have more values in expected than in the resulting
DataSet.
---
If your project is set up fo
[
https://issues.apache.org/jira/browse/FLINK-4002?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15314030#comment-15314030
]
ASF GitHub Bot commented on FLINK-4002:
---
Github user omaralvarez commented on the is
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/2063
when we have more data than expected, remove() will be called on an empty
list and should throw an exception, no?
if you want to execute the python tests you only have to call mvn verify on
t
[
https://issues.apache.org/jira/browse/FLINK-4002?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15314028#comment-15314028
]
ASF GitHub Bot commented on FLINK-4002:
---
Github user zentol commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-4015?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15314026#comment-15314026
]
Robert Metzger commented on FLINK-4015:
---
Hi Sebastian,
do you have set the number of
Github user omaralvarez commented on the issue:
https://github.com/apache/flink/pull/2063
I have corrected Verify2(), but there is another case that is not checked,
when the resulting datasets have more elements than expected, right now the
error will go unnoticed.
I also wan
[
https://issues.apache.org/jira/browse/FLINK-4002?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15314023#comment-15314023
]
ASF GitHub Bot commented on FLINK-4002:
---
Github user omaralvarez commented on the is
Sebastian Klemke created FLINK-4015:
---
Summary: FlinkKafkaProducer08 fails when partition leader changes
Key: FLINK-4015
URL: https://issues.apache.org/jira/browse/FLINK-4015
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-3650?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15314000#comment-15314000
]
ASF GitHub Bot commented on FLINK-3650:
---
Github user zentol commented on the issue:
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/1856
I did not look at it in detail, just checked whether the builds passed.
---
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-3650?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15313995#comment-15313995
]
ASF GitHub Bot commented on FLINK-3650:
---
Github user ramkrish86 commented on the iss
Github user ramkrish86 commented on the issue:
https://github.com/apache/flink/pull/1856
Thanks for the review @zentol . Ok. I will correct the line length. Does
the overall approach look good?
---
If your project is set up for it, you can reply to this email and have your
reply appe
[
https://issues.apache.org/jira/browse/FLINK-3650?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15313990#comment-15313990
]
ASF GitHub Bot commented on FLINK-3650:
---
Github user zentol commented on the issue:
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/1856
Build is failing due to 54 scala style violations. (line length)
---
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-3650?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15313977#comment-15313977
]
ramkrishna.s.vasudevan commented on FLINK-3650:
---
[~till.rohrmann] [~fhueske]
[
https://issues.apache.org/jira/browse/FLINK-3919?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15313955#comment-15313955
]
Simone Robutti commented on FLINK-3919:
---
Umh, probably you're right. I checked breez
[
https://issues.apache.org/jira/browse/FLINK-3919?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15313952#comment-15313952
]
ASF GitHub Bot commented on FLINK-3919:
---
Github user chiwanpark commented on a diff
Github user chiwanpark commented on a diff in the pull request:
https://github.com/apache/flink/pull/1996#discussion_r65688309
--- Diff:
flink-libraries/flink-ml/src/main/scala/org/apache/flink/ml/math/distributed/DistributedRowMatrix.scala
---
@@ -0,0 +1,162 @@
+/*
+ * Li
[
https://issues.apache.org/jira/browse/FLINK-4014?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ZhengBowen updated FLINK-4014:
--
Description:
I also run a five jobs, and all the slot filled.And I seem to find my five jobs
is all han
[
https://issues.apache.org/jira/browse/FLINK-4014?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ZhengBowen updated FLINK-4014:
--
Summary: Jobs hang. Maybe NetworkBufferPool and LocalBufferPool has some
problem (was: Jobs hang， Maybe
[
https://issues.apache.org/jira/browse/FLINK-4014?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ZhengBowen updated FLINK-4014:
--
Description:
I also run a five jobs, and all the slot filled.And I seem to find my five jobs
is all han
GitHub user techmaniack opened a pull request:
https://github.com/apache/flink/pull/2066
Updated ssh configuration in base Dockerfile
- The pull request addresses only one issue
Won't allow ssh into the container as 'without-password' is now replaced
with 'prohibit-passwo
[
https://issues.apache.org/jira/browse/FLINK-4014?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15313944#comment-15313944
]
ZhengBowen commented on FLINK-4014:
---
[~StephanEwen]
can you help me?
> Jobs hang， Maybe
[
https://issues.apache.org/jira/browse/FLINK-4014?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ZhengBowen updated FLINK-4014:
--
Attachment: FlinkJob_20160603_174748_03.java
> Jobs hang， Maybe NetworkBufferPool and LocalBufferPoo
ZhengBowen created FLINK-4014:
-
Summary: Jobs hang， Maybe NetworkBufferPool and Local、
Key: FLINK-4014
URL: https://issues.apache.org/jira/browse/FLINK-4014
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-4014?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ZhengBowen updated FLINK-4014:
--
Attachment: hang.stack
> Jobs hang， Maybe NetworkBufferPool and LocalBufferPool has some problem
> -
[
https://issues.apache.org/jira/browse/FLINK-4014?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ZhengBowen updated FLINK-4014:
--
Summary: Jobs hang， Maybe NetworkBufferPool and LocalBufferPool has some
problem (was: Jobs hang， Maybe
[
https://issues.apache.org/jira/browse/FLINK-4014?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ZhengBowen updated FLINK-4014:
--
Summary: Jobs hang， Maybe NetworkBufferPool and LocalBuffer (was: Jobs
hang， Maybe NetworkBufferPool an
[
https://issues.apache.org/jira/browse/FLINK-1873?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15313938#comment-15313938
]
Simone Robutti commented on FLINK-1873:
---
That would be perfect :)
> Distributed mat
[
https://issues.apache.org/jira/browse/FLINK-1873?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15313915#comment-15313915
]
Chiwan Park commented on FLINK-1873:
I think we don't need to hurry, but I'll review t
[
https://issues.apache.org/jira/browse/FLINK-1873?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15313903#comment-15313903
]
Simone Robutti commented on FLINK-1873:
---
Ok. Anyway tomorrow will be my first day of
[
https://issues.apache.org/jira/browse/FLINK-3937?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15313890#comment-15313890
]
ASF GitHub Bot commented on FLINK-3937:
---
Github user mxm commented on the issue:
Github user mxm commented on the issue:
https://github.com/apache/flink/pull/2034
Thanks for the update!
---
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, o
[
https://issues.apache.org/jira/browse/FLINK-3908?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15313872#comment-15313872
]
ASF GitHub Bot commented on FLINK-3908:
---
Github user zentol commented on the issue:
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/2007
I'm not sure; in any case it should not be removed as part of this PR.
You can open a separate JIRA or ask on the mailing list.
---
If your project is set up for it, you can reply to this ema
Github user fpompermaier commented on the issue:
https://github.com/apache/flink/pull/2007
Now it should be ok, according to your suggestions. I misunderstood what
@StephanEwen was trying to say, thanks @zentol for the clarification!
Just another thing: the method GenericCsvInputF
[
https://issues.apache.org/jira/browse/FLINK-3908?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15313864#comment-15313864
]
ASF GitHub Bot commented on FLINK-3908:
---
Github user fpompermaier commented on the i
Github user chobeat commented on a diff in the pull request:
https://github.com/apache/flink/pull/1996#discussion_r65671113
--- Diff:
flink-libraries/flink-ml/src/main/scala/org/apache/flink/ml/math/distributed/DistributedRowMatrix.scala
---
@@ -0,0 +1,166 @@
+/*
+ * Licen
Github user ggevay commented on a diff in the pull request:
https://github.com/apache/flink/pull/1517#discussion_r65667687
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/operators/ReduceCombineDriver.java
---
@@ -42,34 +44,38 @@
* Combine operator for Reduce
[
https://issues.apache.org/jira/browse/FLINK-3477?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15313791#comment-15313791
]
ASF GitHub Bot commented on FLINK-3477:
---
Github user ggevay commented on a diff in t
73 matches
Mail list logo
