Mike Kaplinskiy created FLINK-19206:
---
Summary: Add an ability to set ownerReference manually in
Kubernetes
Key: FLINK-19206
URL: https://issues.apache.org/jira/browse/FLINK-19206
Project: Flink
flinkbot edited a comment on pull request #13375:
URL: https://github.com/apache/flink/pull/13375#issuecomment-691410175
## CI report:
* c10af2d6ed4136ff9a8ae30ab0841343635bf0f4 Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot commented on pull request #13375:
URL: https://github.com/apache/flink/pull/13375#issuecomment-691410175
## CI report:
* c10af2d6ed4136ff9a8ae30ab0841343635bf0f4 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot r
kezhuw commented on pull request #13375:
URL: https://github.com/apache/flink/pull/13375#issuecomment-691409015
@flinkbot attention @tillrohrmann
This is an automated message from the Apache Git Service.
To respond to the me
flinkbot commented on pull request #13375:
URL: https://github.com/apache/flink/pull/13375#issuecomment-691408906
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
to review your pull request. We will use this comment to track the pro
kezhuw opened a new pull request #13375:
URL: https://github.com/apache/flink/pull/13375
## What is the purpose of the change
Fix unstable `SafetyNetCloseableRegistryTest.testClose`.
## Brief change log
- Add method `SafetyNetCloseableRegistry.closeInternally` to return reaper
[
https://issues.apache.org/jira/browse/FLINK-15467?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu updated FLINK-15467:
Fix Version/s: (was: 1.11.2)
1.11.3
> Should wait for the end of the source thread
flinkbot edited a comment on pull request #13373:
URL: https://github.com/apache/flink/pull/13373#issuecomment-691085636
## CI report:
* 8396f34387c87703171a06563b15e0f0b2a53699 UNKNOWN
* bab621c4f92387eef5bf0101a5b687e45c479f80 Azure:
[SUCCESS](https://dev.azure.com/apache-fl
flinkbot edited a comment on pull request #13373:
URL: https://github.com/apache/flink/pull/13373#issuecomment-691085636
## CI report:
* 8396f34387c87703171a06563b15e0f0b2a53699 UNKNOWN
* 0999b2c052be034e7de38f03a13840292a4b497f Azure:
[FAILURE](https://dev.azure.com/apache-fl
flinkbot edited a comment on pull request #13360:
URL: https://github.com/apache/flink/pull/13360#issuecomment-689414065
## CI report:
* 11060ad5a395f536d865bedc2e3034cfa950bc72 Azure:
[SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot edited a comment on pull request #13373:
URL: https://github.com/apache/flink/pull/13373#issuecomment-691085636
## CI report:
* 8396f34387c87703171a06563b15e0f0b2a53699 UNKNOWN
* 0999b2c052be034e7de38f03a13840292a4b497f Azure:
[FAILURE](https://dev.azure.com/apache-fl
flinkbot edited a comment on pull request #13373:
URL: https://github.com/apache/flink/pull/13373#issuecomment-691085636
## CI report:
* 8396f34387c87703171a06563b15e0f0b2a53699 UNKNOWN
* 0999b2c052be034e7de38f03a13840292a4b497f Azure:
[FAILURE](https://dev.azure.com/apache-fl
flinkbot edited a comment on pull request #13373:
URL: https://github.com/apache/flink/pull/13373#issuecomment-691085636
## CI report:
* 8396f34387c87703171a06563b15e0f0b2a53699 UNKNOWN
* 2cb9ec4b5e8daf8f4333acb2a8c09a8f2b1cfdb8 Azure:
[SUCCESS](https://dev.azure.com/apache-fl
flinkbot edited a comment on pull request #13373:
URL: https://github.com/apache/flink/pull/13373#issuecomment-691085636
## CI report:
* 8396f34387c87703171a06563b15e0f0b2a53699 UNKNOWN
* 2cb9ec4b5e8daf8f4333acb2a8c09a8f2b1cfdb8 Azure:
[SUCCESS](https://dev.azure.com/apache-fl
dawidwys commented on pull request #13373:
URL: https://github.com/apache/flink/pull/13373#issuecomment-691240195
Thank you for the review. I hope I addressed all your comments.
This is an automated message from the Apache Gi
dawidwys commented on a change in pull request #13373:
URL: https://github.com/apache/flink/pull/13373#discussion_r487208716
##
File path:
flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/typeutils/AvroSchemaConverter.java
##
@@ -272,11 +276,14 @@ private s
flinkbot edited a comment on pull request #13374:
URL: https://github.com/apache/flink/pull/13374#issuecomment-691175789
## CI report:
* 858ce532bd1800cb354ae304296db67764aad433 Travis:
[FAILURE](https://travis-ci.com/github/flink-ci/flink/builds/183959923)
Bot comman
[
https://issues.apache.org/jira/browse/FLINK-18980?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger closed FLINK-18980.
--
Resolution: Fixed
> "Avro Confluent Schema Registry nightly end-to-end test" hangs
> -
flinkbot edited a comment on pull request #13374:
URL: https://github.com/apache/flink/pull/13374#issuecomment-691175789
## CI report:
* 8f845f98d1eed0bb8e852198085b5bb21629d984 Travis:
[SUCCESS](https://travis-ci.com/github/flink-ci/flink/builds/183939166)
* 858ce532bd1800cb
flinkbot edited a comment on pull request #13373:
URL: https://github.com/apache/flink/pull/13373#issuecomment-691085636
## CI report:
* df666257b536825e8cb4e3497349079e9a35c51e Azure:
[CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul
flinkbot edited a comment on pull request #13372:
URL: https://github.com/apache/flink/pull/13372#issuecomment-691076967
## CI report:
* 9ddd54fa12be8d0f43e16b96d01725005d8c145e Azure:
[SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
[
https://issues.apache.org/jira/browse/FLINK-18447?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-18447.
> Add 'flink-connector-base' to 'flink-dist'
> --
>
>
[
https://issues.apache.org/jira/browse/FLINK-18447?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-18447.
--
Release Note:
The 'flink-connector-base' module is now part of 'flink-dist' and is always in
[
https://issues.apache.org/jira/browse/FLINK-19205?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-19205.
> SourceReaderContext should give access to Configuration and Hostbame
> -
[
https://issues.apache.org/jira/browse/FLINK-19162?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-19162.
> Allow Split Reader based sources to reuse record batches
>
[
https://issues.apache.org/jira/browse/FLINK-19205?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-19205.
--
Resolution: Fixed
Fixed in 1.12 via 428fbbad85379f71a9fbf1a1ab3e3dcfa9006436
> SourceReaderCo
[
https://issues.apache.org/jira/browse/FLINK-19162?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-19162.
--
Resolution: Fixed
Fixed in 1.12 via e3d273de822b085183d09b275a445879ff94b350
> Allow Split Re
[
https://issues.apache.org/jira/browse/FLINK-18680?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-18680.
> Improve RecordsWithSplitIds API
> ---
>
> Key: FLINK-186
[
https://issues.apache.org/jira/browse/FLINK-18680?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-18680.
--
Assignee: Stephan Ewen (was: Jiangjie Qin)
Resolution: Fixed
Fixed in 1.12 via f42a3ebc
pnowojski commented on a change in pull request #13228:
URL: https://github.com/apache/flink/pull/13228#discussion_r487038327
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/PipelinedSubpartition.java
##
@@ -167,23 +171,46 @@ private boo
Stephan Ewen created FLINK-19205:
Summary: SourceReaderContext should give access to Configuration
and Hostbame
Key: FLINK-19205
URL: https://issues.apache.org/jira/browse/FLINK-19205
Project: Flink
flinkbot edited a comment on pull request #13360:
URL: https://github.com/apache/flink/pull/13360#issuecomment-689414065
## CI report:
* 52e820f37e453f7f083d7c646ad6c9ca5e9d30da Azure:
[SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot edited a comment on pull request #13374:
URL: https://github.com/apache/flink/pull/13374#issuecomment-691175789
## CI report:
* 8f845f98d1eed0bb8e852198085b5bb21629d984 Travis:
[PENDING](https://travis-ci.com/github/flink-ci/flink/builds/183939166)
Bot comman
flinkbot edited a comment on pull request #13360:
URL: https://github.com/apache/flink/pull/13360#issuecomment-689414065
## CI report:
* 52e820f37e453f7f083d7c646ad6c9ca5e9d30da Azure:
[SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot edited a comment on pull request #13228:
URL: https://github.com/apache/flink/pull/13228#issuecomment-679099456
## CI report:
* d141f10ef060063162dc073b1cd66729f5f75a3b UNKNOWN
* 89b0550c7b223f304b67a6f64dfc4252509eb76e UNKNOWN
* fa3e495b6ba201769d908adea420e4944ddd
aljoscha commented on pull request #13360:
URL: https://github.com/apache/flink/pull/13360#issuecomment-691176913
Thanks for the review! I pushed a commit that should address all comments.
This is an automated message from th
flinkbot commented on pull request #13374:
URL: https://github.com/apache/flink/pull/13374#issuecomment-691175789
## CI report:
* 8f845f98d1eed0bb8e852198085b5bb21629d984 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot r
[
https://issues.apache.org/jira/browse/FLINK-19109?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17194350#comment-17194350
]
Arvid Heise edited comment on FLINK-19109 at 9/11/20, 3:50 PM:
---
[
https://issues.apache.org/jira/browse/FLINK-19109?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17194350#comment-17194350
]
Arvid Heise commented on FLINK-19109:
-
{{Added a PR. However, I'm quite positive tha
[
https://issues.apache.org/jira/browse/FLINK-19203?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Seth Wiesman resolved FLINK-19203.
--
Resolution: Fixed
> Use Flink-*-scala2.12 variants for StateFun
>
[
https://issues.apache.org/jira/browse/FLINK-19203?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17194347#comment-17194347
]
Seth Wiesman commented on FLINK-19203:
--
fixed in 038560a3c88718137544dc014528e41112
sjwiesman closed pull request #149:
URL: https://github.com/apache/flink-statefun/pull/149
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to
flinkbot commented on pull request #13374:
URL: https://github.com/apache/flink/pull/13374#issuecomment-691168441
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
to review your pull request. We will use this comment to track the pro
AHeise opened a new pull request #13374:
URL: https://github.com/apache/flink/pull/13374
## What is the purpose of the change
ProcessingTimeCallbacks cannot be guaranteed to be invoked in a timely
manner (or at all) if ContinuousFileReaderOperator is yielding.
aljoscha commented on a change in pull request #13360:
URL: https://github.com/apache/flink/pull/13360#discussion_r487121698
##
File path: docs/dev/connectors/kafka.md
##
@@ -405,8 +385,7 @@ Consider setting appropriate [idelness timeouts]({{
site.baseurl }}/dev/event_ti
#
sjwiesman commented on a change in pull request #147:
URL: https://github.com/apache/flink-statefun/pull/147#discussion_r487120168
##
File path: docs/sdk/java.md
##
@@ -364,6 +364,43 @@ PersistedTable table =
PersistedTable.of("my-table", String.cla
PersistedAppendingBuffer b
[
https://issues.apache.org/jira/browse/FLINK-18830?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17194313#comment-17194313
]
liupengcheng commented on FLINK-18830:
--
Hi, [~aljoscha] It's about both of them. I'
aljoscha commented on pull request #13343:
URL: https://github.com/apache/flink/pull/13343#issuecomment-691149771
This looks good to merge! I think we can address @gaoyunhaii's comment as a
follow-up, right?
This is an autom
flinkbot edited a comment on pull request #13228:
URL: https://github.com/apache/flink/pull/13228#issuecomment-679099456
## CI report:
* d141f10ef060063162dc073b1cd66729f5f75a3b UNKNOWN
* 89b0550c7b223f304b67a6f64dfc4252509eb76e UNKNOWN
* a6a2d36afcce1758e885f0751359ccf035ae
zhuzhurk edited a comment on pull request #378:
URL: https://github.com/apache/flink-web/pull/378#issuecomment-691136281
Just ignore my last comment.
I checked the contribution doc again and find I was wrong.
The commit for rebuilt web files are not needed in the PR.
The committer
zhuzhurk commented on pull request #378:
URL: https://github.com/apache/flink-web/pull/378#issuecomment-691136281
Checked the contribution doc again and I think I was wrong.
The commit for rebuilt web files are not needed in the PR.
The committer should do it when merging the pull req
flinkbot edited a comment on pull request #13373:
URL: https://github.com/apache/flink/pull/13373#issuecomment-691085636
## CI report:
* df666257b536825e8cb4e3497349079e9a35c51e Azure:
[PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot edited a comment on pull request #13228:
URL: https://github.com/apache/flink/pull/13228#issuecomment-679099456
## CI report:
* d141f10ef060063162dc073b1cd66729f5f75a3b UNKNOWN
* 89b0550c7b223f304b67a6f64dfc4252509eb76e UNKNOWN
* a6a2d36afcce1758e885f0751359ccf035ae
zhuzhurk commented on pull request #378:
URL: https://github.com/apache/flink-web/pull/378#issuecomment-691131606
Hi @xintongsong , another commit is needed which contains the rebuilt web
files.
This is an automated message
[
https://issues.apache.org/jira/browse/FLINK-17016?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu closed FLINK-17016.
---
Resolution: Fixed
Done via:
d918cc3e660d9cdbb84a175c8bb93ce6a14e38dc
4df2295f54709f4292888a3b4fcbb019dd4d790
zhuzhurk merged pull request #13284:
URL: https://github.com/apache/flink/pull/13284
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to
zhuzhurk commented on pull request #13284:
URL: https://github.com/apache/flink/pull/13284#issuecomment-691124551
Thanks for reviewing! @azagrebin
Merging.
This is an automated message from the Apache Git Service.
To resp
twalthr commented on a change in pull request #13373:
URL: https://github.com/apache/flink/pull/13373#discussion_r487065893
##
File path: flink-formats/pom.xml
##
@@ -81,6 +81,7 @@ under the License.
flink-sql-orc
flinkbot edited a comment on pull request #13373:
URL: https://github.com/apache/flink/pull/13373#issuecomment-691085636
## CI report:
* df666257b536825e8cb4e3497349079e9a35c51e Azure:
[PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
twalthr commented on a change in pull request #13373:
URL: https://github.com/apache/flink/pull/13373#discussion_r487046691
##
File path:
flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AvroRowDeserializationSchema.java
##
@@ -340,10 +357,22 @@ private Tim
flinkbot edited a comment on pull request #13373:
URL: https://github.com/apache/flink/pull/13373#issuecomment-691085636
## CI report:
* df666257b536825e8cb4e3497349079e9a35c51e Azure:
[PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
[
https://issues.apache.org/jira/browse/FLINK-9974?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17194267#comment-17194267
]
Matthias commented on FLINK-9974:
-
[~NicoK] Is there a way to reproduce this issue?
> "I
dawidwys commented on a change in pull request #13373:
URL: https://github.com/apache/flink/pull/13373#discussion_r487038283
##
File path:
flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AvroRowDeserializationSchema.java
##
@@ -218,7 +231,7 @@ private Obje
dawidwys commented on a change in pull request #13373:
URL: https://github.com/apache/flink/pull/13373#discussion_r487035872
##
File path:
flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/PojoComparator.java
##
@@ -176,14 +181,25 @@ public void getFlatCompa
twalthr commented on a change in pull request #13373:
URL: https://github.com/apache/flink/pull/13373#discussion_r487032180
##
File path:
flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AvroRowDeserializationSchema.java
##
@@ -218,7 +231,7 @@ private Objec
[
https://issues.apache.org/jira/browse/FLINK-7894?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17194263#comment-17194263
]
Matthias commented on FLINK-7894:
-
[~chesnay] Does these feature is still valuable? Shoul
flinkbot commented on pull request #13373:
URL: https://github.com/apache/flink/pull/13373#issuecomment-691085636
## CI report:
* df666257b536825e8cb4e3497349079e9a35c51e UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot r
flinkbot edited a comment on pull request #13372:
URL: https://github.com/apache/flink/pull/13372#issuecomment-691076967
## CI report:
* 9ddd54fa12be8d0f43e16b96d01725005d8c145e Azure:
[PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
twalthr commented on a change in pull request #13373:
URL: https://github.com/apache/flink/pull/13373#discussion_r487029161
##
File path:
flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/PojoComparator.java
##
@@ -176,14 +181,25 @@ public void getFlatCompar
dawidwys commented on a change in pull request #13373:
URL: https://github.com/apache/flink/pull/13373#discussion_r487027309
##
File path:
flink-formats/flink-avro/src/test/java/org/apache/flink/table/runtime/batch/AvroTypesITCase.java
##
@@ -58,7 +55,7 @@
@RunWith(Parameteri
dawidwys commented on a change in pull request #13373:
URL: https://github.com/apache/flink/pull/13373#discussion_r487027309
##
File path:
flink-formats/flink-avro/src/test/java/org/apache/flink/table/runtime/batch/AvroTypesITCase.java
##
@@ -58,7 +55,7 @@
@RunWith(Parameteri
flinkbot commented on pull request #13373:
URL: https://github.com/apache/flink/pull/13373#issuecomment-691077759
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
to review your pull request. We will use this comment to track the pro
[
https://issues.apache.org/jira/browse/FLINK-7355?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17194256#comment-17194256
]
Matthias commented on FLINK-7355:
-
We looked at the issue as part of the Engine team's ba
[
https://issues.apache.org/jira/browse/FLINK-7355?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias updated FLINK-7355:
Affects Version/s: 1.12.0
> ignored (manual) tests in YARNSessionFIFOITCase do not run anymore
> --
[
https://issues.apache.org/jira/browse/FLINK-7355?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias updated FLINK-7355:
Labels: starter (was: )
> ignored (manual) tests in YARNSessionFIFOITCase do not run anymore
> ---
flinkbot commented on pull request #13372:
URL: https://github.com/apache/flink/pull/13372#issuecomment-691076967
## CI report:
* 9ddd54fa12be8d0f43e16b96d01725005d8c145e UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot r
[
https://issues.apache.org/jira/browse/FLINK-4755?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias closed FLINK-4755.
---
Resolution: Won't Fix
The ID system was improved as part of
[FLIP-118.|https://cwiki.apache.org/confluence/p
dawidwys opened a new pull request #13373:
URL: https://github.com/apache/flink/pull/13373
## What is the purpose of the change
This PR upgrades the default version of avro that Flink will use. It makes
Flink no longer in sync with the version of avro used in Hadoop. Users might
nee
[
https://issues.apache.org/jira/browse/FLINK-4254?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias closed FLINK-4254.
---
Resolution: Won't Fix
We discussed this issue in the Engine team's backlog grooming: We decided to
close it
flinkbot commented on pull request #13372:
URL: https://github.com/apache/flink/pull/13372#issuecomment-691067862
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
to review your pull request. We will use this comment to track the pro
[
https://issues.apache.org/jira/browse/FLINK-19187?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-19187:
---
Labels: pull-request-available (was: )
> Add a new basic Table API example
> --
twalthr opened a new pull request #13372:
URL: https://github.com/apache/flink/pull/13372
## What is the purpose of the change
Example for getting started with the Table & SQL API in Scala.
## Brief change log
The example shows how to create, transform, and query a table
[
https://issues.apache.org/jira/browse/FLINK-19176?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17194243#comment-17194243
]
Galen Warren commented on FLINK-19176:
--
Thanks for the quick reply! A few comments/
flinkbot edited a comment on pull request #13344:
URL: https://github.com/apache/flink/pull/13344#issuecomment-688495541
## CI report:
* 15a81e82a4a42cd255baad4ffd3e7e20343b5389 UNKNOWN
* f92fc8cc4259c40dfc7a4a4847a9e41d00e772ae Azure:
[FAILURE](https://dev.azure.com/apache-fl
[
https://issues.apache.org/jira/browse/FLINK-19204?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther updated FLINK-19204:
-
Affects Version/s: 1.11.1
> Improve warning during a Table.execute()
> -
[
https://issues.apache.org/jira/browse/FLINK-19204?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17194238#comment-17194238
]
Timo Walther commented on FLINK-19204:
--
CC [~godfreyhe]
Is there anything we can do
Timo Walther created FLINK-19204:
Summary: Improve warning during a Table.execute()
Key: FLINK-19204
URL: https://issues.apache.org/jira/browse/FLINK-19204
Project: Flink
Issue Type: Improvem
flinkbot edited a comment on pull request #13344:
URL: https://github.com/apache/flink/pull/13344#issuecomment-688495541
## CI report:
* 15a81e82a4a42cd255baad4ffd3e7e20343b5389 UNKNOWN
* e563be1c3fe203184c2f78bd01ed23d35e83198c Azure:
[FAILURE](https://dev.azure.com/apache-fl
[
https://issues.apache.org/jira/browse/FLINK-19195?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17194235#comment-17194235
]
Robert Metzger commented on FLINK-19195:
Thanks a lot for opening this ticket. I
[
https://issues.apache.org/jira/browse/FLINK-16961?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17194231#comment-17194231
]
Robert Metzger commented on FLINK-16961:
Why was this dependency not upgraded?
[
https://issues.apache.org/jira/browse/FLINK-19203?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-19203:
---
Labels: pull-request-available (was: )
> Use Flink-*-scala2.12 variants for StateFun
>
igalshilman opened a new pull request #149:
URL: https://github.com/apache/flink-statefun/pull/149
This PR uses Scala 2.12 variants of the various Flink artifacts.
It was tested by running the e2e tests, executing few of the examples, and
running StateFun on Kubernetes.
---
flinkbot edited a comment on pull request #13344:
URL: https://github.com/apache/flink/pull/13344#issuecomment-688495541
## CI report:
* 15a81e82a4a42cd255baad4ffd3e7e20343b5389 UNKNOWN
* e563be1c3fe203184c2f78bd01ed23d35e83198c Azure:
[FAILURE](https://dev.azure.com/apache-fl
Igal Shilman created FLINK-19203:
Summary: Use Flink-*-scala2.12 variants for StateFun
Key: FLINK-19203
URL: https://issues.apache.org/jira/browse/FLINK-19203
Project: Flink
Issue Type: Impro
[
https://issues.apache.org/jira/browse/FLINK-19176?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17194219#comment-17194219
]
Igal Shilman commented on FLINK-19176:
--
Hi [~galenwarren], welcome to project!
Ind
[
https://issues.apache.org/jira/browse/FLINK-8357?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17194218#comment-17194218
]
Robert Metzger commented on FLINK-8357:
---
Thanks a lot for working on this!
For the
dawidwys commented on a change in pull request #13360:
URL: https://github.com/apache/flink/pull/13360#discussion_r486946393
##
File path: docs/dev/connectors/kafka.md
##
@@ -466,12 +445,12 @@ Through the producer record you can:
### Kafka Producers and Fault Tolerance
-
-
morsapaes commented on a change in pull request #16:
URL: https://github.com/apache/flink-playgrounds/pull/16#discussion_r486966065
##
File path: pyflink-walkthrough/payment_msg_proccessing.py
##
@@ -0,0 +1,93 @@
+
[
https://issues.apache.org/jira/browse/FLINK-19200?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
leslieyuan updated FLINK-19200:
---
Description:
Now i use Flink1.10.0, i found that:
time = "2020-09-11 13:14:29.153"
UNIX_TIMESTAMP(
[
https://issues.apache.org/jira/browse/FLINK-6900?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17194197#comment-17194197
]
Andrey Zagrebin commented on FLINK-6900:
ping [~chesnay]
> Limit size of indiivu
1 - 100 of 130 matches
Mail list logo
