[
https://issues.apache.org/jira/browse/FLINK-6468?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16002143#comment-16002143
]
Petr Novotnik commented on FLINK-6468:
--
Thank you!
> release 1.2.1 tag in git
>
[
https://issues.apache.org/jira/browse/FLINK-6500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16002131#comment-16002131
]
radu commented on FLINK-6500:
-
[~fhueske]
Thanks for the info. Considering the workaround - s
[
https://issues.apache.org/jira/browse/FLINK-6476?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16002125#comment-16002125
]
ASF GitHub Bot commented on FLINK-6476:
---
Github user rtudoran commented on the issue
Github user rtudoran commented on the issue:
https://github.com/apache/flink/pull/3849
@fhueske thanks for the review. I will have make another pass and resubmit
it
---
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
[
https://issues.apache.org/jira/browse/FLINK-6247?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16002083#comment-16002083
]
Xingcan Cui commented on FLINK-6247:
Sorry for reawakening this. I know setting the de
[
https://issues.apache.org/jira/browse/FLINK-5967?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
yanghua updated FLINK-5967:
---
Comment: was deleted
(was: hi [~aljoscha] where to add the document?)
> Document AggregatingState
> -
[
https://issues.apache.org/jira/browse/FLINK-6397?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16001936#comment-16001936
]
ASF GitHub Bot commented on FLINK-6397:
---
Github user ifndef-SleePy commented on the
Github user ifndef-SleePy commented on the issue:
https://github.com/apache/flink/pull/3810
Hi, I updated this review. I don't know why there is no reminding in jira
and email.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as w
[
https://issues.apache.org/jira/browse/FLINK-6343?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16001922#comment-16001922
]
Fang Yong commented on FLINK-6343:
--
[~tzulitai] I aggree with you that register two state
[
https://issues.apache.org/jira/browse/FLINK-6020?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16001897#comment-16001897
]
ASF GitHub Bot commented on FLINK-6020:
---
Github user WangTaoTheTonic commented on th
Github user WangTaoTheTonic commented on the issue:
https://github.com/apache/flink/pull/3525
That looks good to me. Looking forward to fix from @tillrohrmann. Thank you
very much :)
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHu
[
https://issues.apache.org/jira/browse/FLINK-6364?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16001880#comment-16001880
]
ASF GitHub Bot commented on FLINK-6364:
---
Github user shixiaogang closed the pull req
Github user shixiaogang closed the pull request at:
https://github.com/apache/flink/pull/3801
---
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-5690?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16001826#comment-16001826
]
Shannon Carey commented on FLINK-5690:
--
Regarding the comment:
{quote}
Mh, that's we
[
https://issues.apache.org/jira/browse/FLINK-6479?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16001461#comment-16001461
]
ASF GitHub Bot commented on FLINK-6479:
---
Github user fhueske commented on the issue:
Github user fhueske commented on the issue:
https://github.com/apache/flink/pull/3841
Thanks for fixing this bug @sunjincheng121!
Will merge this later.
---
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
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3849#discussion_r115339279
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/TableEnvironment.scala
---
@@ -677,6 +678,23 @@ abstract class TableEnvironm
[
https://issues.apache.org/jira/browse/FLINK-6476?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16001453#comment-16001453
]
ASF GitHub Bot commented on FLINK-6476:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-6476?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16001450#comment-16001450
]
ASF GitHub Bot commented on FLINK-6476:
---
Github user fhueske commented on a diff in
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3849#discussion_r115339202
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/TableEnvironment.scala
---
@@ -677,6 +678,23 @@ abstract class TableEnvironm
[
https://issues.apache.org/jira/browse/FLINK-6476?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16001451#comment-16001451
]
ASF GitHub Bot commented on FLINK-6476:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-6476?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16001452#comment-16001452
]
ASF GitHub Bot commented on FLINK-6476:
---
Github user fhueske commented on a diff in
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3849#discussion_r115340600
--- Diff:
flink-libraries/flink-table/src/test/java/org/apache/flink/table/api/java/stream/sql/SqlITCase.java
---
@@ -30,11 +30,125 @@
import org.apach
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3849#discussion_r115339883
--- Diff:
flink-libraries/flink-table/src/test/java/org/apache/flink/table/api/java/stream/sql/SqlITCase.java
---
@@ -30,11 +30,125 @@
import org.apach
[
https://issues.apache.org/jira/browse/FLINK-6500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16001408#comment-16001408
]
Fabian Hueske commented on FLINK-6500:
--
I agree, this behavior is not very nice. Ther
[
https://issues.apache.org/jira/browse/FLINK-6013?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16001380#comment-16001380
]
ASF GitHub Bot commented on FLINK-6013:
---
Github user bowenli86 commented on the issu
Github user bowenli86 commented on the issue:
https://github.com/apache/flink/pull/3736
Sure.
BTW, that reminds me of one thing - I need to update the project version in
my code from 1.3-SNAPSHOT to 1.4-SNAPSHOT.
---
If your project is set up for it, you can reply to this em
[
https://issues.apache.org/jira/browse/FLINK-6013?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16001362#comment-16001362
]
ASF GitHub Bot commented on FLINK-6013:
---
Github user StephanEwen commented on the is
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/3736
@bowenli86 Th good thing is that should be able to use the reporter version
1.4-SNAPSHOT also with a Flink 1.3 release, because the reporter API is quite
stable by now.
---
If your project is s
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/3736
I can merge it sometime this week, once i found a few more things to merge
alongside it.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well
[
https://issues.apache.org/jira/browse/FLINK-6013?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16001359#comment-16001359
]
ASF GitHub Bot commented on FLINK-6013:
---
Github user zentol commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-6013?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16001346#comment-16001346
]
ASF GitHub Bot commented on FLINK-6013:
---
Github user bowenli86 commented on the issu
Github user bowenli86 commented on the issue:
https://github.com/apache/flink/pull/3736
I see - by looking at the code, I saw Flink has switched to version
1.4-SNAPSHOT 12h ago. Getting it into 1.4 is fine, our company has a open
ticket for getting this code into Flink, and I want to
Stephan Ewen created FLINK-6501:
---
Summary: Make sure NOTICE files are bundled into shaded JAR files
Key: FLINK-6501
URL: https://issues.apache.org/jira/browse/FLINK-6501
Project: Flink
Issue Ty
[
https://issues.apache.org/jira/browse/FLINK-5781?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16001320#comment-16001320
]
ASF GitHub Bot commented on FLINK-5781:
---
Github user zentol commented on the issue:
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/3495
I'm also thinking that we should hide ConfigOptions that are marked as
deprecated, which should be rather easy to fix since we're already employing
reflection.
---
If your project is set up for it,
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/3599#discussion_r115323196
--- Diff: flink-shaded-curator/flink-shaded-curator-recipes/pom.xml ---
@@ -70,6 +70,15 @@ under the License.
[
https://issues.apache.org/jira/browse/FLINK-6500?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
radu updated FLINK-6500:
Description:
Relying on implicit types in scala can lead to errors when the arity of the
input is different than th
[
https://issues.apache.org/jira/browse/FLINK-6174?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16001319#comment-16001319
]
ASF GitHub Bot commented on FLINK-6174:
---
Github user StephanEwen commented on a diff
[
https://issues.apache.org/jira/browse/FLINK-6174?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16001318#comment-16001318
]
ASF GitHub Bot commented on FLINK-6174:
---
Github user StephanEwen commented on the is
[
https://issues.apache.org/jira/browse/FLINK-6013?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16001311#comment-16001311
]
ASF GitHub Bot commented on FLINK-6013:
---
Github user zentol commented on the issue:
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/3599
Thanks for adding this!
I have a few questions:
- From the formatting, the code looks like might be adapted from some
other project. If yes, can you share from where and add a comme
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/3736
This won't make it into 1.3. For one the feature freeze is in effect since
today, so it is too late to merge it now.
That said it may be possible to merge it for 1.4 and maintain a separate
r
[
https://issues.apache.org/jira/browse/FLINK-6493?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger updated FLINK-6493:
--
Component/s: State Backends, Checkpointing
> Ineffective null check in RegisteredOperatorBackend
[
https://issues.apache.org/jira/browse/FLINK-6492?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger updated FLINK-6492:
--
Component/s: State Backends, Checkpointing
> Unclosed DataOutputViewStream in GenericArraySerial
[
https://issues.apache.org/jira/browse/FLINK-6467?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger updated FLINK-6467:
--
Component/s: State Backends, Checkpointing
> Potential lack of synchronization w.r.t. newSstFile
[
https://issues.apache.org/jira/browse/FLINK-6464?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger updated FLINK-6464:
--
Component/s: Metrics
> Metric name is not stable
> -
>
>
[
https://issues.apache.org/jira/browse/FLINK-6500?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
radu updated FLINK-6500:
Description:
Relying on implicit types in scala can lead to errors when the arity of the
input is different than th
[
https://issues.apache.org/jira/browse/FLINK-6500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16001304#comment-16001304
]
radu commented on FLINK-6500:
-
[~fhueske]
While testing various ways of using the sql i foun
radu created FLINK-6500:
---
Summary: RowSerialization problem
Key: FLINK-6500
URL: https://issues.apache.org/jira/browse/FLINK-6500
Project: Flink
Issue Type: Bug
Components: Table API & SQL
[
https://issues.apache.org/jira/browse/FLINK-6476?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16001284#comment-16001284
]
ASF GitHub Bot commented on FLINK-6476:
---
Github user rtudoran commented on the issue
Github user rtudoran commented on the issue:
https://github.com/apache/flink/pull/3849
@fhueske
Please have a look. I inserted tests in scala and java to check the
registration of the stream.
For scala - it seemed to work directly if the implicit value is set (i did
not k
GitHub user rtudoran opened a pull request:
https://github.com/apache/flink/pull/3849
[FLINK-6476] - Table environment register row data stream
Added tests for registering row streams in java and scala
Thanks for contributing to Apache Flink. Before you open your pull reques
[
https://issues.apache.org/jira/browse/FLINK-6476?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16001280#comment-16001280
]
ASF GitHub Bot commented on FLINK-6476:
---
GitHub user rtudoran opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-6487?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16001269#comment-16001269
]
Patrick Lucas commented on FLINK-6487:
--
This appears to work:
{code}
#!/bin/bash
JM
Chesnay Schepler created FLINK-6499:
---
Summary: Migrate state configuration options
Key: FLINK-6499
URL: https://issues.apache.org/jira/browse/FLINK-6499
Project: Flink
Issue Type: Sub-task
Chesnay Schepler created FLINK-6498:
---
Summary: Migrate Zookeeper configuration options
Key: FLINK-6498
URL: https://issues.apache.org/jira/browse/FLINK-6498
Project: Flink
Issue Type: Sub-t
Chesnay Schepler created FLINK-6497:
---
Summary: Deprecate High Availability options in ConfigConstants
Key: FLINK-6497
URL: https://issues.apache.org/jira/browse/FLINK-6497
Project: Flink
Is
Chesnay Schepler created FLINK-6496:
---
Summary: Migrate SSL configuration options
Key: FLINK-6496
URL: https://issues.apache.org/jira/browse/FLINK-6496
Project: Flink
Issue Type: Sub-task
Chesnay Schepler created FLINK-6495:
---
Summary: Migrate Akka configuration options
Key: FLINK-6495
URL: https://issues.apache.org/jira/browse/FLINK-6495
Project: Flink
Issue Type: Sub-task
[
https://issues.apache.org/jira/browse/FLINK-4767?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16001234#comment-16001234
]
Chesnay Schepler commented on FLINK-4767:
-
Are the blob server options part fo thi
Chesnay Schepler created FLINK-6494:
---
Summary: Migrate ResourceManager configuration options
Key: FLINK-6494
URL: https://issues.apache.org/jira/browse/FLINK-6494
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-6487?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16001228#comment-16001228
]
Patrick Lucas commented on FLINK-6487:
--
I think we have to be cleverer (more clever?)
Ted Yu created FLINK-6493:
-
Summary: Ineffective null check in
RegisteredOperatorBackendStateMetaInfo#equals()
Key: FLINK-6493
URL: https://issues.apache.org/jira/browse/FLINK-6493
Project: Flink
Is
Ted Yu created FLINK-6492:
-
Summary: Unclosed DataOutputViewStream in
GenericArraySerializerConfigSnapshot#write()
Key: FLINK-6492
URL: https://issues.apache.org/jira/browse/FLINK-6492
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-4766?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16001161#comment-16001161
]
ASF GitHub Bot commented on FLINK-4766:
---
GitHub user zentol opened a pull request:
GitHub user zentol opened a pull request:
https://github.com/apache/flink/pull/3848
[FLINK-4766] Port TM config parameters to Config Options
This PR ports most taskmanager related config parameters to config options.
The following keys were not ported as i wasn't sure whethe
[
https://issues.apache.org/jira/browse/FLINK-6487?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16001120#comment-16001120
]
Stephan Ewen commented on FLINK-6487:
-
I think what we want can be done via
{code}
{ j
[
https://issues.apache.org/jira/browse/FLINK-6466?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16001094#comment-16001094
]
ASF GitHub Bot commented on FLINK-6466:
---
Github user greghogan commented on the issu
Github user greghogan commented on the issue:
https://github.com/apache/flink/pull/3832
@StephanEwen changes made, and I rebased back a few commits for stable
tests and also made yarn-tests non-optional.
---
If your project is set up for it, you can reply to this email and have your
[
https://issues.apache.org/jira/browse/FLINK-6476?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16001074#comment-16001074
]
ASF GitHub Bot commented on FLINK-6476:
---
Github user rtudoran closed the pull reques
Github user rtudoran closed the pull request at:
https://github.com/apache/flink/pull/3847
---
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 en
Fabian Hueske created FLINK-6491:
Summary: Add QueryConfig to specify state retention time for
streaming queries
Key: FLINK-6491
URL: https://issues.apache.org/jira/browse/FLINK-6491
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-6476?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16001048#comment-16001048
]
ASF GitHub Bot commented on FLINK-6476:
---
Github user rtudoran commented on the issue
Github user rtudoran commented on the issue:
https://github.com/apache/flink/pull/3847
@fhueske
Please have a look. I inserted tests in scala and java to check the
registration of the stream.
For scala - it seemed to work directly if the implicit value is set (i did
not k
[
https://issues.apache.org/jira/browse/FLINK-6476?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16001046#comment-16001046
]
ASF GitHub Bot commented on FLINK-6476:
---
GitHub user rtudoran opened a pull request:
GitHub user rtudoran opened a pull request:
https://github.com/apache/flink/pull/3847
[FLINK-6476] - Table environment register row data stream
Thanks for contributing to Apache Flink. Before you open your pull request,
please take the following check list into consideration.
If
[
https://issues.apache.org/jira/browse/FLINK-6476?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16001039#comment-16001039
]
ASF GitHub Bot commented on FLINK-6476:
---
Github user rtudoran closed the pull reques
Github user rtudoran closed the pull request at:
https://github.com/apache/flink/pull/3846
---
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 en
[
https://issues.apache.org/jira/browse/FLINK-6476?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16001032#comment-16001032
]
ASF GitHub Bot commented on FLINK-6476:
---
GitHub user rtudoran opened a pull request:
GitHub user rtudoran opened a pull request:
https://github.com/apache/flink/pull/3846
[FLINK-6476] - Table environment register row data stream
Thanks for contributing to Apache Flink. Before you open your pull request,
please take the following check list into consideration.
If
Github user rtudoran commented on the issue:
https://github.com/apache/flink/pull/3845
i will close this PR to push one with only one commit
---
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 th
[
https://issues.apache.org/jira/browse/FLINK-6476?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16001028#comment-16001028
]
ASF GitHub Bot commented on FLINK-6476:
---
Github user rtudoran closed the pull reques
[
https://issues.apache.org/jira/browse/FLINK-6476?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16001027#comment-16001027
]
ASF GitHub Bot commented on FLINK-6476:
---
Github user rtudoran commented on the issue
Github user rtudoran closed the pull request at:
https://github.com/apache/flink/pull/3845
---
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 en
[
https://issues.apache.org/jira/browse/FLINK-6020?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16001004#comment-16001004
]
ASF GitHub Bot commented on FLINK-6020:
---
Github user StephanEwen commented on the is
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/3525
@WangTaoTheTonic I think we can solve that the following way:
- The local upload uses `ATOMIC_MOVE` to rename the file
- Only the thread that succeeds will store the blob in HDFS o
[
https://issues.apache.org/jira/browse/FLINK-6487?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16000980#comment-16000980
]
Patrick Lucas commented on FLINK-6487:
--
Something like that should be fine. Even just
[
https://issues.apache.org/jira/browse/FLINK-4766?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler reassigned FLINK-4766:
---
Assignee: Chesnay Schepler
> Migrate TaskManager configuration options
>
[
https://issues.apache.org/jira/browse/FLINK-6487?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16000960#comment-16000960
]
Stephan Ewen commented on FLINK-6487:
-
I see. I would vote to have a different form of
[
https://issues.apache.org/jira/browse/FLINK-6474?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger updated FLINK-6474:
--
Component/s: Network
> Potential loss of precision in 32 bit integer multiplication
> --
[
https://issues.apache.org/jira/browse/FLINK-6486?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger updated FLINK-6486:
--
Component/s: Table API & SQL
> Pass RowTypeInfo to CodeGenerator instead of CRowTypeInfo
>
[
https://issues.apache.org/jira/browse/FLINK-6490?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger updated FLINK-6490:
--
Component/s: Core
> Explicitly support dynamic defaults in ConfigOption
> --
[
https://issues.apache.org/jira/browse/FLINK-6476?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16000937#comment-16000937
]
ASF GitHub Bot commented on FLINK-6476:
---
Github user rtudoran commented on the issue
Github user rtudoran commented on the issue:
https://github.com/apache/flink/pull/3845
@fhueske
Please have a look. I inserted tests in scala and java to check the
registration of the stream.
For scala - it seemed to work directly if the implicit value is set (i did
not
[
https://issues.apache.org/jira/browse/FLINK-6476?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16000933#comment-16000933
]
ASF GitHub Bot commented on FLINK-6476:
---
GitHub user rtudoran opened a pull request:
GitHub user rtudoran opened a pull request:
https://github.com/apache/flink/pull/3845
[FLINK-6476] - Table environment register row data stream
Thanks for contributing to Apache Flink. Before you open your pull request,
please take the following check list into consideration.
If
[
https://issues.apache.org/jira/browse/FLINK-6468?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger resolved FLINK-6468.
---
Resolution: Fixed
Assignee: Robert Metzger
Fix Version/s: 1.2.1
Good point. I
[
https://issues.apache.org/jira/browse/FLINK-6484?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stefan Richter updated FLINK-6484:
--
Description:
State handles for files that are (potentially) shared across multiple
incremental
[
https://issues.apache.org/jira/browse/FLINK-6487?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16000909#comment-16000909
]
Patrick Lucas edited comment on FLINK-6487 at 5/8/17 3:28 PM:
--
1 - 100 of 201 matches
Mail list logo
