Github user alpinegizmo commented on a diff in the pull request:
https://github.com/apache/flink/pull/3130#discussion_r96613305
--- Diff: docs/dev/migration.md ---
@@ -25,9 +25,326 @@ under the License.
* This will be replaced by the TOC
{:toc}
-## Flink 1.1 to
[
https://issues.apache.org/jira/browse/FLINK-5549?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther reassigned FLINK-5549:
---
Assignee: Timo Walther
> TypeExtractor fails with RuntimeException, but should use
[
https://issues.apache.org/jira/browse/FLINK-5480?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15828015#comment-15828015
]
ASF GitHub Bot commented on FLINK-5480:
---
Github user StefanRRichter commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-4693?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15828013#comment-15828013
]
ASF GitHub Bot commented on FLINK-4693:
---
Github user twalthr commented on the issue:
Github user StefanRRichter commented on a diff in the pull request:
https://github.com/apache/flink/pull/3117#discussion_r96630784
--- Diff:
flink-connectors/flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra/CassandraSink.java
---
@@ -95,6
Github user twalthr commented on the issue:
https://github.com/apache/flink/pull/3150
Btw it is not necessary to close and open a new PR after rebasing. You can
simply perform a force push.
---
If your project is set up for it, you can reply to this email and have your
reply appear
Github user twalthr commented on a diff in the pull request:
https://github.com/apache/flink/pull/3150#discussion_r96609116
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/DataSetSessionWindowAggregateReduceGroupFunction.scala
---
@@
Github user twalthr commented on a diff in the pull request:
https://github.com/apache/flink/pull/3150#discussion_r96607999
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/DataSetSessionWindowAggregateReduceGroupFunction.scala
---
@@
Github user twalthr commented on a diff in the pull request:
https://github.com/apache/flink/pull/3150#discussion_r96629778
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/DataSetSessionWindowAggregateReduceGroupFunction.scala
---
@@
Github user twalthr commented on a diff in the pull request:
https://github.com/apache/flink/pull/3150#discussion_r96629837
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/AggregateUtil.scala
---
@@ -226,27 +225,102 @@ object
Github user twalthr commented on a diff in the pull request:
https://github.com/apache/flink/pull/3150#discussion_r96606158
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/DataSetSessionWindowAggregateCombineGroupFunction.scala
---
@@
Github user twalthr commented on a diff in the pull request:
https://github.com/apache/flink/pull/3150#discussion_r96601727
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/dataset/DataSetWindowAggregate.scala
---
@@ -218,6 +216,84 @@ class
Github user twalthr commented on a diff in the pull request:
https://github.com/apache/flink/pull/3150#discussion_r96605812
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/DataSetSessionWindowAggregateCombineGroupFunction.scala
---
@@
Github user twalthr commented on a diff in the pull request:
https://github.com/apache/flink/pull/3150#discussion_r96609935
--- Diff:
flink-libraries/flink-table/src/test/scala/org/apache/flink/table/runtime/dataset/DataSetWindowAggregateITCase.scala
---
@@ -119,4 +119,35 @@
[
https://issues.apache.org/jira/browse/FLINK-4693?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15828006#comment-15828006
]
ASF GitHub Bot commented on FLINK-4693:
---
Github user twalthr commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-4693?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15828009#comment-15828009
]
ASF GitHub Bot commented on FLINK-4693:
---
Github user twalthr commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-4693?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15828004#comment-15828004
]
ASF GitHub Bot commented on FLINK-4693:
---
Github user twalthr commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-4693?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15828011#comment-15828011
]
ASF GitHub Bot commented on FLINK-4693:
---
Github user twalthr commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-4693?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15828010#comment-15828010
]
ASF GitHub Bot commented on FLINK-4693:
---
Github user twalthr commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-4693?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15828007#comment-15828007
]
ASF GitHub Bot commented on FLINK-4693:
---
Github user twalthr commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-4693?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15828008#comment-15828008
]
ASF GitHub Bot commented on FLINK-4693:
---
Github user twalthr commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-4693?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15828005#comment-15828005
]
ASF GitHub Bot commented on FLINK-4693:
---
Github user twalthr commented on a diff in the pull
Github user docete commented on a diff in the pull request:
https://github.com/apache/flink/pull/3111#discussion_r96628698
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/rules/FlinkRuleSets.scala
---
@@ -96,6 +96,13 @@ object FlinkRuleSets {
[
https://issues.apache.org/jira/browse/FLINK-3475?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15827994#comment-15827994
]
ASF GitHub Bot commented on FLINK-3475:
---
Github user docete commented on a diff in the pull request:
Github user kl0u commented on the issue:
https://github.com/apache/flink/pull/3134
From what I understood from the JIRA, it is only when restoring from
legacy. If not, then the problem is deeper. @rmetzger ?
---
If your project is set up for it, you can reply to this email and have
[
https://issues.apache.org/jira/browse/FLINK-5450?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15827992#comment-15827992
]
ASF GitHub Bot commented on FLINK-5450:
---
Github user kl0u commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-5092?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15827973#comment-15827973
]
ASF GitHub Bot commented on FLINK-5092:
---
Github user kenmy commented on the issue:
Github user kenmy commented on the issue:
https://github.com/apache/flink/pull/2836
I have tryed to collect coverage by this approach.
During my attempt I rebased this PR into
e187b5ee9aa6d1bf9feec151ff460d1a28c4e5f0 (master in apach/flink at the
yesterday evening). And share
[
https://issues.apache.org/jira/browse/FLINK-2168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15827957#comment-15827957
]
ASF GitHub Bot commented on FLINK-2168:
---
Github user ramkrish86 commented on the issue:
Github user ramkrish86 commented on the issue:
https://github.com/apache/flink/pull/3149
I see. Am not sure how I missed that because my IDE I thought was already
updated with latest code. Will check it.
---
If your project is set up for it, you can reply to this email and have your
GitHub user keijiyoshida opened a pull request:
https://github.com/apache/flink/pull/3153
[hotfix] [docs] Insert closing parentheses on "Flink DataStream API
Programming Guide".
Insert closing parentheses into sample code on "Flink DataStream API
Programming Guide".
You can merge
[
https://issues.apache.org/jira/browse/FLINK-5551?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Andrey updated FLINK-5551:
--
Description:
Prerequisites:
* Configure hdfs-based backend for the job
* cancel it using webapp admin
In
[
https://issues.apache.org/jira/browse/FLINK-5519?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15827911#comment-15827911
]
ASF GitHub Bot commented on FLINK-5519:
---
Github user StephanEwen commented on the issue:
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/3132
Looks good, thanks. 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 have this feature
[
https://issues.apache.org/jira/browse/FLINK-5450?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15827907#comment-15827907
]
ASF GitHub Bot commented on FLINK-5450:
---
Github user StephanEwen commented on the issue:
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/3134
To understand the implications better: Is this only logged on the initial
legacy savepoint restore? Or also on subsequent checkpoint restore operations?
---
If your project is set up for it,
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/3135
Good fix, thanks!
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 have this
[
https://issues.apache.org/jira/browse/FLINK-5521?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15827904#comment-15827904
]
ASF GitHub Bot commented on FLINK-5521:
---
Github user StephanEwen commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-5484?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15827903#comment-15827903
]
ASF GitHub Bot commented on FLINK-5484:
---
GitHub user uce opened a pull request:
GitHub user uce opened a pull request:
https://github.com/apache/flink/pull/3152
[FLINK-5484] [serialization] Revert Chill version update
This PR reverts the Twitter Chill dependency update. The version updates
breaks backwards compatability for savepoints which contain user types
[
https://issues.apache.org/jira/browse/FLINK-5531?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15827902#comment-15827902
]
ASF GitHub Bot commented on FLINK-5531:
---
Github user StephanEwen commented on the issue:
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/3140
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 have this feature
enabled and
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/3142
In a separate change, we actually deprecated the default value in states.
It does not behave very well at runtime in many cases and we thought that it
would be simpler to let the user code
[
https://issues.apache.org/jira/browse/FLINK-5527?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15827901#comment-15827901
]
ASF GitHub Bot commented on FLINK-5527:
---
Github user StephanEwen commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-5530?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15827897#comment-15827897
]
ASF GitHub Bot commented on FLINK-5530:
---
Github user StephanEwen commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-5530?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15827894#comment-15827894
]
ASF GitHub Bot commented on FLINK-5530:
---
Github user StephanEwen commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-5530?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15827895#comment-15827895
]
ASF GitHub Bot commented on FLINK-5530:
---
Github user StephanEwen commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-5530?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15827896#comment-15827896
]
ASF GitHub Bot commented on FLINK-5530:
---
Github user StephanEwen commented on a diff in the pull
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/3143#discussion_r96613474
--- Diff:
flink-contrib/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/AbstractRocksDBState.java
---
@@ -132,55
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/3143#discussion_r96613631
--- Diff:
flink-contrib/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/AbstractRocksDBState.java
---
@@ -132,55
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/3143#discussion_r96612773
--- Diff:
flink-contrib/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/AbstractRocksDBState.java
---
@@ -132,55
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/3143#discussion_r96612430
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/state/StateBackendTestBase.java
---
@@ -242,6 +245,132 @@ public void testValueState()
[
https://issues.apache.org/jira/browse/FLINK-4364?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15827892#comment-15827892
]
Zhijiang Wang commented on FLINK-4364:
--
[~till.rohrmann], I closed the previous pull request for this
[
https://issues.apache.org/jira/browse/FLINK-4364?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15827889#comment-15827889
]
ASF GitHub Bot commented on FLINK-4364:
---
Github user wangzhijiang999 closed the pull request at:
Github user wangzhijiang999 closed the pull request at:
https://github.com/apache/flink/pull/2798
---
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
GitHub user wangzhijiang999 opened a pull request:
https://github.com/apache/flink/pull/3151
[FLINK-4364][runtime]mplement TaskManager side of heartbeat from JobMâ¦
1. **TaskManagerRunner** creates **HeartbeatManagerImpl** components when
constructs the **TaskManager**.
2.
[
https://issues.apache.org/jira/browse/FLINK-4364?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15827885#comment-15827885
]
ASF GitHub Bot commented on FLINK-4364:
---
GitHub user wangzhijiang999 opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-3150?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15827883#comment-15827883
]
ASF GitHub Bot commented on FLINK-3150:
---
Github user asfgit closed the pull request at:
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/3056
---
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-3150?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger resolved FLINK-3150.
---
Resolution: Fixed
Fix Version/s: 1.3.0
Thanks a lot for implementing this.
Merged in
david.wang created FLINK-5552:
-
Summary: Make the JMX port available through RESTful API
Key: FLINK-5552
URL: https://issues.apache.org/jira/browse/FLINK-5552
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-5543?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15827872#comment-15827872
]
ASF GitHub Bot commented on FLINK-5543:
---
Github user StephanEwen commented on the issue:
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/3144
Thanks, 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 have this feature
Andrey created FLINK-5551:
-
Summary: NPE at SourceStreamTask
Key: FLINK-5551
URL: https://issues.apache.org/jira/browse/FLINK-5551
Project: Flink
Issue Type: Bug
Components: DataStream API
jiwengang created FLINK-5550:
Summary: NotFoundException: Could not find job with id
Key: FLINK-5550
URL: https://issues.apache.org/jira/browse/FLINK-5550
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-5549?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger updated FLINK-5549:
--
Summary: TypeExtractor fails with RuntimeException, but should use
GenericTypeInfo (was:
[
https://issues.apache.org/jira/browse/FLINK-5549?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger updated FLINK-5549:
--
Summary: TypeExtractor fails with RuntimeException, but should use
GenericTypeInfoeneric (was:
[
https://issues.apache.org/jira/browse/FLINK-2168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15827841#comment-15827841
]
ASF GitHub Bot commented on FLINK-2168:
---
Github user fhueske commented on the issue:
Github user fhueske commented on the issue:
https://github.com/apache/flink/pull/3149
@tonycox is right. Please rebase your PR to the current master branch. The
`TableSource` interface was recently modified.
---
If your project is set up for it, you can reply to this email and have
[
https://issues.apache.org/jira/browse/FLINK-5520?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15827831#comment-15827831
]
ASF GitHub Bot commented on FLINK-5520:
---
Github user fhueske commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-2168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15827833#comment-15827833
]
ASF GitHub Bot commented on FLINK-2168:
---
Github user tonycox commented on the issue:
Github user fhueske commented on the issue:
https://github.com/apache/flink/pull/3141
Great 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, or if
Github user tonycox commented on the issue:
https://github.com/apache/flink/pull/3149
You need to recompile `TableSource` trait manually and implement
`DefinedFieldNames` in `HBaseTableSource`
---
If your project is set up for it, you can reply to this email and have your
reply
Github user lincoln-lil commented on the issue:
https://github.com/apache/flink/pull/3141
@fhueske FLINK-5547 make sense to me, I'll update this pr 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
[
https://issues.apache.org/jira/browse/FLINK-5520?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15827818#comment-15827818
]
ASF GitHub Bot commented on FLINK-5520:
---
Github user lincoln-lil commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-5546?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15827811#comment-15827811
]
Chesnay Schepler commented on FLINK-5546:
-
This is probably the case for every test that uses
Robert Metzger created FLINK-5549:
-
Summary: TypeExtractor fails with RuntimeException, but should use
GGenericTypeInfoeneric
Key: FLINK-5549
URL: https://issues.apache.org/jira/browse/FLINK-5549
[
https://issues.apache.org/jira/browse/FLINK-4682?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Anton Solovev updated FLINK-4682:
-
Assignee: (was: Anton Solovev)
> Add TumbleRow row-windows for batch tables.
>
[
https://issues.apache.org/jira/browse/FLINK-5512?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15827779#comment-15827779
]
ASF GitHub Bot commented on FLINK-5512:
---
Github user alpinegizmo commented on the issue:
Github user alpinegizmo commented on the issue:
https://github.com/apache/flink/pull/3136
Very helpful. But I did stumble on this sentence -- I'm not sure what "of a
queue" is telling me.
> This limitation is mainly due to RabbitMQ's approach to dispatching
messages of a
[
https://issues.apache.org/jira/browse/FLINK-5520?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15827772#comment-15827772
]
ASF GitHub Bot commented on FLINK-5520:
---
Github user fhueske commented on the issue:
Github user fhueske commented on the issue:
https://github.com/apache/flink/pull/3141
The difference between failing during validation and translation is the
code line that throws the exception. A check during validation causes an
exception on the line that is responsible for the
Github user lincoln-lil commented on the issue:
https://github.com/apache/flink/pull/3141
@fhueske agree with you that the check in validation phase of the Table API
is useful for failing fast( IMO, it seems no difference on user experience that
when an exception be thrown either in
[
https://issues.apache.org/jira/browse/FLINK-5520?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15827762#comment-15827762
]
ASF GitHub Bot commented on FLINK-5520:
---
Github user lincoln-lil commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-4693?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15827742#comment-15827742
]
ASF GitHub Bot commented on FLINK-4693:
---
Github user twalthr commented on the issue:
Github user twalthr commented on the issue:
https://github.com/apache/flink/pull/3150
Thanks for updating the PR @sunjincheng121. I will shepherd 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
[
https://issues.apache.org/jira/browse/FLINK-4693?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15827718#comment-15827718
]
ASF GitHub Bot commented on FLINK-4693:
---
Github user sunjincheng121 commented on the issue:
Github user sunjincheng121 commented on the issue:
https://github.com/apache/flink/pull/3150
@fhueske @twalthr I reopened the PR and propose the design doc.
https://docs.google.com/document/d/1WIOKNwfTW8nMZsRVL-ANIzxIiuXqVNGxwjiPj7go7hg/edit
---
If your project is set up for
GitHub user sunjincheng121 opened a pull request:
https://github.com/apache/flink/pull/3150
[FLINK-4693][tableApi] Add session group-windows for batch tables
Thanks for contributing to Apache Flink. Before you open your pull request,
please take the following check list into
[
https://issues.apache.org/jira/browse/FLINK-4693?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15827708#comment-15827708
]
ASF GitHub Bot commented on FLINK-4693:
---
GitHub user sunjincheng121 opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-4693?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15827705#comment-15827705
]
ASF GitHub Bot commented on FLINK-4693:
---
Github user sunjincheng121 closed the pull request at:
Github user sunjincheng121 closed the pull request at:
https://github.com/apache/flink/pull/2983
---
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
[
https://issues.apache.org/jira/browse/FLINK-3398?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai updated FLINK-3398:
---
Fix Version/s: (was: 1.2.0)
1.3.0
> Flink Kafka consumer
[
https://issues.apache.org/jira/browse/FLINK-5017?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai updated FLINK-5017:
---
Fix Version/s: 1.3.0
> Introduce WatermarkStatus stream element to allow for
[
https://issues.apache.org/jira/browse/FLINK-4280?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai updated FLINK-4280:
---
Fix Version/s: (was: 1.2.0)
1.3.0
> New Flink-specific option
[
https://issues.apache.org/jira/browse/FLINK-5548?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske updated FLINK-5548:
-
Description:
At the moment, most check to verify that a {{DataStreamRel}} is valid are done
in
[
https://issues.apache.org/jira/browse/FLINK-5548?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske updated FLINK-5548:
-
Summary: Move checks for DataStreamRel validity into constructor (was:
Move)
> Move checks for
Fabian Hueske created FLINK-5548:
Summary: Move
Key: FLINK-5548
URL: https://issues.apache.org/jira/browse/FLINK-5548
Project: Flink
Issue Type: Improvement
Components: Table API &
[
https://issues.apache.org/jira/browse/FLINK-2168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15827692#comment-15827692
]
ASF GitHub Bot commented on FLINK-2168:
---
Github user ramkrish86 commented on the issue:
Fabian Hueske created FLINK-5547:
Summary: Move checks for DataSetRel validity into constructor
Key: FLINK-5547
URL: https://issues.apache.org/jira/browse/FLINK-5547
Project: Flink
Issue
201 - 300 of 335 matches
Mail list logo
