[
https://issues.apache.org/jira/browse/FLINK-10702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16665904#comment-16665904
]
ASF GitHub Bot commented on FLINK-10702:
TisonKun commented on issue #6948: [FLI
TisonKun commented on issue #6948: [FLINK-10702][scala-shell] Yarn app is not
killed when scala shell is terminated
URL: https://github.com/apache/flink/pull/6948#issuecomment-433589505
Oh sorry, now we base on `RestClusterClient` thus what I mention above is
not a problem. Sorry for burde
[
https://issues.apache.org/jira/browse/FLINK-10702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16665901#comment-16665901
]
ASF GitHub Bot commented on FLINK-10702:
TisonKun commented on issue #6948: [FLI
TisonKun commented on issue #6948: [FLINK-10702][scala-shell] Yarn app is not
killed when scala shell is terminated
URL: https://github.com/apache/flink/pull/6948#issuecomment-433589159
Looks reasonable. However, recently I am working with FLINK-10392 "Remove
legacy mode" and I find `YarnC
[
https://issues.apache.org/jira/browse/FLINK-9718?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16665879#comment-16665879
]
ASF GitHub Bot commented on FLINK-9718:
---
zjffdu commented on issue #6245: [FLINK-97
zjffdu commented on issue #6245: [FLINK-9718][scala-shell]. Add enviroment
variable in start-scala-shell.sh and flink to enable remote debug
URL: https://github.com/apache/flink/pull/6245#issuecomment-433587399
Sorry for late response, @yanghua do you have more comments ?
-
[
https://issues.apache.org/jira/browse/FLINK-10702?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-10702:
---
Labels: pull-request-available (was: )
> Yarn app is not killed when scala shell is termina
[
https://issues.apache.org/jira/browse/FLINK-10702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16665868#comment-16665868
]
ASF GitHub Bot commented on FLINK-10702:
zjffdu opened a new pull request #6948:
zjffdu opened a new pull request #6948: [FLINK-10702][scala-shell] Yarn app is
not killed when scala shell is terminated
URL: https://github.com/apache/flink/pull/6948
## What is the purpose of the change
This PR is trying to fix issue that yarn app is not killed when scala s
[
https://issues.apache.org/jira/browse/FLINK-10702?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jeff Zhang reassigned FLINK-10702:
--
Assignee: Jeff Zhang
> Yarn app is not killed when scala shell is terminated
> --
Jeff Zhang created FLINK-10702:
--
Summary: Yarn app is not killed when scala shell is terminated
Key: FLINK-10702
URL: https://issues.apache.org/jira/browse/FLINK-10702
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-9697?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16665833#comment-16665833
]
ASF GitHub Bot commented on FLINK-9697:
---
yanghua commented on issue #6703: [FLINK-9
yanghua commented on issue #6703: [FLINK-9697] Provide connector for modern
Kafka
URL: https://github.com/apache/flink/pull/6703#issuecomment-433583162
@pnowojski Yes, I have created
[FLINK-10701](https://issues.apache.org/jira/browse/FLINK-10701) to track this
problem.
-
[
https://issues.apache.org/jira/browse/FLINK-10701?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
vinoyang updated FLINK-10701:
-
Description: The modern connector is run in the {{misc}} profile since it
wasn't properly added to the {
[
https://issues.apache.org/jira/browse/FLINK-10701?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
vinoyang updated FLINK-10701:
-
Description: The modern connector is run in the {{misc}} profile since it
wasn't properly added to the {
vinoyang created FLINK-10701:
Summary: Move modern kafka connector module into connector profile
Key: FLINK-10701
URL: https://issues.apache.org/jira/browse/FLINK-10701
Project: Flink
Issue Type
TisonKun opened a new pull request #6947: [hotfix] [tests] refactor
YARNSessionCapacitySchedulerITCase
URL: https://github.com/apache/flink/pull/6947
## What is the purpose of the change
refactor `YARNSessionCapacitySchedulerITCase` to get rid of dependency of
`JobClient`.
ho
[
https://issues.apache.org/jira/browse/FLINK-10700?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-10700:
---
Labels: pull-request-available (was: )
> Remove LegacyStandaloneClusterDescriptor
> ---
[
https://issues.apache.org/jira/browse/FLINK-10700?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16665823#comment-16665823
]
ASF GitHub Bot commented on FLINK-10700:
TisonKun opened a new pull request #694
TisonKun opened a new pull request #6946: [FLINK-10700] [cluster managerment]
Remove LegacyStandaloneClusterDes…
URL: https://github.com/apache/flink/pull/6946
…criptor
## What is the purpose of the change
Remove legacy `LegacyStandaloneClusterDescriptor`. No any other use po
TisonKun created FLINK-10700:
Summary: Remove LegacyStandaloneClusterDescriptor
Key: FLINK-10700
URL: https://issues.apache.org/jira/browse/FLINK-10700
Project: Flink
Issue Type: Sub-task
Xuefu Zhang created FLINK-10699:
---
Summary: Create a catalog implementation for persistent Flink meta
objects using Hive metastore as a registry
Key: FLINK-10699
URL: https://issues.apache.org/jira/browse/FLINK-10699
Xuefu Zhang created FLINK-10698:
---
Summary: Create CatalogManager class manages all external catalogs
and temporary meta objects
Key: FLINK-10698
URL: https://issues.apache.org/jira/browse/FLINK-10698
Pr
Xuefu Zhang created FLINK-10697:
---
Summary: Create an in-memory catalog that stores Flink's meta
objects
Key: FLINK-10697
URL: https://issues.apache.org/jira/browse/FLINK-10697
Project: Flink
I
[
https://issues.apache.org/jira/browse/FLINK-10696?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xuefu Zhang updated FLINK-10696:
Description:
Currently there are APIs for tables only. However, views and UDFs are also
common ob
Xuefu Zhang created FLINK-10696:
---
Summary: Add APIs to ExternalCatalog for views and UDFs
Key: FLINK-10696
URL: https://issues.apache.org/jira/browse/FLINK-10696
Project: Flink
Issue Type: Sub-
[
https://issues.apache.org/jira/browse/FLINK-10695?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16665713#comment-16665713
]
ASF GitHub Bot commented on FLINK-10695:
A412 opened a new pull request #6945: [
[
https://issues.apache.org/jira/browse/FLINK-10695?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-10695:
---
Labels: pull-request-available (was: )
> "Cannot load user class" errors should set the und
A412 opened a new pull request #6945: [FLINK-10695] Cannot load user class
errors set underlying cause
URL: https://github.com/apache/flink/pull/6945
## What is the purpose of the change
* This pull request improves the traceability of "Cannot load user class"
exceptions.
##
[
https://issues.apache.org/jira/browse/FLINK-10694?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mikhail Pryakhin updated FLINK-10694:
-
Description:
When a streaming job with Zookeeper-HA enabled gets cancelled all the
job-
Max Feng created FLINK-10695:
Summary: "Cannot load user class" errors should set the underlying
ClassNotFoundException as their cause
Key: FLINK-10695
URL: https://issues.apache.org/jira/browse/FLINK-10695
[
https://issues.apache.org/jira/browse/FLINK-10695?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Max Feng updated FLINK-10695:
-
Description: In {{StreamConfig#getStreamOperator}},
{{ClassNotFoundException}} is propagated as {{Stream
[
https://issues.apache.org/jira/browse/FLINK-4582?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16665593#comment-16665593
]
Devin Thomson commented on FLINK-4582:
--
[~yxu-apache] I appreciate the quick respons
[
https://issues.apache.org/jira/browse/FLINK-4582?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16665527#comment-16665527
]
Ying Xu commented on FLINK-4582:
Hi [~tinder-dthomson] thanks for raising this issue up.
kingbase opened a new pull request #6944: fix typo on comment
URL: https://github.com/apache/flink/pull/6944
just a little typo that "working directory" occured twice
This is an automated message from the Apache Git Servic
[
https://issues.apache.org/jira/browse/FLINK-10600?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16665409#comment-16665409
]
ASF GitHub Bot commented on FLINK-10600:
yanghua commented on issue #6924: [FLIN
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-433472224
No, I mean if we package a jar which contains old connector and new
connector and multiple kafka client this pr's
[
https://issues.apache.org/jira/browse/FLINK-10694?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mikhail Pryakhin updated FLINK-10694:
-
Description:
When a streaming job with Zookeeper-HA enabled gets cancelled all the
job-
Mikhail Pryakhin created FLINK-10694:
Summary: ZooKeeperRunningJobsRegistry Cleanup
Key: FLINK-10694
URL: https://issues.apache.org/jira/browse/FLINK-10694
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-9083?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16665336#comment-16665336
]
ASF GitHub Bot commented on FLINK-9083:
---
jparkie commented on issue #6782: [FLINK-9
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-433455493
My apologies; I've been quite busy with my personal life and work, but I
should be able to carve t
[
https://issues.apache.org/jira/browse/FLINK-10107?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16665322#comment-16665322
]
ASF GitHub Bot commented on FLINK-10107:
twalthr opened a new pull request #6534
[
https://issues.apache.org/jira/browse/FLINK-10107?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16665320#comment-16665320
]
ASF GitHub Bot commented on FLINK-10107:
pnowojski closed pull request #6534: [F
[
https://issues.apache.org/jira/browse/FLINK-10107?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16665319#comment-16665319
]
ASF GitHub Bot commented on FLINK-10107:
pnowojski commented on issue #6534: [FL
[
https://issues.apache.org/jira/browse/FLINK-10107?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16665321#comment-16665321
]
ASF GitHub Bot commented on FLINK-10107:
pnowojski removed a comment on issue #6
twalthr opened a new pull request #6534: [FLINK-10107] [sql-client] Relocate
Flink Kafka connectors for SQL JARs
URL: https://github.com/apache/flink/pull/6534
## What is the purpose of the change
This PR enforces even more shading for SQL JARs than before. In the past, we
only shad
pnowojski commented on issue #6534: [FLINK-10107] [sql-client] Relocate Flink
Kafka connectors for SQL JARs
URL: https://github.com/apache/flink/pull/6534#issuecomment-433452892
e
This is an automated message from the Apache
pnowojski removed a comment on issue #6534: [FLINK-10107] [sql-client] Relocate
Flink Kafka connectors for SQL JARs
URL: https://github.com/apache/flink/pull/6534#issuecomment-433452892
e
This is an automated message from the
pnowojski closed pull request #6534: [FLINK-10107] [sql-client] Relocate Flink
Kafka connectors for SQL JARs
URL: https://github.com/apache/flink/pull/6534
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 prove
[
https://issues.apache.org/jira/browse/FLINK-10107?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16665316#comment-16665316
]
ASF GitHub Bot commented on FLINK-10107:
pnowojski commented on issue #6534: [FL
pnowojski commented on issue #6534: [FLINK-10107] [sql-client] Relocate Flink
Kafka connectors for SQL JARs
URL: https://github.com/apache/flink/pull/6534#issuecomment-433452599
@twalthr what is the problem here? Do I understand this correctly, that
different versions of `flink-kafka-conne
[
https://issues.apache.org/jira/browse/FLINK-10681?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16665309#comment-16665309
]
ASF GitHub Bot commented on FLINK-10681:
tillrohrmann commented on a change in p
tillrohrmann commented on a change in pull request #6928: [FLINK-10681] Harden
ElasticsearchSinkITCase against wrong JNA library
URL: https://github.com/apache/flink/pull/6928#discussion_r228574427
##
File path: flink-connectors/flink-connector-elasticsearch6/pom.xml
##
@@
[
https://issues.apache.org/jira/browse/FLINK-10600?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16665305#comment-16665305
]
ASF GitHub Bot commented on FLINK-10600:
pnowojski commented on issue #6924: [FL
pnowojski 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-433449682
@yanghua do you mean this end-to-end test is failing because of
https://issues.apache.org/jira/browse/FLINK-1010
[
https://issues.apache.org/jira/browse/FLINK-10678?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dawid Wysakowicz reassigned FLINK-10678:
Assignee: Dawid Wysakowicz (was: Hequn Cheng)
> Add a switch to run_test to conf
[
https://issues.apache.org/jira/browse/FLINK-10678?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16665304#comment-16665304
]
Dawid Wysakowicz commented on FLINK-10678:
--
Thx, then I will take it over.
> A
[
https://issues.apache.org/jira/browse/FLINK-10678?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16665302#comment-16665302
]
Hequn Cheng commented on FLINK-10678:
-
Sure. I haven't started yet.
> Add a switch
[
https://issues.apache.org/jira/browse/FLINK-9697?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16665283#comment-16665283
]
ASF GitHub Bot commented on FLINK-9697:
---
pnowojski commented on issue #6703: [FLINK
pnowojski commented on issue #6703: [FLINK-9697] Provide connector for modern
Kafka
URL: https://github.com/apache/flink/pull/6703#issuecomment-433442098
ok thx, we will have to clean this up somehow.
This is an automated mes
pnowojski commented on a change in pull request #6926: [FLINK-10623][e2e]
Extended sql-client e2e test with MATCH_RECOGNIZE
URL: https://github.com/apache/flink/pull/6926#discussion_r228564019
##
File path:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/ru
pnowojski commented on a change in pull request #6926: [FLINK-10623][e2e]
Extended sql-client e2e test with MATCH_RECOGNIZE
URL: https://github.com/apache/flink/pull/6926#discussion_r228564019
##
File path:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/ru
[
https://issues.apache.org/jira/browse/FLINK-10623?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16665280#comment-16665280
]
ASF GitHub Bot commented on FLINK-10623:
pnowojski commented on a change in pull
[
https://issues.apache.org/jira/browse/FLINK-10623?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16665281#comment-16665281
]
ASF GitHub Bot commented on FLINK-10623:
pnowojski commented on a change in pull
zhijiangW commented on issue #6942: [hotfix] [docs] Fixed small typos in the
documentation.
URL: https://github.com/apache/flink/pull/6942#issuecomment-433440581
Thanks for the contribution! @contradictioned
LGTM!
Th
zentol closed pull request #6942: [hotfix] [docs] Fixed small typos in the
documentation.
URL: https://github.com/apache/flink/pull/6942
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
[
https://issues.apache.org/jira/browse/FLINK-10632?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-10632:
---
Labels: pull-request-available (was: )
> Run general purpose test job with failures in per-
[
https://issues.apache.org/jira/browse/FLINK-10632?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16665265#comment-16665265
]
ASF GitHub Bot commented on FLINK-10632:
dawidwys opened a new pull request #694
dawidwys opened a new pull request #6943: [FLINK-10632][e2e] Running general
purpose testing job with failure in per-job mode
URL: https://github.com/apache/flink/pull/6943
## What is the purpose of the change
Add test that runs general purpose job with failure in per-job cluster mod
[
https://issues.apache.org/jira/browse/FLINK-10678?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16665262#comment-16665262
]
Dawid Wysakowicz commented on FLINK-10678:
--
Hi [~hequn8128]
Thanks for interest
[
https://issues.apache.org/jira/browse/FLINK-10678?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16665259#comment-16665259
]
Hequn Cheng commented on FLINK-10678:
-
I think it is also useful for tests that cont
[
https://issues.apache.org/jira/browse/FLINK-10678?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hequn Cheng reassigned FLINK-10678:
---
Assignee: Hequn Cheng
> Add a switch to run_test to configure if logs should be checked for
[
https://issues.apache.org/jira/browse/FLINK-10668?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16665245#comment-16665245
]
Hequn Cheng edited comment on FLINK-10668 at 10/26/18 2:26 PM:
---
[
https://issues.apache.org/jira/browse/FLINK-10668?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16665245#comment-16665245
]
Hequn Cheng commented on FLINK-10668:
-
[~gjy] Hi, I see two options to solve the pro
[
https://issues.apache.org/jira/browse/FLINK-10623?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16665232#comment-16665232
]
ASF GitHub Bot commented on FLINK-10623:
dawidwys commented on a change in pull
dawidwys commented on a change in pull request #6926: [FLINK-10623][e2e]
Extended sql-client e2e test with MATCH_RECOGNIZE
URL: https://github.com/apache/flink/pull/6926#discussion_r228542484
##
File path:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/rul
[
https://issues.apache.org/jira/browse/FLINK-10623?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16665228#comment-16665228
]
ASF GitHub Bot commented on FLINK-10623:
pnowojski commented on a change in pull
pnowojski commented on a change in pull request #6926: [FLINK-10623][e2e]
Extended sql-client e2e test with MATCH_RECOGNIZE
URL: https://github.com/apache/flink/pull/6926#discussion_r228539342
##
File path:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/ru
Stephan Ewen created FLINK-10693:
Summary: Fix Scala EitherSerializer duplication
Key: FLINK-10693
URL: https://issues.apache.org/jira/browse/FLINK-10693
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-10664?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16665210#comment-16665210
]
Stephan Ewen commented on FLINK-10664:
--
I would suggest to try and use the {{flink-
[
https://issues.apache.org/jira/browse/FLINK-10682?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16665203#comment-16665203
]
Stephan Ewen commented on FLINK-10682:
--
This is a deserialization error when readin
[
https://issues.apache.org/jira/browse/FLINK-10683?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16665185#comment-16665185
]
Stephan Ewen commented on FLINK-10683:
--
Seems to be an error (or byte flip) in the
contradictioned opened a new pull request #6942: [hotfix] [docs] Fixed small
typos in the documentation.
URL: https://github.com/apache/flink/pull/6942
Fixed some small typos that I spotted in the documentation.
This is an au
[
https://issues.apache.org/jira/browse/FLINK-10600?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16665123#comment-16665123
]
ASF GitHub Bot commented on FLINK-10600:
yanghua edited a comment on issue #6924
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-433394209
@pnowojski Using maven-shade-plugin, it's hard to package a jar (in
`flink-example-streaming`) that doesn't
[
https://issues.apache.org/jira/browse/FLINK-10600?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16665122#comment-16665122
]
ASF GitHub Bot commented on FLINK-10600:
yanghua commented on issue #6924: [FLIN
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-433394209
@pnowojski Using maven-shade-plugin, it's hard to type a jar that doesn't
contain flink kafka 0.10 or old kafka cl
[
https://issues.apache.org/jira/browse/FLINK-10600?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16665102#comment-16665102
]
ASF GitHub Bot commented on FLINK-10600:
yanghua commented on a change in pull r
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_r228505807
##
File path: flink-end-to-end-tests/test-scripts/test-data/modern-kafka-common.sh
#
[
https://issues.apache.org/jira/browse/FLINK-10600?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16665094#comment-16665094
]
ASF GitHub Bot commented on FLINK-10600:
pnowojski commented on a change in pull
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_r228504540
##
File path: flink-end-to-end-tests/test-scripts/test-data/modern-kafka-common.sh
###
[
https://issues.apache.org/jira/browse/FLINK-9697?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16665092#comment-16665092
]
ASF GitHub Bot commented on FLINK-9697:
---
yanghua commented on issue #6703: [FLINK-9
yanghua commented on issue #6703: [FLINK-9697] Provide connector for modern
Kafka
URL: https://github.com/apache/flink/pull/6703#issuecomment-433387046
hi @pnowojski see
[here](https://github.com/apache/flink/pull/6890#issuecomment-431917344).
-
[
https://issues.apache.org/jira/browse/FLINK-9697?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16665089#comment-16665089
]
ASF GitHub Bot commented on FLINK-9697:
---
pnowojski commented on issue #6703: [FLINK
pnowojski commented on issue #6703: [FLINK-9697] Provide connector for modern
Kafka
URL: https://github.com/apache/flink/pull/6703#issuecomment-433386403
@yanghua is this new `flink-connector-kafka` module being compiled/tested on
travis? I do not see the logs in travis builds and `flink-c
[
https://issues.apache.org/jira/browse/FLINK-10603?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16665088#comment-16665088
]
vinoyang commented on FLINK-10603:
--
[~pnowojski] In fact, there is no timeout added. Do
[
https://issues.apache.org/jira/browse/FLINK-10603?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16665080#comment-16665080
]
Piotr Nowojski commented on FLINK-10603:
[~yanghua] can not we decrease the time
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_r228492647
##
File path: flink-end-to-end-tests/test-scripts/test-data/modern-kafka-common.sh
#
[
https://issues.apache.org/jira/browse/FLINK-10600?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16665058#comment-16665058
]
ASF GitHub Bot commented on FLINK-10600:
yanghua commented on a change in pull r
[
https://issues.apache.org/jira/browse/FLINK-10624?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16665055#comment-16665055
]
ASF GitHub Bot commented on FLINK-10624:
yanghua commented on issue #6927: [FLIN
1 - 100 of 143 matches
Mail list logo
