xueyumusic commented on issue #7749: [FLINK-11709][sql-client] bump jline
version
URL: https://github.com/apache/flink/pull/7749#issuecomment-465898688
Hi, @zentol , Thanks for explain. I created jira and update PR
description... Could you please help to re-open this...thank you
flinkbot commented on issue #7787: [hotfix][docs] Fix typo in cep.md.
URL: https://github.com/apache/flink/pull/7787#issuecomment-465897882
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
wenhuitang opened a new pull request #7787: [hotfix][docs] Fix typo in cep.md.
URL: https://github.com/apache/flink/pull/7787
[hotfix][docs] Fix typo in cep.md.
This is an automated message from the Apache Git Service.
To
xueyu created FLINK-11709:
-
Summary: Bump jline version
Key: FLINK-11709
URL: https://issues.apache.org/jira/browse/FLINK-11709
Project: Flink
Issue Type: Improvement
Components: SQL
[
https://issues.apache.org/jira/browse/FLINK-11706?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-11706:
---
Labels: pull-request-available (was: )
> Add the SumFunction to support KeyedStream.sum
flinkbot commented on issue #7786: [FLINK-11706] Add the SumFunction to support
KeyedStream.sum
URL: https://github.com/apache/flink/pull/7786#issuecomment-465892806
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
to review your
wangpeibin713 opened a new pull request #7786: [FLINK-11706] Add the
SumFunction to support KeyedStream.sum
URL: https://github.com/apache/flink/pull/7786
## What is the purpose of the change
* The goal is to implement a KeyedStream API to sum with field which is array
klion26 edited a comment on issue #7784: [FLINK-11704][tests] Improve
AbstractCheckpointStateOutputStreamTestBase by using JUnit's Parameterized
URL: https://github.com/apache/flink/pull/7784#issuecomment-465890278
My personal Travis test
[
https://issues.apache.org/jira/browse/FLINK-11708?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kai Chen updated FLINK-11708:
-
Description:
Currently *TaskExecutor.start()* method starts by connecting to the
ResourceManager and
[
https://issues.apache.org/jira/browse/FLINK-10481?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16773755#comment-16773755
]
Congxian Qiu(klion26) commented on FLINK-10481:
---
another instance:
klion26 commented on issue #7784: [FLINK-11704][tests] Improve
AbstractCheckpointStateOutputStreamTestBase by using JUnit's Parameterized
URL: https://github.com/apache/flink/pull/7784#issuecomment-465890278
The test failed because of the unstable word count test
Travis
flinkbot commented on issue #7785: [FLINK-11707][network] Make InputGate extend
AutoCloseable
URL: https://github.com/apache/flink/pull/7785#issuecomment-465888996
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
to review your
zhijiangW opened a new pull request #7785: [FLINK-11707][network] Make
InputGate extend AutoCloseable
URL: https://github.com/apache/flink/pull/7785
## What is the purpose of the change
*This is a sub-task for refactoring the interface of `InputGate` which would
be created by
[
https://issues.apache.org/jira/browse/FLINK-11707?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-11707:
---
Labels: pull-request-available (was: )
> Make InputGate interface extend AutoCloseable
>
[
https://issues.apache.org/jira/browse/FLINK-11708?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kai Chen updated FLINK-11708:
-
Description:
Currently *TaskExecutor.start()* method starts by connecting to the
ResourceManager and
Kai Chen created FLINK-11708:
Summary: There is a big chance that a taskExecutor starts another
RegistrationTimeout after successfully registered at RM
Key: FLINK-11708
URL:
zhijiang created FLINK-11707:
Summary: Make InputGate interface extend AutoCloseable
Key: FLINK-11707
URL: https://issues.apache.org/jira/browse/FLINK-11707
Project: Flink
Issue Type: Sub-task
wangpeibin created FLINK-11706:
--
Summary: Add the SumFunction to support KeyedStream.sum with field
which is array
Key: FLINK-11706
URL: https://issues.apache.org/jira/browse/FLINK-11706
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-11068?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16773732#comment-16773732
]
sunjincheng commented on FLINK-11068:
-
Hi [~twalthr] for the current JIRA. we do not introduce Java
[
https://issues.apache.org/jira/browse/FLINK-11705?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shimin Yang updated FLINK-11705:
Issue Type: Sub-task (was: Bug)
Parent: FLINK-10392
> remove
Shimin Yang created FLINK-11705:
---
Summary: remove org.apache.flink.runtime.testingUtils.TestingUtils
Key: FLINK-11705
URL: https://issues.apache.org/jira/browse/FLINK-11705
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-11665?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16773720#comment-16773720
]
TisonKun commented on FLINK-11665:
--
[~basharaj] I've checked out your logs and agree with your
[
https://issues.apache.org/jira/browse/FLINK-11067?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16773726#comment-16773726
]
sunjincheng commented on FLINK-11067:
-
Yes，+1 for {{api.BaseTableEnvironment}} to
[
https://issues.apache.org/jira/browse/FLINK-11700?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16773722#comment-16773722
]
Yun Tang commented on FLINK-11700:
--
Does the class {{org/apache/commons/lang3/SystemUtils}} existed in
yanghua commented on issue #7764: [FLINK-11546] Add option to manually set job
ID in CLI
URL: https://github.com/apache/flink/pull/7764#issuecomment-465875192
cc @uce and @zentol
This is an automated message from the Apache
klion26 opened a new pull request #7784: [FLINK-11704][tests] Improve
AbstractCheckpointStateOutputStreamTestBase by using JUnit's Parameterized
URL: https://github.com/apache/flink/pull/7784
## What is the purpose of the change
Improve AbstractCheckpointStateOutputStreamTestBase by
[
https://issues.apache.org/jira/browse/FLINK-11704?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-11704:
---
Labels: pull-request-available (was: )
> Improve
becketqin commented on issue #7772: [FLINK-11681] [Metrics] Add a
flink-metrics-common module to combine the metric definition an…
URL: https://github.com/apache/flink/pull/7772#issuecomment-465865223
@zentol Thanks for the review. I'll start a voting thread in the mailing
list shortly.
flinkbot commented on issue #7784: [FLINK-11704][tests] Improve
AbstractCheckpointStateOutputStreamTestBase by using JUnit's Parameterized
URL: https://github.com/apache/flink/pull/7784#issuecomment-465865638
Thanks a lot for your contribution to the Apache Flink project. I'm the
Congxian Qiu(klion26) created FLINK-11704:
-
Summary: Improve AbstractCheckpointStateOutputStreamTestBase with
Parameterized
Key: FLINK-11704
URL: https://issues.apache.org/jira/browse/FLINK-11704
[
https://issues.apache.org/jira/browse/FLINK-11703?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu updated FLINK-11703:
Issue Type: New Feature (was: Task)
> Add a basic framework for Blink SQL
>
[
https://issues.apache.org/jira/browse/FLINK-11703?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu updated FLINK-11703:
Description:
We need an initial commit to add something like Table, TableEnvironment,
Expressions,
Jark Wu created FLINK-11703:
---
Summary: Add a basic framework for Blink SQL
Key: FLINK-11703
URL: https://issues.apache.org/jira/browse/FLINK-11703
Project: Flink
Issue Type: Task
Jingsong Lee created FLINK-11702:
Summary: Introduce a new table type system: InternalType
Key: FLINK-11702
URL: https://issues.apache.org/jira/browse/FLINK-11702
Project: Flink
Issue Type:
Jingsong Lee created FLINK-11701:
Summary: Introduce an abstract set of data formats
Key: FLINK-11701
URL: https://issues.apache.org/jira/browse/FLINK-11701
Project: Flink
Issue Type: New
[
https://issues.apache.org/jira/browse/FLINK-10882?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
vinoyang reassigned FLINK-10882:
Assignee: vinoyang
> Misleading job/task state for scheduled jobs
>
[
https://issues.apache.org/jira/browse/FLINK-11603?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16773627#comment-16773627
]
TisonKun commented on FLINK-11603:
--
[~till.rohrmann] We now create a separated {{ActorSystem}} for
libenchao commented on issue #7783: [FLINK-11699][JobManager] Use equals for
String compare in AbstractDispatcherResourceManagerComponentFactory
URL: https://github.com/apache/flink/pull/7783#issuecomment-465845433
There is no bug caused by this for now.
Yes, the address maybe the same
tzulitai commented on a change in pull request #7759:
[FLINK-11485][FLINK-10897] POJO state schema evolution / migrate PojoSerializer
to use new compatibility APIs
URL: https://github.com/apache/flink/pull/7759#discussion_r258764932
##
File path:
Myasuka commented on issue #7783: [FLINK-11699][JobManager] Use equals for
String compare in AbstractDispatcherResourceManagerComponentFactory
URL: https://github.com/apache/flink/pull/7783#issuecomment-465843723
Just feel curious about that had this ever caused a bug?
The possible
suyuan19 created FLINK-11700:
Summary: mvn package field
Key: FLINK-11700
URL: https://issues.apache.org/jira/browse/FLINK-11700
Project: Flink
Issue Type: Bug
Components: Build System
[
https://issues.apache.org/jira/browse/FLINK-11698?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
vinoyang updated FLINK-11698:
-
Issue Type: New Feature (was: Improvement)
> Add readMapRedTextFile API for HadoopInputs
>
flinkbot commented on issue #7783: [FLINK-11699][JobManager] Use equals for
String compare in AbstractDispatcherResourceManagerComponentFactory
URL: https://github.com/apache/flink/pull/7783#issuecomment-465839969
Thanks a lot for your contribution to the Apache Flink project. I'm the
[
https://issues.apache.org/jira/browse/FLINK-11699?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-11699:
---
Labels: pull-request-available (was: )
> Should use `String.equals()` instead of `==` for
libenchao opened a new pull request #7783: [FLINK-11699][JobManager] Use equals
for String compare in AbstractDispatcherResourceManagerComponentFactory
URL: https://github.com/apache/flink/pull/7783
## What is the purpose of the change
*Fix String compare bug*
##
[
https://issues.apache.org/jira/browse/FLINK-11697?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
vinoyang updated FLINK-11697:
-
Issue Type: New Feature (was: Improvement)
> Add readMapReduceTextFile API for HadoopInputs
>
vinoyang created FLINK-11698:
Summary: Add readMapRedTextFile API for HadoopInputs
Key: FLINK-11698
URL: https://issues.apache.org/jira/browse/FLINK-11698
Project: Flink
Issue Type: Improvement
Benchao Li created FLINK-11699:
--
Summary: Should use `String.equals()` instead of `==` for String
compares in AbstractDispatcherResourceManagerComponentFactory.getHostname()
Key: FLINK-11699
URL:
vinoyang created FLINK-11697:
Summary: Add readMapReduceTextFile API for HadoopInputs
Key: FLINK-11697
URL: https://issues.apache.org/jira/browse/FLINK-11697
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-11672?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
shengjk1 updated FLINK-11672:
-
Description: add example for streaming operators's connect such as
[
https://issues.apache.org/jira/browse/FLINK-11672?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16773601#comment-16773601
]
shengjk1 commented on FLINK-11672:
--
hi, [~StephanEwen] ,Thanks for your attention, I mean to add
tzulitai commented on a change in pull request #7759:
[FLINK-11485][FLINK-10897] POJO state schema evolution / migrate PojoSerializer
to use new compatibility APIs
URL: https://github.com/apache/flink/pull/7759#discussion_r258757851
##
File path:
tzulitai commented on a change in pull request #7759:
[FLINK-11485][FLINK-10897] POJO state schema evolution / migrate PojoSerializer
to use new compatibility APIs
URL: https://github.com/apache/flink/pull/7759#discussion_r258755544
##
File path:
tzulitai commented on a change in pull request #7759:
[FLINK-11485][FLINK-10897] POJO state schema evolution / migrate PojoSerializer
to use new compatibility APIs
URL: https://github.com/apache/flink/pull/7759#discussion_r258755169
##
File path:
tzulitai commented on a change in pull request #7759:
[FLINK-11485][FLINK-10897] POJO state schema evolution / migrate PojoSerializer
to use new compatibility APIs
URL: https://github.com/apache/flink/pull/7759#discussion_r258755115
##
File path:
tzulitai commented on a change in pull request #7759:
[FLINK-11485][FLINK-10897] POJO state schema evolution / migrate PojoSerializer
to use new compatibility APIs
URL: https://github.com/apache/flink/pull/7759#discussion_r258754989
##
File path:
tzulitai commented on a change in pull request #7759:
[FLINK-11485][FLINK-10897] POJO state schema evolution / migrate PojoSerializer
to use new compatibility APIs
URL: https://github.com/apache/flink/pull/7759#discussion_r258754885
##
File path:
tzulitai closed pull request #7759: [FLINK-11485][FLINK-10897] POJO state
schema evolution / migrate PojoSerializer to use new compatibility APIs
URL: https://github.com/apache/flink/pull/7759
This is an automated message
tzulitai opened a new pull request #7759: [FLINK-11485][FLINK-10897] POJO state
schema evolution / migrate PojoSerializer to use new compatibility APIs
URL: https://github.com/apache/flink/pull/7759
## What is the purpose of the change
This PR mainly solves FLINK-11485 (migrate
[
https://issues.apache.org/jira/browse/FLINK-10967?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16773498#comment-16773498
]
Ismael Juma commented on FLINK-10967:
-
[~StephanEwen] do you have more details on the test
[
https://issues.apache.org/jira/browse/FLINK-10967?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ismael Juma updated FLINK-10967:
Summary: Update kafka dependency to 2.1.1 (was: Update kafka dependency to
2.1.0)
> Update
[
https://issues.apache.org/jira/browse/FLINK-10967?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16773486#comment-16773486
]
Seth Wiesman edited comment on FLINK-10967 at 2/20/19 11:16 PM:
[
https://issues.apache.org/jira/browse/FLINK-10967?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16773490#comment-16773490
]
Ismael Juma commented on FLINK-10967:
-
The PR was updated to 2.1.1 earlier this week.
> Update
[
https://issues.apache.org/jira/browse/FLINK-10967?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16773486#comment-16773486
]
Seth Wiesman commented on FLINK-10967:
--
[~aljoscha] There is a bug in the kafka client version
[
https://issues.apache.org/jira/browse/FLINK-11654?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16773458#comment-16773458
]
Jürgen Kreileder edited comment on FLINK-11654 at 2/20/19 10:44 PM:
afedulov 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_r258711256
##
File path:
[
https://issues.apache.org/jira/browse/FLINK-11665?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16773470#comment-16773470
]
Joey Echeverria commented on FLINK-11665:
-
That makes sense [~basharaj]. I think that's more
[
https://issues.apache.org/jira/browse/FLINK-11654?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16773458#comment-16773458
]
Jürgen Kreileder commented on FLINK-11654:
--
I could probably provide a fix and test case for
[
https://issues.apache.org/jira/browse/FLINK-11665?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16773435#comment-16773435
]
Bashar Abdul Jawad commented on FLINK-11665:
[~Tison] I think we found what might be causing
[
https://issues.apache.org/jira/browse/FLINK-11665?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bashar Abdul Jawad updated FLINK-11665:
---
Attachment: FLINK-11665.csv
> Flink fails to remove JobGraph from ZK even though it
StefanRRichter commented on a change in pull request #7674: [FLINK-10043]
[State Backends] Refactor RocksDBKeyedStateBackend object
construction/initialization/restore code
URL: https://github.com/apache/flink/pull/7674#discussion_r258674539
##
File path:
[
https://issues.apache.org/jira/browse/FLINK-11665?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16773302#comment-16773302
]
Bashar Abdul Jawad commented on FLINK-11665:
[~fwiffo] that makes sense, [the docs for
TisonKun commented on issue #7707: [hotfix] Keep consistent implementation
style in VoidHistoryServerArc…
URL: https://github.com/apache/flink/pull/7707#issuecomment-46571
I am not sure and thus the commit message is "[hotfix] Keep consistent
implementation style **in
[
https://issues.apache.org/jira/browse/FLINK-11665?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16773282#comment-16773282
]
Joey Echeverria commented on FLINK-11665:
-
[~basharaj], I see one code path where jobs are
TisonKun commented on issue #7722: [FLINK-10569] Remove Instance usage in
FailoverRegionTest
URL: https://github.com/apache/flink/pull/7722#issuecomment-465705489
@zentol Actually I did the refactor. The only possibly problematic change is
I expose `AllocatedSlot` to `public`. Since it
[
https://issues.apache.org/jira/browse/FLINK-11678?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann closed FLINK-11678.
-
Resolution: Fixed
Fixed via
ce49a9040d255ebda3dd3b4512c9d9b00746ac12
tillrohrmann closed pull request #7769: [FLINK-11678] Clean up
ExecutionGraphCache to use ArchivedExecutionGraphs
URL: https://github.com/apache/flink/pull/7769
This is an automated message from the Apache Git Service.
To
tillrohrmann closed pull request #7756: [FLINK-11357] Make
ExecutionGraph#suspend terminate ExecutionGraph atomically
URL: https://github.com/apache/flink/pull/7756
This is an automated message from the Apache Git Service.
[
https://issues.apache.org/jira/browse/FLINK-11537?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann closed FLINK-11537.
-
Resolution: Fixed
Fixed via c9e392b53b48c8ae0b189905a9b4cf878bf741e4
> ExecutionGraph does not
Yun Tang created FLINK-11696:
Summary: [checkpoint] Avoid to send mkdir requests to DFS from
task side
Key: FLINK-11696
URL: https://issues.apache.org/jira/browse/FLINK-11696
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-11691?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stefan Richter closed FLINK-11691.
--
Resolution: Implemented
Merged in:
master: c763c35
> Introduce ClassLoader in the methods of
Myasuka commented on issue #7779: [FLINK-11691] Introduce ClassLoader in the
methods of StateBackendFactory and ConfigurableStateBackend
URL: https://github.com/apache/flink/pull/7779#issuecomment-465661294
@StefanRRichter Thanks for your quick review, already added the missing
javadocs.
StefanRRichter merged pull request #7779: [FLINK-11691] Introduce ClassLoader
in the methods of StateBackendFactory and ConfigurableStateBackend
URL: https://github.com/apache/flink/pull/7779
This is an automated message
Yun Tang created FLINK-11695:
Summary: [checkpoint] Make sharedStateDir could create
sub-directories to avoid MaxDirectoryItemsExceededException
Key: FLINK-11695
URL: https://issues.apache.org/jira/browse/FLINK-11695
[
https://issues.apache.org/jira/browse/FLINK-11692?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16773179#comment-16773179
]
Scott Mitchell commented on FLINK-11692:
I was thinking of adding a configurable proxy to the
[
https://issues.apache.org/jira/browse/FLINK-11695?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Tang updated FLINK-11695:
-
Description:
We meet this annoying problem many times when the {{sharedStateDir}} in
checkpoint path
StefanRRichter commented on issue #7779: [FLINK-11691] Introduce ClassLoader in
the methods of StateBackendFactory and ConfigurableStateBackend
URL: https://github.com/apache/flink/pull/7779#issuecomment-465656907
Overall, the changes look good. Please correct the java doc in the few
StefanRRichter commented on a change in pull request #7779: [FLINK-11691]
Introduce ClassLoader in the methods of StateBackendFactory and
ConfigurableStateBackend
URL: https://github.com/apache/flink/pull/7779#discussion_r258569847
##
File path:
StefanRRichter commented on a change in pull request #7779: [FLINK-11691]
Introduce ClassLoader in the methods of StateBackendFactory and
ConfigurableStateBackend
URL: https://github.com/apache/flink/pull/7779#discussion_r258569797
##
File path:
StefanRRichter commented on a change in pull request #7779: [FLINK-11691]
Introduce ClassLoader in the methods of StateBackendFactory and
ConfigurableStateBackend
URL: https://github.com/apache/flink/pull/7779#discussion_r258568483
##
File path:
StefanRRichter commented on a change in pull request #7779: [FLINK-11691]
Introduce ClassLoader in the methods of StateBackendFactory and
ConfigurableStateBackend
URL: https://github.com/apache/flink/pull/7779#discussion_r258568415
##
File path:
[
https://issues.apache.org/jira/browse/FLINK-11665?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16773164#comment-16773164
]
Bashar Abdul Jawad commented on FLINK-11665:
[~Tison] you're exactly right, the sequence of
aljoscha commented on issue #6615: [FLINK-8354] [flink-connectors] Add ability
to access and provider Kafka headers
URL: https://github.com/apache/flink/pull/6615#issuecomment-465647551
I created rebased PRs that have separate commits to be easier to review:
#7781 and #7782
flinkbot commented on issue #7782: Pr/6615 rebased
URL: https://github.com/apache/flink/pull/7782#issuecomment-465646310
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
aljoscha commented on issue #7781: [FLINK-8354] Add KafkaDeserializationSchema
that directly uses ConsumerRecord
URL: https://github.com/apache/flink/pull/7781#issuecomment-465646453
cc @alexeyt820
cc @azagrebin
This is
aljoscha commented on issue #7782: Pr/6615 rebased
URL: https://github.com/apache/flink/pull/7782#issuecomment-465646529
cc @alexeyt820
cc @azagrebin
This is an automated message from the Apache Git Service.
To respond to
aljoscha opened a new pull request #7782: Pr/6615 rebased
URL: https://github.com/apache/flink/pull/7782
This is a rebased and cleaned-up version of #6615 that has the Producer
changes, this also has the changes of #7781.
# What is the purpose of the change
* Add a new
[
https://issues.apache.org/jira/browse/FLINK-11672?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16773155#comment-16773155
]
Stephan Ewen commented on FLINK-11672:
--
Do you mean to add an example to directly use
flinkbot commented on issue #7781: [FLINK-8354] Add KafkaDeserializationSchema
that directly uses ConsumerRecord
URL: https://github.com/apache/flink/pull/7781#issuecomment-465645232
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
aljoscha opened a new pull request #7781: [FLINK-8354] Add
KafkaDeserializationSchema that directly uses ConsumerRecord
URL: https://github.com/apache/flink/pull/7781
This is a rebased and cleaned-up version of #6615 that only has the Consumer
changes.
# What is the purpose of the
1 - 100 of 432 matches
Mail list logo
