[
https://issues.apache.org/jira/browse/FLINK-11153?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16799522#comment-16799522
]
vinoyang edited comment on FLINK-11153 at 3/23/19 4:34 AM:
---
+1, I agree
[
https://issues.apache.org/jira/browse/FLINK-11153?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16799522#comment-16799522
]
vinoyang edited comment on FLINK-11153 at 3/23/19 4:27 AM:
---
+1, I agree
[
https://issues.apache.org/jira/browse/FLINK-11153?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16799522#comment-16799522
]
vinoyang commented on FLINK-11153:
--
+1, I agree [~twalthr] 's idea. I have just had a look at the
[
https://issues.apache.org/jira/browse/FLINK-11153?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
vinoyang reassigned FLINK-11153:
Assignee: vinoyang
> Remove UdfAnalyzer
> --
>
> Key:
[
https://issues.apache.org/jira/browse/FLINK-11996?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
vinoyang reassigned FLINK-11996:
Assignee: vinoyang
> Case class maximum of 22 fields
> ---
>
>
[
https://issues.apache.org/jira/browse/FLINK-11982?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16799515#comment-16799515
]
frank wang commented on FLINK-11982:
you want to dev this function? you don't provide that,
>
flinkbot commented on issue #8039: Release 1.8
URL: https://github.com/apache/flink/pull/8039#issuecomment-475829632
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
to review your pull request. We will use this comment to track the
syijie51 opened a new pull request #8039: Release 1.8
URL: https://github.com/apache/flink/pull/8039
## What is the purpose of the change
*(For example: This pull request makes task deployment go through the blob
server, rather than through RPC. That way we avoid
TisonKun commented on a change in pull request #7927: [FLINK-11603][metrics]
Port the MetricQueryService to the new RpcEndpoint
URL: https://github.com/apache/flink/pull/7927#discussion_r268377279
##
File path:
TisonKun commented on a change in pull request #7927: [FLINK-11603][metrics]
Port the MetricQueryService to the new RpcEndpoint
URL: https://github.com/apache/flink/pull/7927#discussion_r268377229
##
File path:
TisonKun commented on a change in pull request #7927: [FLINK-11603][metrics]
Port the MetricQueryService to the new RpcEndpoint
URL: https://github.com/apache/flink/pull/7927#discussion_r268377188
##
File path:
TisonKun commented on issue #7927: [FLINK-11603][metrics] Port the
MetricQueryService to the new RpcEndpoint
URL: https://github.com/apache/flink/pull/7927#issuecomment-475829204
Thanks for your review @zentol ! React to comments.
TisonKun commented on a change in pull request #7927: [FLINK-11603][metrics]
Port the MetricQueryService to the new RpcEndpoint
URL: https://github.com/apache/flink/pull/7927#discussion_r268377110
##
File path:
TisonKun commented on a change in pull request #7927: [FLINK-11603][metrics]
Port the MetricQueryService to the new RpcEndpoint
URL: https://github.com/apache/flink/pull/7927#discussion_r268375981
##
File path:
TisonKun commented on a change in pull request #7927: [FLINK-11603][metrics]
Port the MetricQueryService to the new RpcEndpoint
URL: https://github.com/apache/flink/pull/7927#discussion_r268375149
##
File path:
TisonKun commented on a change in pull request #7927: [FLINK-11603][metrics]
Port the MetricQueryService to the new RpcEndpoint
URL: https://github.com/apache/flink/pull/7927#discussion_r268373838
##
File path:
TisonKun commented on a change in pull request #7927: [FLINK-11603][metrics]
Port the MetricQueryService to the new RpcEndpoint
URL: https://github.com/apache/flink/pull/7927#discussion_r268373575
##
File path:
[
https://issues.apache.org/jira/browse/FLINK-11996?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16799378#comment-16799378
]
william hesch commented on FLINK-11996:
---
+1
> Case class maximum of 22 fields
>
[
https://issues.apache.org/jira/browse/FLINK-10897?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16799348#comment-16799348
]
william hesch commented on FLINK-10897:
---
[~tzulitai]
> Support POJO state schema evolution
>
[
https://issues.apache.org/jira/browse/FLINK-11889?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kostas Kloudas reassigned FLINK-11889:
--
Assignee: Kostas Kloudas
> Remove "stop" signal along with Stoppable interfaces
>
[
https://issues.apache.org/jira/browse/FLINK-10897?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16798569#comment-16798569
]
william hesch edited comment on FLINK-10897 at 3/22/19 6:36 PM:
Does
[
https://issues.apache.org/jira/browse/FLINK-8902?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16799210#comment-16799210
]
David Anderson commented on FLINK-8902:
---
I'm also seeing this in a completely reproducible way. In
[
https://issues.apache.org/jira/browse/FLINK-11997?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Anderson resolved FLINK-11997.
Resolution: Duplicate
> ConcurrentModificationException: ZooKeeper unexpectedly modified
[
https://issues.apache.org/jira/browse/FLINK-9007?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16799206#comment-16799206
]
Thomas Weise commented on FLINK-9007:
-
1.8.x: 11af4523801164539e186d836462f5884b561941
>
[
https://issues.apache.org/jira/browse/FLINK-9007?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Thomas Weise updated FLINK-9007:
Fix Version/s: 1.8.1
> End-to-end test: Kinesis connector
> --
>
>
tweise merged pull request #8031: [FLINK-9007] [kinesis] [e2e] Add Kinesis
end-to-end test
URL: https://github.com/apache/flink/pull/8031
This is an automated message from the Apache Git Service.
To respond to the message,
[
https://issues.apache.org/jira/browse/FLINK-11997?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Anderson updated FLINK-11997:
---
Description:
Trying to rescale a job running in a k8s job cluster via
{{flink modify
[
https://issues.apache.org/jira/browse/FLINK-11997?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16799203#comment-16799203
]
David Anderson commented on FLINK-11997:
Looking at the logs more carefully (see attached file),
jgrier commented on issue #8031: [FLINK-9007] [kinesis] [e2e] Add Kinesis
end-to-end test
URL: https://github.com/apache/flink/pull/8031#issuecomment-475706723
lgtm
This is an automated message from the Apache Git Service.
flinkbot edited a comment on issue #8031: [FLINK-9007] [kinesis] [e2e] Add
Kinesis end-to-end test
URL: https://github.com/apache/flink/pull/8031#issuecomment-475346824
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
to review
jgrier commented on issue #8031: [FLINK-9007] [kinesis] [e2e] Add Kinesis
end-to-end test
URL: https://github.com/apache/flink/pull/8031#issuecomment-475706272
@flinkbot approve all
This is an automated message from the
[
https://issues.apache.org/jira/browse/FLINK-11997?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Anderson updated FLINK-11997:
---
Attachment: FAILURE
> ConcurrentModificationException: ZooKeeper unexpectedly modified
>
[
https://issues.apache.org/jira/browse/FLINK-5601?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
bupt_ljy updated FLINK-5601:
Affects Version/s: 1.9.0
> Window operator does not checkpoint watermarks
>
[
https://issues.apache.org/jira/browse/FLINK-5601?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
bupt_ljy updated FLINK-5601:
Affects Version/s: 1.8.0
> Window operator does not checkpoint watermarks
>
[
https://issues.apache.org/jira/browse/FLINK-11997?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Anderson updated FLINK-11997:
---
Description:
Trying to rescale a job running in a k8s job cluster via
flink modify
David Anderson created FLINK-11997:
--
Summary: ConcurrentModificationException: ZooKeeper unexpectedly
modified
Key: FLINK-11997
URL: https://issues.apache.org/jira/browse/FLINK-11997
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-11276?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rong Rong updated FLINK-11276:
--
Description:
This umbrella JIRA focus on the improvement of the existing window operator
*WITHOUT*
[
https://issues.apache.org/jira/browse/FLINK-11654?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16799086#comment-16799086
]
Jürgen Kreileder commented on FLINK-11654:
--
[~pnowojski] It's a rather simple job running with
[
https://issues.apache.org/jira/browse/FLINK-11276?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rong Rong updated FLINK-11276:
--
Description:
This is the umbrella ticket for the improvement discussion in:
[
https://issues.apache.org/jira/browse/FLINK-11276?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rong Rong updated FLINK-11276:
--
Summary: Sliding Window Optimization (was: Slicing Window Optimization)
> Sliding Window
HuangZhenQiu commented on issue #7978: [FLINK-11910] [Yarn] add customizable
yarn application type
URL: https://github.com/apache/flink/pull/7978#issuecomment-475655770
@suez1224 @rmetzger
Would you please have one more round of review?
[
https://issues.apache.org/jira/browse/FLINK-7244?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16799083#comment-16799083
]
Zhenqiu Huang commented on FLINK-7244:
--
[~yanghua]
I am adding more test cases. Will have an
flinkbot edited a comment on issue #7856: [FLINK-11776][coordination] Refactor
to simplify the process of scheduleOrUpdateConsumers
URL: https://github.com/apache/flink/pull/7856#issuecomment-468170966
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I
azagrebin commented on issue #7856: [FLINK-11776][coordination] Refactor to
simplify the process of scheduleOrUpdateConsumers
URL: https://github.com/apache/flink/pull/7856#issuecomment-475641676
@flinkbot approve all
@flinkbot attention @tillrohrmann
flinkbot commented on issue #8038: [FLINK-11953] Introduce Plugin/Loading
system and integrate it with FileSystem
URL: https://github.com/apache/flink/pull/8038#issuecomment-475639958
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-11953?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-11953:
---
Labels: pull-request-available (was: )
> Introduce Plugin/Loading system and integrate it
StefanRRichter opened a new pull request #8038: [FLINK-11953] Introduce
Plugin/Loading system and integrate it with FileSystem
URL: https://github.com/apache/flink/pull/8038
## What is the purpose of the change
We want to change the general architecture for loading FileSystems in
azagrebin commented on a change in pull request #7856:
[FLINK-11776][coordination] Refactor to simplify the process of
scheduleOrUpdateConsumers
URL: https://github.com/apache/flink/pull/7856#discussion_r268189476
##
File path:
azagrebin commented on a change in pull request #7856:
[FLINK-11776][coordination] Refactor to simplify the process of
scheduleOrUpdateConsumers
URL: https://github.com/apache/flink/pull/7856#discussion_r268188124
##
File path:
azagrebin commented on a change in pull request #7856:
[FLINK-11776][coordination] Refactor to simplify the process of
scheduleOrUpdateConsumers
URL: https://github.com/apache/flink/pull/7856#discussion_r268180242
##
File path:
azagrebin commented on a change in pull request #7856:
[FLINK-11776][coordination] Refactor to simplify the process of
scheduleOrUpdateConsumers
URL: https://github.com/apache/flink/pull/7856#discussion_r268177944
##
File path:
flinkbot edited a comment on issue #7856: [FLINK-11776][coordination] Refactor
to simplify the process of scheduleOrUpdateConsumers
URL: https://github.com/apache/flink/pull/7856#issuecomment-468170966
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I
azagrebin commented on a change in pull request #7856:
[FLINK-11776][coordination] Refactor to simplify the process of
scheduleOrUpdateConsumers
URL: https://github.com/apache/flink/pull/7856#discussion_r268172289
##
File path:
[
https://issues.apache.org/jira/browse/FLINK-11907?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-11907:
---
Labels: pull-request-available (was: )
> GenericTypeInfoTest fails on Java 9
>
flinkbot commented on issue #8037: [FLINK-11907][types] Normalize
String/BigInteger in GenericTypeInfoTest
URL: https://github.com/apache/flink/pull/8037#issuecomment-475624722
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
to
zentol opened a new pull request #8037: [FLINK-11907][types] Normalize
String/BigInteger in GenericTypeInfoTest
URL: https://github.com/apache/flink/pull/8037
## What is the purpose of the change
This PR modifies modifies the `GenericTypeInfoTest` to run on Java 9. The
test
[
https://issues.apache.org/jira/browse/FLINK-11907?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler reassigned FLINK-11907:
Assignee: Chesnay Schepler
> GenericTypeInfoTest fails on Java 9
>
aljoscha commented on a change in pull request #7605: [FLINK-11463][PROTOTYPE]
Port Kafka E2E test to Java
URL: https://github.com/apache/flink/pull/7605#discussion_r268147612
##
File path:
aljoscha commented on a change in pull request #7605: [FLINK-11463][PROTOTYPE]
Port Kafka E2E test to Java
URL: https://github.com/apache/flink/pull/7605#discussion_r268150850
##
File path:
aljoscha commented on a change in pull request #7605: [FLINK-11463][PROTOTYPE]
Port Kafka E2E test to Java
URL: https://github.com/apache/flink/pull/7605#discussion_r268149545
##
File path:
aljoscha commented on a change in pull request #7605: [FLINK-11463][PROTOTYPE]
Port Kafka E2E test to Java
URL: https://github.com/apache/flink/pull/7605#discussion_r268154828
##
File path:
maqingxiang commented on a change in pull request #8008: [FLINK-11963][History
Server]Add time-based cleanup mechanism in history server
URL: https://github.com/apache/flink/pull/8008#discussion_r268164156
##
File path:
aljoscha commented on a change in pull request #7605: [FLINK-11463][PROTOTYPE]
Port Kafka E2E test to Java
URL: https://github.com/apache/flink/pull/7605#discussion_r268147030
##
File path:
aljoscha commented on a change in pull request #7605: [FLINK-11463][PROTOTYPE]
Port Kafka E2E test to Java
URL: https://github.com/apache/flink/pull/7605#discussion_r268149503
##
File path:
maqingxiang commented on a change in pull request #8008: [FLINK-11963][History
Server]Add time-based cleanup mechanism in history server
URL: https://github.com/apache/flink/pull/8008#discussion_r268163453
##
File path:
[
https://issues.apache.org/jira/browse/FLINK-11153?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-11153:
-
Summary: Remove UdfAnalyzer (was: UdfAnalyzerTest fails with
CodeAnalyzerException)
>
gustavo-momente edited a comment on issue #7980: [FLINK-11913] Shadding
cassandra driver dependencies in cassandra conector
URL: https://github.com/apache/flink/pull/7980#issuecomment-475612671
I understand your point, but what would be the best possible way that we
could support multiple
[
https://issues.apache.org/jira/browse/FLINK-11988?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski closed FLINK-11988.
--
Resolution: Fixed
Fix Version/s: 1.9.0
[~zjwang] thanks for the clean up. One remark,
gustavo-momente commented on issue #7980: [FLINK-11913] Shadding cassandra
driver dependencies in cassandra conector
URL: https://github.com/apache/flink/pull/7980#issuecomment-475612671
I understand your point, but what would be the best possible way that we
could support multiple
pnowojski merged pull request #8028: [FLINK-11988][network] Remove legacy
MockNetworkEnvironment
URL: https://github.com/apache/flink/pull/8028
This is an automated message from the Apache Git Service.
To respond to the
[
https://issues.apache.org/jira/browse/FLINK-11974?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16798987#comment-16798987
]
Piotr Nowojski commented on FLINK-11974:
[~lzljs3620320] could elaborate a little bit more
[
https://issues.apache.org/jira/browse/FLINK-11654?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16798970#comment-16798970
]
Piotr Nowojski commented on FLINK-11654:
I don't think so, unless there is a stupid bug or we
pnowojski commented on a change in pull request #7911: [FLINK-11082][network]
Fix the logic of getting backlog in sub partition
URL: https://github.com/apache/flink/pull/7911#discussion_r268145222
##
File path:
pnowojski commented on a change in pull request #7911: [FLINK-11082][network]
Fix the logic of getting backlog in sub partition
URL: https://github.com/apache/flink/pull/7911#discussion_r268145093
##
File path:
[
https://issues.apache.org/jira/browse/FLINK-11996?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-11996:
-
Component/s: API / Type Serialization System
API / Scala
> Case class
Wouter Zorgdrager created FLINK-11996:
-
Summary: Case class maximum of 22 fields
Key: FLINK-11996
URL: https://issues.apache.org/jira/browse/FLINK-11996
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-11431?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-11431:
-
Fix Version/s: 1.9.0
Component/s: Runtime / Coordination
Summary:
[
https://issues.apache.org/jira/browse/FLINK-5429?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
vinoyang reassigned FLINK-5429:
---
Assignee: vinoyang
> Code generate types between operators in Table API
>
flinkbot commented on issue #8036: [FLINK-11431][runtime] Upgrade akka to 2.5
URL: https://github.com/apache/flink/pull/8036#issuecomment-475595316
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
to review your pull request. We
[
https://issues.apache.org/jira/browse/FLINK-9607?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16798942#comment-16798942
]
vinoyang commented on FLINK-9607:
-
[~guibopan] What's the status about this issue?
> Support
[
https://issues.apache.org/jira/browse/FLINK-7244?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16798941#comment-16798941
]
vinoyang commented on FLINK-7244:
-
[~ZhenqiuHuang] What's the status about this issue?
> Add
[
https://issues.apache.org/jira/browse/FLINK-3476?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
vinoyang reassigned FLINK-3476:
---
Assignee: vinoyang
> Support hash-based partial aggregate
>
>
[
https://issues.apache.org/jira/browse/FLINK-11431?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-11431:
---
Labels: pull-request-available (was: )
> Akka dependency not compatible with java 9 or
zentol opened a new pull request #8036: [FLINK-11431][runtime] Upgrade akka to
2.5
URL: https://github.com/apache/flink/pull/8036
## What is the purpose of the change
This PR upgrades akka to 2.5.21. This is a hard requirement for JDK 9+
support.
## Brief change log
[
https://issues.apache.org/jira/browse/FLINK-3480?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
vinoyang reassigned FLINK-3480:
---
Assignee: vinoyang
> Add hash-based strategy for ReduceFunction
>
flinkbot commented on issue #8035: [FLINK-11975][table-planner-blink] Support
to run a sql query : 'SELECT * FROM (VALUES (1, 2, 3)) T(a, b, c)'
URL: https://github.com/apache/flink/pull/8035#issuecomment-475591092
Thanks a lot for your contribution to the Apache Flink project. I'm the
[
https://issues.apache.org/jira/browse/FLINK-11975?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-11975:
---
Labels: pull-request-available (was: )
> Support to run a sql query : 'SELECT * FROM
beyond1920 opened a new pull request #8035: [FLINK-11975][table-planner-blink]
Support to run a sql query : 'SELECT * FROM (VALUES (1, 2, 3)) T(a, b, c)'
URL: https://github.com/apache/flink/pull/8035
## What is the purpose of the change
Support to run a sql query : 'SELECT * FROM
[
https://issues.apache.org/jira/browse/FLINK-9170?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16798937#comment-16798937
]
vinoyang commented on FLINK-9170:
-
Hi [~hpeter] What's the status about this issue?
> HCatolog
[
https://issues.apache.org/jira/browse/FLINK-8474?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
vinoyang reassigned FLINK-8474:
---
Assignee: TANG Wen-hui
> Add documentation for HBaseTableSource
>
[
https://issues.apache.org/jira/browse/FLINK-9278?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
vinoyang reassigned FLINK-9278:
---
Assignee: vinoyang
> Allow restore savepoint with some SQL queries added/removed
>
[
https://issues.apache.org/jira/browse/FLINK-9673?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
vinoyang reassigned FLINK-9673:
---
Assignee: vinoyang
> Improve State efficiency of bounded OVER window operators
>
[
https://issues.apache.org/jira/browse/FLINK-9605?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
vinoyang reassigned FLINK-9605:
---
Assignee: vinoyang (was: zhangminglei)
> Support KafkaProtoBufTableSink
>
[
https://issues.apache.org/jira/browse/FLINK-9651?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
vinoyang reassigned FLINK-9651:
---
Assignee: vinoyang (was: zhangminglei)
> Add a Kafka table source factory with Protobuf format
[
https://issues.apache.org/jira/browse/FLINK-9604?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
vinoyang reassigned FLINK-9604:
---
Assignee: vinoyang (was: zhangminglei)
> Support KafkaProtoBufTableSource
>
[
https://issues.apache.org/jira/browse/FLINK-11775?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16798922#comment-16798922
]
Piotr Nowojski commented on FLINK-11775:
Sorry for asking maybe stupid question, I'm not very
[
https://issues.apache.org/jira/browse/FLINK-11975?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jing Zhang updated FLINK-11975:
---
Description:
Support to run a sql query : 'SELECT * FROM (VALUES (1, 2, 3)) T(a, b, c)',
asfgit closed pull request #7882: [typo] Inaccurate info on Avro splitting
support
URL: https://github.com/apache/flink/pull/7882
This is an automated message from the Apache Git Service.
To respond to the message, please
[
https://issues.apache.org/jira/browse/FLINK-11975?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jing Zhang updated FLINK-11975:
---
Description:
Support to run a sql query : 'SELECT * FROM (VALUES (1, 2, 3)) T(a, b, c)',
flinkbot edited a comment on issue #7882: [typo] Inaccurate info on Avro
splitting support
URL: https://github.com/apache/flink/pull/7882#issuecomment-468973315
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
to review your pull
1 - 100 of 249 matches
Mail list logo
