[
https://issues.apache.org/jira/browse/FLINK-1275?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16779001#comment-16779001
]
vinoyang commented on FLINK-1275:
-
[~zjwang] Glad to hear Blink has provided this feature, hope for it
vinoyang created FLINK-11770:
Summary: Update FlinkKinesisConsumerMigrationTest for 1.8
Key: FLINK-11770
URL: https://issues.apache.org/jira/browse/FLINK-11770
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-1275?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16778988#comment-16778988
]
zhijiang commented on FLINK-1275:
-
[~uce], thanks for creating this valuable ticket before and I think
flinkbot edited a comment on issue #7808: [FLINK-11718][rpc] Add onStart method
to RpcEndpoint
URL: https://github.com/apache/flink/pull/7808#issuecomment-466367293
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
to review your
[
https://issues.apache.org/jira/browse/FLINK-11563?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu closed FLINK-11563.
---
Resolution: Fixed
Fixed in flink-web: c1ebeef585d15cc583d6340dce6df3d5d3393e44
> Translate "Getting Help"
wuchong edited a comment on issue #7817: [FLINK-11702][table-planner-blink]
Introduce a new table type system: InternalType
URL: https://github.com/apache/flink/pull/7817#issuecomment-467738791
@flinkbot approve description
@flinkbot approve consensus
JingsongLi commented on a change in pull request #7817:
[FLINK-11702][table-planner-blink] Introduce a new table type system:
InternalType
URL: https://github.com/apache/flink/pull/7817#discussion_r260609056
##
File path:
[
https://issues.apache.org/jira/browse/FLINK-8314?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16778947#comment-16778947
]
Praveen Gattu commented on FLINK-8314:
--
Hi - Kinesis FH doesn't support read functionality, so FH as
wuchong commented on issue #7817: [FLINK-11702][table-planner-blink] Introduce
a new table type system: InternalType
URL: https://github.com/apache/flink/pull/7817#issuecomment-467738791
@flinkbot approve description, consensus
wuchong commented on a change in pull request #7817:
[FLINK-11702][table-planner-blink] Introduce a new table type system:
InternalType
URL: https://github.com/apache/flink/pull/7817#discussion_r260595401
##
File path:
wuchong commented on a change in pull request #7817:
[FLINK-11702][table-planner-blink] Introduce a new table type system:
InternalType
URL: https://github.com/apache/flink/pull/7817#discussion_r260595009
##
File path:
wuchong commented on a change in pull request #7817:
[FLINK-11702][table-planner-blink] Introduce a new table type system:
InternalType
URL: https://github.com/apache/flink/pull/7817#discussion_r260606059
##
File path:
wuchong commented on a change in pull request #7817:
[FLINK-11702][table-planner-blink] Introduce a new table type system:
InternalType
URL: https://github.com/apache/flink/pull/7817#discussion_r260594949
##
File path:
wuchong commented on a change in pull request #7817:
[FLINK-11702][table-planner-blink] Introduce a new table type system:
InternalType
URL: https://github.com/apache/flink/pull/7817#discussion_r260593643
##
File path:
[
https://issues.apache.org/jira/browse/FLINK-11754?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu updated FLINK-11754:
Environment: (was: The markdown file will be located in:
flink-web/roadmap.zh.md
The url link is:
[
https://issues.apache.org/jira/browse/FLINK-11754?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu updated FLINK-11754:
Description:
The markdown file will be located in: flink-web/roadmap.zh.md
The url link is:
[
https://issues.apache.org/jira/browse/FLINK-1275?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16778922#comment-16778922
]
Ufuk Celebi commented on FLINK-1275:
[~yanghua] It has been a long time since I created this ticket.
[
https://issues.apache.org/jira/browse/FLINK-11753?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-11753:
---
Labels: pull-request-available (was: )
> Add utils for serialization compatibility tests
>
flinkbot commented on issue #7845: [FLINK-11753][tests] Add utilities to ease
TypeSerializerSchemaCompatibility testing
URL: https://github.com/apache/flink/pull/7845#issuecomment-467733316
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the
igalshilman opened a new pull request #7845: [FLINK-11753][tests] Add
utilities to ease TypeSerializerSchemaCompatibility testing
URL: https://github.com/apache/flink/pull/7845
## What is the purpose of the change
This PR adds few test utils to help testing serializers
[
https://issues.apache.org/jira/browse/FLINK-11754?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
hanfei reassigned FLINK-11754:
--
Assignee: hanfei
> Translate the "Roadmap" page into Chinese
>
[
https://issues.apache.org/jira/browse/FLINK-11728?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sunjincheng closed FLINK-11728.
---
Resolution: Fixed
Fix Version/s: 1.9.0
1.8.0
Fixed in master:
[
https://issues.apache.org/jira/browse/FLINK-10785?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16778899#comment-16778899
]
Tzu-Li (Gordon) Tai commented on FLINK-10785:
-
The exceptions are occurring because you need
[
https://issues.apache.org/jira/browse/FLINK-11756?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
vinoyang updated FLINK-11756:
-
Fix Version/s: 1.9.0
> Update migration tests for Flink 1.8
>
>
>
[
https://issues.apache.org/jira/browse/FLINK-10785?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai reassigned FLINK-10785:
---
Assignee: Tzu-Li (Gordon) Tai
> Update FlinkKinesisConsumerMigrationTest
[
https://issues.apache.org/jira/browse/FLINK-10776?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16778891#comment-16778891
]
vinoyang commented on FLINK-10776:
--
[~tzulitai] I am talking about fixing this umbrella issue
[
https://issues.apache.org/jira/browse/FLINK-10776?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16778877#comment-16778877
]
vinoyang edited comment on FLINK-10776 at 2/27/19 5:07 AM:
---
[~tzulitai] I have
[
https://issues.apache.org/jira/browse/FLINK-10776?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16778889#comment-16778889
]
Tzu-Li (Gordon) Tai commented on FLINK-10776:
-
[~yanghua] FLINK-11756 should not block the
[
https://issues.apache.org/jira/browse/FLINK-11756?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
vinoyang updated FLINK-11756:
-
Description:
Now that the feature branch is cut for Flink 18, we should now update existing
migration
[
https://issues.apache.org/jira/browse/FLINK-11764?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
vinoyang updated FLINK-11764:
-
Description: Update {{BucketingSinkMigrationTest}} so that it covers
restoring from 1.8.
> Update
flinkbot edited a comment on issue #7837: [FLINK-11091][table] Clear the use of
deprecated `process(ProcessFunc…
URL: https://github.com/apache/flink/pull/7837#issuecomment-467394497
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
[
https://issues.apache.org/jira/browse/FLINK-11766?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
vinoyang updated FLINK-11766:
-
Description: Update Java / Scala {{StatefulJobSavepointMigrationITCase}} so
that it covers recovering
[
https://issues.apache.org/jira/browse/FLINK-11756?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16778882#comment-16778882
]
Tzu-Li (Gordon) Tai commented on FLINK-11756:
-
[~yanghua] please keep in mind, that these
asfgit closed pull request #7840: [FLINK-11728] [table] Deprecate CalciteConfig
temporarily
URL: https://github.com/apache/flink/pull/7840
This is an automated message from the Apache Git Service.
To respond to the message,
sunjincheng121 commented on issue #7837: [FLINK-11091][table] Clear the use of
deprecated `process(ProcessFunc…
URL: https://github.com/apache/flink/pull/7837#issuecomment-467725363
@flinkbot approve all
This is an
[
https://issues.apache.org/jira/browse/FLINK-11758?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
vinoyang updated FLINK-11758:
-
Description: Update {{ContinuousFileProcessingMigrationTest}} so that it
covers restoring from 1.8.
>
[
https://issues.apache.org/jira/browse/FLINK-11756?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16778885#comment-16778885
]
vinoyang commented on FLINK-11756:
--
[~tzulitai] yes, I know. All of these issues will be started after
[
https://issues.apache.org/jira/browse/FLINK-11756?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
vinoyang updated FLINK-11756:
-
Fix Version/s: (was: 1.8.0)
> Update migration tests for Flink 1.8
>
[
https://issues.apache.org/jira/browse/FLINK-11759?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
vinoyang updated FLINK-11759:
-
Description: Update {{AbstractNonKeyedOperatorRestoreTestBase}} and
subclasses so that it covers
[
https://issues.apache.org/jira/browse/FLINK-11760?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
vinoyang updated FLINK-11760:
-
Description: Update {{CEPMigrationTest}} so that it covers restoring from
1.8.
> Update
[
https://issues.apache.org/jira/browse/FLINK-11761?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
vinoyang updated FLINK-11761:
-
Description: Update {{FlinkKafkaConsumerBaseMigrationTest}} so that it
covers restoring from 1.8.
>
[
https://issues.apache.org/jira/browse/FLINK-11763?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
vinoyang updated FLINK-11763:
-
Description: Update {{AbstractKeyedOperatorRestoreTestBase}} and subclasses
so that it covers restoring
[
https://issues.apache.org/jira/browse/FLINK-11762?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
vinoyang updated FLINK-11762:
-
Description: Update {{WindowOperatorMigrationTest}} so that it covers
restoring from 1.8.
> Update
[
https://issues.apache.org/jira/browse/FLINK-11765?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
vinoyang updated FLINK-11765:
-
Summary: Update Java / Scala StatefulJobWBroadcastStateMigrationITCase for
1.8 (was: Update Java /
[
https://issues.apache.org/jira/browse/FLINK-11765?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
vinoyang updated FLINK-11765:
-
Description: Update Java / Scala
{{StatefulJobWBroadcastStateMigrationITCase}} so that it covers
vinoyang created FLINK-11765:
Summary: Update Java / Scala
StatefulJobWBroadcastStateMigrationITCase for 1.7
Key: FLINK-11765
URL: https://issues.apache.org/jira/browse/FLINK-11765
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-11767?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
vinoyang updated FLINK-11767:
-
Description: Update {{TypeSerializerSnapshotMigrationTestBase}} and
subclasses to cover restoring from
[
https://issues.apache.org/jira/browse/FLINK-11768?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
vinoyang updated FLINK-11768:
-
Description: Update {{TypeSerializerSnapshotMigrationITCase}} to cover
restoring from Flink 1.8.
>
[
https://issues.apache.org/jira/browse/FLINK-10776?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16778877#comment-16778877
]
vinoyang commented on FLINK-10776:
--
[~tzulitai] I have created an umbrella issue FLINK-11756 to update
Xingcan Cui created FLINK-11769:
---
Summary: The estimateDataTypesSize method in FlinkRelNode causes
NPE for Multiset
Key: FLINK-11769
URL: https://issues.apache.org/jira/browse/FLINK-11769
Project:
vinoyang created FLINK-11768:
Summary: Update TypeSerializerSnapshotMigrationITCase for Flink 1.8
Key: FLINK-11768
URL: https://issues.apache.org/jira/browse/FLINK-11768
Project: Flink
Issue
vinoyang created FLINK-11767:
Summary: Update TypeSerializerSnapshotMigrationTestBase and
subclasses for 1.8
Key: FLINK-11767
URL: https://issues.apache.org/jira/browse/FLINK-11767
Project: Flink
vinoyang created FLINK-11766:
Summary: Update Java / Scala StatefulJobSavepointMigrationITCase
for 1.8
Key: FLINK-11766
URL: https://issues.apache.org/jira/browse/FLINK-11766
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-11763?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
vinoyang updated FLINK-11763:
-
Summary: Update AbstractKeyedOperatorRestoreTestBase for 1.8 (was: Update
vinoyang created FLINK-11764:
Summary: Update BucketingSinkMigrationTest for Flink 1.8
Key: FLINK-11764
URL: https://issues.apache.org/jira/browse/FLINK-11764
Project: Flink
Issue Type: Sub-task
[
https://issues.apache.org/jira/browse/FLINK-11567?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xingcan Cui resolved FLINK-11567.
-
Resolution: Done
Fixed in flink-web: 63af7e0c6fa4a87072f54fc6bf0cf4ebe5c56b25
> Translate "How
flinkbot edited a comment on issue #7840: [FLINK-11728] [table] Deprecate
CalciteConfig temporarily
URL: https://github.com/apache/flink/pull/7840#issuecomment-467434827
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
to review
sunjincheng121 commented on issue #7840: [FLINK-11728] [table] Deprecate
CalciteConfig temporarily
URL: https://github.com/apache/flink/pull/7840#issuecomment-467716024
+1 to merged
Merging...
This is an automated
[
https://issues.apache.org/jira/browse/FLINK-11760?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
vinoyang updated FLINK-11760:
-
Issue Type: Sub-task (was: Test)
Parent: FLINK-11756
> Update CEPMigrationTest for 1.8
>
vinoyang created FLINK-11763:
Summary: Update AbstractKeyedOperatorRestoreTestBase for 1.9
Key: FLINK-11763
URL: https://issues.apache.org/jira/browse/FLINK-11763
Project: Flink
Issue Type:
vinoyang created FLINK-11762:
Summary: Update WindowOperatorMigrationTest for 1.8
Key: FLINK-11762
URL: https://issues.apache.org/jira/browse/FLINK-11762
Project: Flink
Issue Type: Sub-task
vinoyang created FLINK-11761:
Summary: Update FlinkKafkaConsumerBaseMigrationTest for 1.8
Key: FLINK-11761
URL: https://issues.apache.org/jira/browse/FLINK-11761
Project: Flink
Issue Type:
tzulitai commented on issue #7726: [FLINK-10342] Filter restored partitions
with discovered partitions b…
URL: https://github.com/apache/flink/pull/7726#issuecomment-467713422
There seems to be failing tests that are related:
```
17:52:59.921 [ERROR] Failures:
17:52:59.921
vinoyang created FLINK-11759:
Summary: Update AbstractNonKeyedOperatorRestoreTestBase for 1.8
Key: FLINK-11759
URL: https://issues.apache.org/jira/browse/FLINK-11759
Project: Flink
Issue Type:
tzulitai commented on a change in pull request #7726: [FLINK-10342] Filter
restored partitions with discovered partitions b…
URL: https://github.com/apache/flink/pull/7726#discussion_r260583691
##
File path:
vinoyang created FLINK-11760:
Summary: Update CEPMigrationTest for 1.8
Key: FLINK-11760
URL: https://issues.apache.org/jira/browse/FLINK-11760
Project: Flink
Issue Type: Test
vinoyang created FLINK-11758:
Summary: Update ContinuousFileProcessingMigrationTest for 1.8
Key: FLINK-11758
URL: https://issues.apache.org/jira/browse/FLINK-11758
Project: Flink
Issue Type:
vinoyang created FLINK-11757:
Summary: Add the version number of Flink 1.8 to MigrationVersion
Key: FLINK-11757
URL: https://issues.apache.org/jira/browse/FLINK-11757
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-11756?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16778845#comment-16778845
]
vinoyang commented on FLINK-11756:
--
Hi [~tzulitai] I created this umbrella issue for tracking migration
[
https://issues.apache.org/jira/browse/FLINK-11393?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16778842#comment-16778842
]
zhijiang commented on FLINK-11393:
--
[~Salatich], I am glad to see you are interested in it and welcome
vinoyang created FLINK-11756:
Summary: Update migration tests for Flink 1.8
Key: FLINK-11756
URL: https://issues.apache.org/jira/browse/FLINK-11756
Project: Flink
Issue Type: Test
hequn8128 edited a comment on issue #7837: [FLINK-11091][table] Clear the use
of deprecated `process(ProcessFunc…
URL: https://github.com/apache/flink/pull/7837#issuecomment-467699495
@sunjincheng121 Thanks a lot for updating the PR. Looks good from my side.
+1 to merge.
@flinkbot
carp84 commented on a change in pull request #7841: [FLINK-11743] Fix RocksDB
incremental restore from local state after refactoring
URL: https://github.com/apache/flink/pull/7841#discussion_r260571497
##
File path:
Tzu-Li (Gordon) Tai created FLINK-11755:
---
Summary: Remove ensureCompatibility method from TypeSerializer
abstraction
Key: FLINK-11755
URL: https://issues.apache.org/jira/browse/FLINK-11755
flinkbot edited a comment on issue #7840: [FLINK-11728] [table] Deprecate
CalciteConfig temporarily
URL: https://github.com/apache/flink/pull/7840#issuecomment-467434827
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
to review
wuchong commented on issue #7840: [FLINK-11728] [table] Deprecate CalciteConfig
temporarily
URL: https://github.com/apache/flink/pull/7840#issuecomment-467707398
@flinkbot approve all
LGTM
This is an automated message
[
https://issues.apache.org/jira/browse/FLINK-11067?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16778819#comment-16778819
]
Hequn Cheng commented on FLINK-11067:
-
[~twalthr] [~sunjincheng121] Thanks for your suggestions. I
[
https://issues.apache.org/jira/browse/FLINK-11754?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16778811#comment-16778811
]
xiangtao commented on FLINK-11754:
--
How do i Assignee this task to me ?
> Translate the "Roadmap"
glaksh100 commented on a change in pull request #7679: [FLINK-11501][Kafka
Connector] Add ratelimiting to Kafka consumer
URL: https://github.com/apache/flink/pull/7679#discussion_r260576221
##
File path:
[
https://issues.apache.org/jira/browse/FLINK-11483?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Congxian Qiu(klion26) resolved FLINK-11483.
---
Resolution: Fixed
> Improve StreamOperatorSnapshotRestoreTest with
[
https://issues.apache.org/jira/browse/FLINK-11754?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
xulinjie reassigned FLINK-11754:
Assignee: (was: xulinjie)
> Translate the "Roadmap" page into Chinese
>
sunhaibotb commented on issue #7797: [FLINK-11379] Fix OutOfMemoryError caused
by Files.readAllBytes() when TM loads a large size TDD
URL: https://github.com/apache/flink/pull/7797#issuecomment-467700414
Thanks for the review @sunjincheng121 .
[
https://issues.apache.org/jira/browse/FLINK-11754?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
xulinjie reassigned FLINK-11754:
Assignee: xulinjie
> Translate the "Roadmap" page into Chinese
>
hequn8128 commented on issue #7837: [FLINK-11091][table] Clear the use of
deprecated `process(ProcessFunc…
URL: https://github.com/apache/flink/pull/7837#issuecomment-467699495
@sunjincheng121 Thanks a lot for updating the PR. Looks good from my side.
+1 to merge.
Best, Hequn
sunjincheng121 edited a comment on issue #7837: [FLINK-11091][table] Clear the
use of deprecated `process(ProcessFunc…
URL: https://github.com/apache/flink/pull/7837#issuecomment-467697840
Thanks for your review and very nice comments! @hequn8128
I'm not sure if abstracting an
sunjincheng121 commented on issue #7837: [FLINK-11091][table] Clear the use of
deprecated `process(ProcessFunc…
URL: https://github.com/apache/flink/pull/7837#issuecomment-467697840
Thanks for your review and very nice comments! @hequn8128
I have updated the PR.
Thanks,
Jark Wu created FLINK-11754:
---
Summary: Translate the "Roadmap" page into Chinese
Key: FLINK-11754
URL: https://issues.apache.org/jira/browse/FLINK-11754
Project: Flink
Issue Type: Sub-task
sunjincheng121 commented on a change in pull request #7837:
[FLINK-11091][table] Clear the use of deprecated `process(ProcessFunc…
URL: https://github.com/apache/flink/pull/7837#discussion_r260566766
##
File path:
[
https://issues.apache.org/jira/browse/FLINK-11068?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16778782#comment-16778782
]
Hequn Cheng commented on FLINK-11068:
-
[~twalthr] [~yanghua] Thank you a lot for helping to
glaksh100 commented on issue #7679: [FLINK-11501][Kafka Connector] Add
ratelimiting to Kafka consumer
URL: https://github.com/apache/flink/pull/7679#issuecomment-467689934
@tweise I added a test to the `Kafka09ITCase` that runs a job that uses the
ratelimiter (and asserts an approximate
[
https://issues.apache.org/jira/browse/FLINK-5931?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16778777#comment-16778777
]
vinoyang commented on FLINK-5931:
-
Hi [~StephanEwen] What do you think about whether we can introduce a
JingsongLi commented on a change in pull request #7817:
[FLINK-11702][table-planner-blink] Introduce a new table type system:
InternalType
URL: https://github.com/apache/flink/pull/7817#discussion_r260560550
##
File path:
[
https://issues.apache.org/jira/browse/FLINK-11068?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hequn Cheng reassigned FLINK-11068:
---
Assignee: Hequn Cheng
> Convert the API classes *Table, *Window to interfaces
>
[
https://issues.apache.org/jira/browse/FLINK-1275?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16778764#comment-16778764
]
vinoyang edited comment on FLINK-1275 at 2/27/19 1:13 AM:
--
[~uce] Can you give
[
https://issues.apache.org/jira/browse/FLINK-1275?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16778764#comment-16778764
]
vinoyang commented on FLINK-1275:
-
Can you give more details or description for this issue? Thanks.
>
[
https://issues.apache.org/jira/browse/FLINK-11068?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16778761#comment-16778761
]
vinoyang commented on FLINK-11068:
--
[~twalthr] Ok, I haven't started this issue yet. Since it is
[
https://issues.apache.org/jira/browse/FLINK-11068?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
vinoyang reassigned FLINK-11068:
Assignee: (was: vinoyang)
> Convert the API classes *Table, *Window to interfaces
>
klion26 commented on a change in pull request #7726: [FLINK-10342] Filter
restored partitions with discovered partitions b…
URL: https://github.com/apache/flink/pull/7726#discussion_r260539665
##
File path:
Xeli commented on issue #6594: [FLINK-9311] [pubsub] Added PubSub source
connector with support for checkpointing (ATLEAST_ONCE)
URL: https://github.com/apache/flink/pull/6594#issuecomment-467660076
@rmetzger @afedulov I think I've addressed all review points now.
Could you do a
Xeli commented on a change in pull request #6594: [FLINK-9311] [pubsub] Added
PubSub source connector with support for checkpointing (ATLEAST_ONCE)
URL: https://github.com/apache/flink/pull/6594#discussion_r260536150
##
File path:
1 - 100 of 394 matches
Mail list logo
