[
https://issues.apache.org/jira/browse/FLINK-3644?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15240711#comment-15240711
]
ASF GitHub Bot commented on FLINK-3644:
---
Github user fhueske commented on the pull r
Github user fhueske commented on the pull request:
https://github.com/apache/flink/pull/1824#issuecomment-209788558
Although Github marks the PR as closed, the change has been merged to the
master branch. Because Stephan squashed the commits of the PR into a single
commit and rebased
[
https://issues.apache.org/jira/browse/FLINK-3644?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15240700#comment-15240700
]
ASF GitHub Bot commented on FLINK-3644:
---
Github user Astralidea commented on the pul
Github user Astralidea commented on the pull request:
https://github.com/apache/flink/pull/1824#issuecomment-209784384
@StephanEwen
It looks like did not merge into Flink Master?
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHu
Github user ramkrish86 commented on a diff in the pull request:
https://github.com/apache/flink/pull/1881#discussion_r59661849
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/codegen/CodeGenerator.scala
---
@@ -551,23 +551,27 @@ class CodeGenerator(
[
https://issues.apache.org/jira/browse/FLINK-3749?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15240569#comment-15240569
]
ASF GitHub Bot commented on FLINK-3749:
---
Github user ramkrish86 commented on a diff
[
https://issues.apache.org/jira/browse/FLINK-3738?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15240459#comment-15240459
]
Yijie Shen edited comment on FLINK-3738 at 4/14/16 2:13 AM:
Hi
[
https://issues.apache.org/jira/browse/FLINK-3738?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15240459#comment-15240459
]
Yijie Shen commented on FLINK-3738:
---
Hi [~fhueske], I've opened
{FLINK-3754|https://iss
[
https://issues.apache.org/jira/browse/FLINK-3738?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15240459#comment-15240459
]
Yijie Shen edited comment on FLINK-3738 at 4/14/16 2:13 AM:
Hi
Yijie Shen created FLINK-3754:
-
Summary: Add a validation phase before construct RelNode using
TableAPI
Key: FLINK-3754
URL: https://issues.apache.org/jira/browse/FLINK-3754
Project: Flink
Issue
Ted Yu created FLINK-3753:
-
Summary: KillerWatchDog should not use kill on toKill thread
Key: FLINK-3753
URL: https://issues.apache.org/jira/browse/FLINK-3753
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-1979?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15239918#comment-15239918
]
ASF GitHub Bot commented on FLINK-1979:
---
Github user skavulya commented on the pull
Github user skavulya commented on the pull request:
https://github.com/apache/flink/pull/656#issuecomment-209618076
I need this pull request for work I am doing with L-BFGS. I would like to
take it over and make the recommended changes since there has not been any
activity on this for
[
https://issues.apache.org/jira/browse/FLINK-2544?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15239877#comment-15239877
]
Soila Kavulya commented on FLINK-2544:
--
I created a pull request to update README.md
[
https://issues.apache.org/jira/browse/FLINK-2544?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15239870#comment-15239870
]
ASF GitHub Bot commented on FLINK-2544:
---
GitHub user skavulya opened a pull request:
GitHub user skavulya opened a pull request:
https://github.com/apache/flink/pull/1882
[FLINK-2544] Add Java 8 version for building PowerMock tests to docs
Java 8 update 11 introduced a stricter bytecode verifier that leads to
failures in unit tests that use the PowerMock runner. The
Stephan Ewen created FLINK-3752:
---
Summary: Add Per-Kafka-Partition Watermark Generation to the docs
Key: FLINK-3752
URL: https://issues.apache.org/jira/browse/FLINK-3752
Project: Flink
Issue Ty
[
https://issues.apache.org/jira/browse/FLINK-3375?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-3375.
-
Resolution: Fixed
Fix Version/s: (was: 1.0.0)
1.1.0
Finalized in 2dc
[
https://issues.apache.org/jira/browse/FLINK-3375?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-3375.
---
> Allow Watermark Generation in the Kafka Source
> --
>
>
[
https://issues.apache.org/jira/browse/FLINK-3747?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-3747.
-
Resolution: Fixed
Fix Version/s: 1.1.0
Fixed via e40e29da9b68ec6da59f7b5372cb1483283c0530
[
https://issues.apache.org/jira/browse/FLINK-3747?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-3747.
---
> Consolidate TimestampAssigner Methods in Kafka Consumer
> --
[
https://issues.apache.org/jira/browse/FLINK-3745?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-3745.
---
> TimestampITCase testWatermarkPropagationNoFinalWatermarkOnStop failing
> intermittently
> -
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/1876
---
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-3745?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-3745.
-
Resolution: Fixed
Fix Version/s: 1.1.0
Fixed via 8570b6dc3ae3c69dc50e81a46835d40df8a03992
[
https://issues.apache.org/jira/browse/FLINK-3747?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15239829#comment-15239829
]
ASF GitHub Bot commented on FLINK-3747:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-3743?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15239828#comment-15239828
]
ASF GitHub Bot commented on FLINK-3743:
---
Github user asfgit closed the pull request
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/1877
---
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-2909?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Greg Hogan closed FLINK-2909.
-
Resolution: Fixed
Fixed with b0a7a1b813b29dbfd5c959ee2929372c31befda8
> Gelly Graph Generators
>
[
https://issues.apache.org/jira/browse/FLINK-1579?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15239798#comment-15239798
]
Stephan Ewen commented on FLINK-1579:
-
Here is a brief thread talking about that in th
[
https://issues.apache.org/jira/browse/FLINK-1579?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15239790#comment-15239790
]
Stephan Ewen commented on FLINK-1579:
-
The good thing in the current design is that al
[
https://issues.apache.org/jira/browse/FLINK-2909?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15239777#comment-15239777
]
ASF GitHub Bot commented on FLINK-2909:
---
Github user asfgit closed the pull request
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/1807
---
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-3657?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15239709#comment-15239709
]
ASF GitHub Bot commented on FLINK-3657:
---
GitHub user smarthi reopened a pull request
GitHub user smarthi reopened a pull request:
https://github.com/apache/flink/pull/1829
FLINK-3657: Change access of DataSetUtils.countElements() to 'public'
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/smarthi/flink Flink-3657
[
https://issues.apache.org/jira/browse/FLINK-3589?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15239514#comment-15239514
]
ASF GitHub Bot commented on FLINK-3589:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-3589?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Greg Hogan closed FLINK-3589.
-
Resolution: Fixed
Fixed in 5350bc48af37a1d6296de5b290b870b7d68407fa
> Allow setting Operator parallelism
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/1778
---
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 StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/1853#issuecomment-209507866
Manually merged in 885d543be8a8c0d1acdffa0003e394347d5376ef
---
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-3700?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15239418#comment-15239418
]
ASF GitHub Bot commented on FLINK-3700:
---
Github user StephanEwen commented on the pu
[
https://issues.apache.org/jira/browse/FLINK-3700?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15239419#comment-15239419
]
ASF GitHub Bot commented on FLINK-3700:
---
Github user StephanEwen closed the pull req
Github user StephanEwen closed the pull request at:
https://github.com/apache/flink/pull/1853
---
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-3743?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15239401#comment-15239401
]
ASF GitHub Bot commented on FLINK-3743:
---
Github user StephanEwen commented on the pu
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/1876#issuecomment-209505394
Looks good, merging this...
---
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
[
https://issues.apache.org/jira/browse/FLINK-3358?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-3358.
---
> Create constructors for FsStateBackend in RocksDBBackens
> -
[
https://issues.apache.org/jira/browse/FLINK-3358?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-3358.
-
Resolution: Fixed
Assignee: Stephan Ewen
Fixed via edae79340dd486915d25109cbdc1485accae665a
[
https://issues.apache.org/jira/browse/FLINK-3664?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-3664:
-
Assignee: Todd Lisonbee
> Create a method to easily Summarize a DataSet
>
[
https://issues.apache.org/jira/browse/FLINK-3751?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15239333#comment-15239333
]
Aljoscha Krettek commented on FLINK-3751:
-
+1
> default Operator names are incons
[
https://issues.apache.org/jira/browse/FLINK-3750?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15239331#comment-15239331
]
Aljoscha Krettek commented on FLINK-3750:
-
+1, this would be a good addition.
> M
[
https://issues.apache.org/jira/browse/FLINK-3749?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15239327#comment-15239327
]
ASF GitHub Bot commented on FLINK-3749:
---
GitHub user twalthr opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-3376?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann closed FLINK-3376.
> Add an illustration of Event Time and Watermarks to the docs
> ---
GitHub user twalthr opened a pull request:
https://github.com/apache/flink/pull/1881
[FLINK-3749] [table] Improve decimal handling
This PR improves the decimal handling and fixes several bugs.
You can merge this pull request into a Git repository by running:
$ git pull https://
[
https://issues.apache.org/jira/browse/FLINK-3376?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann resolved FLINK-3376.
--
Resolution: Fixed
Assignee: Stephan Ewen
Has been added to the docs
> Add an illustration
Flavio Pompermaier created FLINK-3750:
-
Summary: Make JDBCInputFormat a parallel source
Key: FLINK-3750
URL: https://issues.apache.org/jira/browse/FLINK-3750
Project: Flink
Issue Type: Im
Chesnay Schepler created FLINK-3751:
---
Summary: default Operator names are inconsistent
Key: FLINK-3751
URL: https://issues.apache.org/jira/browse/FLINK-3751
Project: Flink
Issue Type: Bug
Timo Walther created FLINK-3749:
---
Summary: Improve decimal handling
Key: FLINK-3749
URL: https://issues.apache.org/jira/browse/FLINK-3749
Project: Flink
Issue Type: Bug
Components: Ta
[
https://issues.apache.org/jira/browse/FLINK-3747?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15239159#comment-15239159
]
ASF GitHub Bot commented on FLINK-3747:
---
Github user StephanEwen commented on the pu
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/1877#issuecomment-209408180
Looks good, merging this...
---
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
[
https://issues.apache.org/jira/browse/FLINK-3732?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15239154#comment-15239154
]
ASF GitHub Bot commented on FLINK-3732:
---
Github user StephanEwen commented on the pu
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/1871#issuecomment-209407499
Looks good. Failed test seems to be a Scala compiler issue, not related to
this pull request.
Merging this...
---
If your project is set up for it, you can
Github user zentol commented on the pull request:
https://github.com/apache/flink/pull/1771#issuecomment-209400438
@rmetzger I hav efixed the issue you encountered. The problem was that the
JM tries to discard all state belonging to pending checkpoints upon job
failure, which effectiv
[
https://issues.apache.org/jira/browse/FLINK-3311?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15239127#comment-15239127
]
ASF GitHub Bot commented on FLINK-3311:
---
Github user zentol commented on the pull re
[
https://issues.apache.org/jira/browse/FLINK-3739?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15239073#comment-15239073
]
Vasia Kalavri commented on FLINK-3739:
--
I see, thanks [~twalthr]! I'll review your pr
Timo Walther created FLINK-3748:
---
Summary: Add CASE function to Table API
Key: FLINK-3748
URL: https://issues.apache.org/jira/browse/FLINK-3748
Project: Flink
Issue Type: Sub-task
Com
[
https://issues.apache.org/jira/browse/FLINK-3739?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15239051#comment-15239051
]
Timo Walther commented on FLINK-3739:
-
[~vkalavri] It seems that Calcite needs explici
[
https://issues.apache.org/jira/browse/FLINK-3735?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Vasia Kalavri resolved FLINK-3735.
--
Resolution: Fixed
Fix Version/s: 1.1.0
> Embedded SQL union should fail during translatio
GitHub user twalthr opened a pull request:
https://github.com/apache/flink/pull/1880
[FLINK-3739] [table] Add a null literal to Table API
This PR adds the NULL literal to Java/Scala Table API as well as SQL API.
You can merge this pull request into a Git repository by running:
[
https://issues.apache.org/jira/browse/FLINK-3739?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15239050#comment-15239050
]
ASF GitHub Bot commented on FLINK-3739:
---
GitHub user twalthr opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-3735?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15239047#comment-15239047
]
ASF GitHub Bot commented on FLINK-3735:
---
Github user asfgit closed the pull request
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/1874
---
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 aljoscha opened a pull request:
https://github.com/apache/flink/pull/1879
[FLINK-3718] Add Option For Completely Async Backup in RocksDB State Backend
This also refactors the RocksDB backend to keep one RocksDB data base in
the backend where all key/value state is sto
[
https://issues.apache.org/jira/browse/FLINK-3718?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15239045#comment-15239045
]
ASF GitHub Bot commented on FLINK-3718:
---
GitHub user aljoscha opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-3740?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15239030#comment-15239030
]
ASF GitHub Bot commented on FLINK-3740:
---
GitHub user aljoscha opened a pull request:
GitHub user aljoscha opened a pull request:
https://github.com/apache/flink/pull/1878
[FLINK-3740] Make Session Window State Checkpointed
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/aljoscha/flink window-snapshot-test
Altern
[
https://issues.apache.org/jira/browse/FLINK-3745?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15239029#comment-15239029
]
Stephan Ewen commented on FLINK-3745:
-
I have a fix coming up...
> TimestampITCase te
[
https://issues.apache.org/jira/browse/FLINK-3745?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen reassigned FLINK-3745:
---
Assignee: Stephan Ewen
> TimestampITCase testWatermarkPropagationNoFinalWatermarkOnStop faili
[
https://issues.apache.org/jira/browse/FLINK-3745?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15239026#comment-15239026
]
Stephan Ewen commented on FLINK-3745:
-
Took at look at that one. Here is what I think
[
https://issues.apache.org/jira/browse/FLINK-3735?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15239019#comment-15239019
]
ASF GitHub Bot commented on FLINK-3735:
---
Github user vasia commented on the pull req
Github user vasia commented on the pull request:
https://github.com/apache/flink/pull/1874#issuecomment-209354485
Thanks. I'll fix the style and merge!
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does
[
https://issues.apache.org/jira/browse/FLINK-3738?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15239014#comment-15239014
]
Fabian Hueske commented on FLINK-3738:
--
Oh I see. {{toTable()}} is implicitly added t
[
https://issues.apache.org/jira/browse/FLINK-3738?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15239011#comment-15239011
]
Aljoscha Krettek commented on FLINK-3738:
-
Ah ok, I see.
> Refactor TableEnvironm
[
https://issues.apache.org/jira/browse/FLINK-3735?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15239010#comment-15239010
]
ASF GitHub Bot commented on FLINK-3735:
---
Github user fhueske commented on the pull r
Github user fhueske commented on the pull request:
https://github.com/apache/flink/pull/1874#issuecomment-209352434
Just a minor style comment. Good to merge otherwise. Thanks @vasia
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHu
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/1874#discussion_r59524034
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/plan/rules/dataSet/DataSetUnionRule.scala
---
@@ -32,6 +32,13 @@ class DataSe
[
https://issues.apache.org/jira/browse/FLINK-3735?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15239008#comment-15239008
]
ASF GitHub Bot commented on FLINK-3735:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-3738?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15239004#comment-15239004
]
Fabian Hueske commented on FLINK-3738:
--
That is also supported and for Java the only
[
https://issues.apache.org/jira/browse/FLINK-3738?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15239000#comment-15239000
]
Aljoscha Krettek commented on FLINK-3738:
-
The reason I'm saying this is that the
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/1853#discussion_r59518788
--- Diff: flink-core/src/main/java/org/apache/flink/util/Preconditions.java
---
@@ -0,0 +1,213 @@
+/*
+ * Licensed to the Apache Software Foundati
[
https://issues.apache.org/jira/browse/FLINK-3738?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15238995#comment-15238995
]
Aljoscha Krettek commented on FLINK-3738:
-
Why not {{tEnv.fromDataSet(DataSet)}} t
GitHub user aljoscha opened a pull request:
https://github.com/apache/flink/pull/1877
[FLINK-3747] Consolidate TimestampAssigner Methods in Kafka Consumer
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/aljoscha/flink kafka-fix-a
[
https://issues.apache.org/jira/browse/FLINK-3738?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15238964#comment-15238964
]
Fabian Hueske commented on FLINK-3738:
--
Yes, but these methods will require a {{Table
[
https://issues.apache.org/jira/browse/FLINK-3747?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15238968#comment-15238968
]
ASF GitHub Bot commented on FLINK-3747:
---
GitHub user aljoscha opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-3738?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15238958#comment-15238958
]
Fabian Hueske commented on FLINK-3738:
--
Hi [~yijieshen], that's a good observation. I
[
https://issues.apache.org/jira/browse/FLINK-3747?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15238947#comment-15238947
]
Aljoscha Krettek commented on FLINK-3747:
-
will do
> Consolidate TimestampAssign
[
https://issues.apache.org/jira/browse/FLINK-3738?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15238964#comment-15238964
]
Fabian Hueske edited comment on FLINK-3738 at 4/13/16 9:39 AM:
-
[
https://issues.apache.org/jira/browse/FLINK-3700?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15238946#comment-15238946
]
ASF GitHub Bot commented on FLINK-3700:
---
Github user StephanEwen commented on a diff
[
https://issues.apache.org/jira/browse/FLINK-3747?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek reassigned FLINK-3747:
---
Assignee: Aljoscha Krettek
> Consolidate TimestampAssigner Methods in Kafka Consumer
[
https://issues.apache.org/jira/browse/FLINK-3741?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15238940#comment-15238940
]
Stephan Ewen commented on FLINK-3741:
-
I am also seeing this the {{hcatalog}} project
[
https://issues.apache.org/jira/browse/FLINK-3589?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15238936#comment-15238936
]
ASF GitHub Bot commented on FLINK-3589:
---
Github user zentol commented on the pull re
Github user zentol commented on the pull request:
https://github.com/apache/flink/pull/1778#issuecomment-209330203
The changes look correct. If you could add a small test to verify that
passing PARALLELISM_UNKNOWN doesn't modify the parallelism we're probably good
to go.
---
If your
Github user zentol commented on the pull request:
https://github.com/apache/flink/pull/1778#issuecomment-209330425
and a rebase since github says there are conflicts ,)
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If y
1 - 100 of 139 matches
Mail list logo
