[
https://issues.apache.org/jira/browse/FLINK-3908?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15310646#comment-15310646
]
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
then make parseField protected so users MUST call resetErrorStateAndParse.
there, problem solved.
---
If your project is set up for it, you can reply to this email and have your
reply appear
[
https://issues.apache.org/jira/browse/FLINK-1984?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Eron Wright updated FLINK-1984:
Description:
There are some users asking for an integration of Flink into Mesos.
-There also is a
[
https://issues.apache.org/jira/browse/FLINK-1984?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Eron Wright updated FLINK-1984:
Description:
There are some users asking for an integration of Flink into Mesos.
-There also is a
Greg Hogan created FLINK-4003:
-
Summary: Use intrinsics for MathUtils logarithms
Key: FLINK-4003
URL: https://issues.apache.org/jira/browse/FLINK-4003
Project: Flink
Issue Type: Improvement
Github user fhueske commented on the issue:
https://github.com/apache/flink/pull/2049
Thanks for the PR @gallenvara. I'm currently on vacation with limited
access to internet. Will review your PR when I am back in roughly a week.
---
If your project is set up for it, you can reply
[
https://issues.apache.org/jira/browse/FLINK-3971?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15310722#comment-15310722
]
ASF GitHub Bot commented on FLINK-3971:
---
Github user fhueske commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-4000?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15311362#comment-15311362
]
ASF GitHub Bot commented on FLINK-4000:
---
Github user asavartsov commented on the issue:
Github user asavartsov commented on the issue:
https://github.com/apache/flink/pull/2061
No, it does not make any sense and even makes things worse, sorry.
---
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
Github user rekhajoshm commented on the issue:
https://github.com/apache/flink/pull/2061
@asavartsov Ok. Please let me know how you propose to solve this? thanks
---
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
Github user asavartsov commented on the issue:
https://github.com/apache/flink/pull/2061
Take a look at my pull request at https://github.com/apache/flink/pull/2062
---
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
Github user rekhajoshm commented on the issue:
https://github.com/apache/flink/pull/2061
aha, in one of my intermediate runs had done just initializing
idsProcessedButNotAcknowledged and retain pendingCheckpoints , but in last run
changed it calling open() :-( . makes sense
[
https://issues.apache.org/jira/browse/FLINK-4000?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15311403#comment-15311403
]
ASF GitHub Bot commented on FLINK-4000:
---
Github user rekhajoshm commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-4000?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15311404#comment-15311404
]
ASF GitHub Bot commented on FLINK-4000:
---
Github user rekhajoshm closed the pull request at:
Github user rekhajoshm closed the pull request at:
https://github.com/apache/flink/pull/2061
---
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
Robert Metzger created FLINK-4004:
-
Summary: Do not pass custom flink kafka connector properties to
Kafka to avoid warnings
Key: FLINK-4004
URL: https://issues.apache.org/jira/browse/FLINK-4004
GitHub user greghogan opened a pull request:
https://github.com/apache/flink/pull/2059
[FLINK-4003] Use intrinsics for MathUtils logarithms
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/greghogan/flink
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/2058
Can you please close this pull request and pose this as a question in the
mailing list?
---
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-4003?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15310841#comment-15310841
]
ASF GitHub Bot commented on FLINK-4003:
---
GitHub user greghogan opened a pull request:
GitHub user rekhajoshm opened a pull request:
https://github.com/apache/flink/pull/2060
[FLINK-3921] StringParser encoding
Corrected StringParser encoding
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/rekhajoshm/flink
[
https://issues.apache.org/jira/browse/FLINK-3921?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15311043#comment-15311043
]
ASF GitHub Bot commented on FLINK-3921:
---
GitHub user rekhajoshm opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-4000?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15311087#comment-15311087
]
ASF GitHub Bot commented on FLINK-4000:
---
GitHub user rekhajoshm opened a pull request:
GitHub user rekhajoshm opened a pull request:
https://github.com/apache/flink/pull/2061
[FLINK-4000] Checkpoint dictionaries null after taskmgr failures
Fix for exception during job restart after task mgr failure, at which point
restoreState fails as checkpoint dictionaries can be
[
https://issues.apache.org/jira/browse/FLINK-3921?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rekha Joshi reassigned FLINK-3921:
--
Assignee: Rekha Joshi
> StringParser not specifying encoding to use
>
[
https://issues.apache.org/jira/browse/FLINK-4000?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rekha Joshi reassigned FLINK-4000:
--
Assignee: Rekha Joshi
> Exception: Could not restore checkpointed state to operators and
Ufuk Celebi created FLINK-4005:
--
Summary: LocalExecutorITCase.testLocalExecutorWithWordCount fails
Key: FLINK-4005
URL: https://issues.apache.org/jira/browse/FLINK-4005
Project: Flink
Issue
Github user skavulya commented on the issue:
https://github.com/apache/flink/pull/1985
Thanks @chiwanpark. I made the changes you recommended. Please let me know
if it looks ok.
---
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-1979?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15311314#comment-15311314
]
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
While working on L-BFGS, I realized that I need to remove the gradient
descent step from RegularizationPenalty. I'll update the PR soon.
---
If your project is set up for it, you can reply to this
[
https://issues.apache.org/jira/browse/FLINK-1979?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15311626#comment-15311626
]
ASF GitHub Bot commented on FLINK-1979:
---
Github user skavulya commented on the issue:
Github user asavartsov commented on the issue:
https://github.com/apache/flink/pull/2061
This kind of check is might be useless and probably wouldn't fix the issue.
My debugging shows that the list `idsProcessedButNotAcknowledged` is null on
recovery, not checkpoints itself. This
[
https://issues.apache.org/jira/browse/FLINK-4000?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15311152#comment-15311152
]
ASF GitHub Bot commented on FLINK-4000:
---
Github user asavartsov commented on the issue:
Github user rekhajoshm commented on the issue:
https://github.com/apache/flink/pull/2061
I agree @asavartsov , that was a quick look and was working to
reproduce.Does the updated make sense? thank you.
---
If your project is set up for it, you can reply to this email and have your
[
https://issues.apache.org/jira/browse/FLINK-4000?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15311206#comment-15311206
]
ASF GitHub Bot commented on FLINK-4000:
---
Github user rekhajoshm commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-4000?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15311356#comment-15311356
]
ASF GitHub Bot commented on FLINK-4000:
---
GitHub user asavartsov opened a pull request:
GitHub user asavartsov opened a pull request:
https://github.com/apache/flink/pull/2062
[FLINK-4000] Fix for checkpoint state restore at
MessageAcknowledgingSourceBase
As says documentation for MessageAcknowledgingSourceBase.restoreState()
This method is invoked when a
[
https://issues.apache.org/jira/browse/FLINK-4000?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15311375#comment-15311375
]
ASF GitHub Bot commented on FLINK-4000:
---
Github user rekhajoshm commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-4000?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15311395#comment-15311395
]
ASF GitHub Bot commented on FLINK-4000:
---
Github user asavartsov commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-4000?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rekha Joshi updated FLINK-4000:
---
Assignee: (was: Rekha Joshi)
> Exception: Could not restore checkpointed state to operators and
[
https://issues.apache.org/jira/browse/FLINK-4006?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ZhengBowen updated FLINK-4006:
--
Attachment: FLINK-4006.patch
> ExecutionGraph.restartStrategy field can't be serialized
>
[
https://issues.apache.org/jira/browse/FLINK-4006?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ZhengBowen updated FLINK-4006:
--
Description:
Exception is following
```
java.io.NotSerializableException:
ZhengBowen created FLINK-4006:
-
Summary: ExecutionGraph.restartStrategy field can't be serialized
Key: FLINK-4006
URL: https://issues.apache.org/jira/browse/FLINK-4006
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-3919?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15309419#comment-15309419
]
ASF GitHub Bot commented on FLINK-3919:
---
Github user chiwanpark commented on a diff in the pull
Github user chiwanpark commented on a diff in the pull request:
https://github.com/apache/flink/pull/1996#discussion_r65311449
--- Diff:
flink-libraries/flink-ml/src/main/scala/org/apache/flink/ml/math/distributed/DistributedRowMatrix.scala
---
@@ -0,0 +1,179 @@
+/*
+ *
Github user chiwanpark commented on the pull request:
https://github.com/apache/flink/pull/1996
Hi @chobeat, thanks for update PR. After addressing comments on source
code, I think the last thing to merge this is adding documentation for this.
But you can add the documentation after
Github user chiwanpark commented on a diff in the pull request:
https://github.com/apache/flink/pull/1996#discussion_r65309988
--- Diff:
flink-libraries/flink-ml/src/main/scala/org/apache/flink/ml/math/distributed/DistributedRowMatrix.scala
---
@@ -0,0 +1,179 @@
+/*
+ *
Github user chobeat commented on a diff in the pull request:
https://github.com/apache/flink/pull/1996#discussion_r65318407
--- Diff:
flink-libraries/flink-ml/src/main/scala/org/apache/flink/ml/math/distributed/DistributedRowMatrix.scala
---
@@ -0,0 +1,179 @@
+/*
+ *
[
https://issues.apache.org/jira/browse/FLINK-3919?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15309901#comment-15309901
]
ASF GitHub Bot commented on FLINK-3919:
---
Github user chobeat commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-3919?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15309404#comment-15309404
]
ASF GitHub Bot commented on FLINK-3919:
---
Github user chiwanpark commented on a diff in the pull
Github user chiwanpark commented on a diff in the pull request:
https://github.com/apache/flink/pull/1996#discussion_r65309186
--- Diff:
flink-libraries/flink-ml/src/main/scala/org/apache/flink/ml/math/distributed/DistributedRowMatrix.scala
---
@@ -0,0 +1,179 @@
+/*
+ *
Github user chobeat commented on the pull request:
https://github.com/apache/flink/pull/1996
@chiwanpark before merging I need to go over the numRows/numCols issue
again because I noticed they create problems in another project of mine. I
think that the `collect()` there is too risky
Github user chobeat commented on the pull request:
https://github.com/apache/flink/pull/1996
@chiwanpark I think it should be better to leave to the user the
computation of the dimensionality. I tried different options and all of them
are sub-optimal. I would leave this feature for
[
https://issues.apache.org/jira/browse/FLINK-3806?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15310162#comment-15310162
]
ASF GitHub Bot commented on FLINK-3806:
---
Github user vasia commented on the pull request:
[
https://issues.apache.org/jira/browse/FLINK-4002?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Omar Alvarez updated FLINK-4002:
Description:
The Verify() test function errors out when array elements are missing:
{code}
[
https://issues.apache.org/jira/browse/FLINK-3993?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15310153#comment-15310153
]
ASF GitHub Bot commented on FLINK-3993:
---
Github user omaralvarez commented on the pull request:
[
https://issues.apache.org/jira/browse/FLINK-2314?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15310188#comment-15310188
]
ASF GitHub Bot commented on FLINK-2314:
---
Github user aljoscha commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-3667?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15310210#comment-15310210
]
ASF GitHub Bot commented on FLINK-3667:
---
Github user mxm commented on a diff in the pull request:
GitHub user mrakshay opened a pull request:
https://github.com/apache/flink/pull/2058
Not able to create flink-streaming-connectors jar
Hello,I am not able to create jar of **flink-streaming-connectors** ...I
am able to create jar of others like twitter,kafka,flume but I am not
Github user chiwanpark commented on a diff in the pull request:
https://github.com/apache/flink/pull/1996#discussion_r65309134
--- Diff:
flink-libraries/flink-ml/src/main/scala/org/apache/flink/ml/math/distributed/DistributedRowMatrix.scala
---
@@ -0,0 +1,182 @@
+/*
+ *
[
https://issues.apache.org/jira/browse/FLINK-3919?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15309403#comment-15309403
]
ASF GitHub Bot commented on FLINK-3919:
---
Github user chiwanpark commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-3919?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15310133#comment-15310133
]
ASF GitHub Bot commented on FLINK-3919:
---
Github user chobeat commented on the pull request:
[
https://issues.apache.org/jira/browse/FLINK-3919?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15310160#comment-15310160
]
ASF GitHub Bot commented on FLINK-3919:
---
Github user chobeat commented on the pull request:
Github user vasia commented on the pull request:
https://github.com/apache/flink/pull/2036
Thanks @greghogan! It looks like you have some checkstyle violation,
otherwise +1.
---
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-3806?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15310169#comment-15310169
]
ASF GitHub Bot commented on FLINK-3806:
---
Github user greghogan commented on the pull request:
Omar Alvarez created FLINK-4002:
---
Summary: [py] Improve testing infraestructure
Key: FLINK-4002
URL: https://issues.apache.org/jira/browse/FLINK-4002
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-2765?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15310186#comment-15310186
]
Christophe S commented on FLINK-2765:
-
Great! Almost all distro are in 1.1 or 1.2.
> Upgrade hbase
Github user aljoscha commented on a diff in the pull request:
https://github.com/apache/flink/pull/2020#discussion_r65347119
--- Diff:
flink-tests/src/test/java/org/apache/flink/test/checkpointing/StreamFaultToleranceTestBase.java
---
@@ -104,8 +106,21 @@ public void
[
https://issues.apache.org/jira/browse/FLINK-2314?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15310194#comment-15310194
]
ASF GitHub Bot commented on FLINK-2314:
---
Github user aljoscha commented on the pull request:
[
https://issues.apache.org/jira/browse/FLINK-3667?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15310211#comment-15310211
]
ASF GitHub Bot commented on FLINK-3667:
---
Github user mxm commented on a diff in the pull request:
Github user omaralvarez commented on the pull request:
https://github.com/apache/flink/pull/2055
Perfect. I'll open a new issue and try to fix that and document the test
scripts.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub
Github user chiwanpark commented on the pull request:
https://github.com/apache/flink/pull/1996
@chobeat Okay. Then we should force user to calculate dimensionality of
matrix by changing type of number parameters in constructor.
---
If your project is set up for it, you can reply to
[
https://issues.apache.org/jira/browse/FLINK-3919?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15310165#comment-15310165
]
ASF GitHub Bot commented on FLINK-3919:
---
Github user chiwanpark commented on the pull request:
Github user greghogan commented on the pull request:
https://github.com/apache/flink/pull/2036
Yes. If I allow IntelliJ to handle automatically organize imports then they
can be reordered due to a lack of consistency and project-wide guidelines.
---
If your project is set up for it,
Github user aljoscha commented on the pull request:
https://github.com/apache/flink/pull/2020
The input formats still have a leftover field that stores the split.
After that, the only thing that remains is the API methods. Also what was
the reason for the new code in
[
https://issues.apache.org/jira/browse/FLINK-3993?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15309918#comment-15309918
]
ASF GitHub Bot commented on FLINK-3993:
---
Github user omaralvarez commented on the pull request:
Github user zentol commented on the pull request:
https://github.com/apache/flink/pull/2055
Changing the test infrastructure should be done as a separate issue. There
are a few things that could be improved, especially a bit of documentation
(like what is the difference between
[
https://issues.apache.org/jira/browse/FLINK-3994?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15309941#comment-15309941
]
ASF GitHub Bot commented on FLINK-3994:
---
Github user mxm commented on the pull request:
[
https://issues.apache.org/jira/browse/FLINK-3919?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15309971#comment-15309971
]
ASF GitHub Bot commented on FLINK-3919:
---
Github user chobeat commented on the pull request:
[
https://issues.apache.org/jira/browse/FLINK-3758?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15310006#comment-15310006
]
ASF GitHub Bot commented on FLINK-3758:
---
Github user StephanEwen commented on the pull request:
[
https://issues.apache.org/jira/browse/FLINK-4000?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15310007#comment-15310007
]
Ufuk Celebi commented on FLINK-4000:
Thanks for reporting the issue. Did you configure a specific
Github user omaralvarez commented on the pull request:
https://github.com/apache/flink/pull/2055
I think, everything should be ready now. Although while performing testing,
I have found something that I think is not ideal.
If we use this code:
```python
[
https://issues.apache.org/jira/browse/FLINK-3993?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15309943#comment-15309943
]
ASF GitHub Bot commented on FLINK-3993:
---
Github user zentol commented on the pull request:
[
https://issues.apache.org/jira/browse/FLINK-3477?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15310040#comment-15310040
]
ASF GitHub Bot commented on FLINK-3477:
---
Github user ggevay commented on a diff in the pull request:
Github user ggevay commented on a diff in the pull request:
https://github.com/apache/flink/pull/1517#discussion_r65331149
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/operators/hash/ReduceHashTable.java
---
@@ -0,0 +1,1048 @@
+/*
+ * Licensed to the
Github user zentol commented on the pull request:
https://github.com/apache/flink/commit/7ad8375a89374bec80571029e9166f1336bdea8e#commitcomment-17693170
In
flink-metric-reporters/flink-metrics-graphite/src/main/java/org/apache/flink/metrics/graphite/GraphiteReporter.java:
In
[
https://issues.apache.org/jira/browse/FLINK-2672?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger updated FLINK-2672:
--
Component/s: filesystem-connector
> Add partitioned output format to HDFS RollingSink
>
[
https://issues.apache.org/jira/browse/FLINK-3854?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger updated FLINK-3854:
--
Component/s: (was: esystem-connector)
filesystem-connector
> Support Avro
Github user mxm commented on the pull request:
https://github.com/apache/flink/pull/2056
Thanks for fixing!
---
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
Github user chobeat commented on the pull request:
https://github.com/apache/flink/pull/1996
@chiwanpark Yeah I thought I could write the documentation as a third PR
but I would like to review the block matrix first because it may change in
structure. Anyway I will soon begin working
Github user rmetzger commented on a diff in the pull request:
https://github.com/apache/flink/pull/2054#discussion_r65328505
--- Diff:
flink-streaming-connectors/flink-connector-rabbitmq/src/main/java/org/apache/flink/streaming/connectors/rabbitmq/common/RMQConnectionConfig.java
---
[
https://issues.apache.org/jira/browse/FLINK-3763?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15309992#comment-15309992
]
ASF GitHub Bot commented on FLINK-3763:
---
Github user rmetzger commented on a diff in the pull
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/1979
Sorry for chiming in late.
I was wondering whether we actually need accumulators here, or what we
should add is access to the metrics. Because the use case seems to be
Robert Metzger created FLINK-4001:
-
Summary: Add event time support to filesystem connector
Key: FLINK-4001
URL: https://issues.apache.org/jira/browse/FLINK-4001
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-1873?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15309972#comment-15309972
]
Simone Robutti commented on FLINK-1873:
---
I thought I could open a dedicated issue for the
Github user zentol commented on the pull request:
https://github.com/apache/flink/commit/7ad8375a89374bec80571029e9166f1336bdea8e#commitcomment-17693130
In flink-core/src/main/java/org/apache/flink/metrics/MetricRegistry.java:
In
[
https://issues.apache.org/jira/browse/FLINK-3758?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15309998#comment-15309998
]
Robert Metzger commented on FLINK-3758:
---
I think metrics and accumulators are going to co-exist.
[
https://issues.apache.org/jira/browse/FLINK-2706?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger updated FLINK-2706:
--
Component/s: filesystem-connector
> Add support for streaming RollingFileSink to truncate /
[
https://issues.apache.org/jira/browse/FLINK-3854?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger updated FLINK-3854:
--
Component/s: esystem-connector
> Support Avro key-value rolling sink writer
>
Github user zentol commented on the pull request:
https://github.com/apache/flink/commit/7ad8375a89374bec80571029e9166f1336bdea8e#commitcomment-17693724
In flink-core/src/main/java/org/apache/flink/metrics/MetricRegistry.java:
In
[
https://issues.apache.org/jira/browse/FLINK-3667?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15310217#comment-15310217
]
ASF GitHub Bot commented on FLINK-3667:
---
Github user mxm commented on a diff in the pull request:
1 - 100 of 147 matches
Mail list logo
