[
https://issues.apache.org/jira/browse/FLINK-4821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15979756#comment-15979756
]
ASF GitHub Bot commented on FLINK-4821:
---
Github user tzulitai commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-4821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15979757#comment-15979757
]
ASF GitHub Bot commented on FLINK-4821:
---
Github user tzulitai commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-4821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15979749#comment-15979749
]
ASF GitHub Bot commented on FLINK-4821:
---
Github user tzulitai commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-4821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15979751#comment-15979751
]
ASF GitHub Bot commented on FLINK-4821:
---
Github user tzulitai commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-4821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15979758#comment-15979758
]
ASF GitHub Bot commented on FLINK-4821:
---
Github user tzulitai commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-4821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15979750#comment-15979750
]
ASF GitHub Bot commented on FLINK-4821:
---
Github user tzulitai commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-4821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15979754#comment-15979754
]
ASF GitHub Bot commented on FLINK-4821:
---
Github user tzulitai commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-4821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15979755#comment-15979755
]
ASF GitHub Bot commented on FLINK-4821:
---
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/3001#discussion_r112802060
--- Diff:
flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/FlinkKinesisConsumer.java
---
@@ -194,26 +21
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/3001#discussion_r112802220
--- Diff:
flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/FlinkKinesisConsumer.java
---
@@ -267,38 +28
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/3001#discussion_r112802168
--- Diff:
flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/FlinkKinesisConsumer.java
---
@@ -267,38 +28
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/3001#discussion_r112801654
--- Diff:
flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/FlinkKinesisConsumer.java
---
@@ -91,6 +104,
[
https://issues.apache.org/jira/browse/FLINK-4821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15979748#comment-15979748
]
ASF GitHub Bot commented on FLINK-4821:
---
Github user tzulitai commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-4821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15979753#comment-15979753
]
ASF GitHub Bot commented on FLINK-4821:
---
Github user tzulitai commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-4821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15979752#comment-15979752
]
ASF GitHub Bot commented on FLINK-4821:
---
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/3001#discussion_r112802181
--- Diff:
flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/FlinkKinesisConsumer.java
---
@@ -267,38 +28
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/3001#discussion_r112802072
--- Diff:
flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/FlinkKinesisConsumer.java
---
@@ -194,26 +21
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/3001#discussion_r112802258
--- Diff:
flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/FlinkKinesisConsumer.java
---
@@ -267,38 +28
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/3001#discussion_r112802121
--- Diff:
flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/FlinkKinesisConsumer.java
---
@@ -194,26 +21
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/3001#discussion_r112802386
--- Diff:
flink-connectors/flink-connector-kinesis/src/test/java/org/apache/flink/streaming/connectors/kinesis/FlinkKinesisConsumerMigrationTest.java
---
@
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/3001#discussion_r112802344
--- Diff:
flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/internals/KinesisDataFetcher.java
---
@@ -45
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/3001#discussion_r112802078
--- Diff:
flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/FlinkKinesisConsumer.java
---
@@ -194,26 +21
[
https://issues.apache.org/jira/browse/FLINK-6351?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15979745#comment-15979745
]
ASF GitHub Bot commented on FLINK-6351:
---
GitHub user zhangminglei opened a pull requ
GitHub user zhangminglei opened a pull request:
https://github.com/apache/flink/pull/3755
[FLINK-6351] [YARN] Refactoring YarnFlinkApplicationMasterRunner by câ¦
â¦ombining AbstractYarnFlinkApplicationMasterRunner in one class.
Thanks for contributing to Apache Flink. Befo
[
https://issues.apache.org/jira/browse/FLINK-6355?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15979723#comment-15979723
]
Kaibo Zhou commented on FLINK-6355:
---
Hi, [~fhueske]
The previous version of the example
[
https://issues.apache.org/jira/browse/FLINK-6355?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kaibo Zhou updated FLINK-6355:
--
Description:
Currently {{TableEnvironment}} only supports register ScalarFunction, the Java
users canno
[
https://issues.apache.org/jira/browse/FLINK-6193?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
shijinkui closed FLINK-6193.
Resolution: Fixed
> Flink dist directory normalize
> --
>
> Key:
[
https://issues.apache.org/jira/browse/FLINK-6351?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
mingleizhang updated FLINK-6351:
Summary: Refactor YarnFlinkApplicationMasterRunner by combining
AbstractYarnFlinkApplicationMasterRu
[
https://issues.apache.org/jira/browse/FLINK-6355?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kaibo Zhou updated FLINK-6355:
--
Description:
Currently {{TableEnvironment}} only supports register ScalarFunction, the Java
users canno
Github user shijinkui commented on the issue:
https://github.com/apache/flink/pull/2460
@fhueske 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 project does not have this feature
enabled and wishes so,
[
https://issues.apache.org/jira/browse/FLINK-4562?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15979683#comment-15979683
]
ASF GitHub Bot commented on FLINK-4562:
---
Github user shijinkui commented on the issu
[
https://issues.apache.org/jira/browse/FLINK-6217?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15979671#comment-15979671
]
ASF GitHub Bot commented on FLINK-6217:
---
Github user haohui commented on the issue:
Github user haohui commented on the issue:
https://github.com/apache/flink/pull/3648
Totally Agree :-) @StephanEwen please take another look.
---
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 t
[
https://issues.apache.org/jira/browse/FLINK-6281?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15979665#comment-15979665
]
ASF GitHub Bot commented on FLINK-6281:
---
Github user haohui commented on the issue:
Github user haohui commented on the issue:
https://github.com/apache/flink/pull/3712
Thanks for the review. I'm not aware of the fact that OutputFormats are not
integrated with Flink's checkpointing mechanism.
To address this problem, maybe we can do something similar to the
[
https://issues.apache.org/jira/browse/FLINK-6242?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske closed FLINK-6242.
Resolution: Implemented
Fix Version/s: 1.3.0
Implemented with 3b4542b8f0981f01e42c861bccbc67c
[
https://issues.apache.org/jira/browse/FLINK-6326?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske closed FLINK-6326.
Resolution: Fixed
Fix Version/s: 1.3.0
Fixed with 4024afffcd5a3f011e8ba2a3a1053e8bae6cec4f
>
[
https://issues.apache.org/jira/browse/FLINK-4562?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske closed FLINK-4562.
Resolution: Done
Fix Version/s: (was: 1.2.1)
1.3.0
Done with 46a950df8
[
https://issues.apache.org/jira/browse/FLINK-6242?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15979375#comment-15979375
]
ASF GitHub Bot commented on FLINK-6242:
---
Github user asfgit closed the pull request
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/3735
---
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 enab
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/3739
---
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 enab
[
https://issues.apache.org/jira/browse/FLINK-6326?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15979373#comment-15979373
]
ASF GitHub Bot commented on FLINK-6326:
---
Github user asfgit closed the pull request
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/3754
---
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 enab
[
https://issues.apache.org/jira/browse/FLINK-4562?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15979374#comment-15979374
]
ASF GitHub Bot commented on FLINK-4562:
---
Github user asfgit closed the pull request
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/2460
---
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 enab
[
https://issues.apache.org/jira/browse/FLINK-6326?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15979262#comment-15979262
]
ASF GitHub Bot commented on FLINK-6326:
---
Github user fhueske commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-4562?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15979264#comment-15979264
]
ASF GitHub Bot commented on FLINK-4562:
---
Github user fhueske commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-6242?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15979261#comment-15979261
]
ASF GitHub Bot commented on FLINK-6242:
---
Github user fhueske commented on the issue:
Github user fhueske commented on the issue:
https://github.com/apache/flink/pull/2460
Merging
---
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 fea
Github user fhueske commented on the issue:
https://github.com/apache/flink/pull/3739
Merging
---
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 fea
Github user fhueske commented on the issue:
https://github.com/apache/flink/pull/3735
Thanks @shaoxuan-wang!
Merging
---
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 a
Github user fhueske commented on the issue:
https://github.com/apache/flink/pull/3754
Thanks for the fixes!
Merging
---
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 an
Kostas Kloudas created FLINK-6356:
-
Summary: Make times() eager and enable allowing combinations.
Key: FLINK-6356
URL: https://issues.apache.org/jira/browse/FLINK-6356
Project: Flink
Issue Ty
[
https://issues.apache.org/jira/browse/FLINK-4898?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15979184#comment-15979184
]
ASF GitHub Bot commented on FLINK-4898:
---
Github user EronWright commented on the iss
[
https://issues.apache.org/jira/browse/FLINK-4898?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15979185#comment-15979185
]
ASF GitHub Bot commented on FLINK-4898:
---
Github user EronWright closed the pull requ
Github user EronWright commented on the issue:
https://github.com/apache/flink/pull/2766
@uce thanks for the feedback.
---
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 EronWright closed the pull request at:
https://github.com/apache/flink/pull/2766
---
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
[
https://issues.apache.org/jira/browse/FLINK-6355?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15979182#comment-15979182
]
Fabian Hueske commented on FLINK-6355:
--
You could also define {{tableEnv}} as {{Strea
[
https://issues.apache.org/jira/browse/FLINK-5182?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Eron Wright reassigned FLINK-5182:
---
Assignee: (was: Eron Wright )
> Implement SSL file-shipping
> ---
[
https://issues.apache.org/jira/browse/FLINK-5030?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15979175#comment-15979175
]
ASF GitHub Bot commented on FLINK-5030:
---
Github user EronWright closed the pull requ
[
https://issues.apache.org/jira/browse/FLINK-5030?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15979174#comment-15979174
]
ASF GitHub Bot commented on FLINK-5030:
---
Github user EronWright commented on the iss
Github user EronWright commented on the issue:
https://github.com/apache/flink/pull/3061
@tillrohrmann I'm closing this PR because it is quite old, in favor of a
successor.
---
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 EronWright closed the pull request at:
https://github.com/apache/flink/pull/3061
---
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
[
https://issues.apache.org/jira/browse/FLINK-5815?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15979160#comment-15979160
]
ASF GitHub Bot commented on FLINK-5815:
---
Github user EronWright commented on the iss
Github user EronWright commented on the issue:
https://github.com/apache/flink/pull/3388
Just a note: For Mesos, inevitably we'll add support for arbitrary URLs to
be downloaded by the container. The Mesos fetcher deals with HTTP URLs
primarily but actually supports HDFS URLs too (i
GitHub user kgeis opened a pull request:
https://github.com/apache/flink/pull/3754
update Table API Java examples
add trailing semicolons to Java examples in table_api.md for correct syntax
You can merge this pull request into a Git repository by running:
$ git pull https://git
[
https://issues.apache.org/jira/browse/FLINK-6355?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15979153#comment-15979153
]
Kaibo Zhou commented on FLINK-6355:
---
Thanks [~fhueske]
I have updated the description
[
https://issues.apache.org/jira/browse/FLINK-6355?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kaibo Zhou updated FLINK-6355:
--
Description:
Currently {{TableEnvironment}} only supports register ScalarFunction, the Java
users canno
[
https://issues.apache.org/jira/browse/FLINK-6302?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15979137#comment-15979137
]
ASF GitHub Bot commented on FLINK-6302:
---
Github user haohui commented on the issue:
Github user haohui commented on the issue:
https://github.com/apache/flink/pull/3720
I hit the same problem on my Mac. Let me try it out later today.
---
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-5476?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15979121#comment-15979121
]
ASF GitHub Bot commented on FLINK-5476:
---
GitHub user DmytroShkvyra opened a pull req
GitHub user DmytroShkvyra opened a pull request:
https://github.com/apache/flink/pull/3753
[FLINK-5476] Fail fast if trying to submit a job to a non-existing Flâ¦
â¦ink cluster
Thanks for contributing to Apache Flink. Before you open your pull request,
please take the fol
[
https://issues.apache.org/jira/browse/FLINK-6355?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kaibo Zhou updated FLINK-6355:
--
Description:
Currently {{TableEnvironment}} only supports register ScalarFunction, the Java
users canno
[
https://issues.apache.org/jira/browse/FLINK-6333?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15979076#comment-15979076
]
Ted Yu commented on FLINK-6333:
---
I found this issue which was resolved:
https://github.com/
[
https://issues.apache.org/jira/browse/FLINK-6336?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15979056#comment-15979056
]
ASF GitHub Bot commented on FLINK-6336:
---
Github user sgran closed the pull request a
Github user sgran closed the pull request at:
https://github.com/apache/flink/pull/3744
---
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 enabl
[
https://issues.apache.org/jira/browse/FLINK-6336?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15979057#comment-15979057
]
ASF GitHub Bot commented on FLINK-6336:
---
GitHub user sgran reopened a pull request:
GitHub user sgran reopened a pull request:
https://github.com/apache/flink/pull/3744
[FLINK-6336] Initial commit of mesos placement constraints
This adds a HostAttrValueConstraint evaluator for fenzo, allowing tasks
to be placed on agents with matching attributes.
Signed
[
https://issues.apache.org/jira/browse/FLINK-5974?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15979052#comment-15979052
]
ASF GitHub Bot commented on FLINK-5974:
---
Github user EronWright commented on the iss
Github user EronWright commented on the issue:
https://github.com/apache/flink/pull/3692
@StephanEwen in this case, the
[MesosTaskManagerParameters](https://github.com/vijikarthi/flink/blob/aeb432dc7fe8bcdd5faa49b8ad5dfb5630ea0747/flink-mesos/src/main/java/org/apache/flink/mesos/runtim
[
https://issues.apache.org/jira/browse/FLINK-6353?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15979042#comment-15979042
]
Stefan Richter edited comment on FLINK-6353 at 4/21/17 4:42 PM:
[
https://issues.apache.org/jira/browse/FLINK-6353?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15979042#comment-15979042
]
Stefan Richter edited comment on FLINK-6353 at 4/21/17 4:40 PM:
[
https://issues.apache.org/jira/browse/FLINK-6353?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15979042#comment-15979042
]
Stefan Richter commented on FLINK-6353:
---
Just a small idea: do you think that from a
[
https://issues.apache.org/jira/browse/FLINK-6250?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15978996#comment-15978996
]
ASF GitHub Bot commented on FLINK-6250:
---
Github user stefanobortoli commented on a d
Github user bowenli86 commented on a diff in the pull request:
https://github.com/apache/flink/pull/3736#discussion_r112729232
--- Diff:
flink-metrics/flink-metrics-datadog/src/main/java/org/apache/flink/metrics/datadog/DatadogHttpClient.java
---
@@ -0,0 +1,97 @@
+/*
+ * L
[
https://issues.apache.org/jira/browse/FLINK-6013?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15979038#comment-15979038
]
ASF GitHub Bot commented on FLINK-6013:
---
Github user bowenli86 commented on a diff i
[
https://issues.apache.org/jira/browse/FLINK-6013?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15979034#comment-15979034
]
ASF GitHub Bot commented on FLINK-6013:
---
Github user bowenli86 commented on a diff i
Github user bowenli86 commented on a diff in the pull request:
https://github.com/apache/flink/pull/3736#discussion_r112729036
--- Diff: flink-dist/src/main/assemblies/opt.xml ---
@@ -95,5 +95,12 @@
flink-metrics-statsd-${project.version}.jar
[
https://issues.apache.org/jira/browse/FLINK-6013?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15979022#comment-15979022
]
ASF GitHub Bot commented on FLINK-6013:
---
Github user bowenli86 commented on a diff i
Github user bowenli86 commented on a diff in the pull request:
https://github.com/apache/flink/pull/3736#discussion_r112728271
--- Diff:
flink-metrics/flink-metrics-datadog/src/main/java/org/apache/flink/metrics/datadog/DMetric.java
---
@@ -0,0 +1,65 @@
+/*
+ * Licensed to
[
https://issues.apache.org/jira/browse/FLINK-6013?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15979013#comment-15979013
]
ASF GitHub Bot commented on FLINK-6013:
---
Github user bowenli86 commented on a diff i
Github user bowenli86 commented on a diff in the pull request:
https://github.com/apache/flink/pull/3736#discussion_r112727162
--- Diff:
flink-metrics/flink-metrics-datadog/src/main/java/org/apache/flink/metrics/datadog/DatadogHttpReporter.java
---
@@ -0,0 +1,197 @@
+/*
+
Github user bowenli86 commented on a diff in the pull request:
https://github.com/apache/flink/pull/3736#discussion_r112727098
--- Diff:
flink-metrics/flink-metrics-datadog/src/main/java/org/apache/flink/metrics/datadog/DatadogHttpClient.java
---
@@ -0,0 +1,97 @@
+/*
+ * L
Github user bowenli86 commented on a diff in the pull request:
https://github.com/apache/flink/pull/3736#discussion_r112727145
--- Diff:
flink-metrics/flink-metrics-datadog/src/main/java/org/apache/flink/metrics/datadog/DatadogHttpReporter.java
---
@@ -0,0 +1,197 @@
+/*
+
Github user stefanobortoli commented on the issue:
https://github.com/apache/flink/pull/3732
@fhueske I have just pushed a version working with code generation (without
modifying the code generation) There will be the need for some refactoring in
the AggregateUtil function, but if the
[
https://issues.apache.org/jira/browse/FLINK-6013?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15979012#comment-15979012
]
ASF GitHub Bot commented on FLINK-6013:
---
Github user bowenli86 commented on a diff i
[
https://issues.apache.org/jira/browse/FLINK-6013?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15979011#comment-15979011
]
ASF GitHub Bot commented on FLINK-6013:
---
Github user bowenli86 commented on a diff i
Github user stefanobortoli commented on a diff in the pull request:
https://github.com/apache/flink/pull/3732#discussion_r112725482
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/functions/UnsupportedOperatorsIndicatorFunctions.scala
---
@@ -0,0 +1,46
Github user stefanobortoli commented on a diff in the pull request:
https://github.com/apache/flink/pull/3732#discussion_r112725820
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/datastream/DataStreamOverAggregate.scala
---
@@ -91,6 +93,22 @
[
https://issues.apache.org/jira/browse/FLINK-6250?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15979007#comment-15979007
]
ASF GitHub Bot commented on FLINK-6250:
---
Github user stefanobortoli commented on the
1 - 100 of 353 matches
Mail list logo
