[
https://issues.apache.org/jira/browse/FLINK-6107?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15986095#comment-15986095
]
Chesnay Schepler commented on FLINK-6107:
-
The import statements were also frequen
[
https://issues.apache.org/jira/browse/FLINK-6390?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15986084#comment-15986084
]
Gyula Fora commented on FLINK-6390:
---
Not a big deal but Stephan I think you missed my co
[
https://issues.apache.org/jira/browse/FLINK-5969?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15986076#comment-15986076
]
ASF GitHub Bot commented on FLINK-5969:
---
Github user zentol commented on the issue:
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/3778
One thing i was wondering about regarding the added IT cases is whether we
can create a single class with the logic for both 1.1 and 1.2. Given that the
new IT cases appear to be mostly a copy of the
[
https://issues.apache.org/jira/browse/FLINK-6392?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15986023#comment-15986023
]
ASF GitHub Bot commented on FLINK-6392:
---
GitHub user sunjincheng121 opened a pull re
GitHub user sunjincheng121 opened a pull request:
https://github.com/apache/flink/pull/3786
[FLINK-6392][table] Change the alias of Window from optional to essenâ¦
In this PR refactoring the API definition using TYPE SYSTEM lead to
constraint for the alias.
- [x] General
[
https://issues.apache.org/jira/browse/FLINK-6387?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15985992#comment-15985992
]
ASF GitHub Bot commented on FLINK-6387:
---
Github user shijinkui commented on the issu
Github user shijinkui commented on the issue:
https://github.com/apache/flink/pull/3777
> I can see this flooding the logs like crazy, especially with things like
metrics and watermarks that update often. Some kind of filtering is probably
necessary here.
You are right. The c
[
https://issues.apache.org/jira/browse/FLINK-6288?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15985934#comment-15985934
]
ASF GitHub Bot commented on FLINK-6288:
---
Github user fanyon commented on the issue:
Github user fanyon commented on the issue:
https://github.com/apache/flink/pull/3766
@gyfora For the method `int partition(T next, byte[] serializedKey, byte[]
serializedValue, int partitionNum)` in KafkaPartitioner, the correct partition
num of target topic can be used. But the Kafka
GitHub user zhijiangW opened a pull request:
https://github.com/apache/flink/pull/3785
[FLINK-6337][network] Remove the buffer provider from
PartitionRequestServerHandler
Currently, `PartitionRequestServerHandler` will create a `LocalBufferPool`
when the channel is registered. The
[
https://issues.apache.org/jira/browse/FLINK-6337?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15985901#comment-15985901
]
ASF GitHub Bot commented on FLINK-6337:
---
GitHub user zhijiangW opened a pull request
[
https://issues.apache.org/jira/browse/FLINK-6247?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15985890#comment-15985890
]
ASF GitHub Bot commented on FLINK-6247:
---
Github user sunjincheng121 commented on the
Github user sunjincheng121 commented on the issue:
https://github.com/apache/flink/pull/3666
Hi @fhueske Thanks for your Reviewing. And sorry for late reply. I have
updated the PR. Please take a look. Thanks a lot.
Thanks,
SunJincheng
---
If your project is set up for it
[
https://issues.apache.org/jira/browse/FLINK-6392?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sunjincheng updated FLINK-6392:
---
Description:
Currently, The window clause use case looks like as following:
{code}
tab //Table('a,'b,'
[
https://issues.apache.org/jira/browse/FLINK-6392?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sunjincheng updated FLINK-6392:
---
Description:
Currently, The window clause use case looks like as following:
{code}
tab //Table('a,'b,'
[
https://issues.apache.org/jira/browse/FLINK-6392?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sunjincheng updated FLINK-6392:
---
Issue Type: Sub-task (was: Improvement)
Parent: FLINK-4557
> Change the alias of Window from
sunjincheng created FLINK-6392:
--
Summary: Change the alias of Window from optional to essential.
Key: FLINK-6392
URL: https://issues.apache.org/jira/browse/FLINK-6392
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-6391?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15985714#comment-15985714
]
ASF GitHub Bot commented on FLINK-6391:
---
Github user EronWright commented on the iss
Github user EronWright commented on the issue:
https://github.com/apache/flink/pull/3784
@greghogan that might be a good idea but I don't know much about it. I'm
merely focused on fixing the build break.
---
If your project is set up for it, you can reply to this email and have your
[
https://issues.apache.org/jira/browse/FLINK-6360?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15985711#comment-15985711
]
Greg Hogan commented on FLINK-6360:
---
[~jlaskowski], have you had a chance to work on thi
[
https://issues.apache.org/jira/browse/FLINK-6391?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15985710#comment-15985710
]
ASF GitHub Bot commented on FLINK-6391:
---
Github user greghogan commented on the issu
Github user greghogan commented on the issue:
https://github.com/apache/flink/pull/3784
Any ideas why we can't just reference `scala.binary.version` in the Maven
configurations rather than specifying `2.10` and modifying this in the change
script? I don't see why `change-scala-version
Github user heytitle commented on the issue:
https://github.com/apache/flink/pull/3511
I also think about the abstract class but I'm not sure how to do it
properly.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If you
[
https://issues.apache.org/jira/browse/FLINK-6360?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15985700#comment-15985700
]
Eron Wright commented on FLINK-6360:
-
I fixed this and opened a PR at the same time a
[
https://issues.apache.org/jira/browse/FLINK-6360?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15985700#comment-15985700
]
Eron Wright edited comment on FLINK-6360 at 4/26/17 10:55 PM:
-
[
https://issues.apache.org/jira/browse/FLINK-6391?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15985699#comment-15985699
]
ASF GitHub Bot commented on FLINK-6391:
---
GitHub user EronWright opened a pull reques
GitHub user EronWright opened a pull request:
https://github.com/apache/flink/pull/3784
FLINK-6391
FLINK-6391
Improve change-scala-version.sh to correctly deal with references to
flink-gelly-examples.
You can merge this pull request into a Git repository by running:
$ git
[
https://issues.apache.org/jira/browse/FLINK-6391?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Greg Hogan closed FLINK-6391.
-
Resolution: Duplicate
> fix build for scala 2.11 (gelly-examples)
> --
Eron Wright created FLINK-6391:
---
Summary: fix build for scala 2.11 (gelly-examples)
Key: FLINK-6391
URL: https://issues.apache.org/jira/browse/FLINK-6391
Project: Flink
Issue Type: Bug
Github user greghogan commented on the issue:
https://github.com/apache/flink/pull/3511
@heytitle, you can `rebase -i dd20^` and then delete the first two lines
which removes those commits from the history.
An initial thought from skimming the code: should we create an abstrac
[
https://issues.apache.org/jira/browse/FLINK-3722?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15985629#comment-15985629
]
ASF GitHub Bot commented on FLINK-3722:
---
Github user heytitle commented on the issue
Github user heytitle commented on the issue:
https://github.com/apache/flink/pull/3511
@greghogan May I ask you how to remove `FLINK-3722` commits?. Only way I
can think of is `git rebase -i`, but this will rewrite history of this PR.
---
If your project is set up for it, you can rep
[
https://issues.apache.org/jira/browse/FLINK-6390?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-6390.
---
> Add Trigger Hooks to the Checkpoint Coordinator
> ---
>
>
[
https://issues.apache.org/jira/browse/FLINK-6390?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-6390.
-
Resolution: Fixed
Implemented in 90ca438106e63c5032ee2ad27e54e9f573eac386
> Add Trigger Hooks to
[
https://issues.apache.org/jira/browse/FLINK-6390?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15985621#comment-15985621
]
ASF GitHub Bot commented on FLINK-6390:
---
Github user asfgit closed the pull request
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/3782
---
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-4370?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15985606#comment-15985606
]
ASF GitHub Bot commented on FLINK-4370:
---
Github user greghogan commented on the issu
Github user greghogan commented on the issue:
https://github.com/apache/flink/pull/2352
@StephanEwen can these be shared under `tools/idea/...`? If they are
installed by default then any user modifications will be noted by git.
Conversely, most contributors won't notice these files or
[
https://issues.apache.org/jira/browse/FLINK-6107?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15985578#comment-15985578
]
Greg Hogan commented on FLINK-6107:
---
[~StephanEwen], I think there was a perception that
[
https://issues.apache.org/jira/browse/FLINK-6281?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15985498#comment-15985498
]
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 your pointer of the prototype!
> Do you intend to provide exactly-once guarantees for arbitrary updates?
As I think about it a little bit more, I think it might make sense t
[
https://issues.apache.org/jira/browse/FLINK-6293?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15985432#comment-15985432
]
Stephan Ewen commented on FLINK-6293:
-
Hitting this frequently on local builds as well
[
https://issues.apache.org/jira/browse/FLINK-6293?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen updated FLINK-6293:
Priority: Critical (was: Major)
> Flakey JobManagerITCase
> ---
>
>
[
https://issues.apache.org/jira/browse/FLINK-6225?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15985423#comment-15985423
]
ASF GitHub Bot commented on FLINK-6225:
---
Github user zentol commented on a diff in t
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/3748#discussion_r113541703
--- Diff:
flink-connectors/flink-connector-cassandra/src/test/java/org/apache/flink/streaming/connectors/cassandra/CassandraConnectorITCase.java
---
@@ -108,
[
https://issues.apache.org/jira/browse/FLINK-6287?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15985404#comment-15985404
]
Stephan Ewen commented on FLINK-6287:
-
A recent PR has addressed some instability, but
[
https://issues.apache.org/jira/browse/FLINK-5969?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15985378#comment-15985378
]
ASF GitHub Bot commented on FLINK-5969:
---
Github user zentol commented on a diff in t
[
https://issues.apache.org/jira/browse/FLINK-5969?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15985379#comment-15985379
]
ASF GitHub Bot commented on FLINK-5969:
---
Github user zentol commented on a diff in t
[
https://issues.apache.org/jira/browse/FLINK-5969?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15985375#comment-15985375
]
ASF GitHub Bot commented on FLINK-5969:
---
Github user zentol commented on a diff in t
[
https://issues.apache.org/jira/browse/FLINK-5969?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15985381#comment-15985381
]
ASF GitHub Bot commented on FLINK-5969:
---
Github user zentol commented on a diff in t
[
https://issues.apache.org/jira/browse/FLINK-5969?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15985380#comment-15985380
]
ASF GitHub Bot commented on FLINK-5969:
---
Github user zentol commented on a diff in t
[
https://issues.apache.org/jira/browse/FLINK-5969?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15985376#comment-15985376
]
ASF GitHub Bot commented on FLINK-5969:
---
Github user zentol commented on a diff in t
[
https://issues.apache.org/jira/browse/FLINK-5969?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15985377#comment-15985377
]
ASF GitHub Bot commented on FLINK-5969:
---
Github user zentol commented on a diff in t
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/3778#discussion_r113441899
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/AbstractUdfStreamOperator.java
---
@@ -155,12 +155,14 @@ public void sn
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/3778#discussion_r113435639
--- Diff:
flink-clients/src/main/java/org/apache/flink/client/program/ClusterClient.java
---
@@ -489,6 +489,39 @@ public JobExecutionResult retrieveJob(JobID
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/3778#discussion_r113435697
--- Diff:
flink-clients/src/main/java/org/apache/flink/client/program/ClusterClient.java
---
@@ -489,6 +489,39 @@ public JobExecutionResult retrieveJob(JobID
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/3778#discussion_r113446953
--- Diff:
flink-tests/src/test/java/org/apache/flink/test/checkpointing/utils/StatefulUDFSavepointFrom12MigrationITCase.java
---
@@ -0,0 +1,771 @@
+/*
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/3778#discussion_r113442453
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/AbstractUdfStreamOperator.java
---
@@ -155,12 +155,14 @@ public void sn
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/3778#discussion_r113435588
--- Diff:
flink-clients/src/main/java/org/apache/flink/client/program/ClusterClient.java
---
@@ -489,6 +489,39 @@ public JobExecutionResult retrieveJob(JobID
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/3778#discussion_r113440360
--- Diff:
flink-fs-tests/src/test/java/org/apache/flink/hdfstests/ContinuousFileProcessingFrom12MigrationTest.java
---
@@ -0,0 +1,378 @@
+/*
+ * Lice
Github user ramkrish86 commented on the issue:
https://github.com/apache/flink/pull/3760
I checked the recent failure.
`Tests run: 2, Failures: 1, Errors: 0, Skipped: 0, Time elapsed: 20.417 sec
<<< FAILURE! - in
org.apache.flink.runtime.jobmanager.JobManagerRegistrationTest`
[
https://issues.apache.org/jira/browse/FLINK-6175?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15985286#comment-15985286
]
ASF GitHub Bot commented on FLINK-6175:
---
Github user StephanEwen commented on the is
[
https://issues.apache.org/jira/browse/FLINK-5752?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15985287#comment-15985287
]
ASF GitHub Bot commented on FLINK-5752:
---
Github user ramkrish86 commented on the iss
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/3655
While at hardening: The test seems to work with a fix port. That is bound
to cause failures due to conflicts (for example 8082 is common to be used if
you have a local HA Flink for testing).
--
[
https://issues.apache.org/jira/browse/FLINK-6048?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15985265#comment-15985265
]
ASF GitHub Bot commented on FLINK-6048:
---
Github user StefanRRichter closed the pull
Github user StefanRRichter closed the pull request at:
https://github.com/apache/flink/pull/3536
---
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/3736#discussion_r113519219
--- Diff: flink-metrics/flink-metrics-datadog/pom.xml ---
@@ -0,0 +1,109 @@
+
+
+http://maven.apache.org/POM/4.0.0";
+ xmlns:xsi="http:
[
https://issues.apache.org/jira/browse/FLINK-6013?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15985247#comment-15985247
]
ASF GitHub Bot commented on FLINK-6013:
---
Github user zentol commented on a diff in t
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/3783
Please fix the PR title, you are referencing the wrong JIRA.
---
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 ha
[
https://issues.apache.org/jira/browse/FLINK-6338?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15985245#comment-15985245
]
ASF GitHub Bot commented on FLINK-6338:
---
Github user zentol commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-6048?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15985237#comment-15985237
]
ASF GitHub Bot commented on FLINK-6048:
---
Github user StefanRRichter commented on the
Github user StefanRRichter commented on the issue:
https://github.com/apache/flink/pull/3536
Thanks for the review @tillrohrmann. I addressed your comments concerning
unregistration of streams. Will merge this now.
---
If your project is set up for it, you can reply to this email and
[
https://issues.apache.org/jira/browse/FLINK-6107?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15985221#comment-15985221
]
Stephan Ewen commented on FLINK-6107:
-
I would like to make a suggestion for an adjust
[
https://issues.apache.org/jira/browse/FLINK-3722?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15985213#comment-15985213
]
ASF GitHub Bot commented on FLINK-3722:
---
Github user greghogan commented on the issu
Github user greghogan commented on the issue:
https://github.com/apache/flink/pull/3511
@heytitle please remove the old FLINK-3722 commits and rebase to master.
---
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 proj
[
https://issues.apache.org/jira/browse/FLINK-6250?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15985209#comment-15985209
]
ASF GitHub Bot commented on FLINK-6250:
---
Github user stefanobortoli closed the pull
Github user stefanobortoli closed the pull request at:
https://github.com/apache/flink/pull/3771
---
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
[
https://issues.apache.org/jira/browse/FLINK-6357?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Greg Hogan updated FLINK-6357:
--
Summary: ParameterTool get unrequested parameters (was: Parametertool get
unrequested parameters)
> Pa
Github user huawei-flink commented on the issue:
https://github.com/apache/flink/pull/3771
@fhueske I have created #3783 with just the code generation part. At least
the GROUP BY distinct can move ahead. I will close this PR and wait for the
merging of the Calcite fix.
---
If your p
[
https://issues.apache.org/jira/browse/FLINK-6250?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15985208#comment-15985208
]
ASF GitHub Bot commented on FLINK-6250:
---
Github user huawei-flink commented on the i
[
https://issues.apache.org/jira/browse/FLINK-3722?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Greg Hogan updated FLINK-3722:
--
Fix Version/s: 1.3.0
> The divisions in the InMemorySorters' swap/compare methods hurt performance
> ---
[
https://issues.apache.org/jira/browse/FLINK-3722?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Greg Hogan closed FLINK-3722.
-
Resolution: Implemented
Implemented in 336b95d4eedc23e5ce37d1739165157e127c65f8
> The divisions in the In
[
https://issues.apache.org/jira/browse/FLINK-3722?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15985203#comment-15985203
]
ASF GitHub Bot commented on FLINK-3722:
---
Github user asfgit closed the pull request
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/2628
---
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-6338?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15985198#comment-15985198
]
ASF GitHub Bot commented on FLINK-6338:
---
Github user huawei-flink commented on the i
Github user huawei-flink commented on the issue:
https://github.com/apache/flink/pull/3783
@fhueske please have a look at this PR, it contains just the code
generation part with optional distinct.
---
If your project is set up for it, you can reply to this email and have your
reply a
[
https://issues.apache.org/jira/browse/FLINK-6338?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15985197#comment-15985197
]
ASF GitHub Bot commented on FLINK-6338:
---
GitHub user huawei-flink opened a pull requ
GitHub user huawei-flink opened a pull request:
https://github.com/apache/flink/pull/3783
[FLINK-6338] Add support for DISTINCT into Code Generated Aggregations
Thanks for contributing to Apache Flink. Before you open your pull request,
please take the following check list into cons
[
https://issues.apache.org/jira/browse/FLINK-6013?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15985190#comment-15985190
]
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_r113512176
--- Diff:
flink-metrics/flink-metrics-datadog/src/main/java/org/apache/flink/metrics/datadog/DatadogHttpReporter.java
---
@@ -0,0 +1,199 @@
+/*
+
[
https://issues.apache.org/jira/browse/FLINK-6013?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15985159#comment-15985159
]
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_r113510125
--- Diff: flink-metrics/flink-metrics-datadog/pom.xml ---
@@ -0,0 +1,109 @@
+
+
+http://maven.apache.org/POM/4.0.0";
+ xmlns:xsi="ht
[
https://issues.apache.org/jira/browse/FLINK-6390?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15985157#comment-15985157
]
ASF GitHub Bot commented on FLINK-6390:
---
Github user StephanEwen commented on the is
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/3782
Thanks a lot for the fast review. Agree with both issues raised. Will
address them while merging...
---
If your project is set up for it, you can reply to this email and have your
reply appear o
[
https://issues.apache.org/jira/browse/FLINK-6390?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15985154#comment-15985154
]
ASF GitHub Bot commented on FLINK-6390:
---
Github user tillrohrmann commented on a dif
[
https://issues.apache.org/jira/browse/FLINK-6390?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15985155#comment-15985155
]
ASF GitHub Bot commented on FLINK-6390:
---
Github user tillrohrmann commented on a dif
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/3782#discussion_r113504901
--- Diff:
flink-core/src/main/java/org/apache/flink/core/io/SimpleVersionedSerializer.java
---
@@ -0,0 +1,80 @@
+/*
+ * Licensed to the Apache
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/3782#discussion_r113507485
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/hooks/MasterHooks.java
---
@@ -0,0 +1,272 @@
+/*
+ * Licensed to the
[
https://issues.apache.org/jira/browse/FLINK-6288?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15985138#comment-15985138
]
ASF GitHub Bot commented on FLINK-6288:
---
Github user gyfora commented on the issue:
1 - 100 of 352 matches
Mail list logo
