[
https://issues.apache.org/jira/browse/FLINK-10630?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stefan Richter closed FLINK-10630.
--
Resolution: Duplicate
> Update migration tests for Flink 1.6
> ---
[
https://issues.apache.org/jira/browse/FLINK-10356?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16660371#comment-16660371
]
ASF GitHub Bot commented on FLINK-10356:
NicoK commented on issue #6705: [FLINK-
NicoK commented on issue #6705: [FLINK-10356][network] add sanity checks to
SpillingAdaptiveSpanningRecordDeserializer
URL: https://github.com/apache/flink/pull/6705#issuecomment-432180676
thanks again @zhijiangW - I updated the tests accordingly.
Regarding performance: there may be
tillrohrmann commented on a change in pull request #6899: [FLINK-10637] Use
MiniClusterResource for tests in flink-runtime
URL: https://github.com/apache/flink/pull/6899#discussion_r227316017
##
File path:
flink-tests/src/test/java/org/apache/flink/test/checkpointing/EventTimeWindo
[
https://issues.apache.org/jira/browse/FLINK-10627?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Andrey Zagrebin reassigned FLINK-10627:
---
Assignee: Andrey Zagrebin
> Extend test_streaming_file_sink to test S3 writer
> ---
Stefan Richter created FLINK-10652:
--
Summary: Update StatefulJobWBroadcastStateMigrationITCase for 1.6
Key: FLINK-10652
URL: https://issues.apache.org/jira/browse/FLINK-10652
Project: Flink
Stefan Richter created FLINK-10651:
--
Summary: Update CEPMigrationTest for 1.6
Key: FLINK-10651
URL: https://issues.apache.org/jira/browse/FLINK-10651
Project: Flink
Issue Type: Sub-task
Stefan Richter created FLINK-10650:
--
Summary: Update BucketingSinkMigrationTest for 1.6
Key: FLINK-10650
URL: https://issues.apache.org/jira/browse/FLINK-10650
Project: Flink
Issue Type: Sub
Stefan Richter created FLINK-10649:
--
Summary: Update FlinkKafkaConsumerBaseMigrationTest for 1.6
Key: FLINK-10649
URL: https://issues.apache.org/jira/browse/FLINK-10649
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-10637?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16660361#comment-16660361
]
ASF GitHub Bot commented on FLINK-10637:
tillrohrmann commented on a change in p
Stefan Richter created FLINK-10648:
--
Summary: Update ContinuousFileProcessingMigrationTest for 1.6
Key: FLINK-10648
URL: https://issues.apache.org/jira/browse/FLINK-10648
Project: Flink
Issu
tillrohrmann commented on a change in pull request #6899: [FLINK-10637] Use
MiniClusterResource for tests in flink-runtime
URL: https://github.com/apache/flink/pull/6899#discussion_r227312621
##
File path:
flink-tests/src/test/java/org/apache/flink/test/checkpointing/EventTimeWindo
Stefan Richter created FLINK-10647:
--
Summary: Update WindowOperatorMigrationTest for 1.6
Key: FLINK-10647
URL: https://issues.apache.org/jira/browse/FLINK-10647
Project: Flink
Issue Type: Su
Stefan Richter created FLINK-10646:
--
Summary: Update AbstractOperatorRestoreTestBase for 1.6
Key: FLINK-10646
URL: https://issues.apache.org/jira/browse/FLINK-10646
Project: Flink
Issue Type
Stefan Richter created FLINK-10645:
--
Summary: Update StatefulJobSavepointMigrationITCase for 1.6
Key: FLINK-10645
URL: https://issues.apache.org/jira/browse/FLINK-10645
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-10630?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stefan Richter reassigned FLINK-10630:
--
Assignee: Stefan Richter (was: vinoyang)
> Update migration tests for Flink 1.6
> --
[
https://issues.apache.org/jira/browse/FLINK-10637?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16660352#comment-16660352
]
ASF GitHub Bot commented on FLINK-10637:
tillrohrmann commented on a change in p
tillrohrmann commented on a change in pull request #6899: [FLINK-10637] Use
MiniClusterResource for tests in flink-runtime
URL: https://github.com/apache/flink/pull/6899#discussion_r227308881
##
File path:
flink-tests/src/test/java/org/apache/flink/test/streaming/runtime/BigUserPro
[
https://issues.apache.org/jira/browse/FLINK-10356?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16660342#comment-16660342
]
ASF GitHub Bot commented on FLINK-10356:
NicoK commented on a change in pull req
NicoK commented on a change in pull request #6705: [FLINK-10356][network] add
sanity checks to SpillingAdaptiveSpanningRecordDeserializer
URL: https://github.com/apache/flink/pull/6705#discussion_r227307487
##
File path:
flink-runtime/src/test/java/org/apache/flink/runtime/io/netwo
[
https://issues.apache.org/jira/browse/FLINK-10637?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16660335#comment-16660335
]
ASF GitHub Bot commented on FLINK-10637:
tillrohrmann commented on a change in p
[
https://issues.apache.org/jira/browse/FLINK-10637?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16660332#comment-16660332
]
ASF GitHub Bot commented on FLINK-10637:
tillrohrmann commented on a change in p
tillrohrmann commented on a change in pull request #6899: [FLINK-10637] Use
MiniClusterResource for tests in flink-runtime
URL: https://github.com/apache/flink/pull/6899#discussion_r227303748
##
File path:
flink-runtime-web/src/test/java/org/apache/flink/runtime/webmonitor/WebFront
tillrohrmann commented on a change in pull request #6899: [FLINK-10637] Use
MiniClusterResource for tests in flink-runtime
URL: https://github.com/apache/flink/pull/6899#discussion_r227303857
##
File path:
flink-runtime/src/test/java/org/apache/flink/runtime/taskmanager/TaskCancelA
[
https://issues.apache.org/jira/browse/FLINK-8880?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther resolved FLINK-8880.
-
Resolution: Fixed
Fix Version/s: 1.7.0
This issues has mostly been implemented as part of
[
https://issues.apache.org/jira/browse/FLINK-10095?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16660309#comment-16660309
]
aitozi commented on FLINK-10095:
Ok, I get it , thanks [~azagrebin]
> Change the serial
[
https://issues.apache.org/jira/browse/FLINK-7811?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16660304#comment-16660304
]
ASF GitHub Bot commented on FLINK-7811:
---
aljoscha commented on issue #6894: [FLINK-
aljoscha commented on issue #6894: [FLINK-7811] Add support for Scala 2.12
URL: https://github.com/apache/flink/pull/6894#issuecomment-432160532
@zentol I think I addressed all your comments except the json, avro, and
sql-client comments.
---
[
https://issues.apache.org/jira/browse/FLINK-9737?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16660300#comment-16660300
]
Timo Walther commented on FLINK-9737:
-
Fixed in 1.7.0: 6c9193ff288919a7ac8dfdb5773b92
[
https://issues.apache.org/jira/browse/FLINK-9737?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16660293#comment-16660293
]
ASF GitHub Bot commented on FLINK-9737:
---
twalthr commented on issue #6897: [FLINK-9
[
https://issues.apache.org/jira/browse/FLINK-10356?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16660296#comment-16660296
]
ASF GitHub Bot commented on FLINK-10356:
zhijiangW commented on a change in pull
[
https://issues.apache.org/jira/browse/FLINK-7811?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16660295#comment-16660295
]
ASF GitHub Bot commented on FLINK-7811:
---
aljoscha commented on a change in pull req
[
https://issues.apache.org/jira/browse/FLINK-10601?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16660294#comment-16660294
]
ASF GitHub Bot commented on FLINK-10601:
link3280 commented on issue #6887: [FLI
aljoscha commented on a change in pull request #6894: [FLINK-7811] Add support
for Scala 2.12
URL: https://github.com/apache/flink/pull/6894#discussion_r227290801
##
File path: pom.xml
##
@@ -613,6 +619,61 @@ under the License.
+
+
link3280 commented on issue #6887: [FLINK-10601] [YARN] Make user home dir
consistent with Flink default filesystem
URL: https://github.com/apache/flink/pull/6887#issuecomment-432158551
@StefanRRichter would you please have a look at this PR? Should be a quick
one. Thanks!
---
aljoscha commented on a change in pull request #6894: [FLINK-7811] Add support
for Scala 2.12
URL: https://github.com/apache/flink/pull/6894#discussion_r227290425
##
File path: tools/releasing/deploy_staging_jars.sh
##
@@ -41,5 +41,10 @@ cd ..
echo "Deploying to repositor
zhijiangW commented on a change in pull request #6705: [FLINK-10356][network]
add sanity checks to SpillingAdaptiveSpanningRecordDeserializer
URL: https://github.com/apache/flink/pull/6705#discussion_r227290793
##
File path:
flink-tests/src/test/java/org/apache/flink/test/misc/Cust
twalthr commented on issue #6897: [FLINK-9737] [FLINK-8880] [sql-client]
Support defining temporal tables in environment files
URL: https://github.com/apache/flink/pull/6897#issuecomment-432158343
Thanks for the feedback @dawidwys and @pnowojski. I addressed your comments
and will merge th
[
https://issues.apache.org/jira/browse/FLINK-7811?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16660292#comment-16660292
]
ASF GitHub Bot commented on FLINK-7811:
---
aljoscha commented on a change in pull req
[
https://issues.apache.org/jira/browse/FLINK-9878?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16660287#comment-16660287
]
ASF GitHub Bot commented on FLINK-9878:
---
NicoK closed pull request #6838: [FLINK-98
NicoK closed pull request #6838: [FLINK-9878][network][ssl] add more low-level
ssl options
URL: https://github.com/apache/flink/pull/6838
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-10356?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16660286#comment-16660286
]
ASF GitHub Bot commented on FLINK-10356:
zhijiangW commented on a change in pull
zhijiangW commented on a change in pull request #6705: [FLINK-10356][network]
add sanity checks to SpillingAdaptiveSpanningRecordDeserializer
URL: https://github.com/apache/flink/pull/6705#discussion_r227287614
##
File path:
flink-runtime/src/test/java/org/apache/flink/runtime/io/n
[
https://issues.apache.org/jira/browse/FLINK-10356?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16660283#comment-16660283
]
ASF GitHub Bot commented on FLINK-10356:
zhijiangW commented on a change in pull
[
https://issues.apache.org/jira/browse/FLINK-10356?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16660282#comment-16660282
]
ASF GitHub Bot commented on FLINK-10356:
zhijiangW commented on a change in pull
zhijiangW commented on a change in pull request #6705: [FLINK-10356][network]
add sanity checks to SpillingAdaptiveSpanningRecordDeserializer
URL: https://github.com/apache/flink/pull/6705#discussion_r227286887
##
File path:
flink-runtime/src/test/java/org/apache/flink/runtime/io/n
zhijiangW commented on a change in pull request #6705: [FLINK-10356][network]
add sanity checks to SpillingAdaptiveSpanningRecordDeserializer
URL: https://github.com/apache/flink/pull/6705#discussion_r227286509
##
File path:
flink-runtime/src/test/java/org/apache/flink/runtime/io/n
[
https://issues.apache.org/jira/browse/FLINK-9975?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Nico Kruber resolved FLINK-9975.
Resolution: Fixed
Release Note: We now also relocate Hadoop's Netty dependency from
{{io.nett
[
https://issues.apache.org/jira/browse/FLINK-9975?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16660278#comment-16660278
]
ASF GitHub Bot commented on FLINK-9975:
---
NicoK closed pull request #6461: [FLINK-99
NicoK closed pull request #6461: [FLINK-9975][hadoop] also shade Hadoop's
io.netty dependency
URL: https://github.com/apache/flink/pull/6461
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
beyond1920 opened a new pull request #6906: [Flink-6036][table]Let catalog
support partition.
URL: https://github.com/apache/flink/pull/6906
## What is the purpose of the change
This pull request supports partition in external catalog.
## Brief change log
- * Introduces E
[
https://issues.apache.org/jira/browse/FLINK-10095?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16660258#comment-16660258
]
Andrey Zagrebin commented on FLINK-10095:
-
Hi [~aitozi], the options for timesta
twalthr commented on a change in pull request #6897: [FLINK-9737] [FLINK-8880]
[sql-client] Support defining temporal tables in environment files
URL: https://github.com/apache/flink/pull/6897#discussion_r227270152
##
File path: docs/dev/table/sqlClient.md
##
@@ -503,7 +50
[
https://issues.apache.org/jira/browse/FLINK-9737?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16660232#comment-16660232
]
ASF GitHub Bot commented on FLINK-9737:
---
twalthr commented on a change in pull requ
[
https://issues.apache.org/jira/browse/FLINK-9737?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16660228#comment-16660228
]
ASF GitHub Bot commented on FLINK-9737:
---
pnowojski commented on a change in pull re
pnowojski commented on a change in pull request #6897: [FLINK-9737]
[FLINK-8880] [sql-client] Support defining temporal tables in environment files
URL: https://github.com/apache/flink/pull/6897#discussion_r227267053
##
File path: docs/dev/table/sqlClient.md
##
@@ -503,7 +
[
https://issues.apache.org/jira/browse/FLINK-9737?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16660227#comment-16660227
]
ASF GitHub Bot commented on FLINK-9737:
---
pnowojski commented on a change in pull re
[
https://issues.apache.org/jira/browse/FLINK-9737?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16660226#comment-16660226
]
ASF GitHub Bot commented on FLINK-9737:
---
pnowojski commented on a change in pull re
pnowojski commented on a change in pull request #6897: [FLINK-9737]
[FLINK-8880] [sql-client] Support defining temporal tables in environment files
URL: https://github.com/apache/flink/pull/6897#discussion_r227268384
##
File path: docs/dev/table/sqlClient.md
##
@@ -503,7 +
pnowojski commented on a change in pull request #6897: [FLINK-9737]
[FLINK-8880] [sql-client] Support defining temporal tables in environment files
URL: https://github.com/apache/flink/pull/6897#discussion_r227267053
##
File path: docs/dev/table/sqlClient.md
##
@@ -503,7 +
tillrohrmann opened a new pull request #6905: [BP-1.5][FLINK-10637] Start
MiniCluster with random REST port
URL: https://github.com/apache/flink/pull/6905
## What is the purpose of the change
This commit starts the MiniCluster used in tests with a random REST port.
This
will fix
tillrohrmann opened a new pull request #6904: [FLINK-10637] Start MiniCluster
with random REST port
URL: https://github.com/apache/flink/pull/6904
## What is the purpose of the change
This commit starts the MiniCluster used in tests with a random REST port.
This
will fix the prob
[
https://issues.apache.org/jira/browse/FLINK-10637?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16660218#comment-16660218
]
ASF GitHub Bot commented on FLINK-10637:
tillrohrmann opened a new pull request
[
https://issues.apache.org/jira/browse/FLINK-10356?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16660203#comment-16660203
]
ASF GitHub Bot commented on FLINK-10356:
zhijiangW commented on a change in pull
[
https://issues.apache.org/jira/browse/FLINK-10356?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16660204#comment-16660204
]
ASF GitHub Bot commented on FLINK-10356:
zhijiangW commented on a change in pull
zhijiangW commented on a change in pull request #6705: [FLINK-10356][network]
add sanity checks to SpillingAdaptiveSpanningRecordDeserializer
URL: https://github.com/apache/flink/pull/6705#discussion_r227256749
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/io/n
zhijiangW commented on a change in pull request #6705: [FLINK-10356][network]
add sanity checks to SpillingAdaptiveSpanningRecordDeserializer
URL: https://github.com/apache/flink/pull/6705#discussion_r227256594
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/io/n
[
https://issues.apache.org/jira/browse/FLINK-9737?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16660201#comment-16660201
]
ASF GitHub Bot commented on FLINK-9737:
---
twalthr commented on a change in pull requ
TisonKun opened a new pull request #6903: [hotfix] [python] correct strict
access
URL: https://github.com/apache/flink/pull/6903
## What is the purpose of the change
`PythonPlanBinder#LOG` can/should be private.
## Verifying this change
This change is a trivial rework /
twalthr commented on a change in pull request #6897: [FLINK-9737] [FLINK-8880]
[sql-client] Support defining temporal tables in environment files
URL: https://github.com/apache/flink/pull/6897#discussion_r227255346
##
File path:
flink-libraries/flink-table/src/main/scala/org/apache
[
https://issues.apache.org/jira/browse/FLINK-9737?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16660200#comment-16660200
]
ASF GitHub Bot commented on FLINK-9737:
---
twalthr commented on a change in pull requ
twalthr commented on a change in pull request #6897: [FLINK-9737] [FLINK-8880]
[sql-client] Support defining temporal tables in environment files
URL: https://github.com/apache/flink/pull/6897#discussion_r227254032
##
File path: docs/dev/table/sqlClient.md
##
@@ -503,7 +50
201 - 272 of 272 matches
Mail list logo
