[
https://issues.apache.org/jira/browse/FLINK-11295?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
BoWang updated FLINK-11295:
---
Component/s: Configuration
> Rename configuration options of queryable state from query.x to
>
OlegZhukov commented on a change in pull request #7436: [FLINK-11071][core] add
support for dynamic proxy classes resolution …
URL: https://github.com/apache/flink/pull/7436#discussion_r246564637
##
File path:
eaglewatcherwb commented on issue #7412: [FLINK-10866][Runtime] 1. Explicitly
enable qs server and proxy. 2. QS
URL: https://github.com/apache/flink/pull/7412#issuecomment-452951913
> This looks good now! I'll merge once Travis is green.
>
> @eaglewatcherwb Do you want to open a
walterddr commented on a change in pull request #7420:
[FLINK-11272][flink-yarn] Support for parsing multiple --yarnship par…
URL: https://github.com/apache/flink/pull/7420#discussion_r246631239
##
File path:
hequn8128 commented on issue #7418: FLINK-11053 Documentation - update scala
sample code for bucketing sink according
URL: https://github.com/apache/flink/pull/7418#issuecomment-452943225
@123avi Yes, I think we should keep it as `Tuple2`. It would be helpful for
users, especially for
zhijiangW commented on a change in pull request #7438: [FLINK-11282][network]
Merge StreamRecordWriter into RecordWriter
URL: https://github.com/apache/flink/pull/7438#discussion_r246626442
##
File path:
OlegZhukov commented on a change in pull request #7436: [FLINK-11071][core] add
support for dynamic proxy classes resolution …
URL: https://github.com/apache/flink/pull/7436#discussion_r246565932
##
File path:
flink-core/src/main/java/org/apache/flink/util/InstantiationUtil.java
klion26 commented on issue #7351: [FLINK-11008][State Backends,
Checkpointing]SpeedUp upload state files using multithread
URL: https://github.com/apache/flink/pull/7351#issuecomment-452938913
@azagrebin Thank you for your quick response, and all the patience comments,
I'vs addressed the
TisonKun created FLINK-11294:
Summary: Remove legacy JobInfo usage in valid tests
Key: FLINK-11294
URL: https://issues.apache.org/jira/browse/FLINK-11294
Project: Flink
Issue Type: Sub-task
eaglewatcherwb commented on issue #7436: [FLINK-11071][core] add support for
dynamic proxy classes resolution …
URL: https://github.com/apache/flink/pull/7436#issuecomment-452959381
@OlegZhukov for the `resolveProxyClass(interfaces)` calling sequence, I
think
[
https://issues.apache.org/jira/browse/FLINK-11295?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
BoWang reassigned FLINK-11295:
--
Assignee: BoWang
> Rename configuration options of queryable state from query.x to
>
[
https://issues.apache.org/jira/browse/FLINK-9700?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16738900#comment-16738900
]
leesf commented on FLINK-9700:
--
[~pnowojski], hi piotr, it has been stated in the document [kafka
eaglewatcherwb commented on a change in pull request #7436: [FLINK-11071][core]
add support for dynamic proxy classes resolution …
URL: https://github.com/apache/flink/pull/7436#discussion_r246621028
##
File path:
[
https://issues.apache.org/jira/browse/FLINK-11071?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16738745#comment-16738745
]
Oleg Zhukov commented on FLINK-11071:
-
BoWang, I don't think anyone looked into it, so you're
eaglewatcherwb commented on issue #7412: [FLINK-10866][Runtime] 1. Explicitly
enable qs server and proxy. 2. QS
URL: https://github.com/apache/flink/pull/7412#issuecomment-452950837
> @eaglewatcherwb Are both `eaglewatcherwb` and `yanyu.wb` your nicknames? I
want to squash the git commits
eaglewatcherwb commented on a change in pull request #7436: [FLINK-11071][core]
add support for dynamic proxy classes resolution …
URL: https://github.com/apache/flink/pull/7436#discussion_r246624417
##
File path:
TisonKun opened a new pull request #7447: [FLINK-11294] [test] Remove legacy
JobInfo usage in valid tests
URL: https://github.com/apache/flink/pull/7447
## What is the purpose of the change
Remove legacy JobInfo usage in valid tests,
StandaloneSubmittedJobGraphStoreTest.java and
[
https://issues.apache.org/jira/browse/FLINK-11294?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-11294:
---
Labels: pull-request-available (was: )
> Remove legacy JobInfo usage in valid tests
>
xuqianjin created FLINK-11296:
-
Summary: Support truncate in TableAPI
Key: FLINK-11296
URL: https://issues.apache.org/jira/browse/FLINK-11296
Project: Flink
Issue Type: Improvement
Affects
BoWang created FLINK-11295:
--
Summary: Rename configuration options of queryable state from
query.x to queryable-state.x
Key: FLINK-11295
URL: https://issues.apache.org/jira/browse/FLINK-11295
Project: Flink
zhijiangW commented on a change in pull request #7438: [FLINK-11282][network]
Merge StreamRecordWriter into RecordWriter
URL: https://github.com/apache/flink/pull/7438#discussion_r246626579
##
File path:
walterddr commented on a change in pull request #7356:
[FLINK-10868][flink-yarn] Enforce maximum failed TMs in YarnResourceManager
URL: https://github.com/apache/flink/pull/7356#discussion_r246633525
##
File path:
walterddr commented on a change in pull request #7356:
[FLINK-10868][flink-yarn] Enforce maximum failed TMs in YarnResourceManager
URL: https://github.com/apache/flink/pull/7356#discussion_r246634064
##
File path:
Yiqun Lin created FLINK-11297:
-
Summary: Add a doc link of jobmanager ha details
Key: FLINK-11297
URL: https://issues.apache.org/jira/browse/FLINK-11297
Project: Flink
Issue Type: Improvement
shuai.xu created FLINK-11298:
Summary: Scheduling job in the unit of concurrent groups
Key: FLINK-11298
URL: https://issues.apache.org/jira/browse/FLINK-11298
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-11256?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16739066#comment-16739066
]
Haibo Suen commented on FLINK-11256:
Okay, we'll just do a small fix.
> Referencing StreamNode
123avi edited a comment on issue #7418: FLINK-11053 Documentation - update
scala sample code for bucketing sink according
URL: https://github.com/apache/flink/pull/7418#issuecomment-452835988
I understand, nice, but that will not be a pure Scala example I think it’s
more like a
HuangZhenQiu commented on a change in pull request #7356:
[FLINK-10868][flink-yarn] Enforce maximum failed TMs in YarnResourceManager
URL: https://github.com/apache/flink/pull/7356#discussion_r246652721
##
File path:
zsq12138 opened a new pull request #7448: [hotfix][runtime] fix synchronous
snapshots completed log
URL: https://github.com/apache/flink/pull/7448
## What is the purpose of the change
The log output problems of methods snapshot in optimization
DefaultOperatorStateBackend.java are shown
walterddr commented on a change in pull request #7356:
[FLINK-10868][flink-yarn] Enforce maximum failed TMs in YarnResourceManager
URL: https://github.com/apache/flink/pull/7356#discussion_r246633969
##
File path:
walterddr commented on a change in pull request #7356:
[FLINK-10868][flink-yarn] Enforce maximum failed TMs in YarnResourceManager
URL: https://github.com/apache/flink/pull/7356#discussion_r246635359
##
File path:
walterddr commented on issue #6472: [FLINK-9294] [table] Improve type inference
for UDFs with composite parameter and/or result type
URL: https://github.com/apache/flink/pull/6472#issuecomment-452972995
@twalthr could you kindly take a look at the overall changes for this
support?
[
https://issues.apache.org/jira/browse/FLINK-11297?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16739105#comment-16739105
]
Yiqun Lin commented on FLINK-11297:
---
Anyone who can help add me to the contributor role? I will take a
[
https://issues.apache.org/jira/browse/FLINK-10433?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16739159#comment-16739159
]
shuai.xu commented on FLINK-10433:
--
Like this proposal. Autoscaling is very useful. Further more, we
123avi commented on a change in pull request #7418: FLINK-11053 Documentation -
update scala sample code for bucketing sink according
URL: https://github.com/apache/flink/pull/7418#discussion_r246645781
##
File path: docs/dev/connectors/filesystem_sink.md
##
@@ -117,11
HuangZhenQiu commented on a change in pull request #7356:
[FLINK-10868][flink-yarn] Enforce maximum failed TMs in YarnResourceManager
URL: https://github.com/apache/flink/pull/7356#discussion_r246652065
##
File path:
shuai.xu created FLINK-11299:
Summary: Decide the result partition type dynamically
Key: FLINK-11299
URL: https://issues.apache.org/jira/browse/FLINK-11299
Project: Flink
Issue Type:
bowenli86 commented on issue #7409: [FLINK-11064] [table] Setup a new
flink-table module structure
URL: https://github.com/apache/flink/pull/7409#issuecomment-452976188
@zentol agree, would be nice to split into a couple or multiple PRs if it's
not too late
[
https://issues.apache.org/jira/browse/FLINK-11299?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
shuai.xu reassigned FLINK-11299:
Assignee: shuai.xu
> Decide the result partition type dynamically
>
[
https://issues.apache.org/jira/browse/FLINK-11298?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
shuai.xu reassigned FLINK-11298:
Assignee: shuai.xu
> Scheduling job in the unit of concurrent groups
>
sunjincheng121 commented on issue #7437: [FLINK-11278] [docs] Add documentation
for TableAPI in scala-shell
URL: https://github.com/apache/flink/pull/7437#issuecomment-453000779
Merging...
This is an automated message from
dianfu commented on issue #7286: [FLINK-8739] [table] Optimize DISTINCT
aggregates to use the same distinct accumulator if possible
URL: https://github.com/apache/flink/pull/7286#issuecomment-453002680
@sunjincheng121 Thanks a lot for reviewing this PR. I have rebased the PR.
HuangZhenQiu commented on a change in pull request #7356:
[FLINK-10868][flink-yarn] Enforce maximum failed TMs in YarnResourceManager
URL: https://github.com/apache/flink/pull/7356#discussion_r246646421
##
File path:
[
https://issues.apache.org/jira/browse/FLINK-10432?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16739120#comment-16739120
]
shuai.xu commented on FLINK-10432:
--
Hi [~srichter], it's really a good idea. I think we could benefit
[
https://issues.apache.org/jira/browse/FLINK-11232?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-11232:
-
Fix Version/s: 1.8.0
1.7.2
1.6.4
> Empty Start
dawidwys commented on issue #7440: [FLINK-10591][table] Introduced functions
to return time attributes from MATCH_RECOGNIZE
URL: https://github.com/apache/flink/pull/7440#issuecomment-452620684
@twalthr I would appreciate your review, whenever you have some spare cycles
;)
zentol closed pull request #7427: [hotfix] [test] Reduce test timeout to a
reasonable value
URL: https://github.com/apache/flink/pull/7427
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
zhijiangW commented on issue #7396: [FLINK-11250][streaming] fix thread lack
when StreamTask switched from DEPLOYING to CANCELING
URL: https://github.com/apache/flink/pull/7396#issuecomment-452633376
@lamber-ken FYI, the `OutputFlusher` thread would be removed for the
motivation of #6698.
[
https://issues.apache.org/jira/browse/FLINK-11197?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-11197:
---
Labels: pull-request-available (was: )
> Improve migration test comments about how to
[
https://issues.apache.org/jira/browse/FLINK-11022?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16738013#comment-16738013
]
Chesnay Schepler commented on FLINK-11022:
--
1.6: add0a4e7dc53a24a39600e1a0bedf0c9342dffdf ->
zentol commented on issue #7348: [FLINK-11207][core] update commons-compress to
1.18
URL: https://github.com/apache/flink/pull/7348#issuecomment-452638983
(with the exception of NOTICE-binary (see
tools/releasing/collect_license_files.sh))
[
https://issues.apache.org/jira/browse/FLINK-10326?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann resolved FLINK-10326.
---
Resolution: Fixed
Fixed via
tillrohrmann commented on issue #7417: [FLINK-11268][release] Deploy multiple
flink-shaded-hadoop2 artifacts
URL: https://github.com/apache/flink/pull/7417#issuecomment-452713386
Failing test case is reported via
https://issues.apache.org/jira/browse/FLINK-11293.
[
https://issues.apache.org/jira/browse/FLINK-11293?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16738290#comment-16738290
]
Till Rohrmann commented on FLINK-11293:
---
Another instance:
[
https://issues.apache.org/jira/browse/FLINK-10550?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16738321#comment-16738321
]
Till Rohrmann commented on FLINK-10550:
---
Hi [~yanghua], are you working on this issue? If not,
[
https://issues.apache.org/jira/browse/FLINK-11288?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-11288:
---
Labels: pull-request-available (was: )
> Add separate flink-ml module for building fat jar
zentol closed pull request #7416: [FLINK-11267][release] Only create
hadoop-free binary by default
URL: https://github.com/apache/flink/pull/7416
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:
pnowojski commented on a change in pull request #7438: [FLINK-11282][network]
Merge StreamRecordWriter into RecordWriter
URL: https://github.com/apache/flink/pull/7438#discussion_r246416809
##
File path:
pnowojski commented on a change in pull request #7438: [FLINK-11282][network]
Merge StreamRecordWriter into RecordWriter
URL: https://github.com/apache/flink/pull/7438#discussion_r246427748
##
File path:
[
https://issues.apache.org/jira/browse/FLINK-10571?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-10571.
Resolution: Fixed
master: 7a9a6adf18bc6232e15e42252807793c8a94a131
> Remove support for
[
https://issues.apache.org/jira/browse/FLINK-10550?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
vinoyang reassigned FLINK-10550:
Assignee: (was: vinoyang)
> Remove LegacyYarnClusterDescriptor
>
[
https://issues.apache.org/jira/browse/FLINK-10550?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16738334#comment-16738334
]
vinoyang edited comment on FLINK-10550 at 1/9/19 3:19 PM:
--
No, I have not
zentol commented on a change in pull request #7409: [FLINK-11064] [table] Setup
a new flink-table module structure
URL: https://github.com/apache/flink/pull/7409#discussion_r246399194
##
File path: flink-table/flink-table-runtime/pom.xml
##
@@ -0,0 +1,53 @@
+
+
[
https://issues.apache.org/jira/browse/FLINK-10848?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann reassigned FLINK-10848:
-
Assignee: Till Rohrmann (was: Shuyi Chen)
> Flink's Yarn ResourceManager can allocate
[
https://issues.apache.org/jira/browse/FLINK-11286?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16738318#comment-16738318
]
vinoyang commented on FLINK-11286:
--
[~aljoscha]
I think it makes sense to allow watermarks to be
[
https://issues.apache.org/jira/browse/FLINK-11263?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann closed FLINK-11263.
-
Resolution: Duplicate
> yarn session script doesn't boot up task managers
>
[
https://issues.apache.org/jira/browse/FLINK-10550?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16738334#comment-16738334
]
vinoyang commented on FLINK-10550:
--
Yes, I have not started this issue. Done.
> Remove
zentol opened a new pull request #7444: [FLINK-11288][examples] Rework examples
to account for licensing
URL: https://github.com/apache/flink/pull/7444
## What is the purpose of the change
This PR adds separate fat-jar modules for the twitter and state-machine
examples so that we
TisonKun commented on a change in pull request #7340: [FLINK-11174]
[prometheus] Flink Metrics Prometheus label values supp…
URL: https://github.com/apache/flink/pull/7340#discussion_r246389832
##
File path:
zentol commented on issue #7416: [FLINK-11267][release] Only create hadoop-free
binary by default
URL: https://github.com/apache/flink/pull/7416#issuecomment-452704894
reversing the profile is a follow-up, see FLINK-11270.
klion26 commented on issue #7351: [FLINK-11008][State Backends,
Checkpointing]SpeedUp upload state files using multithread
URL: https://github.com/apache/flink/pull/7351#issuecomment-452707135
@azagrebin I've rebased master and addressed all the comments. I can't
fast-forward push the
pnowojski commented on a change in pull request #7438: [FLINK-11282][network]
Merge StreamRecordWriter into RecordWriter
URL: https://github.com/apache/flink/pull/7438#discussion_r246416809
##
File path:
[
https://issues.apache.org/jira/browse/FLINK-11291?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16738117#comment-16738117
]
Dian Fu commented on FLINK-11291:
-
[~dawidwys] Thanks a lot for the feedback. Yes, it will break the
zentol opened a new pull request #7442: [FLINK-11023][kafka] Add NOTICE files
URL: https://github.com/apache/flink/pull/7442
## What is the purpose of the change
This PR adds NOTICE files for the kafka connectors. This is rather
straight-forward since they only bundle
asfgit closed pull request #7434: [FLINK-11287] [rocksdb] RocksDBListState
should be using registered serializer in state meta infos
URL: https://github.com/apache/flink/pull/7434
This is a PR merged from a forked repository.
As GitHub hides the original diff on merge, it is displayed
sunjincheng121 commented on issue #7286: [FLINK-8739] [table] Optimize DISTINCT
aggregates to use the same distinct accumulator if possible
URL: https://github.com/apache/flink/pull/7286#issuecomment-452673093
@dianfu Thanks for the PR. I'll take look at the change after you rebase the
hequn8128 commented on issue #6787: [FLINK-8577][table] Implement proctime
DataStream to Table upsert conversion
URL: https://github.com/apache/flink/pull/6787#issuecomment-452674963
@pnowojski Hi, should we move on :-)
pnowojski commented on a change in pull request #6787: [FLINK-8577][table]
Implement proctime DataStream to Table upsert conversion
URL: https://github.com/apache/flink/pull/6787#discussion_r246322448
##
File path:
klion26 commented on a change in pull request #7351: [FLINK-11008][State
Backends, Checkpointing]SpeedUp upload state files using multithread
URL: https://github.com/apache/flink/pull/7351#discussion_r246367385
##
File path:
[
https://issues.apache.org/jira/browse/FLINK-11293?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-11293:
--
Issue Type: Bug (was: Improvement)
> KafkaITCase.testConcurrentProducerConsumerTopology
Till Rohrmann created FLINK-11293:
-
Summary: KafkaITCase.testConcurrentProducerConsumerTopology times
out on Travis
Key: FLINK-11293
URL: https://issues.apache.org/jira/browse/FLINK-11293
Project:
zentol commented on issue #7402: [hotfix][docs] Fulfill some empty description
in Config Doc
URL: https://github.com/apache/flink/pull/7402#issuecomment-452689975
Let's stick to the missing ones for now, I don't think anyone has time to
review such a cleanup.
[
https://issues.apache.org/jira/browse/FLINK-11187?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16738224#comment-16738224
]
Aljoscha Krettek commented on FLINK-11187:
--
After the fix, does this even need the stream
[
https://issues.apache.org/jira/browse/FLINK-11288?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16738230#comment-16738230
]
Aljoscha Krettek commented on FLINK-11288:
--
I would be in favour of keeping {{flink-diet}}
[
https://issues.apache.org/jira/browse/FLINK-11291?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16738117#comment-16738117
]
Dian Fu edited comment on FLINK-11291 at 1/9/19 11:18 AM:
--
[~dawidwys] Thanks a
[
https://issues.apache.org/jira/browse/FLINK-11291?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu closed FLINK-11291.
---
Resolution: Later
> Reorganize the package of flink-cep module
> --
klion26 commented on a change in pull request #7351: [FLINK-11008][State
Backends, Checkpointing]SpeedUp upload state files using multithread
URL: https://github.com/apache/flink/pull/7351#discussion_r246350022
##
File path:
[
https://issues.apache.org/jira/browse/FLINK-11187?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16738131#comment-16738131
]
Steve Loughran commented on FLINK-11187:
bq. As far as I can tell, this is just a transient s3
klion26 commented on a change in pull request #7351: [FLINK-11008][State
Backends, Checkpointing]SpeedUp upload state files using multithread
URL: https://github.com/apache/flink/pull/7351#discussion_r246358163
##
File path:
klion26 commented on a change in pull request #7351: [FLINK-11008][State
Backends, Checkpointing]SpeedUp upload state files using multithread
URL: https://github.com/apache/flink/pull/7351#discussion_r246358163
##
File path:
[
https://issues.apache.org/jira/browse/FLINK-11288?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16738149#comment-16738149
]
Chesnay Schepler commented on FLINK-11288:
--
Alternatively we could also just not include it in
yanghua commented on a change in pull request #6876: [FLINK-10251] Handle
oversized response messages in AkkaRpcActor
URL: https://github.com/apache/flink/pull/6876#discussion_r246359424
##
File path:
klion26 commented on issue #7351: [FLINK-11008][State Backends,
Checkpointing]SpeedUp upload state files using multithread
URL: https://github.com/apache/flink/pull/7351#issuecomment-452675203
@azagrebin Thank you for your review, I'll rebase master and address the
comments in the next
[
https://issues.apache.org/jira/browse/FLINK-11293?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16738234#comment-16738234
]
Till Rohrmann commented on FLINK-11293:
---
In the test logs I looks as if the deletion of the topic
[
https://issues.apache.org/jira/browse/FLINK-10596?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dawid Wysakowicz closed FLINK-10596.
Resolution: Fixed
Implemented in 60f8826de75bdb1294ca4cd26b2af155de62c0df
> Add access
tzulitai edited a comment on issue #7405: [FLINK-11249] FlinkKafkaProducer011
can not be migrated to FlinkKafkaProducer
URL: https://github.com/apache/flink/pull/7405#issuecomment-452623432
@yanghua @pnowojski I took a look, so from my understanding, the migration
that we're trying to
tzulitai commented on a change in pull request #7405: [FLINK-11249]
FlinkKafkaProducer011 can not be migrated to FlinkKafkaProducer
URL: https://github.com/apache/flink/pull/7405#discussion_r246305549
##
File path:
[
https://issues.apache.org/jira/browse/FLINK-11262?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-11262:
-
Affects Version/s: 1.8.0
1.6.3
1.7.1
>
[
https://issues.apache.org/jira/browse/FLINK-11262?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-11262:
-
Fix Version/s: 1.6.4
> Bump jython-standalone to 2.7.1
>
[
https://issues.apache.org/jira/browse/FLINK-11264?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-11264:
---
Labels: pull-request-available (was: )
> Fail to start scala shell
>
1 - 100 of 249 matches
Mail list logo
