[
https://issues.apache.org/jira/browse/FLINK-9083?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16668116#comment-16668116
]
ASF GitHub Bot commented on FLINK-9083:
---
jparkie commented on issue #6782: [FLINK-9083][Cassandra
jparkie commented on issue #6782: [FLINK-9083][Cassandra Connector] Add async
backpressure support to Cassandra Connector
URL: https://github.com/apache/flink/pull/6782#issuecomment-434168230
I rebased my PR, and I'll be working on the new changes to address the PR
comments.
[
https://issues.apache.org/jira/browse/FLINK-9083?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16668098#comment-16668098
]
ASF GitHub Bot commented on FLINK-9083:
---
jparkie commented on a change in pull request #6782:
jparkie commented on a change in pull request #6782: [FLINK-9083][Cassandra
Connector] Add async backpressure support to Cassandra Connector
URL: https://github.com/apache/flink/pull/6782#discussion_r229170161
##
File path:
[
https://issues.apache.org/jira/browse/FLINK-10231?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16668093#comment-16668093
]
winifredtang commented on FLINK-10231:
--
[~fhueske] Hello, could you give more details about it? I
[
https://issues.apache.org/jira/browse/FLINK-9083?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16668091#comment-16668091
]
ASF GitHub Bot commented on FLINK-9083:
---
jparkie commented on a change in pull request #6782:
[
https://issues.apache.org/jira/browse/FLINK-10231?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
winifredtang reassigned FLINK-10231:
Assignee: winifredtang
> Add a view SQL DDL
> --
>
>
jparkie commented on a change in pull request #6782: [FLINK-9083][Cassandra
Connector] Add async backpressure support to Cassandra Connector
URL: https://github.com/apache/flink/pull/6782#discussion_r229169780
##
File path:
[
https://issues.apache.org/jira/browse/FLINK-9083?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16668081#comment-16668081
]
ASF GitHub Bot commented on FLINK-9083:
---
jparkie commented on a change in pull request #6782:
jparkie commented on a change in pull request #6782: [FLINK-9083][Cassandra
Connector] Add async backpressure support to Cassandra Connector
URL: https://github.com/apache/flink/pull/6782#discussion_r229168212
##
File path:
[
https://issues.apache.org/jira/browse/FLINK-9142?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
blues zheng reassigned FLINK-9142:
--
Assignee: blues zheng
> Lower the minimum number of buffers for incoming channels to 1
>
[
https://issues.apache.org/jira/browse/FLINK-9083?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16668058#comment-16668058
]
ASF GitHub Bot commented on FLINK-9083:
---
jparkie commented on a change in pull request #6782:
jparkie commented on a change in pull request #6782: [FLINK-9083][Cassandra
Connector] Add async backpressure support to Cassandra Connector
URL: https://github.com/apache/flink/pull/6782#discussion_r229163101
##
File path:
[
https://issues.apache.org/jira/browse/FLINK-9083?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16668054#comment-16668054
]
ASF GitHub Bot commented on FLINK-9083:
---
jparkie commented on a change in pull request #6782:
jparkie commented on a change in pull request #6782: [FLINK-9083][Cassandra
Connector] Add async backpressure support to Cassandra Connector
URL: https://github.com/apache/flink/pull/6782#discussion_r229162559
##
File path: docs/dev/connectors/cassandra.md
##
@@ -72,10
[
https://issues.apache.org/jira/browse/FLINK-10600?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16668028#comment-16668028
]
ASF GitHub Bot commented on FLINK-10600:
yanghua commented on a change in pull request #6924:
yanghua commented on a change in pull request #6924: [FLINK-10600] Provide
End-to-end test cases for modern Kafka connectors
URL: https://github.com/apache/flink/pull/6924#discussion_r229159258
##
File path: flink-examples/flink-examples-streaming/pom.xml
##
@@ -538,6
[
https://issues.apache.org/jira/browse/FLINK-10704?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16668025#comment-16668025
]
vinoyang commented on FLINK-10704:
--
[~pnowojski] [~twalthr] Yes, I am just curious about why we ruled
[
https://issues.apache.org/jira/browse/FLINK-10698?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
winifredtang reassigned FLINK-10698:
Assignee: winifredtang
> Create CatalogManager class manages all external catalogs and
[
https://issues.apache.org/jira/browse/FLINK-9697?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16668016#comment-16668016
]
ASF GitHub Bot commented on FLINK-9697:
---
yanghua edited a comment on issue #6703: [FLINK-9697]
[
https://issues.apache.org/jira/browse/FLINK-9697?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16668015#comment-16668015
]
ASF GitHub Bot commented on FLINK-9697:
---
yanghua commented on issue #6703: [FLINK-9697] Provide
yanghua edited a comment on issue #6703: [FLINK-9697] Provide connector for
modern Kafka
URL: https://github.com/apache/flink/pull/6703#issuecomment-434147725
@pnowojski Not only the modern kafka connector, but also other connectors.
Each version of the flink-connector relies on the base
yanghua commented on issue #6703: [FLINK-9697] Provide connector for modern
Kafka
URL: https://github.com/apache/flink/pull/6703#issuecomment-434147725
@pnowojski Not only the modern kafka connector, but also other connectors.
Each version of the flink-connector relies on the base module,
[
https://issues.apache.org/jira/browse/FLINK-10714?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16668009#comment-16668009
]
Xiaogang Shi commented on FLINK-10714:
--
[~cmick] I came across a similar problem before. It seems
[
https://issues.apache.org/jira/browse/FLINK-10718?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
vinoyang reassigned FLINK-10718:
Assignee: vinoyang
> Use IO executor in RpcService for message serialization
>
kbohinski opened a new pull request #6962: change accumulator value to be
formatted with digit group separator
URL: https://github.com/apache/flink/pull/6962
## What is the purpose of the change
*This pull request is a small qol change that makes it easier for users to
read the
[
https://issues.apache.org/jira/browse/FLINK-10687?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16667841#comment-16667841
]
ASF GitHub Bot commented on FLINK-10687:
bowenli86 edited a comment on issue #6958:
bowenli86 edited a comment on issue #6958: [FLINK-10687] [table] Make
flink-formats Scala-free
URL: https://github.com/apache/flink/pull/6958#issuecomment-434103016
I only had a detailed look at classes in `flink-format/flink-avro` and
`flink-table-common`. Big PR while changes are mostly
[
https://issues.apache.org/jira/browse/FLINK-10687?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16667839#comment-16667839
]
ASF GitHub Bot commented on FLINK-10687:
bowenli86 commented on issue #6958: [FLINK-10687]
bowenli86 commented on issue #6958: [FLINK-10687] [table] Make flink-formats
Scala-free
URL: https://github.com/apache/flink/pull/6958#issuecomment-434103016
I only had a detailed look at classes in `flink-table-common`. Big PR while
changes are mostly renaming and migrating without
[
https://issues.apache.org/jira/browse/FLINK-10720?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16667809#comment-16667809
]
Chesnay Schepler commented on FLINK-10720:
--
Could you check whether the
Till Rohrmann created FLINK-10720:
-
Summary: Add stress deployment end-to-end test
Key: FLINK-10720
URL: https://issues.apache.org/jira/browse/FLINK-10720
Project: Flink
Issue Type: Sub-task
[
https://issues.apache.org/jira/browse/FLINK-10686?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16667642#comment-16667642
]
Bowen Li commented on FLINK-10686:
--
Hi [~twalthr], I just found in our mail list that 1.7 release was
Bowen Li created FLINK-10719:
Summary: Add user documentation for Flink-Hive integration
Key: FLINK-10719
URL: https://issues.apache.org/jira/browse/FLINK-10719
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-10697?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bowen Li reassigned FLINK-10697:
Assignee: Bowen Li
> Create an in-memory catalog that stores Flink's meta objects
>
[
https://issues.apache.org/jira/browse/FLINK-10696?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bowen Li reassigned FLINK-10696:
Assignee: Bowen Li
> Add APIs to ExternalCatalog for views and UDFs
>
[
https://issues.apache.org/jira/browse/FLINK-10686?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16667608#comment-16667608
]
Bowen Li commented on FLINK-10686:
--
I'd vote for this, and hope it can be done ASAP so all the coming
[
https://issues.apache.org/jira/browse/FLINK-10556?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16667607#comment-16667607
]
Bowen Li commented on FLINK-10556:
--
FLINK-10686 will create a Java-based flink-table-common module that
[
https://issues.apache.org/jira/browse/FLINK-4582?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16667569#comment-16667569
]
Ying Xu commented on FLINK-4582:
Thanks [~tinder-dthomson] for the detailed comments. Yes that's
[
https://issues.apache.org/jira/browse/FLINK-9061?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16667474#comment-16667474
]
Jonathan Miles commented on FLINK-9061:
---
Agreed it should be harder, but we were able to trigger
[
https://issues.apache.org/jira/browse/FLINK-9061?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16667437#comment-16667437
]
Elias Levy commented on FLINK-9061:
---
Just a note to say that changes AWS made to S3 in July means that
[
https://issues.apache.org/jira/browse/FLINK-10714?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stefan Richter updated FLINK-10714:
---
Fix Version/s: 1.7.0
> java.lang.IndexOutOfBoundsException when creating a heap backend
[
https://issues.apache.org/jira/browse/FLINK-10714?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stefan Richter updated FLINK-10714:
---
Priority: Blocker (was: Major)
> java.lang.IndexOutOfBoundsException when creating a heap
[
https://issues.apache.org/jira/browse/FLINK-10691?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16667370#comment-16667370
]
Hequn Cheng commented on FLINK-10691:
-
Would it be ok if we replace {{BucketingSink}} with
[
https://issues.apache.org/jira/browse/FLINK-10687?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16667367#comment-16667367
]
ASF GitHub Bot commented on FLINK-10687:
twalthr commented on issue #6958: [FLINK-10687] [table]
twalthr commented on issue #6958: [FLINK-10687] [table] Make flink-formats
Scala-free
URL: https://github.com/apache/flink/pull/6958#issuecomment-433960589
Thanks for the review @aljoscha. I added more tests and improvements to the
type parser.
[
https://issues.apache.org/jira/browse/FLINK-9635?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-9635:
--
Labels: pull-request-available (was: )
> Local recovery scheduling can cause spread out of
[
https://issues.apache.org/jira/browse/FLINK-9635?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16667366#comment-16667366
]
ASF GitHub Bot commented on FLINK-9635:
---
StefanRRichter opened a new pull request #6961:
StefanRRichter opened a new pull request #6961: [FLINK-9635] Fix scheduling for
local recovery
URL: https://github.com/apache/flink/pull/6961
## What is the purpose of the change
This change fixes the task spread-out problem in scheduling with local
recovery. The solution is based
[
https://issues.apache.org/jira/browse/FLINK-10691?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hequn Cheng reassigned FLINK-10691:
---
Assignee: Hequn Cheng
> StreamSQL E2E test relies on hadoop
>
[
https://issues.apache.org/jira/browse/FLINK-10461?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16667357#comment-16667357
]
ASF GitHub Bot commented on FLINK-10461:
azagrebin commented on a change in pull request #6777:
[
https://issues.apache.org/jira/browse/FLINK-10461?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16667360#comment-16667360
]
ASF GitHub Bot commented on FLINK-10461:
azagrebin commented on a change in pull request #6777:
[
https://issues.apache.org/jira/browse/FLINK-10461?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16667354#comment-16667354
]
ASF GitHub Bot commented on FLINK-10461:
azagrebin commented on a change in pull request #6777:
[
https://issues.apache.org/jira/browse/FLINK-10461?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16667359#comment-16667359
]
ASF GitHub Bot commented on FLINK-10461:
azagrebin commented on a change in pull request #6777:
[
https://issues.apache.org/jira/browse/FLINK-10461?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16667355#comment-16667355
]
ASF GitHub Bot commented on FLINK-10461:
azagrebin commented on a change in pull request #6777:
azagrebin commented on a change in pull request #6777: [FLINK-10461] [State
Backends, Checkpointing] Speed up download files when restore from DFS
URL: https://github.com/apache/flink/pull/6777#discussion_r228970609
##
File path:
azagrebin commented on a change in pull request #6777: [FLINK-10461] [State
Backends, Checkpointing] Speed up download files when restore from DFS
URL: https://github.com/apache/flink/pull/6777#discussion_r228970266
##
File path:
[
https://issues.apache.org/jira/browse/FLINK-10461?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16667356#comment-16667356
]
ASF GitHub Bot commented on FLINK-10461:
azagrebin commented on a change in pull request #6777:
[
https://issues.apache.org/jira/browse/FLINK-10461?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16667358#comment-16667358
]
ASF GitHub Bot commented on FLINK-10461:
azagrebin commented on a change in pull request #6777:
azagrebin commented on a change in pull request #6777: [FLINK-10461] [State
Backends, Checkpointing] Speed up download files when restore from DFS
URL: https://github.com/apache/flink/pull/6777#discussion_r228937223
##
File path:
azagrebin commented on a change in pull request #6777: [FLINK-10461] [State
Backends, Checkpointing] Speed up download files when restore from DFS
URL: https://github.com/apache/flink/pull/6777#discussion_r228964472
##
File path:
azagrebin commented on a change in pull request #6777: [FLINK-10461] [State
Backends, Checkpointing] Speed up download files when restore from DFS
URL: https://github.com/apache/flink/pull/6777#discussion_r228937420
##
File path:
azagrebin commented on a change in pull request #6777: [FLINK-10461] [State
Backends, Checkpointing] Speed up download files when restore from DFS
URL: https://github.com/apache/flink/pull/6777#discussion_r228967531
##
File path:
azagrebin commented on a change in pull request #6777: [FLINK-10461] [State
Backends, Checkpointing] Speed up download files when restore from DFS
URL: https://github.com/apache/flink/pull/6777#discussion_r228976096
##
File path:
[
https://issues.apache.org/jira/browse/FLINK-10704?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16667345#comment-16667345
]
Timo Walther commented on FLINK-10704:
--
I thought maybe Maven resource transformers could do it but
[
https://issues.apache.org/jira/browse/FLINK-9697?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16667342#comment-16667342
]
ASF GitHub Bot commented on FLINK-9697:
---
pnowojski commented on issue #6703: [FLINK-9697] Provide
pnowojski commented on issue #6703: [FLINK-9697] Provide connector for modern
Kafka
URL: https://github.com/apache/flink/pull/6703#issuecomment-433950958
One more issue question. Why the new connector has this exclussion:
```
org.apache.flink
[
https://issues.apache.org/jira/browse/FLINK-10704?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16667332#comment-16667332
]
Piotr Nowojski commented on FLINK-10704:
I asked [~twalthr] about that (he added it), and there
[
https://issues.apache.org/jira/browse/FLINK-9635?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-9635:
-
Affects Version/s: 1.6.2
> Local recovery scheduling can cause spread out of tasks
>
[
https://issues.apache.org/jira/browse/FLINK-9635?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann reassigned FLINK-9635:
Assignee: Stefan Richter
> Local recovery scheduling can cause spread out of tasks
>
[
https://issues.apache.org/jira/browse/FLINK-10713?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-10713:
--
Fix Version/s: 1.7.0
> RestartIndividualStrategy does not restore state
>
[
https://issues.apache.org/jira/browse/FLINK-10712?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-10712:
--
Fix Version/s: 1.7.0
> RestartPipelinedRegionStrategy does not restore state
>
[
https://issues.apache.org/jira/browse/FLINK-10715?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16667296#comment-16667296
]
Chesnay Schepler commented on FLINK-10715:
--
This is effectively a duplicate of FLINK-10035.
>
Till Rohrmann created FLINK-10718:
-
Summary: Use IO executor in RpcService for message serialization
Key: FLINK-10718
URL: https://issues.apache.org/jira/browse/FLINK-10718
Project: Flink
Tzu-Li (Gordon) Tai created FLINK-10717:
---
Summary: Introduce SimpleSerializerSnapshot as replacement for
ParameterlessTypeSerializerConfig
Key: FLINK-10717
URL:
[
https://issues.apache.org/jira/browse/FLINK-10600?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16667290#comment-16667290
]
ASF GitHub Bot commented on FLINK-10600:
pnowojski commented on a change in pull request #6924:
pnowojski commented on a change in pull request #6924: [FLINK-10600] Provide
End-to-end test cases for modern Kafka connectors
URL: https://github.com/apache/flink/pull/6924#discussion_r228949560
##
File path: flink-examples/flink-examples-streaming/pom.xml
##
@@ -538,6
[
https://issues.apache.org/jira/browse/FLINK-9552?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-9552:
-
Fix Version/s: 1.7.0
> NPE in SpanningRecordSerializer during checkpoint with iterations
>
[
https://issues.apache.org/jira/browse/FLINK-10603?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16667287#comment-16667287
]
Piotr Nowojski commented on FLINK-10603:
I think the single largest overhead comes from This run
[
https://issues.apache.org/jira/browse/FLINK-10097?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16667248#comment-16667248
]
ASF GitHub Bot commented on FLINK-10097:
kl0u commented on issue #6520: [FLINK-10097][DataStream
kl0u commented on issue #6520: [FLINK-10097][DataStream API] Additional tests
for StreamingFileSink
URL: https://github.com/apache/flink/pull/6520#issuecomment-433920446
Thanks a lot @azagrebin ! I will integrate your comments and merge.
[
https://issues.apache.org/jira/browse/FLINK-10668?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16667238#comment-16667238
]
ASF GitHub Bot commented on FLINK-10668:
GJL commented on issue #6950: [FLINK-10668][e2e]
GJL commented on issue #6950: [FLINK-10668][e2e] Streaming File Sink E2E test
fails because not all legitimate exceptions are excluded
URL: https://github.com/apache/flink/pull/6950#issuecomment-433917808
I think this is relevant: https://github.com/apache/flink/pull/6959
[
https://issues.apache.org/jira/browse/FLINK-10097?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16667226#comment-16667226
]
ASF GitHub Bot commented on FLINK-10097:
azagrebin commented on a change in pull request #6520:
[
https://issues.apache.org/jira/browse/FLINK-10097?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16667224#comment-16667224
]
ASF GitHub Bot commented on FLINK-10097:
azagrebin commented on a change in pull request #6520:
[
https://issues.apache.org/jira/browse/FLINK-10097?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16667225#comment-16667225
]
ASF GitHub Bot commented on FLINK-10097:
azagrebin commented on a change in pull request #6520:
azagrebin commented on a change in pull request #6520: [FLINK-10097][DataStream
API] Additional tests for StreamingFileSink
URL: https://github.com/apache/flink/pull/6520#discussion_r228873834
##
File path:
azagrebin commented on a change in pull request #6520: [FLINK-10097][DataStream
API] Additional tests for StreamingFileSink
URL: https://github.com/apache/flink/pull/6520#discussion_r228928607
##
File path:
azagrebin commented on a change in pull request #6520: [FLINK-10097][DataStream
API] Additional tests for StreamingFileSink
URL: https://github.com/apache/flink/pull/6520#discussion_r228920095
##
File path:
Tzu-Li (Gordon) Tai created FLINK-10716:
---
Summary: Upgrade ListSerializer / ArrayListSerializer for state
evolution
Key: FLINK-10716
URL: https://issues.apache.org/jira/browse/FLINK-10716
[
https://issues.apache.org/jira/browse/FLINK-10600?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16667191#comment-16667191
]
ASF GitHub Bot commented on FLINK-10600:
yanghua commented on a change in pull request #6924:
yanghua commented on a change in pull request #6924: [FLINK-10600] Provide
End-to-end test cases for modern Kafka connectors
URL: https://github.com/apache/flink/pull/6924#discussion_r228923208
##
File path: flink-examples/flink-examples-streaming/pom.xml
##
@@ -538,6
[
https://issues.apache.org/jira/browse/FLINK-10600?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16667188#comment-16667188
]
ASF GitHub Bot commented on FLINK-10600:
yanghua edited a comment on issue #6924: [FLINK-10600]
yanghua edited a comment on issue #6924: [FLINK-10600] Provide End-to-end test
cases for modern Kafka connectors
URL: https://github.com/apache/flink/pull/6924#issuecomment-433904230
Let me try to locate it. This code was written by @tzulitai before.
It seems the call :
```
[
https://issues.apache.org/jira/browse/FLINK-10600?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16667183#comment-16667183
]
ASF GitHub Bot commented on FLINK-10600:
yanghua commented on issue #6924: [FLINK-10600] Provide
[
https://issues.apache.org/jira/browse/FLINK-8953?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
xueyu reassigned FLINK-8953:
Assignee: xueyu
> Resolve unresolved field references in FieldComputer expressions
>
yanghua commented on issue #6924: [FLINK-10600] Provide End-to-end test cases
for modern Kafka connectors
URL: https://github.com/apache/flink/pull/6924#issuecomment-433904230
Let me try to locate it. This code was written by @tzulitai before.
dawidwys commented on issue #6955: [hotfix] [docs] Fix typo in ConfigGroups
URL: https://github.com/apache/flink/pull/6955#issuecomment-433901467
Hi @linzhaoming thank you for your contribution. Please remember though to
update the PR description when opening.
Merging
dawidwys closed pull request #6955: [hotfix] [docs] Fix typo in ConfigGroups
URL: https://github.com/apache/flink/pull/6955
This is a PR merged from a forked repository.
As GitHub hides the original diff on merge, it is displayed below for
the sake of provenance:
As this is a foreign
[
https://issues.apache.org/jira/browse/FLINK-10687?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16667177#comment-16667177
]
ASF GitHub Bot commented on FLINK-10687:
aljoscha commented on issue #6958: [FLINK-10687]
1 - 100 of 247 matches
Mail list logo
